worker_client.cc
imports tensorflow/core/data/service/worker.grpc.pb.himports tensorflow/core/platform/errors.h
SHA-256a584d04b76b8f976e3e64fbcd1d1ff23dab19d250e3faedf67ff3d996c3ac2ea
MaleculeMd(In₉)
Evidence
1/* Copyright 2021 The TensorFlow Authors. All Rights Reserved.
2
3Licensed under the Apache License, Version 2.0 (the "License");
4you may not use this file except in compliance with the License.
5You may obtain a copy of the License at
6
7 http://www.apache.org/licenses/LICENSE-2.0
8
9Unless required by applicable law or agreed to in writing, software
10distributed under the License is …
11:42… IND, either express or implied.
12See the License for the specific language governing permissions and
13limitations under the License.
14==============================================================================*/
15#include "tensorflow/core/data/service/worker_client.h"
16
17#include <cstdint>
18#include <functional>
19#include <memory>
20#include <string>
21#include <utility>
22#include <vector>
23
24#include "grpcpp/client_context.h"
25#include "grpcpp/create_channel.h"
26#include "grpcpp/security/credentials.h"
27#include "grpcpp/support/channel_arguments.h"
28#include "grpcpp/support/status.h"
29#include "absl/container/flat_hash_set.h"
30#include "absl/memory/memory.h"
31#include "absl/strings/string_view.h"
32#include "absl/strings/substitute.h"
33#include "xla/tsl/platform/errors.h"
34#include "tensorflow/core/data/service/credentials_factory.h"
35#include "tensorflow/core/data/service/data_transfer.h"
36#include "tensorflow/core/data/service/grpc_util.h"
37#include "tensorflow/core/data/service/worker.grpc.pb.h"
38#include "tensorflow/core/data/service/worker.pb.h"
39#include "tensorflow/core/data/service/worker_impl.h"
40#include "tensorflow/core/framework/allocator.h"
41#include "tensorflow/core/framework/dataset.pb.h"
42#include "tensorflow/core/framework/device_base.h"
43#include "tensorflow/core/framework/metrics.h"
44#include "tensorflow/core/framework/tensor.h"
45#include "tensorflow/core/framework/tensor_shape.h"
46#include "tensorflow/core/framework/tensor_types.h"
47#include "tensorflow/core/framework/types.pb.h"
48#include "tensorflow/core/framework/variant.h"
49#include "tensorflow/core/platform/errors.h"
50#include "tensorflow/core/platform/mutex.h"
51#include "tensorflow/core/platform/status.h"
52#include "tensorflow/core/platform/statusor.h"
53#include "tensorflow/core/platform/thread_annotations.h"
54#include "tensorflow/core/platform/types.h"
55#include "tsl/platform/host_info.h"
56
57namespace tensorflow {
58namespace data {
187:57… texts_
188 TF_GUARDED_BY(mu_);
189 // Indicates that the client has been cancelled, so no further requests should
190 // be accepted.
191 bool cancelled …