diff --git a/paddle/operators/CMakeLists.txt b/paddle/operators/CMakeLists.txt index 0e9b3ba8dc57b005eeca5e708e7c74322cd15e9c..5aaaf993323c2d4dbef688d0977ec6374fde6512 100644 --- a/paddle/operators/CMakeLists.txt +++ b/paddle/operators/CMakeLists.txt @@ -227,10 +227,6 @@ set_source_files_properties( COMPILE_FLAGS "-Wno-non-virtual-dtor -Wno-error=non-virtual-dtor -Wno-error=delete-non-virtual-dtor") cc_test(test_send_recv SRCS send_recv_op_test.cc DEPS send_op recv_op sum_op executor) -# FIXME(typhoonzero): use gtest to get benchmark result -if(WITH_PROFILER) - cc_test(test_send_recv_benchmark SRCS send_recv_op_benchmark.cc DEPS send_op recv_op sum_op executor) -endif() endif() op_library(cond_op SRCS cond_op.cc DEPS framework_proto tensor operator net_op) diff --git a/paddle/operators/recv_op.cc b/paddle/operators/recv_op.cc index f599bf984173a8ca873eda9fe72201eb9cd97724..4770976709ca661bfcda031957fc911b1177aad4 100644 --- a/paddle/operators/recv_op.cc +++ b/paddle/operators/recv_op.cc @@ -62,9 +62,7 @@ class RecvOp : public framework::OperatorBase { void Stop() override { detail::TensorWithName term_msg; term_msg.first = LISTEN_TERMINATE_MESSAGE; - LOG(ERROR) << "push term msg"; rpc_service_->Push(term_msg); - LOG(ERROR) << "push term msg over"; rpc_server_->Shutdown(); server_thread_->join(); } @@ -98,7 +96,6 @@ class RecvOp : public framework::OperatorBase { // blocking get one var from client. const detail::TensorWithName &v = rpc_service_->Get(); auto grad_var_name = v.first; - LOG(ERROR) << "recved varname" << grad_var_name; if (grad_var_name == LISTEN_TERMINATE_MESSAGE) { exit_flag = true; break; diff --git a/paddle/operators/send_recv_op_test.cc b/paddle/operators/send_recv_op_test.cc index 383509aa1acf00aa5c565435bcea8bef37b0d769..0e507cb7c769f7926571c746fac0a8d451a7f9e3 100644 --- a/paddle/operators/send_recv_op_test.cc +++ b/paddle/operators/send_recv_op_test.cc @@ -13,7 +13,6 @@ limitations under the License. */ #include -#include #include #include