| /external/parameter-framework/asio-1.10.6/include/asio/detail/impl/ |
| D | service_registry.hpp | 20 template <typename Service, typename Arg>
22 asio::io_service& o, Service*, Arg arg) in service_registry() argument
24 first_service_(new Service(o, arg)) in service_registry()
27 init_key(key, Service::id); in service_registry()
32 template <typename Service>
33 Service& service_registry::first_service() in first_service()
35 return *static_cast<Service*>(first_service_); in first_service()
38 template <typename Service>
39 Service& service_registry::use_service() in use_service()
42 init_key(key, Service::id); in use_service()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ServiceManagerTest.java | 112 Service a = new NoOpDelayedService(150); in testServiceStartupTimes()
113 Service b = new NoOpDelayedService(353); in testServiceStartupTimes()
116 ImmutableMap<Service, Long> startupTimes = serviceManager.startupTimes(); in testServiceStartupTimes()
127 final Service b = new NoOpDelayedService(353) { in testServiceStartupTimes_selfStartingServices()
134 Service a = new NoOpDelayedService(150) { in testServiceStartupTimes_selfStartingServices()
142 ImmutableMap<Service, Long> startupTimes = serviceManager.startupTimes(); in testServiceStartupTimes_selfStartingServices()
153 Service a = new NoOpService(); in testServiceStartStop()
154 Service b = new NoOpService(); in testServiceStartStop()
158 assertState(manager, Service.State.NEW, a, b); in testServiceStartStop()
161 assertState(manager, Service.State.RUNNING, a, b); in testServiceStartStop()
[all …]
|
| D | AbstractIdleServiceTest.java | 52 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
54 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
70 assertEquals(Service.State.FAILED, service.state()); in testStart_failed()
87 assertEquals(Service.State.FAILED, service.state()); in testStop_failed()
96 assertEquals(Service.State.RUNNING, service.state()); in testStart()
97 assertThat(service.transitionStates).has().exactly(Service.State.STARTING).inOrder(); in testStart()
116 assertEquals(Service.State.FAILED, service.state()); in testStart_failed()
117 assertThat(service.transitionStates).has().exactly(Service.State.STARTING).inOrder(); in testStart_failed()
125 assertEquals(Service.State.TERMINATED, service.state()); in testStop_withoutStart()
137 assertEquals(Service.State.TERMINATED, service.state()); in testStop_afterStart()
[all …]
|
| D | AbstractExecutionThreadServiceTest.java | 69 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
75 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
89 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStopIdempotence()
91 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStopIdempotence()
99 service.expectedShutdownState = Service.State.RUNNING; in testServiceExitingOnItsOwn()
103 assertEquals(Service.State.RUNNING, service.state()); in testServiceExitingOnItsOwn()
109 assertEquals(Service.State.TERMINATED, service.state()); in testServiceExitingOnItsOwn()
113 assertEquals(Service.State.TERMINATED, service.state()); in testServiceExitingOnItsOwn()
177 assertEquals(Service.State.FAILED, service.state()); in testServiceThrowOnStartUp()
210 assertEquals(Service.State.FAILED, service.state()); in testServiceThrowOnRun()
[all …]
|
| D | ServiceTest.java | 19 import static com.google.common.util.concurrent.Service.State.FAILED;
20 import static com.google.common.util.concurrent.Service.State.NEW;
21 import static com.google.common.util.concurrent.Service.State.RUNNING;
22 import static com.google.common.util.concurrent.Service.State.STARTING;
23 import static com.google.common.util.concurrent.Service.State.STOPPING;
24 import static com.google.common.util.concurrent.Service.State.TERMINATED;
|
| /external/guice/extensions/service/src/com/google/inject/service/ |
| D | CompositeService.java | 40 private final Set<Key<? extends Service>> services = Sets.newLinkedHashSet();
47 private volatile Service.State compositeState;
56 public CompositeService add(Class<? extends Service> service) { in add()
60 public CompositeService add(Key<? extends Service> service) { in add()
71 public Service compose() { in compose()
78 final List<Key<? extends Service>> services = ImmutableList.copyOf(this.services); in compose()
80 return new Service() { in compose()
84 for (Key<? extends Service> service : services) { in compose()
94 for (Key<? extends Service> service : services) { in compose()
108 private FutureTask<Service.State> futureGet(
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ServiceManager.java | 26 import static com.google.common.util.concurrent.Service.State.FAILED;
27 import static com.google.common.util.concurrent.Service.State.NEW;
28 import static com.google.common.util.concurrent.Service.State.RUNNING;
29 import static com.google.common.util.concurrent.Service.State.STARTING;
30 import static com.google.common.util.concurrent.Service.State.STOPPING;
31 import static com.google.common.util.concurrent.Service.State.TERMINATED;
54 import com.google.common.util.concurrent.Service.State;
171 public void failure(Service service) {} in failure()
182 private final ImmutableList<Service> services;
192 public ServiceManager(Iterable<? extends Service> services) { in ServiceManager()
[all …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/impl/ |
| D | io_service.hpp | 22 template <typename Service>
23 inline Service& use_service(io_service& ios) in use_service()
26 (void)static_cast<io_service::service*>(static_cast<Service*>(0)); in use_service()
27 (void)static_cast<const io_service::id*>(&Service::id); in use_service()
29 return ios.service_registry_->template use_service<Service>(); in use_service()
39 template <typename Service>
40 inline void add_service(io_service& ios, Service* svc) in add_service()
43 (void)static_cast<io_service::service*>(static_cast<Service*>(0)); in add_service()
44 (void)static_cast<const io_service::id*>(&Service::id); in add_service()
46 ios.service_registry_->template add_service<Service>(svc); in add_service()
[all …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| D | service_registry.hpp | 34 template <typename Service, typename Arg>
36 Service* initial_service, Arg arg);
46 template <typename Service>
47 Service& first_service();
52 template <typename Service>
53 Service& use_service();
57 template <typename Service>
58 void add_service(Service* new_service);
61 template <typename Service>
72 template <typename Service>
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_call.h | 75 template <class Service>
90 virtual void RequestReceived(Service* service, bool ok) = 0;
96 virtual void RequestCancelled(Service* service, bool ok) = 0;
111 void OnCompleted(Service* service, bool ok) { in OnCompleted()
134 template <class Service, class GrpcService, class RequestMessage,
136 class Call : public UntypedCall<Service> {
148 using HandleRequestFunction = void (Service::*)(
149 Call<Service, GrpcService, RequestMessage, ResponseMessage>*);
156 void RequestReceived(Service* service, bool ok) override { in RequestReceived()
169 void RequestCancelled(Service* service, bool ok) override { in RequestCancelled()
[all …]
|
| /external/guice/core/test/com/google/inject/example/ |
| D | ClientServiceWithDependencyInjection.java | 26 public interface Service { interface in ClientServiceWithDependencyInjection
30 public static class ServiceImpl implements ClientServiceWithDependencyInjection.Service {
41 private static final Service service = new ServiceImpl();
43 public static Service getInstance() { in getInstance()
50 private final Service service;
52 public Client(Service service) { in Client()
66 Service service = ServiceFactory.getInstance(); in getInstance()
78 public static class MockService implements Service {
|
| D | ClientServiceWithFactories.java | 26 public interface Service { interface in ClientServiceWithFactories
30 public static class ServiceImpl implements Service {
41 private static Service instance = new ServiceImpl();
43 public static Service getInstance() { in getInstance()
47 public static void setInstance(Service service) { in setInstance()
55 Service service = ServiceFactory.getInstance(); in go()
61 Service previous = ServiceFactory.getInstance(); in testClient()
73 public static class MockService implements Service {
|
| D | ClientServiceWithGuice.java | 33 public interface Service { interface in ClientServiceWithGuice
37 public static class ServiceImpl implements Service {
47 bind(Service.class).to(ServiceImpl.class).in(Scopes.SINGLETON); in configure()
53 private final Service service;
56 public Client(Service service) { in Client()
72 public static class MockService implements Service {
|
| /external/grpc-grpc/src/python/grpcio/grpc/framework/interfaces/face/ |
| D | utilities.py | 53 style.Service.INLINE, behavior, None, None,
69 style.Service.INLINE, None, behavior, None,
85 style.Service.INLINE, None, None, behavior,
101 style.Service.INLINE, None, None, None,
117 style.Service.EVENT, None, None, None, None,
133 style.Service.EVENT, None, None, None, None,
150 style.Service.EVENT, None, None, None, None,
167 style.Service.EVENT, None, None, None, None,
|
| /external/mockito/src/test/java/org/mockitousage/bugs/ |
| D | ShouldNotDeadlockAnswerExecutionTest.java | 24 Service service = Mockito.mock(Service.class); in failIfMockIsSharedBetweenThreads()
49 Service service1 = Mockito.mock(Service.class); in successIfEveryThreadHasItsOwnMock()
50 Service service2 = Mockito.mock(Service.class); in successIfEveryThreadHasItsOwnMock()
99 private Service service;
101 public ServiceRunner(Service service) { in ServiceRunner()
111 interface Service { interface in ShouldNotDeadlockAnswerExecutionTest
|
| /external/ppp/pppd/plugins/radius/etc/ |
| D | dictionary.compat | 6 ATTRIBUTE User-Service-Type 6 integer
19 VALUE Service-Type Shell-User 6
21 VALUE Service-Type Dialback-Login-User 3
22 VALUE Service-Type Dialback-Framed-User 4
33 VALUE Service-Type Login 1
34 VALUE Service-Type Framed 2
35 VALUE Service-Type Callback-Login 3
36 VALUE Service-Type Callback-Framed 4
37 VALUE Service-Type Exec-User 7
|
| /external/parameter-framework/asio-1.10.6/include/asio/ |
| D | io_service.hpp | 33 template <typename Service> Service& use_service(io_service& ios);
34 template <typename Service> void add_service(io_service& ios, Service* svc);
35 template <typename Service> bool has_service(io_service& ios);
548 template <typename Service>
549 friend Service& use_service(io_service& ios);
568 template <typename Service>
569 friend void add_service(io_service& ios, Service* svc);
580 template <typename Service>
|
| /external/grpc-grpc/src/compiler/ |
| D | python_private_generator.h | 55 const grpc_generator::Service* service, grpc_generator::Printer* out);
56 bool PrintServicer(const grpc_generator::Service* service,
59 const grpc_generator::Service* service,
62 bool PrintBetaServicer(const grpc_generator::Service* service,
66 const grpc_generator::Service* service, grpc_generator::Printer* out);
67 bool PrintBetaStub(const grpc_generator::Service* service,
70 const grpc_generator::Service* service,
|
| /external/grpc-grpc/test/cpp/codegen/ |
| D | compiler_test_golden | 209 class Service : public ::grpc::Service {
211 Service();
212 virtual ~Service();
232 void BaseClassMustBeDerivedFromService(const Service *service) {}
235 ::grpc::Service::MarkMethodAsync(0);
246 …::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, ta…
252 void BaseClassMustBeDerivedFromService(const Service *service) {}
255 ::grpc::Service::MarkMethodAsync(1);
266 …::grpc::Service::RequestAsyncClientStreaming(1, context, reader, new_call_cq, notification_cq, tag…
272 void BaseClassMustBeDerivedFromService(const Service *service) {}
[all …]
|
| /external/flatbuffers/tests/ |
| D | monster_test.grpc.fb.cc | 86 MonsterStorage::Service::Service() { in Service() function in MyGame::Example::MonsterStorage::Service
90 …new ::grpc::internal::RpcMethodHandler< MonsterStorage::Service, flatbuffers::grpc::Message<Monste… in Service()
91 std::mem_fn(&MonsterStorage::Service::Store), this))); in Service()
95 …new ::grpc::internal::ServerStreamingHandler< MonsterStorage::Service, flatbuffers::grpc::Message<… in Service()
96 std::mem_fn(&MonsterStorage::Service::Retrieve), this))); in Service()
100 …new ::grpc::internal::ClientStreamingHandler< MonsterStorage::Service, flatbuffers::grpc::Message<… in Service()
101 std::mem_fn(&MonsterStorage::Service::GetMaxHitPoint), this))); in Service()
105 …new ::grpc::internal::BidiStreamingHandler< MonsterStorage::Service, flatbuffers::grpc::Message<Mo… in Service()
106 std::mem_fn(&MonsterStorage::Service::GetMinMaxHitPoints), this))); in Service()
109 MonsterStorage::Service::~Service() { in ~Service()
[all …]
|
| D | monster_test.grpc.fb.h | 143 class Service : public ::grpc::Service {
145 Service();
146 virtual ~Service();
155 void BaseClassMustBeDerivedFromService(const Service *service) {} in BaseClassMustBeDerivedFromService()
158 ::grpc::Service::MarkMethodAsync(0); in WithAsyncMethod_Store()
169 …::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, ta… in RequestStore()
175 void BaseClassMustBeDerivedFromService(const Service *service) {} in BaseClassMustBeDerivedFromService()
178 ::grpc::Service::MarkMethodAsync(1); in WithAsyncMethod_Retrieve()
189 …::grpc::Service::RequestAsyncServerStreaming(1, context, request, writer, new_call_cq, notificatio… in RequestRetrieve()
195 void BaseClassMustBeDerivedFromService(const Service *service) {} in BaseClassMustBeDerivedFromService()
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.HealthCheck/ |
| D | Health.cs | 86 public string Service { property in Grpc.Health.V1.HealthCheckRequest
106 if (Service != other.Service) return false; in Equals()
113 if (Service.Length != 0) hash ^= Service.GetHashCode(); in GetHashCode()
127 if (Service.Length != 0) { in WriteTo()
129 output.WriteString(Service); in WriteTo()
139 if (Service.Length != 0) { in CalculateSize()
140 size += 1 + pb::CodedOutputStream.ComputeStringSize(Service); in CalculateSize()
153 if (other.Service.Length != 0) { in MergeFrom()
154 Service = other.Service; in MergeFrom()
168 Service = input.ReadString(); in MergeFrom()
|
| /external/grpc-grpc/src/ruby/pb/src/proto/grpc/testing/ |
| D | test_services_pb.rb | 30 class Service class
66 Stub = Service.rpc_stub_class
71 class Service class
83 Stub = Service.rpc_stub_class
87 class Service class
99 Stub = Service.rpc_stub_class
|
| /external/grpc-grpc/examples/ruby/pubsub/tech/pubsub/proto/ |
| D | pubsub_services.rb | 27 class Service class
43 Stub = Service.rpc_stub_class
48 class Service class
69 Stub = Service.rpc_stub_class
74 class Service class
85 Stub = Service.rpc_stub_class
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | binding_unittest.cc | 28 class ServiceImpl : public sample::Service {
80 Binding<sample::Service> binding(&impl, std::move(request)); in TEST_P()
100 Binding<sample::Service> binding(&impl, std::move(request)); in TEST_P()
101 ptr->Frobinate(nullptr, sample::Service::BazOptions::REGULAR, nullptr, in TEST_P()
115 ptr->Frobinate(nullptr, sample::Service::BazOptions::REGULAR, nullptr, in TEST_P()
129 Binding<sample::Service> binding(&impl, MakeRequest(&ptr)); in TEST_P()
148 Binding<sample::Service> binding(&impl, MakeRequest(&ptr)); in TEST_P()
166 InterfaceRequest<sample::Service> request) in ServiceImplWithBinding()
182 Binding<sample::Service> binding_;
206 Binding<sample::Service> binding(&impl, MakeRequest(&ptr)); in TEST_P()
[all …]
|