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> |
22 | namespace tensorflow { |
23 | namespace eager { |
24 | |
25 | static 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 | |
36 | std::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 | |
42 | grpc::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 | |
57 | void 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 | |
61 | void 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 | |
65 | void 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 | |
69 | void 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::(::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::(::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 | |
85 | void 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 | |
89 | void 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 | |
93 | void 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 | |
97 | void 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::(::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::(::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 | |
113 | void 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 | |
117 | void 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 | |
121 | void 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 | |
125 | void 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 | |
141 | void 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 | |
157 | void 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 | |
161 | void 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 | |
165 | void 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 | |
169 | void 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 | |
185 | void 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 | |
189 | void 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 | |
193 | void 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 | |
197 | void 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 | |
213 | void 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 | |
217 | void 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 | |
221 | void 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 | |
225 | void 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 | |
241 | void 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 | |
245 | void 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 | |
249 | void 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 | |
253 | void 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::(::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::(::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 | |
265 | grpc::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 | |
308 | grpc::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 | |