/external/grpc-grpc/src/ruby/end2end/ |
client_memory_usage_client.rb | 34 stub = Echo::EchoServer::Stub.new("localhost:#{server_port}", :this_channel_is_insecure) 35 stub.echo(Echo::EchoRequest.new(request: 'client/child'))
|
killed_client_thread_client.rb | 34 stub = Echo::EchoServer::Stub.new("localhost:#{server_port}", 36 stub.echo(Echo::EchoRequest.new(request: 'hello'))
|
forking_client_client.rb | 33 stub = Echo::EchoServer::Stub.new("localhost:#{server_port}", 35 stub.echo(Echo::EchoRequest.new(request: 'hello'))
|
/external/grpc-grpc/src/ruby/pb/grpc/testing/duplicate/ |
echo_duplicate_services_pb.rb | 40 Stub = Service.rpc_stub_class
|
/external/grpc-grpc/src/ruby/qps/src/proto/grpc/testing/ |
proxy-service_services_pb.rb | 38 Stub = Service.rpc_stub_class
|
benchmark_service_services_pb.rb | 53 Stub = Service.rpc_stub_class
|
worker_service_services_pb.rb | 55 Stub = Service.rpc_stub_class
|
/external/grpc-grpc/test/cpp/interop/ |
interop_client.h | 41 /// If new_stub_every_test_case is true, a new TestService::Stub object is 97 // TestServce::Stub is returned by Get() everytime it is called 101 TestService::Stub* Get(); 102 UnimplementedService::Stub* GetUnimplementedServiceStub(); 109 std::unique_ptr<TestService::Stub> stub_; 110 std::unique_ptr<UnimplementedService::Stub> unimplemented_service_stub_; 112 bool new_stub_every_call_; // If true, a new stub is returned by every
|
/external/grpc-grpc/src/ruby/pb/src/proto/grpc/testing/ |
test_services_pb.rb | 66 Stub = Service.rpc_stub_class 83 Stub = Service.rpc_stub_class 99 Stub = Service.rpc_stub_class
|
/external/tensorflow/tensorflow/contrib/verbs/ |
grpc_verbs_service_impl.h | 36 // and the gRPC generated stub and service classes. 47 class Stub GRPC_FINAL : public StubInterface { 49 Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel); 58 static std::unique_ptr<Stub> NewStub(
|
grpc_verbs_client.h | 41 std::unique_ptr<grpc::VerbsService::Stub> stub_;
|
/cts/tests/tests/telephony/current/src/android/telephony/euicc/cts/ |
EuiccServiceTest.java | 88 mEuiccServiceBinder = IEuiccService.Stub.asInterface(binder); 126 new IGetEidCallback.Stub() { 149 new IGetOtaStatusCallback.Stub() { 177 new IGetDownloadableSubscriptionMetadataCallback.Stub() { 200 new IOtaStatusChangedCallback.Stub() { 224 new IGetDefaultDownloadableSubscriptionListCallback.Stub() { 255 new IDownloadSubscriptionCallback.Stub() { 279 new IGetEuiccProfileInfoListCallback.Stub() { 303 new IGetEuiccInfoCallback.Stub() { 328 new IDeleteSubscriptionCallback.Stub() { [all...] |
/external/flatbuffers/tests/ |
monster_test.grpc.fb.cc | 26 std::unique_ptr< MonsterStorage::Stub> MonsterStorage::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) { 27 std::unique_ptr< MonsterStorage::Stub> stub(new MonsterStorage::Stub(channel)); 28 return stub; 31 MonsterStorage::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel) 38 ::grpc::Status MonsterStorage::Stub::Store(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Monster>& request, flatbuffers::grpc::Message<Stat>* response) { 42 ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::AsyncStoreRaw(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Monster>& request, ::grpc::CompletionQueue* cq) { 46 ::grpc::ClientAsyncResponseReader< flatbuffers::grpc::Message<Stat>>* MonsterStorage::Stub::PrepareAsyncStoreRaw(::grpc::ClientContext* context, const flatbuffers::grpc::Message<Monster>& r (…) [all...] |
/external/grpc-grpc/examples/ruby/pubsub/tech/pubsub/proto/ |
pubsub_services.rb | 43 Stub = Service.rpc_stub_class 69 Stub = Service.rpc_stub_class 85 Stub = Service.rpc_stub_class
|
/external/tensorflow/tensorflow/compiler/xla/rpc/ |
grpc_stub.h | 28 explicit GRPCStub(grpc::XlaService::Stub* stub) : grpc_stub_(stub) {} 80 grpc::XlaService::Stub* service() { return grpc_stub_; } 83 grpc::XlaService::Stub* grpc_stub_;
|
/device/google/marlin/telephony/ims/src/org/codeaurora/ims/ |
QtiImsExtListenerBaseImpl.java | 37 public class QtiImsExtListenerBaseImpl extends IQtiImsExtListener.Stub {
|
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
ShadowIAppOpsService.java | 13 @Implements(value = IAppOpsService.Stub.class, isInAndroidSdk = false)
|
/external/grpc-grpc/test/cpp/qps/ |
client_async.cc | 67 BenchmarkService::Stub* stub, const RequestType& req, 71 BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&, 76 stub_(stub), 120 BenchmarkService::Stub* stub_; 130 BenchmarkService::Stub*, grpc::ClientContext*, const RequestType&, 301 static std::unique_ptr<BenchmarkService::Stub> BenchmarkStubCreator( 307 : public AsyncClient<BenchmarkService::Stub, SimpleRequest> { 310 : AsyncClient<BenchmarkService::Stub, SimpleRequest>( 322 PrepareReq(BenchmarkService::Stub* stub, grpc::ClientContext* ctx [all...] |
/cts/hostsidetests/net/app2/src/com/android/cts/net/hostside/app2/ |
RemoteSocketFactoryService.java | 36 private IRemoteSocketFactory.Stub mBinder = new IRemoteSocketFactory.Stub() {
|
/external/swiftshader/third_party/LLVM/lib/ExecutionEngine/JIT/ |
JITEmitter.cpp | 99 /// FunctionToLazyStubMap - Keep track of the lazy stub created for a 135 // The address given to us for the stub may not be exactly right, it 136 // might be a little bit after the stub. As such, use upper_bound to 159 // unregister the stub addresses from the StubToResolverMap in 179 /// a lazy stub. It's actually here to make it more likely that far calls 180 /// succeed, but no single stub can guarantee that. I'll remove this in a 202 /// lazy-compilation stub if it has already been created. 206 /// lazy-compilation stub, creating one on demand as needed. 209 /// getExternalFunctionStub - Return a stub for the function at the 222 /// JITCompilerFn - This function is called to resolve a stub to a compile [all...] |
/art/tools/ahat/src/test-dump/ |
DumpedStuff.java | 128 public static class Stub extends android.os.Binder implements IDumpedManager { 130 public Stub() { 143 public static class Stub { 160 private static class BinderService extends IDumpedManager.Stub { 164 private static class FakeBinderService extends IBinderInterfaceImpostor.Stub { 205 Object correctBinderProxyObject = new IDumpedManager.Stub.Proxy(correctBinderProxy); 206 Object impostorBinderProxyObject = new IBinderInterfaceImpostor.Stub.Proxy(imposedBinderProxy);
|
/cts/tests/tests/content/BinderPermissionTestService/src/com/android/cts/ |
BinderPermissionTestService.java | 34 private final IBinder mBinder = new IBinderPermissionTestService.Stub() {
|
/cts/tests/tests/os/src/android/os/cts/ |
SharedMemoryService.java | 34 private static class SharedMemoryServiceImpl extends ISharedMemoryService.Stub {
|
/cts/tests/tests/telecom/ThirdPtyInCallServiceTestApp/src/android/telecom/cts/thirdptyincallservice/ |
CtsThirdPartyInCallServiceControl.java | 30 private final IBinder mCtsCompanionAppControl = new ICtsThirdPartyInCallServiceControl.Stub() {
|
/cts/tests/tests/security/src/android/security/cts/ |
IsolatedService.java | 70 private final IIsolatedService.Stub mBinder = new IIsolatedService.Stub() {
|