| /external/grpc-grpc/src/cpp/server/ |
| D | server_builder.cc | 43 ServerBuilder::ServerBuilder() in ServerBuilder() function in grpc::ServerBuilder
65 ServerBuilder::~ServerBuilder() { in ~ServerBuilder()
71 std::unique_ptr<ServerCompletionQueue> ServerBuilder::AddCompletionQueue( in AddCompletionQueue()
79 ServerBuilder& ServerBuilder::RegisterService(Service* service) { in RegisterService()
84 ServerBuilder& ServerBuilder::RegisterService(const grpc::string& addr, in RegisterService()
90 ServerBuilder& ServerBuilder::RegisterAsyncGenericService( in RegisterAsyncGenericService()
103 ServerBuilder& ServerBuilder::SetOption( in SetOption()
109 ServerBuilder& ServerBuilder::SetSyncServerOption( in SetSyncServerOption()
110 ServerBuilder::SyncServerOption option, int val) { in SetSyncServerOption()
128 ServerBuilder& ServerBuilder::SetCompressionAlgorithmSupportStatus( in SetCompressionAlgorithmSupportStatus()
[all …]
|
| /external/grpc-grpc/include/grpcpp/ |
| D | server_builder.h | 52 class ServerBuilder {
54 ServerBuilder();
55 virtual ~ServerBuilder();
74 ServerBuilder& RegisterService(Service* service);
91 ServerBuilder& AddListeningPort(const grpc::string& addr_uri,
135 ServerBuilder& RegisterService(const grpc::string& host, Service* service);
141 ServerBuilder& RegisterAsyncGenericService(AsyncGenericService* service);
148 ServerBuilder& SetMaxReceiveMessageSize(int max_receive_message_size) { in SetMaxReceiveMessageSize()
155 ServerBuilder& SetMaxSendMessageSize(int max_send_message_size) { in SetMaxSendMessageSize()
161 ServerBuilder& SetMaxMessageSize(int max_message_size) { in SetMaxMessageSize()
[all …]
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | qps_server_builder.cc | 21 using grpc::ServerBuilder;
27 std::unique_ptr<ServerBuilder> DefaultCreateQpsServerBuilder() { in DefaultCreateQpsServerBuilder()
28 return std::unique_ptr<ServerBuilder>(new ServerBuilder()); in DefaultCreateQpsServerBuilder()
31 std::function<std::unique_ptr<ServerBuilder>()> g_create_qps_server_builder =
35 std::unique_ptr<ServerBuilder> CreateQpsServerBuilder() { in CreateQpsServerBuilder()
40 std::function<std::unique_ptr<ServerBuilder>()> create_qps_server_builder) { in SetCreateQpsServerBuilderFunc()
|
| D | qps_server_builder.h | 35 std::unique_ptr<ServerBuilder> CreateQpsServerBuilder();
41 std::function<std::unique_ptr<ServerBuilder>()>);
|
| /external/grpc-grpc/test/cpp/server/ |
| D | server_builder_test.cc | 47 TEST(ServerBuilderTest, NoOp) { ServerBuilder b; } in TEST()
50 ServerBuilder().RegisterService(&g_service).BuildAndStart()->Shutdown(); in TEST()
54 ServerBuilder() in TEST()
62 ServerBuilder() in TEST()
71 EXPECT_EQ(ServerBuilder() in TEST()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/ |
| D | ChannelAndServerBuilderTest.java | 63 if (ServerBuilder.class.isAssignableFrom(clazz) && clazz != ServerBuilder.class) { in params()
76 Assume.assumeTrue(ServerBuilder.class.isAssignableFrom(builderClass)); in serverBuilderHidesMethod_forPort()
80 assertTrue(ServerBuilder.class.isAssignableFrom(method.getReturnType())); in serverBuilderHidesMethod_forPort()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | thread_stress_test.cc | 80 virtual void SetUpStart(ServerBuilder* builder, Service* service) = 0;
81 void SetUpStartCommon(ServerBuilder* builder, Service* service) { in SetUpStartCommon()
86 void SetUpEnd(ServerBuilder* builder) { server_ = builder->BuildAndStart(); } in SetUpEnd()
105 void SetUpStart(ServerBuilder* builder, Service* service) override { in SetUpStart()
129 void SetUpStart(ServerBuilder* builder, Service* service) override { in SetUpStart()
138 ServerBuilder builder; in SetUp()
155 ServerBuilder builder; in SetUp()
177 ServerBuilder builder; in SetUp()
|
| D | server_builder_plugin_test.cc | 128 ::grpc::ServerBuilder::InternalAddPluginFactory( in AddTestServerBuilderPlugin()
146 builder_.reset(new ServerBuilder()); in SetUp()
211 std::unique_ptr<ServerBuilder> builder_;
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ServerBuilder.java | 32 public abstract class ServerBuilder<T extends ServerBuilder<T>> { class
40 public static ServerBuilder<?> forPort(int port) { in forPort()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service.h | 24 class ServerBuilder; variable
34 ::grpc::ServerBuilder* builder);
|
| D | grpc_worker_service.h | 28 class ServerBuilder; variable
75 GrpcWorker* worker, ::grpc::ServerBuilder* builder,
|
| /external/grpc-grpc/include/grpcpp/impl/ |
| D | server_builder_plugin.h | 28 class ServerBuilder; variable
43 virtual void UpdateServerBuilder(ServerBuilder* builder) {} in UpdateServerBuilder()
|
| /external/grpc-grpc/examples/cpp/helloworld/ |
| D | greeter_server.cc | 32 using grpc::ServerBuilder;
53 ServerBuilder builder; in RunServer()
|
| D | greeter_async_server.cc | 31 using grpc::ServerBuilder;
51 ServerBuilder builder; in Run()
|
| /external/grpc-grpc-java/netty/shaded/src/testShadow/java/io/grpc/netty/shaded/ |
| D | ShadingTest.java | 24 import io.grpc.ServerBuilder;
69 assertThat(ServerBuilder.forPort(0)).isInstanceOf(NettyServerBuilder.class); in serviceLoaderFindsNetty()
76 server = ServerBuilder.forPort(0) in basic()
|
| /external/tensorflow/tensorflow/contrib/verbs/ |
| D | grpc_verbs_service.h | 32 GrpcVerbsService(const WorkerEnv* worker_env, ::grpc::ServerBuilder* builder);
61 ::grpc::ServerBuilder* builder);
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/helloworld/ |
| D | HelloWorldServer.java | 20 import io.grpc.ServerBuilder;
36 server = ServerBuilder.forPort(port) in start()
|
| /external/grpc-grpc-java/examples/example-kotlin/src/main/kotlin/io/grpc/examples/helloworld/ |
| D | HelloWorldServer.kt | 20 import io.grpc.ServerBuilder
39 server = ServerBuilder.forPort(port) in start()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/ |
| D | CustomHeaderServer.java | 20 import io.grpc.ServerBuilder;
41 server = ServerBuilder.forPort(PORT) in start()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_fixtures.h | 57 virtual void ApplyCommonServerBuilderConfig(ServerBuilder* b) const { in ApplyCommonServerBuilderConfig()
78 ServerBuilder b; in FullstackFixture()
178 ServerBuilder b; in EndpointPairFixture()
324 void ApplyCommonServerBuilderConfig(ServerBuilder* b) const override { in ApplyCommonServerBuilderConfig()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/ |
| D | ManualFlowControlServer.java | 20 import io.grpc.ServerBuilder;
126 final Server server = ServerBuilder in main()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/advanced/ |
| D | HelloJsonServer.java | 23 import io.grpc.ServerBuilder;
53 server = ServerBuilder.forPort(port) in start()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadServer.java | 27 import io.grpc.ServerBuilder;
86 ServerBuilder<?> serverBuilder = ServerBuilder.forPort(port); in LoadServer()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractServerImplBuilder.java | 34 import io.grpc.ServerBuilder;
54 extends ServerBuilder<T> {
56 public static ServerBuilder<?> forPort(int port) { in forPort()
|
| /external/grpc-grpc/examples/android/helloworld/app/src/main/cpp/ |
| D | grpc-helloworld.cc | 29 using grpc::ServerBuilder;
55 ServerBuilder builder; in StartServer()
|