| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractServiceTest.java | 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()
60 assertTrue(service.running); in testNoOpServiceStartStop()
62 service.stopAsync(); in testNoOpServiceStartStop()
[all …]
|
| D | AbstractScheduledServiceTest.java | 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()
107 assertEquals(Service.State.FAILED, service.state()); in testFailOnExceptionFromRun()
[all …]
|
| D | AbstractExecutionThreadServiceTest.java | 72 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()
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
90 service.startAsync().awaitRunning(); in testServiceStopIdempotence()
[all …]
|
| D | AbstractIdleServiceTest.java | 50 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 …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractServiceTest.java | 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()
60 assertTrue(service.running); in testNoOpServiceStartStop()
62 service.stopAsync(); in testNoOpServiceStartStop()
[all …]
|
| D | AbstractScheduledServiceTest.java | 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()
107 assertEquals(Service.State.FAILED, service.state()); in testFailOnExceptionFromRun()
[all …]
|
| D | AbstractExecutionThreadServiceTest.java | 72 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()
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
90 service.startAsync().awaitRunning(); in testServiceStopIdempotence()
[all …]
|
| D | AbstractIdleServiceTest.java | 50 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 …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/impl/ |
| D | service_registry.ipp | 29 // 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/grpc-grpc/src/python/grpcio_tests/tests/protoc_plugin/ |
| D | _python_plugin_test.py | 36 import tests.protoc_plugin.protos.service.test_service_pb2_grpc as service_pb2_grpc
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)
252 service = _CreateService()
[all …]
|
| /external/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
| D | AttributeServiceTest.java | 44 private AttributeService service; field in AttributeServiceTest
53 service = new AttributeService(providers, ImmutableMap.<String, Object>of()); in setUp()
58 assertThat(service.supportedFileAttributeViews()) in testSupportedFileAttributeViews()
64 assertThat(service.supportsFileAttributeView(BasicFileAttributeView.class)).isTrue(); in testSupportsFileAttributeView()
65 assertThat(service.supportsFileAttributeView(TestAttributeView.class)).isTrue(); in testSupportsFileAttributeView()
66 assertThat(service.supportsFileAttributeView(PosixFileAttributeView.class)).isFalse(); in testSupportsFileAttributeView()
72 service.setInitialAttributes(file); in testSetInitialAttributes()
77 assertThat(service.getAttribute(file, "basic:lastModifiedTime")).isInstanceOf(FileTime.class); in testSetInitialAttributes()
85 service.setInitialAttributes(file); in testGetAttribute()
87 assertThat(service.getAttribute(file, "test:foo")).isEqualTo("hello"); in testGetAttribute()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/service/interpreter/ |
| D | BUILD | 17 "//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/cronet/components/metrics/ |
| D | metrics_service_unittest.cc | 62 explicit TestUnsentLogStore(PrefService* service) in TestUnsentLogStore() argument
64 service, in TestUnsentLogStore()
461 TestMetricsService service(GetMetricsStateManager(user_data_dir_path()), in TEST_P() local
464 auto log1 = service.CreateLogForTesting(MetricsLog::ONGOING_LOG); in TEST_P()
465 auto log2 = service.CreateLogForTesting(MetricsLog::INITIAL_STABILITY_LOG); in TEST_P()
466 auto log3 = service.CreateLogForTesting(MetricsLog::INDEPENDENT_LOG); in TEST_P()
485 TestMetricsService service(GetMetricsStateManager(user_data_dir_path()), in TEST_P() local
489 service.RegisterMetricsProvider( in TEST_P()
492 service.InitializeMetricsRecordingState(); in TEST_P()
495 EXPECT_FALSE(service.has_unsent_logs()); in TEST_P()
[all …]
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/util/ |
| D | ICUServiceTest.java | 77 public SortedMap getDisplayNames(ICUService service) { in getDisplayNames() argument
80 return service.getDisplayNames(locale, col, null); in getDisplayNames()
88 public SortedMap getDisplayNames(ICUService service, ULocale locale) { in getDisplayNames() argument
90 return service.getDisplayNames(locale, col, null); in getDisplayNames()
97 public SortedMap getDisplayNames(ICUService service, ULocale locale, String matchID) { in getDisplayNames() argument
99 return service.getDisplayNames(locale, col, matchID); in getDisplayNames()
117 ICUService service = new TestService(); in TestAPI() local
119 logln("service name:" + service.getName()); in TestAPI()
125 service.registerObject(singleton0, "en_US"); in TestAPI()
126 Object result = service.get("en_US_FOO"); in TestAPI()
[all …]
|
| D | ICUServiceThreadTest.java | 76 public static SortedMap getDisplayNames(ICUService service, ULocale locale) { in getDisplayNames() argument
85 return service.getDisplayNames(locale, col, null); in getDisplayNames()
122 protected ICUService service; field in ICUServiceThreadTest.TestThread
125 public TestThread(String name, ICUService service, long delay) { in TestThread() argument
127 this.service = service; in TestThread()
197 RegisterFactoryThread(String name, ICUService service, long delay) { in RegisterFactoryThread() argument
198 super("REG " + name, service, delay); in RegisterFactoryThread()
204 service.registerFactory(f); in iterate()
213 UnregisterFactoryThread(String name, ICUService service, long delay) { in UnregisterFactoryThread() argument
214 super("UNREG " + name, service, delay); in UnregisterFactoryThread()
[all …]
|
| /external/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/util/ |
| D | ICUServiceTest.java | 74 public SortedMap getDisplayNames(ICUService service) { in getDisplayNames() argument
77 return service.getDisplayNames(locale, col, null); in getDisplayNames()
85 public SortedMap getDisplayNames(ICUService service, ULocale locale) { in getDisplayNames() argument
87 return service.getDisplayNames(locale, col, null); in getDisplayNames()
94 public SortedMap getDisplayNames(ICUService service, ULocale locale, String matchID) { in getDisplayNames() argument
96 return service.getDisplayNames(locale, col, matchID); in getDisplayNames()
114 ICUService service = new TestService(); in TestAPI() local
116 logln("service name:" + service.getName()); in TestAPI()
122 service.registerObject(singleton0, "en_US"); in TestAPI()
123 Object result = service.get("en_US_FOO"); in TestAPI()
[all …]
|
| D | ICUServiceThreadTest.java | 73 public static SortedMap getDisplayNames(ICUService service, ULocale locale) { in getDisplayNames() argument
82 return service.getDisplayNames(locale, col, null); in getDisplayNames()
119 protected ICUService service; field in ICUServiceThreadTest.TestThread
122 public TestThread(String name, ICUService service, long delay) { in TestThread() argument
124 this.service = service; in TestThread()
194 RegisterFactoryThread(String name, ICUService service, long delay) { in RegisterFactoryThread() argument
195 super("REG " + name, service, delay); in RegisterFactoryThread()
201 service.registerFactory(f); in iterate()
210 UnregisterFactoryThread(String name, ICUService service, long delay) { in UnregisterFactoryThread() argument
211 super("UNREG " + name, service, delay); in UnregisterFactoryThread()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/service/spmd/ |
| D | BUILD | 46 "//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/ |
| D | ShadowServiceTest.java | 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()
81 assertThat(shadowOf(service).getLastForegroundNotificationId()).isEqualTo(23); in startForeground()
[all …]
|
| /external/nos/host/generic/libnos/generator/ |
| D | main.cpp | 49 std::string validateServiceOptions(const ServiceDescriptor& service) { in validateServiceOptions() argument
50 if (!service.options().HasExtension(app_id)) { in validateServiceOptions()
51 return "nugget.protobuf.app_id is not defined for service " + service.name(); in validateServiceOptions()
53 if (!service.options().HasExtension(request_buffer_size)) { in validateServiceOptions()
54 return "nugget.protobuf.request_buffer_size is not defined for service " + service.name(); in validateServiceOptions()
56 if (!service.options().HasExtension(response_buffer_size)) { in validateServiceOptions()
57 return "nugget.protobuf.response_buffer_size is not defined for service " + service.name(); in validateServiceOptions()
118 void ForEachMethod(const ServiceDescriptor& service, in ForEachMethod() argument
120 for (int i = 0; i < service.method_count(); ++i) { in ForEachMethod()
121 const MethodDescriptor& method = *service.method(i); in ForEachMethod()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/coordination/ |
| D | coordination_service_rpc_handler.cc | 41 CoordinationServiceInterface* service = in RegisterTaskAsync() local
43 if (service == nullptr) { 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()
67 const uint64_t leader_incarnation = service->GetServiceIncarnation(); in HeartbeatAsync()
68 Status s = service->RecordHeartbeat(task, incarnation); in HeartbeatAsync()
80 CoordinationServiceInterface* service = in WaitForAllTasksAsync() local
82 if (service == nullptr) { in WaitForAllTasksAsync()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | BUILD | 2 # 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/freetype/src/base/ |
| D | fttype1.c | 32 FT_Service_PsInfo service; in FT_Get_PS_Font_Info() local
41 FT_FACE_FIND_SERVICE( face, service, POSTSCRIPT_INFO ); in FT_Get_PS_Font_Info()
43 if ( service && service->ps_get_font_info ) in FT_Get_PS_Font_Info()
44 error = service->ps_get_font_info( face, afont_info ); in FT_Get_PS_Font_Info()
58 FT_Service_PsInfo service; in FT_Has_PS_Glyph_Names() local
63 FT_FACE_FIND_SERVICE( face, service, POSTSCRIPT_INFO ); in FT_Has_PS_Glyph_Names()
65 if ( service && service->ps_has_glyph_names ) in FT_Has_PS_Glyph_Names()
66 result = service->ps_has_glyph_names( face ); in FT_Has_PS_Glyph_Names()
80 FT_Service_PsInfo service; in FT_Get_PS_Font_Private() local
89 FT_FACE_FIND_SERVICE( face, service, POSTSCRIPT_INFO ); in FT_Get_PS_Font_Private()
[all …]
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowServiceTest.java | 27 private MyService service ; field in ShadowServiceTest
37 service = Robolectric.setupService(MyService.class); in setup()
39 new Notification.Builder(service) in setup()
49 service.bindService(new Intent("dummy"), conn, 0); in shouldUnbindServiceAtShadowApplication()
51 service.unbindService(conn); in shouldUnbindServiceAtShadowApplication()
58 service.unbindService(conn); in shouldUnbindServiceSuccessfully()
66 service.unbindService(conn); in shouldUnbindServiceWithExceptionWhenRequested()
76 service.startForeground(23, n); in startForeground()
77 assertThat(shadowOf(service).getLastForegroundNotification()).isSameInstanceAs(n); in startForeground()
78 assertThat(shadowOf(service).getLastForegroundNotificationId()).isEqualTo(23); in startForeground()
[all …]
|
| /external/libcups/tools/ |
| D | ippfind.c | 166 static int eval_expr(ippfind_srv_t *service,
168 static int exec_program(ippfind_srv_t *service, int num_args,
172 static int list_service(ippfind_srv_t *service);
196 static void set_service_uri(ippfind_srv_t *service);
217 ippfind_srv_t *service; /* Current service */ in main() local
1227 service = get_service(services, name, regtype, domain); in main()
1233 service->ref = dnssd_ref; in main()
1234 err = DNSServiceResolve(&(service->ref), in main()
1237 service); in main()
1240 service->ref = avahi_service_resolver_new(avahi_client, AVAHI_IF_UNSPEC, in main()
[all …]
|