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>
22namespace tensorflow {
23
24static const char* grpcEventListener_method_names[] = {
25 "/tensorflow.EventListener/SendEvents",
26 "/tensorflow.EventListener/SendTracebacks",
27 "/tensorflow.EventListener/SendSourceFiles",
28};
29
30std::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
36grpc::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
46void 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
62void 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
66void 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
70void 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
74void 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
90void 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
94void 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
98void 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
102void 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
114grpc::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
132grpc::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