/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/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/ |
D | worker_service.proto | 38 rpc RunClient(stream ClientArgs) returns (stream ClientStatus);
|
D | control.proto | 133 message ClientArgs { message
|
/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
|
/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 …]
|