| /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 | 68 NullService service = new NullService(); in testServiceStartStop() local
69 service.startAsync().awaitRunning(); in testServiceStartStop()
71 service.stopAsync().awaitTerminated(); in testServiceStartStop()
91 TestService service = new TestService(); in testFailOnExceptionFromRun() local
92 service.runException = new Exception(); in testFailOnExceptionFromRun()
93 service.startAsync().awaitRunning(); in testFailOnExceptionFromRun()
94 service.runFirstBarrier.await(); in testFailOnExceptionFromRun()
95 service.runSecondBarrier.await(); in testFailOnExceptionFromRun()
103 assertEquals(service.runException, service.failureCause()); in testFailOnExceptionFromRun()
104 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 | 51 AbstractIdleService service = new DefaultService(); in testServiceStartStop() local
52 service.startAsync().awaitRunning(); in testServiceStartStop()
53 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
54 service.stopAsync().awaitTerminated(); in testServiceStartStop()
55 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
60 AbstractIdleService service = in testStart_failed() local
68 service.startAsync().awaitRunning(); in testStart_failed()
73 assertEquals(Service.State.FAILED, service.state()); in testStart_failed()
78 AbstractIdleService service = in testStop_failed() local
85 service.startAsync().awaitRunning(); in testStop_failed()
[all …]
|
| /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 | 68 NullService service = new NullService(); in testServiceStartStop() local
69 service.startAsync().awaitRunning(); in testServiceStartStop()
71 service.stopAsync().awaitTerminated(); in testServiceStartStop()
91 TestService service = new TestService(); in testFailOnExceptionFromRun() local
92 service.runException = new Exception(); in testFailOnExceptionFromRun()
93 service.startAsync().awaitRunning(); in testFailOnExceptionFromRun()
94 service.runFirstBarrier.await(); in testFailOnExceptionFromRun()
95 service.runSecondBarrier.await(); in testFailOnExceptionFromRun()
103 assertEquals(service.runException, service.failureCause()); in testFailOnExceptionFromRun()
104 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 | 51 AbstractIdleService service = new DefaultService(); in testServiceStartStop() local
52 service.startAsync().awaitRunning(); in testServiceStartStop()
53 assertEquals(Service.State.RUNNING, service.state()); in testServiceStartStop()
54 service.stopAsync().awaitTerminated(); in testServiceStartStop()
55 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
60 AbstractIdleService service = in testStart_failed() local
68 service.startAsync().awaitRunning(); in testStart_failed()
73 assertEquals(Service.State.FAILED, service.state()); in testStart_failed()
78 AbstractIdleService service = in testStop_failed() local
85 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/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | BUILD | 2 # GPU-specific components in XLA service implementation.
87 "//tensorflow/compiler/xla/service:hlo",
108 # "//tensorflow/compiler/xla/service:gpu_plugin",
109 # "//tensorflow/compiler/xla/service:hlo",
128 "//tensorflow/compiler/xla/service:custom_call_target_registry",
129 "//tensorflow/compiler/xla/service:gpu_plugin",
144 "//tensorflow/compiler/xla/service:hlo",
145 "//tensorflow/compiler/xla/service:hlo_reachability",
162 "//tensorflow/compiler/xla/service:hlo",
180 "//tensorflow/compiler/xla/service:buffer_assignment",
[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/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/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/freetype/src/base/ |
| D | fttype1.c | 33 FT_Service_PsInfo service; in FT_Get_PS_Font_Info() local
42 FT_FACE_FIND_SERVICE( face, service, POSTSCRIPT_INFO ); in FT_Get_PS_Font_Info()
44 if ( service && service->ps_get_font_info ) in FT_Get_PS_Font_Info()
45 error = service->ps_get_font_info( face, afont_info ); in FT_Get_PS_Font_Info()
59 FT_Service_PsInfo service; in FT_Has_PS_Glyph_Names() local
64 FT_FACE_FIND_SERVICE( face, service, POSTSCRIPT_INFO ); in FT_Has_PS_Glyph_Names()
66 if ( service && service->ps_has_glyph_names ) in FT_Has_PS_Glyph_Names()
67 result = service->ps_has_glyph_names( face ); in FT_Has_PS_Glyph_Names()
81 FT_Service_PsInfo service; in FT_Get_PS_Font_Private() local
90 FT_FACE_FIND_SERVICE( face, service, POSTSCRIPT_INFO ); in FT_Get_PS_Font_Private()
[all …]
|
| D | ftcid.c | 43 FT_Service_CID service; in FT_Get_CID_Registry_Ordering_Supplement() local
46 FT_FACE_FIND_SERVICE( face, service, CID ); in FT_Get_CID_Registry_Ordering_Supplement()
48 if ( service && service->get_ros ) in FT_Get_CID_Registry_Ordering_Supplement()
49 error = service->get_ros( face, &r, &o, &s ); in FT_Get_CID_Registry_Ordering_Supplement()
75 FT_Service_CID service; in FT_Get_CID_Is_Internally_CID_Keyed() local
78 FT_FACE_FIND_SERVICE( face, service, CID ); in FT_Get_CID_Is_Internally_CID_Keyed()
80 if ( service && service->get_is_cid ) in FT_Get_CID_Is_Internally_CID_Keyed()
81 error = service->get_is_cid( face, &ic); in FT_Get_CID_Is_Internally_CID_Keyed()
102 FT_Service_CID service; in FT_Get_CID_From_Glyph_Index() local
105 FT_FACE_FIND_SERVICE( face, service, CID ); in FT_Get_CID_From_Glyph_Index()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/service/interpreter/ |
| D | BUILD | 16 "//tensorflow/compiler/xla/service:generic_transfer_manager",
17 "//tensorflow/compiler/xla/service:transfer_manager",
18 "//tensorflow/compiler/xla/service/interpreter:platform_id",
35 "//tensorflow/compiler/xla/service:algebraic_simplifier",
36 "//tensorflow/compiler/xla/service:cholesky_expander",
37 "//tensorflow/compiler/xla/service:compiler",
38 "//tensorflow/compiler/xla/service:computation_placer",
39 "//tensorflow/compiler/xla/service:custom_call_target_registry",
40 "//tensorflow/compiler/xla/service:dynamic_index_splitter",
41 "//tensorflow/compiler/xla/service:executable",
[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()).isSameAs(n); in startForeground()
78 assertThat(shadowOf(service).getLastForegroundNotificationId()).isEqualTo(23); in startForeground()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/service/cpu/ |
| D | BUILD | 47 "//tensorflow/compiler/xla/service:generic_transfer_manager",
48 "//tensorflow/compiler/xla/service:transfer_manager",
65 "//tensorflow/compiler/xla/service:buffer_assignment",
93 "//tensorflow/compiler/xla/service:copy_insertion",
94 "//tensorflow/compiler/xla/service:hlo_casting_utils",
95 "//tensorflow/compiler/xla/service:dump",
96 "//tensorflow/compiler/xla/service:map_inliner",
97 "//tensorflow/compiler/xla/service:tree_reduction_rewriter",
98 "//tensorflow/compiler/xla/service:hlo_get_dimension_size_rewriter",
99 "//tensorflow/compiler/xla/service:conditional_to_select",
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ServiceManager.java | 183 public void failure(Service service) {} in failure() argument
218 for (Service service : copy) { in ServiceManager()
219 service.addListener(new ServiceListener(service, stateReference), directExecutor()); in ServiceManager()
222 checkArgument(service.state() == NEW, "Can only manage NEW services, %s", service); in ServiceManager() local
286 for (Service service : services) { in startAsync()
287 State state = service.state(); in startAsync()
288 checkState(state == NEW, "Service %s is %s, cannot start it.", service, state); in startAsync()
290 for (Service service : services) { in startAsync()
292 state.tryStartTiming(service); in startAsync()
293 service.startAsync(); in startAsync()
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ServiceManager.java | 183 public void failure(Service service) {} in failure() argument
218 for (Service service : copy) { in ServiceManager()
219 service.addListener(new ServiceListener(service, stateReference), directExecutor()); in ServiceManager()
222 checkArgument(service.state() == NEW, "Can only manage NEW services, %s", service); in ServiceManager() local
286 for (Service service : services) { in startAsync()
287 State state = service.state(); in startAsync()
288 checkState(state == NEW, "Service %s is %s, cannot start it.", service, state); in startAsync()
290 for (Service service : services) { in startAsync()
292 state.tryStartTiming(service); in startAsync()
293 service.startAsync(); in startAsync()
[all …]
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/tests/ |
| D | BUILD | 44 "//tensorflow/compiler/xla/service:gpu_plugin",
45 "//tensorflow/compiler/xla/service/gpu:gpu_executable",
69 "//tensorflow/compiler/xla/service:gpu_plugin",
70 "//tensorflow/compiler/xla/service:hlo",
71 "//tensorflow/compiler/xla/service:hlo_module_config",
72 "//tensorflow/compiler/xla/service:hlo_parser",
73 "//tensorflow/compiler/xla/service/gpu:gemm_rewriter",
74 "//tensorflow/compiler/xla/service/gpu:gpu_executable",
96 "//tensorflow/compiler/xla/service:gpu_plugin",
97 "//tensorflow/compiler/xla/service:hlo",
[all …]
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | hybrid_end2end_test.cc | 61 void HandleEcho(Service* service, ServerCompletionQueue* cq, bool dup_service) { in HandleEcho() argument
66 service->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq, cq, in HandleEcho()
81 void HandleRawEcho(Service* service, ServerCompletionQueue* cq, in HandleRawEcho() argument
86 service->RequestEcho(&srv_ctx, &recv_buffer, &response_writer, cq, cq, in HandleRawEcho()
99 void HandleClientStreaming(Service* service, ServerCompletionQueue* cq) { in HandleClientStreaming() argument
104 service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1)); in HandleClientStreaming()
117 void HandleRawClientStreaming(Service* service, ServerCompletionQueue* cq) { in HandleRawClientStreaming() argument
123 service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1)); in HandleRawClientStreaming()
141 void HandleServerStreaming(Service* service, ServerCompletionQueue* cq) { in HandleServerStreaming() argument
146 service->RequestResponseStream(&srv_ctx, &recv_request, &srv_stream, cq, cq, in HandleServerStreaming()
[all …]
|