1// Generated by the gRPC C++ plugin.
2// If you make any local change, they will be lost.
3// source: tensorflow/core/protobuf/eager_service.proto
4
5#include "tensorflow/core/protobuf/eager_service.pb.h"
6#include "tensorflow/core/protobuf/eager_service.grpc.pb.h"
7
8#include <functional>
9#include <grpcpp/impl/codegen/async_stream.h>
10#include <grpcpp/impl/codegen/async_unary_call.h>
11#include <grpcpp/impl/codegen/channel_interface.h>
12#include <grpcpp/impl/codegen/client_unary_call.h>
13#include <grpcpp/impl/codegen/client_callback.h>
14#include <grpcpp/impl/codegen/message_allocator.h>
15#include <grpcpp/impl/codegen/method_handler.h>
16#include <grpcpp/impl/codegen/rpc_service_method.h>
17#include <grpcpp/impl/codegen/server_callback.h>
18#include <grpcpp/impl/codegen/server_callback_handlers.h>
19#include <grpcpp/impl/codegen/server_context.h>
20#include <grpcpp/impl/codegen/service_type.h>
21#include <grpcpp/impl/codegen/sync_stream.h>
22namespace tensorflow {
23namespace eager {
24
25static const char* grpcEagerService_method_names[] = {
26 "/tensorflow.eager.EagerService/CreateContext",
27 "/tensorflow.eager.EagerService/UpdateContext",
28 "/tensorflow.eager.EagerService/Enqueue",
29 "/tensorflow.eager.EagerService/StreamingEnqueue",
30 "/tensorflow.eager.EagerService/WaitQueueDone",
31 "/tensorflow.eager.EagerService/RunComponentFunction",
32 "/tensorflow.eager.EagerService/KeepAlive",
33 "/tensorflow.eager.EagerService/CloseContext",
34};
35
36std::unique_ptr< grpc::EagerService::Stub> grpc::EagerService::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) {
37 (void)options;
38 std::unique_ptr< grpc::EagerService::Stub> stub(new grpc::EagerService::Stub(channel));
39 return stub;
40}
41
42grpc::EagerService::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel)
43 : channel_(channel), rpcmethod_CreateContext_(grpcEagerService_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
44 , rpcmethod_UpdateContext_(grpcEagerService_method_names[1], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
45 , rpcmethod_Enqueue_(grpcEagerService_method_names[2], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
46 , rpcmethod_StreamingEnqueue_(grpcEagerService_method_names[3], ::grpc::internal::RpcMethod::BIDI_STREAMING, channel)
47 , rpcmethod_WaitQueueDone_(grpcEagerService_method_names[4], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
48 , rpcmethod_RunComponentFunction_(grpcEagerService_method_names[5], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
49 , rpcmethod_KeepAlive_(grpcEagerService_method_names[6], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
50 , rpcmethod_CloseContext_(grpcEagerService_method_names[7], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
51 {}
52
53::grpc::Status grpc::EagerService::Stub::CreateContext(::grpc::ClientContext* context, const ::tensorflow::eager::CreateContextRequest& request, ::tensorflow::eager::CreateContextResponse* response) {
54 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_CreateContext_, context, request, response);
55}
56
57void grpc::EagerService::Stub::experimental_async::CreateContext(::grpc::ClientContext* context, const ::tensorflow::eager::CreateContextRequest* request, ::tensorflow::eager::CreateContextResponse* response, std::function<void(::grpc::Status)> f) {
58 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_CreateContext_, context, request, response, std::move(f));
59}
60
61void grpc::EagerService::Stub::experimental_async::CreateContext(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::CreateContextResponse* response, std::function<void(::grpc::Status)> f) {
62 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_CreateContext_, context, request, response, std::move(f));
63}
64
65void grpc::EagerService::Stub::experimental_async::CreateContext(::grpc::ClientContext* context, const ::tensorflow::eager::CreateContextRequest* request, ::tensorflow::eager::CreateContextResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
66 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_CreateContext_, context, request, response, reactor);
67}
68
69void grpc::EagerService::Stub::experimental_async::CreateContext(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::CreateContextResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
70 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_CreateContext_, context, request, response, reactor);
71}
72
73::grpc::ClientAsyncResponseReader< ::tensorflow::eager::CreateContextResponse>* grpc::EagerService::Stub::AsyncCreateContextRaw(::grpc::ClientContext* context, const ::tensorflow::eager::CreateContextRequest& request, ::grpc::CompletionQueue* cq) {
74 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::CreateContextResponse>::Create(channel_.get(), cq, rpcmethod_CreateContext_, context, request, true);
75}
76
77::grpc::ClientAsyncResponseReader< ::tensorflow::eager::CreateContextResponse>* grpc::EagerService::Stub::PrepareAsyncCreateContextRaw(::grpc::ClientContext* context, const ::tensorflow::eager::CreateContextRequest& request, ::grpc::CompletionQueue* cq) {
78 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::CreateContextResponse>::Create(channel_.get(), cq, rpcmethod_CreateContext_, context, request, false);
79}
80
81::grpc::Status grpc::EagerService::Stub::UpdateContext(::grpc::ClientContext* context, const ::tensorflow::eager::UpdateContextRequest& request, ::tensorflow::eager::UpdateContextResponse* response) {
82 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_UpdateContext_, context, request, response);
83}
84
85void grpc::EagerService::Stub::experimental_async::UpdateContext(::grpc::ClientContext* context, const ::tensorflow::eager::UpdateContextRequest* request, ::tensorflow::eager::UpdateContextResponse* response, std::function<void(::grpc::Status)> f) {
86 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_UpdateContext_, context, request, response, std::move(f));
87}
88
89void grpc::EagerService::Stub::experimental_async::UpdateContext(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::UpdateContextResponse* response, std::function<void(::grpc::Status)> f) {
90 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_UpdateContext_, context, request, response, std::move(f));
91}
92
93void grpc::EagerService::Stub::experimental_async::UpdateContext(::grpc::ClientContext* context, const ::tensorflow::eager::UpdateContextRequest* request, ::tensorflow::eager::UpdateContextResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
94 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_UpdateContext_, context, request, response, reactor);
95}
96
97void grpc::EagerService::Stub::experimental_async::UpdateContext(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::UpdateContextResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
98 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_UpdateContext_, context, request, response, reactor);
99}
100
101::grpc::ClientAsyncResponseReader< ::tensorflow::eager::UpdateContextResponse>* grpc::EagerService::Stub::AsyncUpdateContextRaw(::grpc::ClientContext* context, const ::tensorflow::eager::UpdateContextRequest& request, ::grpc::CompletionQueue* cq) {
102 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::UpdateContextResponse>::Create(channel_.get(), cq, rpcmethod_UpdateContext_, context, request, true);
103}
104
105::grpc::ClientAsyncResponseReader< ::tensorflow::eager::UpdateContextResponse>* grpc::EagerService::Stub::PrepareAsyncUpdateContextRaw(::grpc::ClientContext* context, const ::tensorflow::eager::UpdateContextRequest& request, ::grpc::CompletionQueue* cq) {
106 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::UpdateContextResponse>::Create(channel_.get(), cq, rpcmethod_UpdateContext_, context, request, false);
107}
108
109::grpc::Status grpc::EagerService::Stub::Enqueue(::grpc::ClientContext* context, const ::tensorflow::eager::EnqueueRequest& request, ::tensorflow::eager::EnqueueResponse* response) {
110 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Enqueue_, context, request, response);
111}
112
113void grpc::EagerService::Stub::experimental_async::Enqueue(::grpc::ClientContext* context, const ::tensorflow::eager::EnqueueRequest* request, ::tensorflow::eager::EnqueueResponse* response, std::function<void(::grpc::Status)> f) {
114 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_Enqueue_, context, request, response, std::move(f));
115}
116
117void grpc::EagerService::Stub::experimental_async::Enqueue(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::EnqueueResponse* response, std::function<void(::grpc::Status)> f) {
118 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_Enqueue_, context, request, response, std::move(f));
119}
120
121void grpc::EagerService::Stub::experimental_async::Enqueue(::grpc::ClientContext* context, const ::tensorflow::eager::EnqueueRequest* request, ::tensorflow::eager::EnqueueResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
122 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_Enqueue_, context, request, response, reactor);
123}
124
125void grpc::EagerService::Stub::experimental_async::Enqueue(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::EnqueueResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
126 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_Enqueue_, context, request, response, reactor);
127}
128
129::grpc::ClientAsyncResponseReader< ::tensorflow::eager::EnqueueResponse>* grpc::EagerService::Stub::AsyncEnqueueRaw(::grpc::ClientContext* context, const ::tensorflow::eager::EnqueueRequest& request, ::grpc::CompletionQueue* cq) {
130 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::EnqueueResponse>::Create(channel_.get(), cq, rpcmethod_Enqueue_, context, request, true);
131}
132
133::grpc::ClientAsyncResponseReader< ::tensorflow::eager::EnqueueResponse>* grpc::EagerService::Stub::PrepareAsyncEnqueueRaw(::grpc::ClientContext* context, const ::tensorflow::eager::EnqueueRequest& request, ::grpc::CompletionQueue* cq) {
134 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::EnqueueResponse>::Create(channel_.get(), cq, rpcmethod_Enqueue_, context, request, false);
135}
136
137::grpc::ClientReaderWriter< ::tensorflow::eager::EnqueueRequest, ::tensorflow::eager::EnqueueResponse>* grpc::EagerService::Stub::StreamingEnqueueRaw(::grpc::ClientContext* context) {
138 return ::grpc_impl::internal::ClientReaderWriterFactory< ::tensorflow::eager::EnqueueRequest, ::tensorflow::eager::EnqueueResponse>::Create(channel_.get(), rpcmethod_StreamingEnqueue_, context);
139}
140
141void grpc::EagerService::Stub::experimental_async::StreamingEnqueue(::grpc::ClientContext* context, ::grpc::experimental::ClientBidiReactor< ::tensorflow::eager::EnqueueRequest,::tensorflow::eager::EnqueueResponse>* reactor) {
142 ::grpc_impl::internal::ClientCallbackReaderWriterFactory< ::tensorflow::eager::EnqueueRequest,::tensorflow::eager::EnqueueResponse>::Create(stub_->channel_.get(), stub_->rpcmethod_StreamingEnqueue_, context, reactor);
143}
144
145::grpc::ClientAsyncReaderWriter< ::tensorflow::eager::EnqueueRequest, ::tensorflow::eager::EnqueueResponse>* grpc::EagerService::Stub::AsyncStreamingEnqueueRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
146 return ::grpc_impl::internal::ClientAsyncReaderWriterFactory< ::tensorflow::eager::EnqueueRequest, ::tensorflow::eager::EnqueueResponse>::Create(channel_.get(), cq, rpcmethod_StreamingEnqueue_, context, true, tag);
147}
148
149::grpc::ClientAsyncReaderWriter< ::tensorflow::eager::EnqueueRequest, ::tensorflow::eager::EnqueueResponse>* grpc::EagerService::Stub::PrepareAsyncStreamingEnqueueRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) {
150 return ::grpc_impl::internal::ClientAsyncReaderWriterFactory< ::tensorflow::eager::EnqueueRequest, ::tensorflow::eager::EnqueueResponse>::Create(channel_.get(), cq, rpcmethod_StreamingEnqueue_, context, false, nullptr);
151}
152
153::grpc::Status grpc::EagerService::Stub::WaitQueueDone(::grpc::ClientContext* context, const ::tensorflow::eager::WaitQueueDoneRequest& request, ::tensorflow::eager::WaitQueueDoneResponse* response) {
154 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_WaitQueueDone_, context, request, response);
155}
156
157void grpc::EagerService::Stub::experimental_async::WaitQueueDone(::grpc::ClientContext* context, const ::tensorflow::eager::WaitQueueDoneRequest* request, ::tensorflow::eager::WaitQueueDoneResponse* response, std::function<void(::grpc::Status)> f) {
158 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_WaitQueueDone_, context, request, response, std::move(f));
159}
160
161void grpc::EagerService::Stub::experimental_async::WaitQueueDone(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::WaitQueueDoneResponse* response, std::function<void(::grpc::Status)> f) {
162 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_WaitQueueDone_, context, request, response, std::move(f));
163}
164
165void grpc::EagerService::Stub::experimental_async::WaitQueueDone(::grpc::ClientContext* context, const ::tensorflow::eager::WaitQueueDoneRequest* request, ::tensorflow::eager::WaitQueueDoneResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
166 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_WaitQueueDone_, context, request, response, reactor);
167}
168
169void grpc::EagerService::Stub::experimental_async::WaitQueueDone(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::WaitQueueDoneResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
170 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_WaitQueueDone_, context, request, response, reactor);
171}
172
173::grpc::ClientAsyncResponseReader< ::tensorflow::eager::WaitQueueDoneResponse>* grpc::EagerService::Stub::AsyncWaitQueueDoneRaw(::grpc::ClientContext* context, const ::tensorflow::eager::WaitQueueDoneRequest& request, ::grpc::CompletionQueue* cq) {
174 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::WaitQueueDoneResponse>::Create(channel_.get(), cq, rpcmethod_WaitQueueDone_, context, request, true);
175}
176
177::grpc::ClientAsyncResponseReader< ::tensorflow::eager::WaitQueueDoneResponse>* grpc::EagerService::Stub::PrepareAsyncWaitQueueDoneRaw(::grpc::ClientContext* context, const ::tensorflow::eager::WaitQueueDoneRequest& request, ::grpc::CompletionQueue* cq) {
178 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::WaitQueueDoneResponse>::Create(channel_.get(), cq, rpcmethod_WaitQueueDone_, context, request, false);
179}
180
181::grpc::Status grpc::EagerService::Stub::RunComponentFunction(::grpc::ClientContext* context, const ::tensorflow::eager::RunComponentFunctionRequest& request, ::tensorflow::eager::RunComponentFunctionResponse* response) {
182 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_RunComponentFunction_, context, request, response);
183}
184
185void grpc::EagerService::Stub::experimental_async::RunComponentFunction(::grpc::ClientContext* context, const ::tensorflow::eager::RunComponentFunctionRequest* request, ::tensorflow::eager::RunComponentFunctionResponse* response, std::function<void(::grpc::Status)> f) {
186 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_RunComponentFunction_, context, request, response, std::move(f));
187}
188
189void grpc::EagerService::Stub::experimental_async::RunComponentFunction(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::RunComponentFunctionResponse* response, std::function<void(::grpc::Status)> f) {
190 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_RunComponentFunction_, context, request, response, std::move(f));
191}
192
193void grpc::EagerService::Stub::experimental_async::RunComponentFunction(::grpc::ClientContext* context, const ::tensorflow::eager::RunComponentFunctionRequest* request, ::tensorflow::eager::RunComponentFunctionResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
194 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_RunComponentFunction_, context, request, response, reactor);
195}
196
197void grpc::EagerService::Stub::experimental_async::RunComponentFunction(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::RunComponentFunctionResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
198 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_RunComponentFunction_, context, request, response, reactor);
199}
200
201::grpc::ClientAsyncResponseReader< ::tensorflow::eager::RunComponentFunctionResponse>* grpc::EagerService::Stub::AsyncRunComponentFunctionRaw(::grpc::ClientContext* context, const ::tensorflow::eager::RunComponentFunctionRequest& request, ::grpc::CompletionQueue* cq) {
202 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::RunComponentFunctionResponse>::Create(channel_.get(), cq, rpcmethod_RunComponentFunction_, context, request, true);
203}
204
205::grpc::ClientAsyncResponseReader< ::tensorflow::eager::RunComponentFunctionResponse>* grpc::EagerService::Stub::PrepareAsyncRunComponentFunctionRaw(::grpc::ClientContext* context, const ::tensorflow::eager::RunComponentFunctionRequest& request, ::grpc::CompletionQueue* cq) {
206 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::RunComponentFunctionResponse>::Create(channel_.get(), cq, rpcmethod_RunComponentFunction_, context, request, false);
207}
208
209::grpc::Status grpc::EagerService::Stub::KeepAlive(::grpc::ClientContext* context, const ::tensorflow::eager::KeepAliveRequest& request, ::tensorflow::eager::KeepAliveResponse* response) {
210 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_KeepAlive_, context, request, response);
211}
212
213void grpc::EagerService::Stub::experimental_async::KeepAlive(::grpc::ClientContext* context, const ::tensorflow::eager::KeepAliveRequest* request, ::tensorflow::eager::KeepAliveResponse* response, std::function<void(::grpc::Status)> f) {
214 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_KeepAlive_, context, request, response, std::move(f));
215}
216
217void grpc::EagerService::Stub::experimental_async::KeepAlive(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::KeepAliveResponse* response, std::function<void(::grpc::Status)> f) {
218 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_KeepAlive_, context, request, response, std::move(f));
219}
220
221void grpc::EagerService::Stub::experimental_async::KeepAlive(::grpc::ClientContext* context, const ::tensorflow::eager::KeepAliveRequest* request, ::tensorflow::eager::KeepAliveResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
222 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_KeepAlive_, context, request, response, reactor);
223}
224
225void grpc::EagerService::Stub::experimental_async::KeepAlive(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::KeepAliveResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
226 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_KeepAlive_, context, request, response, reactor);
227}
228
229::grpc::ClientAsyncResponseReader< ::tensorflow::eager::KeepAliveResponse>* grpc::EagerService::Stub::AsyncKeepAliveRaw(::grpc::ClientContext* context, const ::tensorflow::eager::KeepAliveRequest& request, ::grpc::CompletionQueue* cq) {
230 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::KeepAliveResponse>::Create(channel_.get(), cq, rpcmethod_KeepAlive_, context, request, true);
231}
232
233::grpc::ClientAsyncResponseReader< ::tensorflow::eager::KeepAliveResponse>* grpc::EagerService::Stub::PrepareAsyncKeepAliveRaw(::grpc::ClientContext* context, const ::tensorflow::eager::KeepAliveRequest& request, ::grpc::CompletionQueue* cq) {
234 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::KeepAliveResponse>::Create(channel_.get(), cq, rpcmethod_KeepAlive_, context, request, false);
235}
236
237::grpc::Status grpc::EagerService::Stub::CloseContext(::grpc::ClientContext* context, const ::tensorflow::eager::CloseContextRequest& request, ::tensorflow::eager::CloseContextResponse* response) {
238 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_CloseContext_, context, request, response);
239}
240
241void grpc::EagerService::Stub::experimental_async::CloseContext(::grpc::ClientContext* context, const ::tensorflow::eager::CloseContextRequest* request, ::tensorflow::eager::CloseContextResponse* response, std::function<void(::grpc::Status)> f) {
242 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_CloseContext_, context, request, response, std::move(f));
243}
244
245void grpc::EagerService::Stub::experimental_async::CloseContext(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::CloseContextResponse* response, std::function<void(::grpc::Status)> f) {
246 ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_CloseContext_, context, request, response, std::move(f));
247}
248
249void grpc::EagerService::Stub::experimental_async::CloseContext(::grpc::ClientContext* context, const ::tensorflow::eager::CloseContextRequest* request, ::tensorflow::eager::CloseContextResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
250 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_CloseContext_, context, request, response, reactor);
251}
252
253void grpc::EagerService::Stub::experimental_async::CloseContext(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::eager::CloseContextResponse* response, ::grpc::experimental::ClientUnaryReactor* reactor) {
254 ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_CloseContext_, context, request, response, reactor);
255}
256
257::grpc::ClientAsyncResponseReader< ::tensorflow::eager::CloseContextResponse>* grpc::EagerService::Stub::AsyncCloseContextRaw(::grpc::ClientContext* context, const ::tensorflow::eager::CloseContextRequest& request, ::grpc::CompletionQueue* cq) {
258 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::CloseContextResponse>::Create(channel_.get(), cq, rpcmethod_CloseContext_, context, request, true);
259}
260
261::grpc::ClientAsyncResponseReader< ::tensorflow::eager::CloseContextResponse>* grpc::EagerService::Stub::PrepareAsyncCloseContextRaw(::grpc::ClientContext* context, const ::tensorflow::eager::CloseContextRequest& request, ::grpc::CompletionQueue* cq) {
262 return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::eager::CloseContextResponse>::Create(channel_.get(), cq, rpcmethod_CloseContext_, context, request, false);
263}
264
265grpc::EagerService::Service::Service() {
266 AddMethod(new ::grpc::internal::RpcServiceMethod(
267 grpcEagerService_method_names[0],
268 ::grpc::internal::RpcMethod::NORMAL_RPC,
269 new ::grpc::internal::RpcMethodHandler< grpc::EagerService::Service, ::tensorflow::eager::CreateContextRequest, ::tensorflow::eager::CreateContextResponse>(
270 std::mem_fn(&grpc::EagerService::Service::CreateContext), this)));
271 AddMethod(new ::grpc::internal::RpcServiceMethod(
272 grpcEagerService_method_names[1],
273 ::grpc::internal::RpcMethod::NORMAL_RPC,
274 new ::grpc::internal::RpcMethodHandler< grpc::EagerService::Service, ::tensorflow::eager::UpdateContextRequest, ::tensorflow::eager::UpdateContextResponse>(
275 std::mem_fn(&grpc::EagerService::Service::UpdateContext), this)));
276 AddMethod(new ::grpc::internal::RpcServiceMethod(
277 grpcEagerService_method_names[2],
278 ::grpc::internal::RpcMethod::NORMAL_RPC,
279 new ::grpc::internal::RpcMethodHandler< grpc::EagerService::Service, ::tensorflow::eager::EnqueueRequest, ::tensorflow::eager::EnqueueResponse>(
280 std::mem_fn(&grpc::EagerService::Service::Enqueue), this)));
281 AddMethod(new ::grpc::internal::RpcServiceMethod(
282 grpcEagerService_method_names[3],
283 ::grpc::internal::RpcMethod::BIDI_STREAMING,
284 new ::grpc::internal::BidiStreamingHandler< grpc::EagerService::Service, ::tensorflow::eager::EnqueueRequest, ::tensorflow::eager::EnqueueResponse>(
285 std::mem_fn(&grpc::EagerService::Service::StreamingEnqueue), this)));
286 AddMethod(new ::grpc::internal::RpcServiceMethod(
287 grpcEagerService_method_names[4],
288 ::grpc::internal::RpcMethod::NORMAL_RPC,
289 new ::grpc::internal::RpcMethodHandler< grpc::EagerService::Service, ::tensorflow::eager::WaitQueueDoneRequest, ::tensorflow::eager::WaitQueueDoneResponse>(
290 std::mem_fn(&grpc::EagerService::Service::WaitQueueDone), this)));
291 AddMethod(new ::grpc::internal::RpcServiceMethod(
292 grpcEagerService_method_names[5],
293 ::grpc::internal::RpcMethod::NORMAL_RPC,
294 new ::grpc::internal::RpcMethodHandler< grpc::EagerService::Service, ::tensorflow::eager::RunComponentFunctionRequest, ::tensorflow::eager::RunComponentFunctionResponse>(
295 std::mem_fn(&grpc::EagerService::Service::RunComponentFunction), this)));
296 AddMethod(new ::grpc::internal::RpcServiceMethod(
297 grpcEagerService_method_names[6],
298 ::grpc::internal::RpcMethod::NORMAL_RPC,
299 new ::grpc::internal::RpcMethodHandler< grpc::EagerService::Service, ::tensorflow::eager::KeepAliveRequest, ::tensorflow::eager::KeepAliveResponse>(
300 std::mem_fn(&grpc::EagerService::Service::KeepAlive), this)));
301 AddMethod(new ::grpc::internal::RpcServiceMethod(
302 grpcEagerService_method_names[7],
303 ::grpc::internal::RpcMethod::NORMAL_RPC,
304 new ::grpc::internal::RpcMethodHandler< grpc::EagerService::Service, ::tensorflow::eager::CloseContextRequest, ::tensorflow::eager::CloseContextResponse>(
305 std::mem_fn(&grpc::EagerService::Service::CloseContext), this)));
306}
307
308grpc::EagerService::Service::~Service() {
309}
310
311::grpc::Status grpc::EagerService::Service::CreateContext(::grpc::ServerContext* context, const ::tensorflow::eager::CreateContextRequest* request, ::tensorflow::eager::CreateContextResponse* response) {
312 (void) context;
313 (void) request;
314 (void) response;
315 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
316}
317
318::grpc::Status grpc::EagerService::Service::UpdateContext(::grpc::ServerContext* context, const ::tensorflow::eager::UpdateContextRequest* request, ::tensorflow::eager::UpdateContextResponse* response) {
319 (void) context;
320 (void) request;
321 (void) response;
322 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
323}
324
325::grpc::Status grpc::EagerService::Service::Enqueue(::grpc::ServerContext* context, const ::tensorflow::eager::EnqueueRequest* request, ::tensorflow::eager::EnqueueResponse* response) {
326 (void) context;
327 (void) request;
328 (void) response;
329 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
330}
331
332::grpc::Status grpc::EagerService::Service::StreamingEnqueue(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::tensorflow::eager::EnqueueResponse, ::tensorflow::eager::EnqueueRequest>* stream) {
333 (void) context;
334 (void) stream;
335 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
336}
337
338::grpc::Status grpc::EagerService::Service::WaitQueueDone(::grpc::ServerContext* context, const ::tensorflow::eager::WaitQueueDoneRequest* request, ::tensorflow::eager::WaitQueueDoneResponse* response) {
339 (void) context;
340 (void) request;
341 (void) response;
342 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
343}
344
345::grpc::Status grpc::EagerService::Service::RunComponentFunction(::grpc::ServerContext* context, const ::tensorflow::eager::RunComponentFunctionRequest* request, ::tensorflow::eager::RunComponentFunctionResponse* response) {
346 (void) context;
347 (void) request;
348 (void) response;
349 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
350}
351
352::grpc::Status grpc::EagerService::Service::KeepAlive(::grpc::ServerContext* context, const ::tensorflow::eager::KeepAliveRequest* request, ::tensorflow::eager::KeepAliveResponse* response) {
353 (void) context;
354 (void) request;
355 (void) response;
356 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
357}
358
359::grpc::Status grpc::EagerService::Service::CloseContext(::grpc::ServerContext* context, const ::tensorflow::eager::CloseContextRequest* request, ::tensorflow::eager::CloseContextResponse* response) {
360 (void) context;
361 (void) request;
362 (void) response;
363 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
364}
365
366
367} // namespace tensorflow
368} // namespace eager
369
370