aboutsummaryrefslogtreecommitdiffhomepage
path: root/tensorflow/core/distributed_runtime/rpc/grpc_remote_worker.cc
diff options
context:
space:
mode:
Diffstat (limited to 'tensorflow/core/distributed_runtime/rpc/grpc_remote_worker.cc')
-rw-r--r--tensorflow/core/distributed_runtime/rpc/grpc_remote_worker.cc6
1 files changed, 4 insertions, 2 deletions
diff --git a/tensorflow/core/distributed_runtime/rpc/grpc_remote_worker.cc b/tensorflow/core/distributed_runtime/rpc/grpc_remote_worker.cc
index 36626e1a33..2b1a47a93f 100644
--- a/tensorflow/core/distributed_runtime/rpc/grpc_remote_worker.cc
+++ b/tensorflow/core/distributed_runtime/rpc/grpc_remote_worker.cc
@@ -15,6 +15,8 @@ limitations under the License.
#include "tensorflow/core/distributed_runtime/rpc/grpc_remote_worker.h"
+#include <utility>
+
#include "grpc++/grpc++.h"
#include "tensorflow/core/common_runtime/process_util.h"
@@ -37,7 +39,7 @@ class GrpcRemoteWorker : public WorkerInterface {
explicit GrpcRemoteWorker(SharedGrpcChannelPtr channel,
::grpc::CompletionQueue* completion_queue,
WorkerCacheLogger* logger)
- : channel_(channel),
+ : channel_(std::move(channel)),
cq_(completion_queue),
getstatus_(Method(GrpcWorkerMethod::kGetStatus)),
createworkersession_(Method(GrpcWorkerMethod::kCreateWorkerSession)),
@@ -272,7 +274,7 @@ class GrpcRemoteWorker : public WorkerInterface {
WorkerInterface* NewGrpcRemoteWorker(SharedGrpcChannelPtr channel,
::grpc::CompletionQueue* completion_queue,
WorkerCacheLogger* logger) {
- return new GrpcRemoteWorker(channel, completion_queue, logger);
+ return new GrpcRemoteWorker(std::move(channel), completion_queue, logger);
}
} // namespace tensorflow