| /external/grpc-grpc-java/benchmarks/src/test/java/io/grpc/benchmarks/driver/ |
| D | LoadWorkerTest.java | 46 private static final Control.ClientArgs MARK = Control.ClientArgs.newBuilder()
75 Control.ClientArgs.Builder clientArgsBuilder = Control.ClientArgs.newBuilder(); in runUnaryBlockingClosedLoop()
89 StreamObserver<Control.ClientArgs> clientObserver = startClient(clientArgsBuilder.build()); in runUnaryBlockingClosedLoop()
103 Control.ClientArgs.Builder clientArgsBuilder = Control.ClientArgs.newBuilder(); in runUnaryAsyncClosedLoop()
118 StreamObserver<Control.ClientArgs> clientObserver = startClient(clientArgsBuilder.build()); in runUnaryAsyncClosedLoop()
132 Control.ClientArgs.Builder clientArgsBuilder = Control.ClientArgs.newBuilder(); in runPingPongAsyncClosedLoop()
147 StreamObserver<Control.ClientArgs> clientObserver = startClient(clientArgsBuilder.build()); in runPingPongAsyncClosedLoop()
161 Control.ClientArgs.Builder clientArgsBuilder = Control.ClientArgs.newBuilder(); in runGenericPingPongAsyncClosedLoop()
176 StreamObserver<Control.ClientArgs> clientObserver = startClient(clientArgsBuilder.build()); in runGenericPingPongAsyncClosedLoop()
180 private void assertWorkOccurred(StreamObserver<Control.ClientArgs> clientObserver) in assertWorkOccurred()
[all …]
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadWorker.java | 23 import io.grpc.benchmarks.proto.Control.ClientArgs;
186 public StreamObserver<ClientArgs> runClient(
188 return new StreamObserver<ClientArgs>() {
190 public void onNext(ClientArgs value) {
192 ClientArgs.ArgtypeCase argTypeCase = value.getArgtypeCase();
193 if (argTypeCase == ClientArgs.ArgtypeCase.SETUP && workerClient == null) {
197 } else if (argTypeCase == ClientArgs.ArgtypeCase.MARK && workerClient != null) {
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | WorkerServiceGrpc.cs | 34 …ClientArgs> __Marshaller_grpc_testing_ClientArgs = grpc::Marshallers.Create((arg) => global::Googl…
47 …bal::Grpc.Testing.ClientArgs, global::Grpc.Testing.ClientStatus> __Method_RunClient = new grpc::Me…
106 …ing.Tasks.Task RunClient(grpc::IAsyncStreamReader<global::Grpc.Testing.ClientArgs> requestStream, … in RunClient()
200 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ClientArgs, global::Grpc.Testin… in RunClient()
214 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ClientArgs, global::Grpc.Testin… in RunClient()
|
| D | WorkerServiceImpl.cs | 66 …public override async Task RunClient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWr… in RunClient()
|
| D | Control.cs | 115 …pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ClientArgs), global::Grpc.Testing.ClientArgs… in ControlReflection()
1895 public sealed partial class ClientArgs : pb::IMessage<ClientArgs> { class
1896 …ate static readonly pb::MessageParser<ClientArgs> _parser = new pb::MessageParser<ClientArgs>(() =…
1899 public static pb::MessageParser<ClientArgs> Parser { get { return _parser; } }
1912 public ClientArgs() { in ClientArgs() method in Grpc.Testing.ClientArgs
1919 public ClientArgs(ClientArgs other) : this() { in ClientArgs() method in Grpc.Testing.ClientArgs
1933 public ClientArgs Clone() { in Clone()
1934 return new ClientArgs(this); in Clone()
1980 return Equals(other as ClientArgs); in Equals()
1984 public bool Equals(ClientArgs other) { in Equals()
[all …]
|
| /external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ |
| D | WorkerServiceGrpc.java | 62 private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs,
67 requestType = io.grpc.benchmarks.proto.Control.ClientArgs.class,
70 public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs,
72 …io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Con… in getRunClientMethod()
77 …io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Co… in getRunClientMethod()
83 io.grpc.benchmarks.proto.Control.ClientArgs.getDefaultInstance())) in getRunClientMethod()
210 public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientArgs> runClient( in runClient()
248 io.grpc.benchmarks.proto.Control.ClientArgs, in bindService()
313 public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientArgs> runClient( in runClient()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | qps_worker.cc | 106 ServerReaderWriter<ClientStatus, ClientArgs>* stream) override { in RunClient()
181 ServerReaderWriter<ClientStatus, ClientArgs>* stream) { in RunClientBody()
182 ClientArgs args; in RunClientBody()
|
| D | driver.cc | 329 unique_ptr<ClientReaderWriter<ClientArgs, ClientStatus>> stream; in RunScenario()
361 ClientArgs args; in RunScenario()
381 ClientArgs client_mark; in RunScenario()
|
| /external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/ |
| D | worker_service_services_pb.rb | 48 rpc :RunClient, stream(ClientArgs), stream(ClientStatus)
|
| D | control_pb.rb | 168 …ClientArgs = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.ClientArgs").msg… constant
|
| /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/ |
| D | ClientArgs.php | 14 class ClientArgs extends \Google\Protobuf\Internal\Message class
|
| /external/grpc-grpc/src/proto/grpc/testing/ |
| D | worker_service.proto | 38 rpc RunClient(stream ClientArgs) returns (stream ClientStatus);
|
| D | control.proto | 128 message ClientArgs { message
|
| /external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/ |
| D | Control.java | 7528 public io.grpc.benchmarks.proto.Control.ClientArgs.ArgtypeCase getArgtypeCase(); in getArgtypeCase()
7533 public static final class ClientArgs extends class in Control
7539 private ClientArgs(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in ClientArgs() method in Control.ClientArgs
7542 private ClientArgs() { in ClientArgs() method in Control.ClientArgs
7550 private ClientArgs( in ClientArgs() method in Control.ClientArgs
7625 …io.grpc.benchmarks.proto.Control.ClientArgs.class, io.grpc.benchmarks.proto.Control.ClientArgs.Bui… in internalGetFieldAccessorTable()
7762 if (!(obj instanceof io.grpc.benchmarks.proto.Control.ClientArgs)) { in equals()
7765 …io.grpc.benchmarks.proto.Control.ClientArgs other = (io.grpc.benchmarks.proto.Control.ClientArgs) … in equals()
7811 public static io.grpc.benchmarks.proto.Control.ClientArgs parseFrom( in parseFrom()
7816 public static io.grpc.benchmarks.proto.Control.ClientArgs parseFrom( in parseFrom()
[all …]
|
| /external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/ |
| D | services.proto | 64 rpc RunClient(stream ClientArgs) returns (stream ClientStatus);
|
| D | control.proto | 119 message ClientArgs { message
|