Home
last modified time | relevance | path

Searched refs:ServerArgs (Results 1 – 20 of 20) sorted by relevance

/external/grpc-grpc-java/benchmarks/src/test/java/io/grpc/benchmarks/driver/
DLoadWorkerTest.java67 Control.ServerArgs.Builder serverArgsBuilder = Control.ServerArgs.newBuilder(); in runUnaryBlockingClosedLoop()
95 Control.ServerArgs.Builder serverArgsBuilder = Control.ServerArgs.newBuilder(); in runUnaryAsyncClosedLoop()
124 Control.ServerArgs.Builder serverArgsBuilder = Control.ServerArgs.newBuilder(); in runPingPongAsyncClosedLoop()
153 Control.ServerArgs.Builder serverArgsBuilder = Control.ServerArgs.newBuilder(); in runGenericPingPongAsyncClosedLoop()
235 private int startServer(Control.ServerArgs serverArgs) throws InterruptedException {
238 StreamObserver<Control.ServerArgs> serverObserver =
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadWorker.java24 import io.grpc.benchmarks.proto.Control.ServerArgs;
25 import io.grpc.benchmarks.proto.Control.ServerArgs.ArgtypeCase;
126 public StreamObserver<ServerArgs> runServer( in runServer()
128 return new StreamObserver<ServerArgs>() { in runServer()
130 public void onNext(ServerArgs value) { in runServer()
133 if (argTypeCase == ServerArgs.ArgtypeCase.SETUP && workerServer == null) { in runServer()
135 Control.ServerArgs.Builder builder = value.toBuilder(); in runServer()
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DWorkerServiceGrpc.cs32 …ServerArgs> __Marshaller_grpc_testing_ServerArgs = grpc::Marshallers.Create((arg) => global::Googl…
40 …bal::Grpc.Testing.ServerArgs, global::Grpc.Testing.ServerStatus> __Method_RunServer = new grpc::Me…
89 …ing.Tasks.Task RunServer(grpc::IAsyncStreamReader<global::Grpc.Testing.ServerArgs> requestStream, … in RunServer()
170 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ServerArgs, global::Grpc.Testin… in RunServer()
184 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ServerArgs, global::Grpc.Testin… in RunServer()
DWorkerServiceImpl.cs42 …public override async Task RunServer(IAsyncStreamReader<ServerArgs> requestStream, IServerStreamWr… in RunServer()
DControl.cs117 …pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.ServerArgs), global::Grpc.Testing.ServerArgs… in ControlReflection()
2532 public sealed partial class ServerArgs : pb::IMessage<ServerArgs> { class
2533 …ate static readonly pb::MessageParser<ServerArgs> _parser = new pb::MessageParser<ServerArgs>(() =…
2536 public static pb::MessageParser<ServerArgs> Parser { get { return _parser; } }
2549 public ServerArgs() { in ServerArgs() method in Grpc.Testing.ServerArgs
2556 public ServerArgs(ServerArgs other) : this() { in ServerArgs() method in Grpc.Testing.ServerArgs
2570 public ServerArgs Clone() { in Clone()
2571 return new ServerArgs(this); in Clone()
2617 return Equals(other as ServerArgs); in Equals()
2621 public bool Equals(ServerArgs other) { in Equals()
[all …]
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DWorkerServiceGrpc.java30 private static volatile io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs,
35 requestType = io.grpc.benchmarks.proto.Control.ServerArgs.class,
38 public static io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs,
40 …io.grpc.MethodDescriptor<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Con… in getRunServerMethod()
45 …io.grpc.MethodDescriptor.<io.grpc.benchmarks.proto.Control.ServerArgs, io.grpc.benchmarks.proto.Co… in getRunServerMethod()
51 io.grpc.benchmarks.proto.Control.ServerArgs.getDefaultInstance())) in getRunServerMethod()
195 public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerArgs> runServer( in runServer()
241 io.grpc.benchmarks.proto.Control.ServerArgs, in bindService()
297 public io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerArgs> runServer( in runServer()
/external/grpc-grpc/test/cpp/qps/
Dqps_worker.cc120 ServerReaderWriter<ServerStatus, ServerArgs>* stream) override { in RunServer()
221 ServerReaderWriter<ServerStatus, ServerArgs>* stream) { in RunServerBody()
222 ServerArgs args; in RunServerBody()
Ddriver.cc269 unique_ptr<ClientReaderWriter<ServerArgs, ServerStatus>> stream; in RunScenario()
293 ServerArgs args; in RunScenario()
379 ServerArgs server_mark; in RunScenario()
/external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/
Dworker_service_services_pb.rb41 rpc :RunServer, stream(ServerArgs), stream(ServerStatus)
Dcontrol_pb.rb170 …ServerArgs = Google::Protobuf::DescriptorPool.generated_pool.lookup("grpc.testing.ServerArgs").msg… constant
/external/grpc-grpc/src/php/tests/qps/generated_code/Grpc/Testing/
DServerArgs.php14 class ServerArgs extends \Google\Protobuf\Internal\Message class
/external/llvm-project/lldb/unittests/tools/lldb-server/tests/
DTestClient.cpp64 …stClient>> TestClient::launchCustom(StringRef Log, ArrayRef<StringRef> ServerArgs, ArrayRef<String… in launchCustom() argument
89 for (StringRef arg : ServerArgs) in launchCustom()
DTestClient.h51 …launchCustom(llvm::StringRef Log, llvm::ArrayRef<llvm::StringRef> ServerArgs, llvm::ArrayRef<llvm:…
/external/grpc-grpc/src/proto/grpc/testing/
Dworker_service.proto30 rpc RunServer(stream ServerArgs) returns (stream ServerStatus);
Dcontrol.proto166 message ServerArgs { message
/external/rust/crates/grpcio-sys/grpc/src/proto/grpc/testing/
Dworker_service.proto30 rpc RunServer(stream ServerArgs) returns (stream ServerStatus);
Dcontrol.proto174 message ServerArgs { message
/external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/
Dservices.proto56 rpc RunServer(stream ServerArgs) returns (stream ServerStatus);
Dcontrol.proto153 message ServerArgs { message
/external/grpc-grpc-java/benchmarks/src/generated/main/java/io/grpc/benchmarks/proto/
DControl.java10127 public io.grpc.benchmarks.proto.Control.ServerArgs.ArgtypeCase getArgtypeCase(); in getArgtypeCase()
10132 public static final class ServerArgs extends class in Control
10138 private ServerArgs(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { in ServerArgs() method in Control.ServerArgs
10141 private ServerArgs() { in ServerArgs() method in Control.ServerArgs
10149 private ServerArgs( in ServerArgs() method in Control.ServerArgs
10224 …io.grpc.benchmarks.proto.Control.ServerArgs.class, io.grpc.benchmarks.proto.Control.ServerArgs.Bui… in internalGetFieldAccessorTable()
10361 if (!(obj instanceof io.grpc.benchmarks.proto.Control.ServerArgs)) { in equals()
10364 …io.grpc.benchmarks.proto.Control.ServerArgs other = (io.grpc.benchmarks.proto.Control.ServerArgs) … in equals()
10410 public static io.grpc.benchmarks.proto.Control.ServerArgs parseFrom( in parseFrom()
10415 public static io.grpc.benchmarks.proto.Control.ServerArgs parseFrom( in parseFrom()
[all …]