| /external/grpc-grpc-java/benchmarks/src/test/java/io/grpc/benchmarks/driver/ |
| D | LoadWorkerTest.java | 67 Control.ServerArgs.Builder serverArgsBuilder = Control.ServerArgs.newBuilder(); in runUnaryBlockingClosedLoop()
95 Control.ServerArgs.Builder serverArgsBuilder = Control.ServerArgs.newBuilder(); in runUnaryAsyncClosedLoop()
124 Control.ServerArgs.Builder serverArgsBuilder = Control.ServerArgs.newBuilder(); in runPingPongAsyncClosedLoop()
153 Control.ServerArgs.Builder serverArgsBuilder = Control.ServerArgs.newBuilder(); in runGenericPingPongAsyncClosedLoop()
235 private int startServer(Control.ServerArgs serverArgs) throws InterruptedException {
238 StreamObserver<Control.ServerArgs> serverObserver =
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadWorker.java | 24 import io.grpc.benchmarks.proto.Control.ServerArgs;
25 import io.grpc.benchmarks.proto.Control.ServerArgs.ArgtypeCase;
126 public StreamObserver<ServerArgs> runServer( in runServer()
128 return new StreamObserver<ServerArgs>() { in runServer()
130 public void onNext(ServerArgs value) { in runServer()
133 if (argTypeCase == ServerArgs.ArgtypeCase.SETUP && workerServer == null) { in runServer()
135 Control.ServerArgs.Builder builder = value.toBuilder(); in runServer()
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | WorkerServiceGrpc.cs | 32 …ServerArgs> __Marshaller_grpc_testing_ServerArgs = grpc::Marshallers.Create((arg) => global::Googl…
40 …bal::Grpc.Testing.ServerArgs, global::Grpc.Testing.ServerStatus> __Method_RunServer = new grpc::Me…
89 …ing.Tasks.Task RunServer(grpc::IAsyncStreamReader<global::Grpc.Testing.ServerArgs> requestStream, … in RunServer()
170 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ServerArgs, global::Grpc.Testin… in RunServer()
184 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ServerArgs, global::Grpc.Testin… in RunServer()
|
| D | WorkerServiceImpl.cs | 42 …public override async Task RunServer(IAsyncStreamReader<ServerArgs> requestStream, IServerStreamWr… in RunServer()
|
| D | Control.cs | 117 …pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ServerArgs), global::Grpc.Testing.ServerArgs… in ControlReflection()
2532 public sealed partial class ServerArgs : pb::IMessage<ServerArgs> { class
2533 …ate static readonly pb::MessageParser<ServerArgs> _parser = new pb::MessageParser<ServerArgs>(() =…
2536 public static pb::MessageParser<ServerArgs> Parser { get { return _parser; } }
2549 public ServerArgs() { in ServerArgs() method in Grpc.Testing.ServerArgs
2556 public ServerArgs(ServerArgs other) : this() { in ServerArgs() method in Grpc.Testing.ServerArgs
2570 public ServerArgs Clone() { in Clone()
2571 return new ServerArgs(this); in Clone()
2617 return Equals(other as ServerArgs); in Equals()
2621 public bool Equals(ServerArgs other) { in Equals()
[all …]
|
| /external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ |
| D | WorkerServiceGrpc.java | 30 private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs,
35 requestType = io.grpc.benchmarks.proto.Control.ServerArgs.class,
38 public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs,
40 …io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Con… in getRunServerMethod()
45 …io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Co… in getRunServerMethod()
51 io.grpc.benchmarks.proto.Control.ServerArgs.getDefaultInstance())) in getRunServerMethod()
195 public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerArgs> runServer( in runServer()
241 io.grpc.benchmarks.proto.Control.ServerArgs, in bindService()
297 public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerArgs> runServer( in runServer()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | qps_worker.cc | 120 ServerReaderWriter<ServerStatus, ServerArgs>* stream) override { in RunServer()
221 ServerReaderWriter<ServerStatus, ServerArgs>* stream) { in RunServerBody()
222 ServerArgs args; in RunServerBody()
|
| D | driver.cc | 269 unique_ptr<ClientReaderWriter<ServerArgs, ServerStatus>> stream; in RunScenario()
293 ServerArgs args; in RunScenario()
379 ServerArgs server_mark; in RunScenario()
|
| /external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/ |
| D | worker_service_services_pb.rb | 41 rpc :RunServer, stream(ServerArgs), stream(ServerStatus)
|
| D | control_pb.rb | 170 …ServerArgs = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.ServerArgs").msg… constant
|
| /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/ |
| D | ServerArgs.php | 14 class ServerArgs extends \Google\Protobuf\Internal\Message class
|
| /external/grpc-grpc/src/proto/grpc/testing/ |
| D | worker_service.proto | 30 rpc RunServer(stream ServerArgs) returns (stream ServerStatus);
|
| D | control.proto | 166 message ServerArgs { message
|
| /external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/ |
| D | Control.java | 10127 public io.grpc.benchmarks.proto.Control.ServerArgs.ArgtypeCase getArgtypeCase(); in getArgtypeCase()
10132 public static final class ServerArgs extends class in Control
10138 private ServerArgs(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in ServerArgs() method in Control.ServerArgs
10141 private ServerArgs() { in ServerArgs() method in Control.ServerArgs
10149 private ServerArgs( in ServerArgs() method in Control.ServerArgs
10224 …io.grpc.benchmarks.proto.Control.ServerArgs.class, io.grpc.benchmarks.proto.Control.ServerArgs.Bui… in internalGetFieldAccessorTable()
10361 if (!(obj instanceof io.grpc.benchmarks.proto.Control.ServerArgs)) { in equals()
10364 …io.grpc.benchmarks.proto.Control.ServerArgs other = (io.grpc.benchmarks.proto.Control.ServerArgs) … in equals()
10410 public static io.grpc.benchmarks.proto.Control.ServerArgs parseFrom( in parseFrom()
10415 public static io.grpc.benchmarks.proto.Control.ServerArgs parseFrom( in parseFrom()
[all …]
|
| /external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/ |
| D | services.proto | 56 rpc RunServer(stream ServerArgs) returns (stream ServerStatus);
|
| D | control.proto | 153 message ServerArgs { message
|