1 | // Generated by the gRPC C++ plugin. |
2 | // If you make any local change, they will be lost. |
3 | // source: tensorflow/core/debug/debug_service.proto |
4 | |
5 | #include "tensorflow/core/debug/debug_service.pb.h" |
6 | #include "tensorflow/core/debug/debug_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 | |
24 | static const char* grpcEventListener_method_names[] = { |
25 | "/tensorflow.EventListener/SendEvents" , |
26 | "/tensorflow.EventListener/SendTracebacks" , |
27 | "/tensorflow.EventListener/SendSourceFiles" , |
28 | }; |
29 | |
30 | std::unique_ptr< grpc::EventListener::Stub> grpc::EventListener::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) { |
31 | (void)options; |
32 | std::unique_ptr< grpc::EventListener::Stub> stub(new grpc::EventListener::Stub(channel)); |
33 | return stub; |
34 | } |
35 | |
36 | grpc::EventListener::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel) |
37 | : channel_(channel), rpcmethod_SendEvents_(grpcEventListener_method_names[0], ::grpc::internal::RpcMethod::BIDI_STREAMING, channel) |
38 | , rpcmethod_SendTracebacks_(grpcEventListener_method_names[1], ::grpc::internal::RpcMethod::NORMAL_RPC, channel) |
39 | , rpcmethod_SendSourceFiles_(grpcEventListener_method_names[2], ::grpc::internal::RpcMethod::NORMAL_RPC, channel) |
40 | {} |
41 | |
42 | ::grpc::ClientReaderWriter< ::tensorflow::Event, ::tensorflow::EventReply>* grpc::EventListener::Stub::SendEventsRaw(::grpc::ClientContext* context) { |
43 | return ::grpc_impl::internal::ClientReaderWriterFactory< ::tensorflow::Event, ::tensorflow::EventReply>::Create(channel_.get(), rpcmethod_SendEvents_, context); |
44 | } |
45 | |
46 | void grpc::EventListener::Stub::experimental_async::SendEvents(::grpc::ClientContext* context, ::grpc::experimental::ClientBidiReactor< ::tensorflow::Event,::tensorflow::EventReply>* reactor) { |
47 | ::grpc_impl::internal::ClientCallbackReaderWriterFactory< ::tensorflow::Event,::tensorflow::EventReply>::Create(stub_->channel_.get(), stub_->rpcmethod_SendEvents_, context, reactor); |
48 | } |
49 | |
50 | ::grpc::ClientAsyncReaderWriter< ::tensorflow::Event, ::tensorflow::EventReply>* grpc::EventListener::Stub::AsyncSendEventsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) { |
51 | return ::grpc_impl::internal::ClientAsyncReaderWriterFactory< ::tensorflow::Event, ::tensorflow::EventReply>::Create(channel_.get(), cq, rpcmethod_SendEvents_, context, true, tag); |
52 | } |
53 | |
54 | ::grpc::ClientAsyncReaderWriter< ::tensorflow::Event, ::tensorflow::EventReply>* grpc::EventListener::Stub::PrepareAsyncSendEventsRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) { |
55 | return ::grpc_impl::internal::ClientAsyncReaderWriterFactory< ::tensorflow::Event, ::tensorflow::EventReply>::Create(channel_.get(), cq, rpcmethod_SendEvents_, context, false, nullptr); |
56 | } |
57 | |
58 | ::grpc::Status grpc::EventListener::Stub::SendTracebacks(::grpc::ClientContext* context, const ::tensorflow::CallTraceback& request, ::tensorflow::EventReply* response) { |
59 | return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_SendTracebacks_, context, request, response); |
60 | } |
61 | |
62 | void grpc::EventListener::Stub::experimental_async::SendTracebacks(::grpc::ClientContext* context, const ::tensorflow::CallTraceback* request, ::tensorflow::EventReply* response, std::function<void(::grpc::Status)> f) { |
63 | ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_SendTracebacks_, context, request, response, std::move(f)); |
64 | } |
65 | |
66 | void grpc::EventListener::Stub::experimental_async::SendTracebacks(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::EventReply* response, std::function<void(::grpc::Status)> f) { |
67 | ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_SendTracebacks_, context, request, response, std::move(f)); |
68 | } |
69 | |
70 | void grpc::EventListener::Stub::experimental_async::SendTracebacks(::grpc::ClientContext* context, const ::tensorflow::CallTraceback* request, ::tensorflow::EventReply* response, ::grpc::experimental::ClientUnaryReactor* reactor) { |
71 | ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_SendTracebacks_, context, request, response, reactor); |
72 | } |
73 | |
74 | void grpc::EventListener::Stub::experimental_async::SendTracebacks(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::EventReply* response, ::grpc::experimental::ClientUnaryReactor* reactor) { |
75 | ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_SendTracebacks_, context, request, response, reactor); |
76 | } |
77 | |
78 | ::grpc::ClientAsyncResponseReader< ::tensorflow::EventReply>* grpc::EventListener::Stub::AsyncSendTracebacksRaw(::grpc::ClientContext* context, const ::tensorflow::CallTraceback& request, ::grpc::CompletionQueue* cq) { |
79 | return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::EventReply>::Create(channel_.get(), cq, rpcmethod_SendTracebacks_, context, request, true); |
80 | } |
81 | |
82 | ::grpc::ClientAsyncResponseReader< ::tensorflow::EventReply>* grpc::EventListener::Stub::PrepareAsyncSendTracebacksRaw(::grpc::ClientContext* context, const ::tensorflow::CallTraceback& request, ::grpc::CompletionQueue* cq) { |
83 | return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::EventReply>::Create(channel_.get(), cq, rpcmethod_SendTracebacks_, context, request, false); |
84 | } |
85 | |
86 | ::grpc::Status grpc::EventListener::Stub::SendSourceFiles(::grpc::ClientContext* context, const ::tensorflow::DebuggedSourceFiles& request, ::tensorflow::EventReply* response) { |
87 | return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_SendSourceFiles_, context, request, response); |
88 | } |
89 | |
90 | void grpc::EventListener::Stub::experimental_async::SendSourceFiles(::grpc::ClientContext* context, const ::tensorflow::DebuggedSourceFiles* request, ::tensorflow::EventReply* response, std::function<void(::grpc::Status)> f) { |
91 | ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_SendSourceFiles_, context, request, response, std::move(f)); |
92 | } |
93 | |
94 | void grpc::EventListener::Stub::experimental_async::SendSourceFiles(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::EventReply* response, std::function<void(::grpc::Status)> f) { |
95 | ::grpc_impl::internal::CallbackUnaryCall(stub_->channel_.get(), stub_->rpcmethod_SendSourceFiles_, context, request, response, std::move(f)); |
96 | } |
97 | |
98 | void grpc::EventListener::Stub::experimental_async::SendSourceFiles(::grpc::ClientContext* context, const ::tensorflow::DebuggedSourceFiles* request, ::tensorflow::EventReply* response, ::grpc::experimental::ClientUnaryReactor* reactor) { |
99 | ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_SendSourceFiles_, context, request, response, reactor); |
100 | } |
101 | |
102 | void grpc::EventListener::Stub::experimental_async::SendSourceFiles(::grpc::ClientContext* context, const ::grpc::ByteBuffer* request, ::tensorflow::EventReply* response, ::grpc::experimental::ClientUnaryReactor* reactor) { |
103 | ::grpc_impl::internal::ClientCallbackUnaryFactory::Create(stub_->channel_.get(), stub_->rpcmethod_SendSourceFiles_, context, request, response, reactor); |
104 | } |
105 | |
106 | ::grpc::ClientAsyncResponseReader< ::tensorflow::EventReply>* grpc::EventListener::Stub::AsyncSendSourceFilesRaw(::grpc::ClientContext* context, const ::tensorflow::DebuggedSourceFiles& request, ::grpc::CompletionQueue* cq) { |
107 | return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::EventReply>::Create(channel_.get(), cq, rpcmethod_SendSourceFiles_, context, request, true); |
108 | } |
109 | |
110 | ::grpc::ClientAsyncResponseReader< ::tensorflow::EventReply>* grpc::EventListener::Stub::PrepareAsyncSendSourceFilesRaw(::grpc::ClientContext* context, const ::tensorflow::DebuggedSourceFiles& request, ::grpc::CompletionQueue* cq) { |
111 | return ::grpc_impl::internal::ClientAsyncResponseReaderFactory< ::tensorflow::EventReply>::Create(channel_.get(), cq, rpcmethod_SendSourceFiles_, context, request, false); |
112 | } |
113 | |
114 | grpc::EventListener::Service::Service() { |
115 | AddMethod(new ::grpc::internal::RpcServiceMethod( |
116 | grpcEventListener_method_names[0], |
117 | ::grpc::internal::RpcMethod::BIDI_STREAMING, |
118 | new ::grpc::internal::BidiStreamingHandler< grpc::EventListener::Service, ::tensorflow::Event, ::tensorflow::EventReply>( |
119 | std::mem_fn(&grpc::EventListener::Service::SendEvents), this))); |
120 | AddMethod(new ::grpc::internal::RpcServiceMethod( |
121 | grpcEventListener_method_names[1], |
122 | ::grpc::internal::RpcMethod::NORMAL_RPC, |
123 | new ::grpc::internal::RpcMethodHandler< grpc::EventListener::Service, ::tensorflow::CallTraceback, ::tensorflow::EventReply>( |
124 | std::mem_fn(&grpc::EventListener::Service::SendTracebacks), this))); |
125 | AddMethod(new ::grpc::internal::RpcServiceMethod( |
126 | grpcEventListener_method_names[2], |
127 | ::grpc::internal::RpcMethod::NORMAL_RPC, |
128 | new ::grpc::internal::RpcMethodHandler< grpc::EventListener::Service, ::tensorflow::DebuggedSourceFiles, ::tensorflow::EventReply>( |
129 | std::mem_fn(&grpc::EventListener::Service::SendSourceFiles), this))); |
130 | } |
131 | |
132 | grpc::EventListener::Service::~Service() { |
133 | } |
134 | |
135 | ::grpc::Status grpc::EventListener::Service::SendEvents(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::tensorflow::EventReply, ::tensorflow::Event>* stream) { |
136 | (void) context; |
137 | (void) stream; |
138 | return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "" ); |
139 | } |
140 | |
141 | ::grpc::Status grpc::EventListener::Service::SendTracebacks(::grpc::ServerContext* context, const ::tensorflow::CallTraceback* request, ::tensorflow::EventReply* response) { |
142 | (void) context; |
143 | (void) request; |
144 | (void) response; |
145 | return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "" ); |
146 | } |
147 | |
148 | ::grpc::Status grpc::EventListener::Service::SendSourceFiles(::grpc::ServerContext* context, const ::tensorflow::DebuggedSourceFiles* request, ::tensorflow::EventReply* response) { |
149 | (void) context; |
150 | (void) request; |
151 | (void) response; |
152 | return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "" ); |
153 | } |
154 | |
155 | |
156 | } // namespace tensorflow |
157 | |
158 | |