update remove unused code

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)

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;

paddle/operators/send_recv_op_test.cc

@@ -13,7 +13,6 @@
    limitations under the License. */
 
 #include <unistd.h>
-#include <iostream>
 #include <string>
 #include <thread>