HomeSort by relevance Sort by last modified time
    Searched refs:ClientStatus (Results 1 - 15 of 15) sorted by null

  /external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/
worker_service_services_pb.rb 43 # First request sent specifies the ClientConfig followed by ClientStatus
48 rpc :RunClient, stream(ClientArgs), stream(ClientStatus)
control_pb.rb 51 add_message "grpc.testing.ClientStatus" do
166 ClientStatus = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.ClientStatus").msgclass
  /external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
ClientStatus.php 12 * Generated from protobuf message <code>grpc.testing.ClientStatus</code>
14 class ClientStatus extends \Google\Protobuf\Internal\Message
  /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
WorkerServiceImpl.cs 66 public override async Task RunClient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWriter<ClientStatus> responseStream, ServerCallContext context)
72 await responseStream.WriteAsync(new ClientStatus
80 await responseStream.WriteAsync(new ClientStatus
WorkerServiceGrpc.cs 35 static readonly grpc::Marshaller<global::Grpc.Testing.ClientStatus> __Marshaller_grpc_testing_ClientStatus = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::Grpc.Testing.ClientStatus.Parser.ParseFrom);
47 static readonly grpc::Method<global::Grpc.Testing.ClientArgs, global::Grpc.Testing.ClientStatus> __Method_RunClient = new grpc::Method<global::Grpc.Testing.ClientArgs, global::Grpc.Testing.ClientStatus>(
96 /// First request sent specifies the ClientConfig followed by ClientStatus
106 public virtual global::System.Threading.Tasks.Task RunClient(grpc::IAsyncStreamReader<global::Grpc.Testing.ClientArgs> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.ClientStatus> responseStream, grpc::ServerCallContext context)
190 /// First request sent specifies the ClientConfig followed by ClientStatus
200 public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ClientArgs, global::Grpc.Testing.ClientStatus> RunClient(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken))
206 /// First request sent specifies the ClientConfig followed by ClientStatus
214 public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ClientArgs, global::Grpc.Testing.ClientStatus> RunClient(grpc::CallOptions options
    [all...]
Control.cs 113 new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ClientStatus), global::Grpc.Testing.ClientStatus.Parser, new[]{ "Stats" }, null, null, null),
    [all...]
  /external/grpc-grpc/src/ruby/qps/
worker.rb 65 q.push(Grpc::Testing::ClientStatus.new(stats: client.mark(false)))
67 q.push(Grpc::Testing::ClientStatus.new(stats:
proxy-worker.rb 120 q.push(Grpc::Testing::ClientStatus.new(stats: @bmc.mark(false)))
122 q.push(Grpc::Testing::ClientStatus.new(stats:
  /external/grpc-grpc/test/cpp/qps/
qps_worker.cc 106 ServerReaderWriter<ClientStatus, ClientArgs>* stream) override {
181 ServerReaderWriter<ClientStatus, ClientArgs>* stream) {
195 ClientStatus status;
driver.cc 329 unique_ptr<ClientReaderWriter<ClientArgs, ClientStatus>> stream;
370 ClientStatus init_status;
384 ClientStatus client_status;
  /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
LoadWorker.java 187 final StreamObserver<Control.ClientStatus> responseObserver) {
196 responseObserver.onNext(Control.ClientStatus.newBuilder().build());
198 responseObserver.onNext(Control.ClientStatus.newBuilder()
  /external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
WorkerServiceGrpc.java 63 io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod;
68 responseType = io.grpc.benchmarks.proto.Control.ClientStatus.class,
71 io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod() {
72 io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus> getRunClientMethod;
77 io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ClientArgs, io.grpc.benchmarks.proto.Control.ClientStatus>newBuilder()
85 io.grpc.benchmarks.proto.Control.ClientStatus.getDefaultInstance()))
203 * First request sent specifies the ClientConfig followed by ClientStatus
211 io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus> responseObserver) {
249 io.grpc.benchmarks.proto.Control.ClientStatus>(
306 * First request sent specifies the ClientConfig followed by ClientStatus
    [all...]
  /external/grpc-grpc-java/benchmarks/src/test/java/io/grpc/benchmarks/driver/
LoadWorkerTest.java 209 new StreamObserver<Control.ClientStatus>() {
211 public void onNext(Control.ClientStatus value) {
  /external/grpc-grpc/src/python/grpcio_tests/tests/qps/
worker_server.py 143 return control_pb2.ClientStatus(stats=stats)
  /external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/
Control.java     [all...]

Completed in 500 milliseconds