Home
last modified time | relevance | path

Searched full:service (Results 1 – 25 of 8381) sorted by relevance

12345678910>>...336

/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DAbstractServiceTest.java27 import com.google.common.util.concurrent.Service.Listener;
28 import com.google.common.util.concurrent.Service.State;
50 NoOpService service = new NoOpService(); in testNoOpServiceStartStop() local
51 RecordingListener listener = RecordingListener.record(service); in testNoOpServiceStartStop()
53 assertEquals(State.NEW, service.state()); in testNoOpServiceStartStop()
54 assertFalse(service.isRunning()); in testNoOpServiceStartStop()
55 assertFalse(service.running); in testNoOpServiceStartStop()
57 service.startAsync(); in testNoOpServiceStartStop()
58 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartStop()
59 assertTrue(service.isRunning()); in testNoOpServiceStartStop()
[all …]
DAbstractExecutionThreadServiceTest.java72 WaitOnRunService service = new WaitOnRunService(); in testServiceStartStop() local
73 assertFalse(service.startUpCalled); in testServiceStartStop()
75 service.startAsync().awaitRunning(); in testServiceStartStop()
76 assertTrue(service.startUpCalled); in testServiceStartStop()
77 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
79 enterRun.await(); // to avoid stopping the service until run() is invoked in testServiceStartStop()
81 service.stopAsync().awaitTerminated(); in testServiceStartStop()
82 assertTrue(service.shutDownCalled); in testServiceStartStop()
83 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
88 WaitOnRunService service = new WaitOnRunService(); in testServiceStopIdempotence() local
[all …]
DAbstractIdleServiceTest.java50 AbstractIdleService service = new DefaultService(); in testServiceStartStop() local
51 service.startAsync().awaitRunning(); in testServiceStartStop()
52 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
53 service.stopAsync().awaitTerminated(); in testServiceStartStop()
54 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
59 AbstractIdleService service = in testStart_failed() local
67 service.startAsync().awaitRunning(); in testStart_failed()
72 assertEquals(Service.State.FAILED, service.state()); in testStart_failed()
77 AbstractIdleService service = in testStop_failed() local
84 service.startAsync().awaitRunning(); in testStop_failed()
[all …]
DAbstractScheduledServiceTest.java28 import com.google.common.util.concurrent.Service.State;
71 NullService service = new NullService(); in testServiceStartStop() local
72 service.startAsync().awaitRunning(); in testServiceStartStop()
74 service.stopAsync().awaitTerminated(); in testServiceStartStop()
94 TestService service = new TestService(); in testFailOnExceptionFromRun() local
95 service.runException = new Exception(); in testFailOnExceptionFromRun()
96 service.startAsync().awaitRunning(); in testFailOnExceptionFromRun()
97 service.runFirstBarrier.await(); in testFailOnExceptionFromRun()
98 service.runSecondBarrier.await(); in testFailOnExceptionFromRun()
106 assertEquals(service.runException, service.failureCause()); in testFailOnExceptionFromRun()
[all …]
DServiceManagerTest.java30 import com.google.common.util.concurrent.Service.State;
67 * A NoOp service that will delay the startup and shutdown notification for a configurable amount
123 Service a = new NoOpDelayedService(150); in testServiceStartupTimes()
124 Service b = new NoOpDelayedService(353); in testServiceStartupTimes()
127 ImmutableMap<Service, Long> startupTimes = serviceManager.startupTimes(); in testServiceStartupTimes()
135 // 1. service times are accurate when the service is started by the manager in testServiceStartupTimes_selfStartingServices()
136 // 2. service times are recorded when the service is not started by the manager (but they may in testServiceStartupTimes_selfStartingServices()
138 final Service b = in testServiceStartupTimes_selfStartingServices()
143 // This will delay service listener execution at least 150 milliseconds in testServiceStartupTimes_selfStartingServices()
147 Service a = in testServiceStartupTimes_selfStartingServices()
[all …]
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractServiceTest.java27 import com.google.common.util.concurrent.Service.Listener;
28 import com.google.common.util.concurrent.Service.State;
50 NoOpService service = new NoOpService(); in testNoOpServiceStartStop() local
51 RecordingListener listener = RecordingListener.record(service); in testNoOpServiceStartStop()
53 assertEquals(State.NEW, service.state()); in testNoOpServiceStartStop()
54 assertFalse(service.isRunning()); in testNoOpServiceStartStop()
55 assertFalse(service.running); in testNoOpServiceStartStop()
57 service.startAsync(); in testNoOpServiceStartStop()
58 assertEquals(State.RUNNING, service.state()); in testNoOpServiceStartStop()
59 assertTrue(service.isRunning()); in testNoOpServiceStartStop()
[all …]
DAbstractExecutionThreadServiceTest.java72 WaitOnRunService service = new WaitOnRunService(); in testServiceStartStop() local
73 assertFalse(service.startUpCalled); in testServiceStartStop()
75 service.startAsync().awaitRunning(); in testServiceStartStop()
76 assertTrue(service.startUpCalled); in testServiceStartStop()
77 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
79 enterRun.await(); // to avoid stopping the service until run() is invoked in testServiceStartStop()
81 service.stopAsync().awaitTerminated(); in testServiceStartStop()
82 assertTrue(service.shutDownCalled); in testServiceStartStop()
83 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
88 WaitOnRunService service = new WaitOnRunService(); in testServiceStopIdempotence() local
[all …]
DAbstractIdleServiceTest.java50 AbstractIdleService service = new DefaultService(); in testServiceStartStop() local
51 service.startAsync().awaitRunning(); in testServiceStartStop()
52 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
53 service.stopAsync().awaitTerminated(); in testServiceStartStop()
54 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
59 AbstractIdleService service = in testStart_failed() local
67 service.startAsync().awaitRunning(); in testStart_failed()
72 assertEquals(Service.State.FAILED, service.state()); in testStart_failed()
77 AbstractIdleService service = in testStop_failed() local
84 service.startAsync().awaitRunning(); in testStop_failed()
[all …]
DAbstractScheduledServiceTest.java28 import com.google.common.util.concurrent.Service.State;
71 NullService service = new NullService(); in testServiceStartStop() local
72 service.startAsync().awaitRunning(); in testServiceStartStop()
74 service.stopAsync().awaitTerminated(); in testServiceStartStop()
94 TestService service = new TestService(); in testFailOnExceptionFromRun() local
95 service.runException = new Exception(); in testFailOnExceptionFromRun()
96 service.startAsync().awaitRunning(); in testFailOnExceptionFromRun()
97 service.runFirstBarrier.await(); in testFailOnExceptionFromRun()
98 service.runSecondBarrier.await(); in testFailOnExceptionFromRun()
106 assertEquals(service.runException, service.failureCause()); in testFailOnExceptionFromRun()
[all …]
DServiceManagerTest.java30 import com.google.common.util.concurrent.Service.State;
68 * A NoOp service that will delay the startup and shutdown notification for a configurable amount
124 Service a = new NoOpDelayedService(150); in testServiceStartupTimes()
125 Service b = new NoOpDelayedService(353); in testServiceStartupTimes()
128 ImmutableMap<Service, Long> startupTimes = serviceManager.startupTimes(); in testServiceStartupTimes()
135 Service a = new NoOpDelayedService(150); in testServiceStartupDurations()
136 Service b = new NoOpDelayedService(353); in testServiceStartupDurations()
139 ImmutableMap<Service, Duration> startupTimes = serviceManager.startupDurations(); in testServiceStartupDurations()
147 // 1. service times are accurate when the service is started by the manager in testServiceStartupTimes_selfStartingServices()
148 // 2. service times are recorded when the service is not started by the manager (but they may in testServiceStartupTimes_selfStartingServices()
[all …]
/external/parameter-framework/asio-1.10.6/include/asio/detail/impl/
Dservice_registry.ipp29 // objects may try to access other service objects.
30 asio::io_service::service* service = first_service_;
31 while (service)
33 service->shutdown_service();
34 service = service->next_;
40 asio::io_service::service* next_service = first_service_->next_;
49 // to hold the lock while calling into each service, as it may try to call
51 std::vector<asio::io_service::service*> services;
54 asio::io_service::service* service = first_service_;
55 while (service)
[all …]
/external/python/google-api-python-client/docs/dyn/
Dmonitoring_v3.services.html87 <p class="firstline">Create a Service.</p>
90 <p class="firstline">Soft delete this Service.</p>
93 <p class="firstline">Get the named Service.</p>
102 <p class="firstline">Update this Service.</p>
111 <pre>Create a Service.
118 …Service is a discrete, autonomous, and network-accessible unit, designed to solve an individual co…
119 …&quot;appEngine&quot;: { # App Engine service. Learn more at https://cloud.google.com/appengine. #…
120 … &quot;A String&quot;, # The ID of the App Engine module underlying this service. Corresponds to t…
122 …&quot;cloudEndpoints&quot;: { # Cloud Endpoints service. Learn more at https://cloud.google.com/en…
123 …&quot;service&quot;: &quot;A String&quot;, # The name of the Cloud Endpoints service underlying th…
[all …]
/external/parameter-framework/asio-1.10.6/include/asio/detail/
Dservice_registry.hpp33 // Constructor. Adds the initial service.
34 template <typename Service, typename Arg>
36 Service* initial_service, Arg arg);
44 // Get the first service object cast to the specified type. Called during
46 template <typename Service>
47 Service& first_service();
49 // Get the service object corresponding to the specified service type. Will
50 // create a new service object automatically if no such object already
51 // exists. Ownership of the service object is not transferred to the caller.
52 template <typename Service>
[all …]
/external/python/google-api-python-client/googleapiclient/discovery_cache/documents/
Dmybusinesslodging.v1.json222 "Amenity or service is unavailable due to ongoing work orders.",
223 "Amenity or service availability is seasonal.",
224 "Amenity or service availability depends on the day of the week."
238 "Amenity or service is unavailable due to ongoing work orders.",
239 "Amenity or service availability is seasonal.",
240 "Amenity or service availability depends on the day of the week."
258 "Amenity or service is unavailable due to ongoing work orders.",
259 "Amenity or service availability is seasonal.",
260 "Amenity or service availability depends on the day of the week."
278 "Amenity or service is unavailable due to ongoing work orders.",
[all …]
/external/guava/guava/src/com/google/common/util/concurrent/
DServiceManager.java26 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;
51 import com.google.common.util.concurrent.Service.State;
70 * A manager for monitoring and controlling a set of {@linkplain Service services}. This class
72 * {@linkplain #servicesByState inspecting} a collection of {@linkplain Service services}.
76 * <p>While it is recommended that service lifecycles be managed via this class, state transitions
[all …]
/external/guava/android/guava/src/com/google/common/util/concurrent/
DServiceManager.java25 import static com.google.common.util.concurrent.Service.State.FAILED;
26 import static com.google.common.util.concurrent.Service.State.NEW;
27 import static com.google.common.util.concurrent.Service.State.RUNNING;
28 import static com.google.common.util.concurrent.Service.State.STARTING;
29 import static com.google.common.util.concurrent.Service.State.STOPPING;
30 import static com.google.common.util.concurrent.Service.State.TERMINATED;
50 import com.google.common.util.concurrent.Service.State;
67 * A manager for monitoring and controlling a set of {@linkplain Service services}. This class
69 * {@linkplain #servicesByState inspecting} a collection of {@linkplain Service services}.
73 * <p>While it is recommended that service lifecycles be managed via this class, state transitions
[all …]
/external/tensorflow/tensorflow/compiler/xla/service/gpu/
DBUILD2 # GPU-specific components in XLA service implementation.
111 "//tensorflow/compiler/xla/service:executable",
112 "//tensorflow/compiler/xla/service:global_device_id",
165 "//tensorflow/compiler/xla/service:buffer_assignment",
166 "//tensorflow/compiler/xla/service:custom_call_status_internal",
185 "//tensorflow/compiler/xla/service:custom_call_status",
186 "//tensorflow/compiler/xla/service:custom_call_target_registry",
187 "//tensorflow/compiler/xla/service:gpu_plugin",
206 "//tensorflow/compiler/xla/service:hlo",
207 "//tensorflow/compiler/xla/service/llvm_ir:buffer_assignment_util",
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/
D_python_plugin_test.py36 import tests.protoc_plugin.protos.service.test_service_pb2_grpc as service_pb2_grpc
127 """A live and running service.
236 service = _CreateService()
237 self.assertIsNotNone(service.servicer_methods)
238 self.assertIsNotNone(service.server)
239 self.assertIsNotNone(service.stub)
240 service.server.stop(None)
243 service = _CreateIncompleteService()
246 service.stub.UnaryCall(request)
249 service.server.stop(None)
[all …]
/external/python/mobly/mobly/controllers/android_device_lib/
Dservice_manager.py32 A service is a long running process that involves an Android device, like
41 """Checks if the manager has a service registered with a specific name.
47 True if a service is registered with the specified name, False
54 """True if any service is alive; False otherwise."""
55 for service in self._service_objects.values():
56 if service.is_alive:
61 """Registers a service.
63 This will create a service instance, starts the service, and adds the
68 service_class: class, the service class to instantiate.
69 configs: (optional) config object to pass to the service class's
[all …]
/external/tensorflow/tensorflow/compiler/xla/service/interpreter/
DBUILD17 "//tensorflow/compiler/xla/service:generic_transfer_manager",
18 "//tensorflow/compiler/xla/service:transfer_manager",
19 "//tensorflow/compiler/xla/service/interpreter:platform_id",
35 "//tensorflow/compiler/xla/service:algebraic_simplifier",
36 "//tensorflow/compiler/xla/service:batchnorm_expander",
37 "//tensorflow/compiler/xla/service:cholesky_expander",
38 "//tensorflow/compiler/xla/service:comparison_expander",
39 "//tensorflow/compiler/xla/service:compiler",
40 "//tensorflow/compiler/xla/service:computation_placer",
41 "//tensorflow/compiler/xla/service:custom_call_target_registry",
[all …]
/external/tensorflow/tensorflow/compiler/xla/service/spmd/
DBUILD46 "//tensorflow/compiler/xla/service:dot_as_convolution_util",
47 "//tensorflow/compiler/xla/service:flatten_call_graph",
48 "//tensorflow/compiler/xla/service:hlo",
49 "//tensorflow/compiler/xla/service:hlo_cse",
50 "//tensorflow/compiler/xla/service:hlo_dce",
51 "//tensorflow/compiler/xla/service:hlo_lexer",
52 "//tensorflow/compiler/xla/service:hlo_pass",
53 "//tensorflow/compiler/xla/service:hlo_pass_pipeline",
54 "//tensorflow/compiler/xla/service:hlo_query",
55 "//tensorflow/compiler/xla/service:hlo_reachability",
[all …]
/external/robolectric/robolectric/src/test/java/org/robolectric/shadows/
DShadowServiceTest.java12 import android.app.Service;
30 private MyService service ; field in ShadowServiceTest
40 service = Robolectric.setupService(MyService.class); in setup()
42 new Notification.Builder(service) in setup()
52 service.bindService(new Intent("dummy").setPackage("dummy.package"), conn, 0); in shouldUnbindServiceAtShadowApplication()
54 service.unbindService(conn); in shouldUnbindServiceAtShadowApplication()
61 service.unbindService(conn); in shouldUnbindServiceSuccessfully()
69 service.unbindService(conn); in shouldUnbindServiceWithExceptionWhenRequested()
79 service.startForeground(23, n); in startForeground()
80 assertThat(shadowOf(service).getLastForegroundNotification()).isSameInstanceAs(n); in startForeground()
[all …]
/external/openthread/tests/scripts/thread-cert/border_router/
Dtest_advertising_proxy.py97 # 1. Register a single service.
102 client.srp_client_add_service('my-service', '_ipps._tcp', 12345)
103 client.srp_client_add_service('my-service-1', '_ipps._tcp', 12345)
107 self.check_host_and_service(server, client, '2001::1', 'my-service')
108 self.check_host_and_service(server, client, '2001::1', 'my-service-1')
111 # 2. Discover the service by the HOST on the ethernet. This makes sure
112 # the Advertising Proxy multicasts the same service on ethernet.
115 self.host_check_mdns_service(host, '2001::1', 'my-service')
116 self.host_check_mdns_service(host, '2001::1', 'my-service-1')
119 # 3. Check if the Advertising Proxy removes the service from ethernet
[all …]
/external/openthread/include/openthread/
Dsrp_server.h32 * This file defines the API for server of the Service Registration Protocol (SRP).
52 * This module includes functions of the Service Registration Protocol.
59 * This opaque type represents a SRP service host.
65 * This opaque type represents a SRP service.
71 * The ID of a SRP service update transaction on the SRP Server.
77 …* The service flag type to indicate which services to include or exclude when searching in (or ite…
96 …* This constant defines an `otSrpServerServiceFlags` combination accepting any service (base/sub-t…
104 * This constant defines an `otSrpServerServiceFlags` combination accepting base service only.
111 … * This constant defines an `otSrpServerServiceFlags` combination accepting sub-type service only.
118 …* This constant defines an `otSrpServerServiceFlags` combination accepting any active service (not…
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/coordination/
Dcoordination_service_rpc_handler.cc41 CoordinationServiceInterface* service = in RegisterTaskAsync() local
43 if (service == nullptr) { in RegisterTaskAsync()
45 errors::Internal("Coordination service is not enabled."))); in RegisterTaskAsync()
50 const uint64_t leader_incarnation = service->GetServiceIncarnation(); in RegisterTaskAsync()
52 done(service->RegisterTask(task, incarnation)); in RegisterTaskAsync()
58 CoordinationServiceInterface* service = in HeartbeatAsync() local
60 if (service == nullptr) { in HeartbeatAsync()
62 errors::Internal("Coordination service is not enabled."))); in HeartbeatAsync()
67 const uint64_t leader_incarnation = service->GetServiceIncarnation(); in HeartbeatAsync()
68 Status s = service->RecordHeartbeat(task, incarnation); in HeartbeatAsync()
[all …]

12345678910>>...336