Home
last modified time | relevance | path

Searched refs:ClientArgs (Results 1 – 18 of 18) sorted by relevance

/external/grpc-grpc-java/benchmarks/src/test/java/io/grpc/benchmarks/driver/
DLoadWorkerTest.java46 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/
DLoadWorker.java23 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/
DWorkerServiceGrpc.cs34ClientArgs> __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()
DWorkerServiceImpl.cs66 …public override async Task RunClient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWr… in RunClient()
DControl.cs115 …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/
DWorkerServiceGrpc.java62 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/
Dqps_worker.cc106 ServerReaderWriter<ClientStatus, ClientArgs>* stream) override { in RunClient()
181 ServerReaderWriter<ClientStatus, ClientArgs>* stream) { in RunClientBody()
182 ClientArgs args; in RunClientBody()
Ddriver.cc329 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/
Dworker_service_services_pb.rb48 rpc :RunClient, stream(ClientArgs), stream(ClientStatus)
Dcontrol_pb.rb168ClientArgs = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.ClientArgs").msg… constant
/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
DClientArgs.php14 class ClientArgs extends \Google\Protobuf\Internal\Message class
/external/grpc-grpc/src/proto/grpc/testing/
Dworker_service.proto38 rpc RunClient(stream ClientArgs) returns (stream ClientStatus);
Dcontrol.proto128 message ClientArgs { message
/external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/
Dworker_service.proto38 rpc RunClient(stream ClientArgs) returns (stream ClientStatus);
Dcontrol.proto133 message ClientArgs { message
/external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/
Dservices.proto64 rpc RunClient(stream ClientArgs) returns (stream ClientStatus);
Dcontrol.proto119 message ClientArgs { message
/external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/
DControl.java7528 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 …]