Home
last modified time | relevance | path

Searched refs:grpc (Results 1 – 25 of 47) sorted by relevance

12

/tools/netsim/src/frontend/
Dfrontend_server.cc42 grpc::ServerWriter<netsim::frontend::GetCaptureResponse> *grpc_writer) in CxxServerResponseWritable()
70 mutable grpc::ServerWriter<netsim::frontend::GetCaptureResponse>
80 grpc::Status GetVersion(grpc::ServerContext *context, in GetVersion()
84 return grpc::Status::OK; in GetVersion()
87 grpc::Status ListDevice(grpc::ServerContext *context, in ListDevice()
94 return grpc::Status::OK; in ListDevice()
96 return grpc::Status(grpc::StatusCode::UNKNOWN, writer.err); in ListDevice()
99 grpc::Status CreateDevice(grpc::ServerContext *context, in CreateDevice()
108 return grpc::Status::OK; in CreateDevice()
110 return grpc::Status(grpc::StatusCode::UNKNOWN, writer.err); in CreateDevice()
[all …]
Dfrontend_client.cc47 std::shared_ptr<grpc::Channel> channel = in NewFrontendStub()
48 grpc::CreateChannel(server, grpc::InsecureChannelCredentials()); in NewFrontendStub()
66 const grpc::Status &status, in make_result()
80 grpc::ClientContext context_; in GetVersion()
88 grpc::ClientContext context_; in ListDevice()
94 grpc::ClientContext context_; in Reset()
103 grpc::ClientContext context_; in CreateDevice()
108 grpc::Status( in CreateDevice()
109 grpc::StatusCode::INVALID_ARGUMENT, in CreateDevice()
122 grpc::ClientContext context_; in PatchDevice()
[all …]
Dfrontend_client_stub.cc40 std::shared_ptr<grpc::Channel> channel = in NewFrontendClient()
41 grpc::CreateChannel(server, grpc::InsecureChannelCredentials()); in NewFrontendClient()
/tools/netsim/proto/
DAndroid.bp24 name: "netsim-grpc-gen-defaults",
27 "protoc-gen-grpc-cpp-plugin",
33 " --plugin=protoc-gen-grpc=$(location protoc-gen-grpc-cpp-plugin)" +
46 defaults: ["netsim-grpc-gen-defaults"],
47 out: ["netsim/frontend.grpc.pb.h"],
52 defaults: ["netsim-grpc-gen-defaults"],
53 out: ["netsim/frontend.grpc.pb.cc"],
58 defaults: ["netsim-grpc-gen-defaults"],
59 out: ["netsim/packet_streamer.grpc.pb.h"],
64 defaults: ["netsim-grpc-gen-defaults"],
[all …]
DCMakeLists.txt37 DEPS grpc++ protobuf::libprotobuf)
50 DEPS grpc++ netsimd-proto-lib protobuf::libprotobuf)
64 SRC ${NETSIM_PACKET_STREAMER_GRPC_SRC} DEPS grpc++ netsimd-proto-lib
/tools/netsim/src/backend/
Dpacket_streamer_client.cc44 std::shared_ptr<grpc::Channel> packet_stream_channel;
47 std::shared_ptr<grpc::Channel> CreateGrpcChannel() { in CreateGrpcChannel()
59 std::unique_ptr<grpc::experimental::ClientInterceptorFactoryInterface>> in CreateGrpcChannel()
62 grpc::ChannelArguments args; in CreateGrpcChannel()
63 return grpc::experimental::CreateCustomChannelWithInterceptors( in CreateGrpcChannel()
64 endpoint, grpc::InsecureChannelCredentials(), args, in CreateGrpcChannel()
68 bool GrpcChannelReady(const std::shared_ptr<grpc::Channel> &channel) { in GrpcChannelReady()
106 std::shared_ptr<grpc::Channel> GetChannel(NetsimdOptions options) { in GetChannel()
131 std::shared_ptr<grpc::Channel> CreateChannel(NetsimdOptions options) { in CreateChannel()
135 std::shared_ptr<grpc::Channel> CreateChannel( in CreateChannel()
Dgrpc_client.cc43 using Stream = ::grpc::ClientReaderWriter<netsim::packet::PacketRequest,
51 std::unordered_map<uint32_t, grpc::ClientContext> contexts_;
55 std::shared_ptr<grpc::Channel> channel_;
56 grpc::ClientContext context_;
70 channel_ = grpc::CreateChannel(server, grpc::InsecureChannelCredentials()); in StreamPackets()
Dgrpc_server.cc42 ::grpc::ServerReaderWriter<packet::PacketResponse, packet::PacketRequest>;
57 ::grpc::Status StreamPackets(::grpc::ServerContext *context, in StreamPackets()
69 return ::grpc::Status(::grpc::StatusCode::INVALID_ARGUMENT, in StreamPackets()
108 return ::grpc::Status(::grpc::StatusCode::INVALID_ARGUMENT, in StreamPackets()
137 return ::grpc::Status::OK; in StreamPackets()
Dpacket_streamer_client.h47 ::grpc::ClientReaderWriter<packet::PacketRequest, packet::PacketResponse>>;
59 std::shared_ptr<grpc::Channel> CreateChannel(NetsimdOptions);
62 std::shared_ptr<grpc::Channel> CreateChannel(
DCMakeLists.txt10 android-grpc-interceptors
11 grpc++
/tools/tradefederation/core/
DAndroid.bp42 name: "lab-resource-grpc",
48 plugin: "grpc-java-plugin",
52 "grpc-java",
61 name: "tradefed-service-grpc-lib",
70 plugin: "grpc-java-plugin",
76 "grpc-java",
85 name: "tradefed-invocation-grpc",
91 plugin: "grpc-java-plugin",
95 "grpc-java",
104 name: "tradefed-device-manager-grpc",
[all …]
/tools/apksig/
DAndroid.bp132 "grpc-java-api",
133 "grpc-java-auth",
134 "grpc-java-context",
135 "grpc-java-core",
136 "grpc-java-core-internal",
137 "grpc-java-core-util",
138 "grpc-java-netty-shaded",
139 "grpc-java-protobuf",
140 "grpc-java-protobuf-lite",
141 "grpc-java-stub",
[all …]
/tools/netsim/src/core/
Dserver.cc45 std::pair<std::unique_ptr<grpc::Server>, uint32_t> RunGrpcServer( in RunGrpcServer()
47 grpc::ServerBuilder builder; in RunGrpcServer()
50 grpc::InsecureServerCredentials(), &selected_port); in RunGrpcServer()
61 builder.AddListeningPort(vsock_uri, grpc::InsecureServerCredentials()); in RunGrpcServer()
68 std::unique_ptr<grpc::Server> server(builder.BuildAndStart()); in RunGrpcServer()
Dserver.h28 GrpcServer(std::unique_ptr<grpc::Server> server, std::uint32_t port) in GrpcServer()
35 std::unique_ptr<grpc::Server> server;
/tools/tradefederation/core/javatests/com/android/tradefed/cache/remote/
DByteStreamDownloaderTest.java30 import io.grpc.ManagedChannel;
31 import io.grpc.Server;
32 import io.grpc.Status;
33 import io.grpc.stub.StreamObserver;
34 import io.grpc.inprocess.InProcessChannelBuilder;
35 import io.grpc.inprocess.InProcessServerBuilder;
36 import io.grpc.util.MutableHandlerRegistry;
DRemoteCacheClientTest.java35 import io.grpc.ManagedChannel;
36 import io.grpc.Server;
37 import io.grpc.Status;
38 import io.grpc.stub.StreamObserver;
39 import io.grpc.inprocess.InProcessChannelBuilder;
40 import io.grpc.inprocess.InProcessServerBuilder;
41 import io.grpc.util.MutableHandlerRegistry;
/tools/tradefederation/core/common_util/
DAndroid.bp39 "grpc-java-api",
40 "grpc-java-stub",
41 "remote-execution-java-grpc",
43 "bytestream-java-grpc",
/tools/tradefederation/core/src/com/android/tradefed/invoker/shard/
DConfigurableGrpcDynamicShardingClient.java30 import io.grpc.ManagedChannel;
31 import io.grpc.ManagedChannelBuilder;
32 import io.grpc.auth.MoreCallCredentials;
/tools/tradefederation/core/common_util/com/android/tradefed/cache/remote/
DByteStreamDownloader.java33 import io.grpc.CallCredentials;
34 import io.grpc.Channel;
35 import io.grpc.StatusRuntimeException;
36 import io.grpc.stub.StreamObserver;
DRemoteCacheClient.java34 import io.grpc.CallCredentials;
35 import io.grpc.ManagedChannel;
36 import io.grpc.Status.Code;
37 import io.grpc.StatusRuntimeException;
/tools/tradefederation/core/javatests/com/android/tradefed/monitoring/
DLabResourceDeviceMonitorTest.java48 import io.grpc.ManagedChannel;
49 import io.grpc.Server;
50 import io.grpc.inprocess.InProcessChannelBuilder;
51 import io.grpc.inprocess.InProcessServerBuilder;
52 import io.grpc.testing.GrpcCleanupRule;
/tools/netsim/
DCMakeLists.txt43 DEPS frontend-client grpc++ netsim-cli-proto-lib netsim-cli-rust-lib
50 DEPS grpc++
70 grpc++
100 DEPS grpc++ packet-streamer-client-lib packet-streamer-proto-lib
/tools/tradefederation/core/src/com/android/tradefed/service/
DTradefedFeatureClient.java32 import io.grpc.ManagedChannel;
33 import io.grpc.ManagedChannelBuilder;
34 import io.grpc.StatusRuntimeException;
/tools/tradefederation/core/src/com/android/tradefed/util/
DRequestUtil.java22 import io.grpc.Status;
23 import io.grpc.StatusRuntimeException;
/tools/netsim/rust/
DCMakeLists.txt16 GRPCIO_SYS_GRPC_INCLUDE_PATH="${CMAKE_CURRENT_SOURCE_DIR}/../../../external/grpc/include"
22 GRPCIO_SYS_GRPC_INCLUDE_PATH="${CMAKE_CURRENT_SOURCE_DIR}/../../../external/grpc/include"
27 GRPCIO_SYS_GRPC_INCLUDE_PATH="${CMAKE_CURRENT_SOURCE_DIR}/../../../external/grpc/include"

12