Home
last modified time | relevance | path

Searched refs:ClientStatus (Results 1 – 19 of 19) sorted by relevance

/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DWorkerServiceGrpc.cs35 …ClientStatus> __Marshaller_grpc_testing_ClientStatus = grpc::Marshallers.Create((arg) => global::G…
47 …al::Grpc.Testing.ClientStatus> __Method_RunClient = new grpc::Method<global::Grpc.Testing.ClientAr…
106 …ntArgs> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.ClientStatus> responseStream… in RunClient()
200 …exStreamingCall<global::Grpc.Testing.ClientArgs, global::Grpc.Testing.ClientStatus> RunClient(grpc… in RunClient()
214 …exStreamingCall<global::Grpc.Testing.ClientArgs, global::Grpc.Testing.ClientStatus> RunClient(grpc… in RunClient()
DWorkerServiceImpl.cs66 …ent(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWriter<ClientStatus> responseStream… in RunClient()
72 await responseStream.WriteAsync(new ClientStatus in RunClient()
80 await responseStream.WriteAsync(new ClientStatus in RunClient()
DControl.cs113 …r::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ClientStatus), global::Grpc.Testing.ClientStat… in ControlReflection()
1625 public sealed partial class ClientStatus : pb::IMessage<ClientStatus> { class
1626 … static readonly pb::MessageParser<ClientStatus> _parser = new pb::MessageParser<ClientStatus>(() …
1629 public static pb::MessageParser<ClientStatus> Parser { get { return _parser; } }
1642 public ClientStatus() { in ClientStatus() method in Grpc.Testing.ClientStatus
1649 public ClientStatus(ClientStatus other) : this() { in ClientStatus() method in Grpc.Testing.ClientStatus
1655 public ClientStatus Clone() { in Clone()
1656 return new ClientStatus(this); in Clone()
1672 return Equals(other as ClientStatus); in Equals()
1676 public bool Equals(ClientStatus other) { in Equals()
[all …]
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DWorkerServiceGrpc.java63 io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod;
68 responseType = io.grpc.benchmarks.proto.Control.ClientStatus.class,
71 io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod() { in getRunClientMethod()
72 …benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMe… in getRunClientMethod()
77 …rpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus>newBuilder() in getRunClientMethod()
85 io.grpc.benchmarks.proto.Control.ClientStatus.getDefaultInstance())) in getRunClientMethod()
211 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus> responseObserver) { in runClient()
249 io.grpc.benchmarks.proto.Control.ClientStatus>( in bindService()
314 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus> responseObserver) { in runClient()
467 … (io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus>) responseObserver); in invoke()
/external/grpc-grpc/test/cpp/qps/
Dqps_worker.cc106 ServerReaderWriter<ClientStatus, ClientArgs>* stream) override { in RunClient() argument
181 ServerReaderWriter<ClientStatus, ClientArgs>* stream) { in RunClientBody() argument
195 ClientStatus status; in RunClientBody()
Ddriver.cc329 unique_ptr<ClientReaderWriter<ClientArgs, ClientStatus>> stream; in RunScenario()
370 ClientStatus init_status; in RunScenario()
384 ClientStatus client_status; in RunScenario()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadWorker.java187 final StreamObserver<Control.ClientStatus> responseObserver) {
196 responseObserver.onNext(Control.ClientStatus.newBuilder().build());
198 responseObserver.onNext(Control.ClientStatus.newBuilder()
/external/grpc-grpc/src/proto/grpc/testing/
Dworker_service.proto33 // First request sent specifies the ClientConfig followed by ClientStatus
38 rpc RunClient(stream ClientArgs) returns (stream ClientStatus);
Dcontrol.proto120 message ClientStatus { ClientStats stats = 1; } message
/external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/
Dworker_service.proto33 // First request sent specifies the ClientConfig followed by ClientStatus
38 rpc RunClient(stream ClientArgs) returns (stream ClientStatus);
Dcontrol.proto125 message ClientStatus { ClientStats stats = 1; } message
/external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/
Dworker_service_services_pb.rb48 rpc :RunClient, stream(ClientArgs), stream(ClientStatus)
Dcontrol_pb.rb166 …ClientStatus = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.ClientStatus")… constant
/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
DClientStatus.php14 class ClientStatus extends \Google\Protobuf\Internal\Message class
/external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/
Dservices.proto59 // First request sent specifies the ClientConfig followed by ClientStatus
64 rpc RunClient(stream ClientArgs) returns (stream ClientStatus);
Dcontrol.proto111 message ClientStatus { ClientStats stats = 1; } message
/external/grpc-grpc-java/benchmarks/src/test/java/io/grpc/benchmarks/driver/
DLoadWorkerTest.java209 new StreamObserver<Control.ClientStatus>() {
211 public void onNext(Control.ClientStatus value) {
/external/grpc-grpc/src/python/grpcio_tests/tests/qps/
Dworker_server.py143 return control_pb2.ClientStatus(stats=stats)
/external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/
DControl.java6456 public static final class ClientStatus extends class in Control
6462 private ClientStatus(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in ClientStatus() method in Control.ClientStatus
6465 private ClientStatus() { in ClientStatus() method in Control.ClientStatus
6473 private ClientStatus( in ClientStatus() method in Control.ClientStatus
6533 …io.grpc.benchmarks.proto.Control.ClientStatus.class, io.grpc.benchmarks.proto.Control.ClientStatus… in internalGetFieldAccessorTable()
6594 if (!(obj instanceof io.grpc.benchmarks.proto.Control.ClientStatus)) { in equals()
6597 …io.grpc.benchmarks.proto.Control.ClientStatus other = (io.grpc.benchmarks.proto.Control.ClientStat… in equals()
6625 public static io.grpc.benchmarks.proto.Control.ClientStatus parseFrom( in parseFrom()
6630 public static io.grpc.benchmarks.proto.Control.ClientStatus parseFrom( in parseFrom()
6636 public static io.grpc.benchmarks.proto.Control.ClientStatus parseFrom( in parseFrom()
[all …]