Home
last modified time | relevance | path

Searched refs:grpc (Results 1 – 25 of 116) sorted by relevance

12345

/external/flatbuffers/tests/
Dmonster_test.grpc.fb.h20 namespace grpc {
39 …virtual ::grpc::Status Store(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Mons…
40 …grpc::ClientAsyncResponseReaderInterface< flatbuffers::grpc::Message<Stat>>> AsyncStore(::grpc::Cl… in AsyncStore()
41 …return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< flatbuffers::grpc::Message<Sta… in AsyncStore()
43 …que_ptr< ::grpc::ClientReaderInterface< flatbuffers::grpc::Message<Monster>>> Retrieve(::grpc::Cli… in Retrieve()
44 …return std::unique_ptr< ::grpc::ClientReaderInterface< flatbuffers::grpc::Message<Monster>>>(Retri… in Retrieve()
46 …grpc::ClientAsyncReaderInterface< flatbuffers::grpc::Message<Monster>>> AsyncRetrieve(::grpc::Clie… in AsyncRetrieve()
47 …return std::unique_ptr< ::grpc::ClientAsyncReaderInterface< flatbuffers::grpc::Message<Monster>>>(… in AsyncRetrieve()
50 …grpc::ClientAsyncResponseReaderInterface< flatbuffers::grpc::Message<Stat>>* AsyncStoreRaw(::grpc:…
51 …irtual ::grpc::ClientReaderInterface< flatbuffers::grpc::Message<Monster>>* RetrieveRaw(::grpc::Cl…
[all …]
Dmonster_test.grpc.fb.cc24 …ub> MonsterStorage::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grp… in NewStub()
29 MonsterStorage::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel) in Stub()
30 …: channel_(channel) , rpcmethod_Store_(MonsterStorage_method_names[0], ::grpc::RpcMethod::NORMAL_… in Stub()
31 …, rpcmethod_Retrieve_(MonsterStorage_method_names[1], ::grpc::RpcMethod::SERVER_STREAMING, channel) in Stub()
34 ::grpc::Status MonsterStorage::Stub::Store(::grpc::ClientContext* context, const flatbuffers::grpc:… in Store()
35 return ::grpc::BlockingUnaryCall(channel_.get(), rpcmethod_Store_, context, request, response); in Store()
38 …grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::AsyncSto… in AsyncStoreRaw()
39 …return ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>::Create(channel_.get()… in AsyncStoreRaw()
42 ::grpc::ClientReader< flatbuffers::grpc::Message<Monster>>* MonsterStorage::Stub::RetrieveRaw(::grp… in RetrieveRaw()
43 …return new ::grpc::ClientReader< flatbuffers::grpc::Message<Monster>>(channel_.get(), rpcmethod_Re… in RetrieveRaw()
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service_impl.h40 namespace grpc {
50 namespace grpc {
61 virtual ::grpc::Status CreateSession(::grpc::ClientContext* context,
64 virtual ::grpc::Status ExtendSession(::grpc::ClientContext* context,
67 virtual ::grpc::Status PartialRunSetup(
68 ::grpc::ClientContext* context, const PartialRunSetupRequest& request,
70 virtual ::grpc::Status RunStep(::grpc::ClientContext* context,
73 virtual ::grpc::Status CloseSession(::grpc::ClientContext* context,
76 virtual ::grpc::Status ListDevices(::grpc::ClientContext* context,
79 virtual ::grpc::Status Reset(::grpc::ClientContext* context,
[all …]
Dgrpc_master_service_impl.cc29 namespace grpc { namespace
42 const std::shared_ptr< ::grpc::ChannelInterface>& channel, in NewStub()
43 const ::grpc::StubOptions& options) { in NewStub()
49 const std::shared_ptr< ::grpc::ChannelInterface>& channel) in Stub()
52 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
55 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
58 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
61 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
63 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
65 ::grpc::internal::RpcMethod::NORMAL_RPC, channel), in Stub()
[all …]
Dgrpc_util.h42 inline bool IsStreamRemovedError(const ::grpc::Status& s) { in IsStreamRemovedError()
43 return !s.ok() && s.error_code() == ::grpc::StatusCode::UNKNOWN && in IsStreamRemovedError()
47 inline Status FromGrpcStatus(const ::grpc::Status& s) { in FromGrpcStatus()
61 inline ::grpc::Status ToGrpcStatus(const ::tensorflow::Status& s) { in ToGrpcStatus()
63 return ::grpc::Status::OK; in ToGrpcStatus()
70 return ::grpc::Status(static_cast<::grpc::StatusCode>(s.code()), scratch); in ToGrpcStatus()
72 return ::grpc::Status(static_cast<::grpc::StatusCode>(s.code()), in ToGrpcStatus()
77 typedef std::shared_ptr<::grpc::Channel> SharedGrpcChannelPtr;
83 ::grpc::ByteBuffer* dst);
86 bool GrpcMaybeParseProto(const ::grpc::ByteBuffer& src, protobuf::Message* dst);
[all …]
DBUILD56 "@grpc//:grpc_unsecure",
57 "@grpc//:grpc++_unsecure",
71 "@grpc//:grpc++_unsecure",
85 "@grpc//:grpc++_unsecure",
105 "@grpc//:grpc++_unsecure",
118 "@grpc//:grpc++_unsecure",
133 "@grpc//:grpc++_unsecure",
144 "@grpc//:grpc++_unsecure",
195 "@grpc//:grpc++_unsecure",
207 "@grpc//:grpc++_unsecure",
[all …]
Dgrpc_util.cc23 bool GrpcByteBufferSource::Init(const grpc::ByteBuffer& src) { in Init()
43 const ::grpc::Slice& s = slices_[cur_]; in Next()
77 grpc::protobuf::int64 GrpcByteBufferSource::ByteCount() const { in ByteCount()
82 grpc::ByteBuffer* dst) { in GrpcMaybeUnparseProto()
84 ::grpc::Slice s(src.ByteSizeLong()); in GrpcMaybeUnparseProto()
87 ::grpc::ByteBuffer buffer(&s, 1); in GrpcMaybeUnparseProto()
93 void GrpcMaybeUnparseProto(const string& src, grpc::ByteBuffer* dst) { in GrpcMaybeUnparseProto()
94 ::grpc::Slice s(src.data(), src.size()); in GrpcMaybeUnparseProto()
95 ::grpc::ByteBuffer buffer(&s, 1); in GrpcMaybeUnparseProto()
99 bool GrpcMaybeParseProto(const grpc::ByteBuffer& src, protobuf::Message* dst) { in GrpcMaybeParseProto()
[all …]
Dgrpc_remote_master.cc35 using MasterServiceStub = grpc::MasterService::Stub;
39 : stub_(grpc::MasterService::NewStub(client_channel)) {} in GrpcRemoteMaster()
46 ::grpc::ClientContext ctx; in CreateSession()
54 ::grpc::ClientContext ctx; in ExtendSession()
62 ::grpc::ClientContext ctx; in PartialRunSetup()
69 ::grpc::ClientContext ctx; in RunStep()
78 ::grpc::ClientContext ctx; in CloseSession()
86 ::grpc::ClientContext ctx; in ListDevices()
93 ::grpc::ClientContext ctx; in Reset()
101 ::grpc::ClientContext* ctx) { in TraceRpc()
[all …]
Dgrpc_state.h37 RPCState(::grpc::GenericStub* stub, ::grpc::CompletionQueue* cq, in RPCState()
38 const ::grpc::string& method, const protobuf::Message& request, in RPCState()
44 RPCState(::grpc::GenericStub* stub, ::grpc::CompletionQueue* cq, in RPCState()
45 const ::grpc::string& method, const Request& request, in RPCState()
88 ::grpc::ClientContext context_;
89 std::unique_ptr<::grpc::GenericClientAsyncResponseReader> call_;
91 ::grpc::ByteBuffer request_buf_;
92 ::grpc::ByteBuffer response_buf_;
93 ::grpc::Status status_;
Dgrpc_remote_worker.cc43 ::grpc::CompletionQueue* completion_queue, in GrpcRemoteWorker()
188 protobuf::Message* response, const ::grpc::string& method, in IssueRequest()
194 const ::grpc::string& method, StatusCallback done, in IssueRequest()
204 ::grpc::GenericStub stub_;
205 ::grpc::CompletionQueue* cq_;
207 const ::grpc::string getstatus_;
208 const ::grpc::string createworkersession_;
209 const ::grpc::string deleteworkersession_;
210 const ::grpc::string registergraph_;
211 const ::grpc::string deregistergraph_;
[all …]
Dgrpc_call.h142 ::grpc::ServerContext*, RequestMessage*,
143 ::grpc::ServerAsyncResponseWriter<ResponseMessage>*,
144 ::grpc::CompletionQueue*, ::grpc::ServerCompletionQueue*, void*);
163 void SendResponse(::grpc::Status status) { in SendResponse()
197 ::grpc::ServerCompletionQueue* cq, in EnqueueRequest()
219 GrpcService* grpc_service, ::grpc::ServerCompletionQueue* cq, in EnqueueRequestForMethod()
237 const std::multimap<::grpc::string_ref, ::grpc::string_ref>& client_metadata() in client_metadata()
252 ::grpc::ServerContext ctx_;
253 ::grpc::ServerAsyncResponseWriter<ResponseMessage> responder_;
/external/tensorflow/tensorflow/contrib/cmake/external/
Dgrpc.cmake17 set(GRPC_INCLUDE_DIRS ${CMAKE_CURRENT_BINARY_DIR}/grpc/src/grpc/include)
18 set(GRPC_URL https://github.com/grpc/grpc.git)
19 set(GRPC_BUILD ${CMAKE_CURRENT_BINARY_DIR}/grpc/src/grpc)
25 ${CMAKE_CURRENT_BINARY_DIR}/grpc/src/grpc/Release/grpc++_unsecure.lib
26 ${CMAKE_CURRENT_BINARY_DIR}/grpc/src/grpc/Release/grpc_unsecure.lib
27 ${CMAKE_CURRENT_BINARY_DIR}/grpc/src/grpc/Release/gpr.lib)
30 ${CMAKE_CURRENT_BINARY_DIR}/grpc/src/grpc/grpc++_unsecure.lib
31 ${CMAKE_CURRENT_BINARY_DIR}/grpc/src/grpc/grpc_unsecure.lib
32 ${CMAKE_CURRENT_BINARY_DIR}/grpc/src/grpc/gpr.lib)
36 ${CMAKE_CURRENT_BINARY_DIR}/grpc/src/grpc/libgrpc++_unsecure.a
[all …]
/external/flatbuffers/grpc/src/compiler/
Dschema_interface.h47 namespace grpc {
59 virtual grpc::string GetLeadingComments(const grpc::string prefix) const = 0;
60 virtual grpc::string GetTrailingComments(const grpc::string prefix) const = 0;
61 virtual std::vector<grpc::string> GetAllComments() const = 0;
68 virtual grpc::string name() const = 0;
70 virtual grpc::string input_type_name() const = 0;
71 virtual grpc::string output_type_name() const = 0;
74 grpc::string *str, grpc::string generator_file_name,
75 bool generate_in_pb2_grpc, grpc::string import_prefix) const = 0;
77 grpc::string *str, grpc::string generator_file_name,
[all …]
Dcpp_generator.h52 namespace grpc {
63 grpc::string services_namespace;
67 grpc::string grpc_search_path;
73 grpc::string GetHeaderPrologue(grpc_generator::File *file,
77 grpc::string GetHeaderIncludes(grpc_generator::File *file,
81 grpc::string GetSourceIncludes(grpc_generator::File *file,
85 grpc::string GetHeaderEpilogue(grpc_generator::File *file,
89 grpc::string GetSourcePrologue(grpc_generator::File *file,
93 grpc::string GetHeaderServices(grpc_generator::File *file,
97 grpc::string GetSourceServices(grpc_generator::File *file,
[all …]
Dcpp_generator.cc43 grpc::string message_header_ext() { return "_generated.h"; } in message_header_ext()
44 grpc::string service_header_ext() { return ".grpc.fb.h"; } in service_header_ext()
47 grpc::string as_string(T x) { in as_string()
61 grpc::string FilenameIdentifier(const grpc::string &filename) { in FilenameIdentifier()
62 grpc::string result; in FilenameIdentifier()
84 const std::vector<grpc::string> &headers, in PrintIncludes()
86 std::map<grpc::string, grpc::string> vars; in PrintIncludes()
105 grpc::string GetHeaderPrologue(grpc_generator::File *file, in GetHeaderPrologue()
107 grpc::string output; in GetHeaderPrologue()
111 std::map<grpc::string, grpc::string> vars; in GetHeaderPrologue()
[all …]
Dgo_generator.cc41 grpc::string as_string(T x) { in as_string()
58 grpc::string unexportName(grpc::string s) { in unexportName()
66 grpc::string exportName(grpc::string s) { in exportName()
75 std::map<grpc::string, grpc::string> vars) { in GenerateImports()
95 std::map<grpc::string, grpc::string> vars) { in GenerateServerMethodSignature()
109 std::map<grpc::string, grpc::string> vars) { in GenerateServerMethod()
203 std::map<grpc::string, grpc::string> vars) { in GenerateClientMethodSignature()
218 std::map<grpc::string, grpc::string> vars) { in GenerateClientMethod()
308 std::map<grpc::string, grpc::string> vars) { in GenerateService()
428 grpc::string GenerateServiceSource(grpc_generator::File *file, in GenerateServiceSource()
[all …]
/external/flatbuffers/grpc/tests/
Dgrpctest.cpp29 virtual ::grpc::Status Store(::grpc::ServerContext* context, in Store()
30 const flatbuffers::grpc::Message<Monster> *request, in Store()
31 flatbuffers::grpc::Message<Stat> *response) in Store()
40 return grpc::Status::OK; in Store()
42 virtual ::grpc::Status Retrieve(::grpc::ServerContext *context, in Retrieve()
43 const flatbuffers::grpc::Message<Stat> *request, in Retrieve()
44 ::grpc::ServerWriter< flatbuffers::grpc::Message<Monster>>* writer) in Retrieve()
55 flatbuffers::grpc::Message<Monster> monster = fbb_.ReleaseMessage<Monster>(); in Retrieve()
60 return grpc::Status::OK; in Retrieve()
64 flatbuffers::grpc::MessageBuilder fbb_;
[all …]
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_service_impl.h30 namespace grpc {
40 namespace grpc {
51 virtual ::grpc::Status GetRemoteAddress(
52 ::grpc::ClientContext* context, const GetRemoteAddressRequest& request,
57 Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel);
58 ::grpc::Status GetRemoteAddress(
59 ::grpc::ClientContext* context, const GetRemoteAddressRequest& request,
63 std::shared_ptr< ::grpc::ChannelInterface> channel_;
64 const ::grpc::internal::RpcMethod rpcmethod_GetRemoteAddress_;
67 const std::shared_ptr< ::grpc::ChannelInterface>& channel,
[all …]
Dgrpc_verbs_service_impl.cc29 namespace grpc { namespace
36 const std::shared_ptr< ::grpc::ChannelInterface>& channel, in NewStub()
37 const ::grpc::StubOptions& options) { in NewStub()
43 const std::shared_ptr< ::grpc::ChannelInterface>& channel) in Stub()
46 ::grpc::internal::RpcMethod::NORMAL_RPC, in Stub()
49 ::grpc::Status VerbsService::Stub::GetRemoteAddress( in GetRemoteAddress()
50 ::grpc::ClientContext* context, const GetRemoteAddressRequest& request, in GetRemoteAddress()
52 return ::grpc::internal::BlockingUnaryCall( in GetRemoteAddress()
58 AddMethod(new ::grpc::internal::RpcServiceMethod( in AsyncService()
60 ::grpc::internal::RpcMethod::NORMAL_RPC, nullptr)); in AsyncService()
[all …]
/external/flatbuffers/tests/MyGame/Example/
DMonsterStorage_grpc.go11 grpc "google.golang.org/grpc" packageName
17 opts... grpc.CallOption) (* Stat, error)
19 opts... grpc.CallOption) (MonsterStorage_RetrieveClient, error)
23 cc *grpc.ClientConn
26 func NewMonsterStorageClient(cc *grpc.ClientConn) MonsterStorageClient {
31 opts... grpc.CallOption) (* Stat, error) {
33 err := grpc.Invoke(ctx, "/Example.MonsterStorage/Store", in, out, c.cc, opts...)
39 opts... grpc.CallOption) (MonsterStorage_RetrieveClient, error) {
40 …stream, err := grpc.NewClientStream(ctx, &_MonsterStorage_serviceDesc.Streams[0], c.cc, "/Example.…
50 grpc.ClientStream
[all …]
/external/flatbuffers/grpc/samples/greeter/
Dserver.cpp11 virtual grpc::Status SayHello( in SayHello()
12 grpc::ServerContext *context, in SayHello()
13 const flatbuffers::grpc::Message<HelloRequest> *request_msg, in SayHello()
14 flatbuffers::grpc::Message<HelloReply> *response_msg) override { in SayHello()
37 return grpc::Status::OK; in SayHello()
40 virtual grpc::Status SayManyHellos( in SayManyHellos()
41 grpc::ServerContext *context, in SayManyHellos()
42 const flatbuffers::grpc::Message<ManyHellosRequest> *request_msg, in SayManyHellos()
43 grpc::ServerWriter<flatbuffers::grpc::Message<HelloReply>> *writer) in SayManyHellos()
58 return grpc::Status::OK; in SayManyHellos()
[all …]
Dclient.cpp12 GreeterClient(std::shared_ptr<grpc::Channel> channel) in GreeterClient()
16 flatbuffers::grpc::MessageBuilder mb; in SayHello()
22 flatbuffers::grpc::Message<HelloReply> response_msg; in SayHello()
24 grpc::ClientContext context; in SayHello()
39 flatbuffers::grpc::MessageBuilder mb; in SayManyHellos()
46 flatbuffers::grpc::Message<HelloReply> response_msg; in SayManyHellos()
48 grpc::ClientContext context; in SayManyHellos()
71 grpc::CreateChannel(server_address, grpc::InsecureChannelCredentials()); in main()
/external/flatbuffers/src/
Didl_gen_grpc.cpp49 grpc::string GetLeadingComments(const grpc::string) const { in GetLeadingComments()
52 grpc::string GetTrailingComments(const grpc::string) const { in GetTrailingComments()
55 std::vector<grpc::string> GetAllComments() const { in GetAllComments()
56 return std::vector<grpc::string>(); in GetAllComments()
73 grpc::string * /*str*/, grpc::string /*generator_file_name*/, in get_module_and_message_path_input()
74 bool /*generate_in_pb2_grpc*/, grpc::string /*import_prefix*/) const { in get_module_and_message_path_input()
79 grpc::string * /*str*/, grpc::string /*generator_file_name*/, in get_module_and_message_path_output()
80 bool /*generate_in_pb2_grpc*/, grpc::string /*import_prefix*/) const { in get_module_and_message_path_output()
106 grpc::string GetLeadingComments(const grpc::string) const { in GetLeadingComments()
109 grpc::string GetTrailingComments(const grpc::string) const { in GetTrailingComments()
[all …]
/external/flatbuffers/include/flatbuffers/
Dgrpc.h27 namespace grpc {
195 namespace grpc {
198 class SerializationTraits<flatbuffers::grpc::Message<T>> {
200 static grpc::Status Serialize(const flatbuffers::grpc::Message<T> &msg, in Serialize()
211 return grpc::Status::OK; in Serialize()
215 static grpc::Status Deserialize(grpc_byte_buffer *buffer, in Deserialize()
216 flatbuffers::grpc::Message<T> *msg) { in Deserialize()
218 return ::grpc::Status(::grpc::StatusCode::INTERNAL, "No payload"); in Deserialize()
227 *msg = flatbuffers::grpc::Message<T>(slice, true); in Deserialize()
237 *msg = flatbuffers::grpc::Message<T>(slice, false); in Deserialize()
[all …]
/external/flatbuffers/docs/source/gRPC/
DCppUsage.md10 - [gRPC](http://www.grpc.io/docs/) usage
14 NOTE: The examples below are also in the `grpc/samples/greeter` directory.
18 @include grpc/samples/greeter/greeter.fbs
20 When we run `flatc`, we pass in the `--grpc` option and generage an additional
21 `greeter.grpc.fb.h` and `greeter.grpc.fb.cc`.
25 @include grpc/samples/greeter/server.cpp
29 @include grpc/samples/greeter/client.cpp

12345