| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| SimpleTimeLimiterTest.java | 37 private TimeLimiter service; field in class:SimpleTimeLimiterTest
55 service = new SimpleTimeLimiter(executor);
60 String result = service.callWithTimeout(
74 service.callWithTimeout(
90 service.callWithTimeout(
106 service.callWithTimeout(
121 Sample proxy = service.newProxy(
131 Sample proxy = service.newProxy(
149 Sample proxy = service.newProxy(
162 Sample proxy = service.newProxy
[all...] |
| MoreExecutorsTest.java | 270 ListeningExecutorService service = local
272 assertSame(service, listeningDecorator(service));
277 results = service.invokeAll(callables);
280 results = service.invokeAll(callables, 1, SECONDS);
291 ListeningExecutorService service = listeningDecorator(delegate); local
296 service.execute(task);
308 ListeningScheduledExecutorService service = listeningDecorator(delegate); local
310 service.schedule(Callables.returning(null), 1, TimeUnit.MILLISECONDS);
325 ListeningScheduledExecutorService service = listeningDecorator(delegate) local
335 ListeningScheduledExecutorService service = listeningDecorator(delegate); local
356 ListeningScheduledExecutorService service = listeningDecorator(delegate); local
514 ExecutorService service = mock(ExecutorService.class); local
525 ExecutorService service = mock(ExecutorService.class); local
633 ExecutorService service = Executors.newSingleThreadExecutor(); local
639 ExecutorService service = mock(ExecutorService.class); local
648 ExecutorService service = mock(ExecutorService.class); local
659 ExecutorService service = mock(ExecutorService.class); local
669 final ExecutorService service = mock(ExecutorService.class); local
[all...] |
| /external/icu/android_icu4j/src/main/java/android/icu/text/ |
| BreakIteratorFactory.java | 37 return service.registerObject(iter, locale, kind);
41 if (service.isDefault()) {
44 return service.unregisterFactory((Factory)key);
48 if (service == null) {
51 return service.getAvailableLocales();
56 if (service == null) {
59 return service.getAvailableULocales();
64 // TODO: convert to ULocale when service switches over
65 if (service.isDefault()) {
69 BreakIterator iter = (BreakIterator)service.get(locale, kind, actualLoc)
101 static final ICULocaleService service = new BFService(); field in class:BreakIteratorFactory
[all...] |
| CollatorServiceShim.java | 30 // use service cache, it's faster than instantiation
31 // if (service.isDefault()) {
36 Collator coll = (Collator)service.get(locale, actualLoc);
57 return service.registerObject(collator, locale);
84 return service.registerFactory(new CFactory(f));
88 return service.unregisterFactory((Factory)registryKey);
94 if (service.isDefault()) {
98 result = service.getAvailableLocales();
105 if (service.isDefault()) {
109 result = service.getAvailableULocales()
175 private static ICULocaleService service = new CService(); field in class:CollatorServiceShim
[all...] |
| /external/icu/icu4j/main/classes/collate/src/com/ibm/icu/text/ |
| CollatorServiceShim.java | 29 // use service cache, it's faster than instantiation
30 // if (service.isDefault()) {
35 Collator coll = (Collator)service.get(locale, actualLoc);
56 return service.registerObject(collator, locale);
83 return service.registerFactory(new CFactory(f));
87 return service.unregisterFactory((Factory)registryKey);
93 if (service.isDefault()) {
97 result = service.getAvailableLocales();
104 if (service.isDefault()) {
108 result = service.getAvailableULocales()
174 private static ICULocaleService service = new CService(); field in class:CollatorServiceShim
[all...] |
| /external/icu/icu4j/main/classes/core/src/com/ibm/icu/text/ |
| BreakIteratorFactory.java | 36 return service.registerObject(iter, locale, kind);
40 if (service.isDefault()) {
43 return service.unregisterFactory((Factory)key);
47 if (service == null) {
50 return service.getAvailableLocales();
55 if (service == null) {
58 return service.getAvailableULocales();
63 // TODO: convert to ULocale when service switches over
64 if (service.isDefault()) {
68 BreakIterator iter = (BreakIterator)service.get(locale, kind, actualLoc)
100 static final ICULocaleService service = new BFService(); field in class:BreakIteratorFactory
[all...] |
| /frameworks/base/core/java/android/app/job/ |
| JobService.java | 19 import android.app.Service;
37 * <p>This service executes each incoming job on a {@link android.os.Handler} running on your
44 public abstract class JobService extends Service {
51 * <service android:name="MyJobService"
54 * </service>
57 * <p>If a job service is declared in the manifest but not protected with this
58 * permission, that service will be ignored by the OS.
90 JobInterface(JobService service) {
91 mService = new WeakReference<>(service);
96 JobService service = mService.get() local
106 JobService service = mService.get(); local
[all...] |
| /external/autotest/client/cros/tendo/n_faced_peerd/ |
| dbus_property_exposer.py | 6 import dbus.service namespace
14 class DBusPropertyExposer(dbus.service.Object):
57 @dbus.service.method(dbus_interface=dbus.PROPERTIES_IFACE,
76 @dbus.service.method(dbus_interface=dbus.PROPERTIES_IFACE,
93 @dbus.service.signal(dbus_interface=dbus.PROPERTIES_IFACE,
|
| /external/chromium-trace/catapult/third_party/gsutil/third_party/apitools/apitools/base/py/ |
| base_api_test.py | 95 service = FakeService()
100 self.assertEqual(response_message, service.ProcessHttpResponse(
102 with service.client.JsonResponseModel():
105 service.ProcessHttpResponse(method_config, http_response))
125 service = FakeService()
128 http_request = service.PrepareHttpRequest(method_config, request)
136 service = FakeService()
141 http_request = service.PrepareHttpRequest(method_config, request,
149 http_request = service.PrepareHttpRequest(method_config, request,
157 service = FakeService(
[all...] |
| /frameworks/base/packages/DocumentsUI/src/com/android/documentsui/services/ |
| Job.java | 68 final Context service; field in class:Job
87 * @param service The service context in which this job is running.
96 Job(Context service, Context appContext, Listener listener,
101 this.service = service;
121 Metrics.logFileOperationErrors(service, operationType, failedFiles);
163 Metrics.logFileOperationCancelled(service, operationType);
171 return service.getContentResolver();
214 final Notification.Builder errorBuilder = new Notification.Builder(service)
[all...] |
| /frameworks/base/tests/VoiceInteraction/src/com/android/test/voiceinteraction/ |
| MainInteractionService.java | 22 import android.service.voice.AlwaysOnHotwordDetector;
23 import android.service.voice.AlwaysOnHotwordDetector.Callback;
24 import android.service.voice.AlwaysOnHotwordDetector.EventPayload;
25 import android.service.voice.VoiceInteractionService;
26 import android.service.voice.VoiceInteractionSession;
|
| /frameworks/native/cmds/cmd/ |
| cmd.cpp | 57 ALOGE("Unable to get default service manager!");
58 aerr << "cmd: Unable to get default service manager!" << endl;
63 aout << "cmd: no service specified; use -l to list all services" << endl;
73 sp<IBinder> service = sm->checkService(services[i]); local
74 if (service != NULL) {
86 sp<IBinder> service = sm->checkService(cmd); local
87 if (service == NULL) {
88 aerr << "Can't find service: " << argv[1] << endl;
93 IBinder::shellCommand(service, STDIN_FILENO, STDOUT_FILENO, STDERR_FILENO, args,
|
| /system/connectivity/apmanager/ |
| manager.cc | 51 scoped_refptr<Service> Manager::CreateService() {
53 scoped_refptr<Service> service = new Service(this, service_identifier_++); local
54 services_.push_back(service);
55 return service;
58 bool Manager::RemoveService(const scoped_refptr<Service>& service,
61 if (*it == service) {
69 "Service does not exist"
[all...] |
| /system/connectivity/shill/vpn/ |
| vpn_provider_unittest.cc | 66 string GetServiceFriendlyName(const ServiceRefPtr& service) {
67 return service->friendly_name();
70 void SetConnectState(const ServiceRefPtr& service,
71 Service::ConnectState state) {
72 service->state_ = state;
75 void AddService(const VPNServiceRefPtr& service) {
76 provider_.services_.push_back(service);
101 ServiceRefPtr service = provider_.GetService(args, &e); local
103 EXPECT_FALSE(service);
113 ServiceRefPtr service = provider_.GetService(args, &e) local
127 ServiceRefPtr service = provider_.FindSimilarService(args, &error); local
134 ServiceRefPtr service; local
305 VPNServiceRefPtr service = local
[all...] |
| /external/autotest/client/cros/cellular/ |
| cell_tools.py | 38 a tuple of the service and the service state
44 service = flim.FindCellularService(timeout=timeout)
45 if not service:
47 'Could not find cell service')
48 properties = service.GetProperties(utf8_strings=True)
51 logger.info('Connecting to cell service: %s', service)
54 state = flim.WaitForServiceState(service=service,
[all...] |
| cell_tools_test_on_chromebook.py | 41 logger.debug('Find Celluar Service..')
42 self.service = self.flim.FindCellularService()
44 self.service.SetProperty('AutoConnect', dbus.Boolean(False))
60 service = env.CheckedConnectToCellular()
66 self.service = self.flim.FindCellularService()
67 self.service.SetProperty('AutoConnect', dbus.Boolean(False))
78 self.service = self.flim.FindCellularService()
79 self.service.SetProperty('AutoConnect', dbus.Boolean(False))
89 service = env.CheckedConnectToCellular()
91 env.CheckedDisconnectFromCellular(service)
[all...] |
| /packages/services/Telecomm/tests/src/com/android/server/telecom/tests/ |
| CreateConnectionProcessorTest.java | 93 ConnectionServiceWrapper service = makeConnectionServiceWrapper(); local
99 verify(mMockCall).setConnectionService(eq(service));
100 verify(service).createConnection(eq(mMockCall), any(CreateConnectionResponse.class));
115 ConnectionServiceWrapper service = makeConnectionServiceWrapper(); local
119 verify(service, never()).createConnection(eq(mMockCall),
131 ConnectionServiceWrapper service = makeConnectionServiceWrapper(); local
142 verify(mMockCall).setConnectionService(eq(service));
143 verify(service).createConnection(eq(mMockCall), any(CreateConnectionResponse.class));
156 ConnectionServiceWrapper service = makeConnectionServiceWrapper(); local
162 when(mMockCall.getConnectionService()).thenReturn(service);
191 ConnectionServiceWrapper service = makeConnectionServiceWrapper(); local
222 ConnectionServiceWrapper service = makeConnectionServiceWrapper(); local
251 ConnectionServiceWrapper service = makeConnectionServiceWrapper(); local
[all...] |
| /system/connectivity/shill/wifi/ |
| wifi_provider.cc | 74 "service mode is unsupported";
109 WiFiServiceRefPtr service = services_.back(); local
110 ForgetService(service);
111 SLOG(this, 3) << "WiFiProvider deregistering service "
112 << service->unique_name();
113 manager_->DeregisterService(service);
140 // If service already exists, we have nothing to do, since the
141 // service has already loaded its configuration from storage.
150 // By registering the service in AddService, the rest of the configuration
151 // will be loaded from the profile into the service via ConfigureService()
288 WiFiServiceRefPtr service = FindService(endpoint->ssid(), local
315 WiFiServiceRefPtr service = FindServiceForEndpoint(endpoint); local
342 WiFiService* service = FindServiceForEndpoint(endpoint).get(); local
457 WiFiServiceRefPtr service = new WiFiService(control_interface_, local
[all...] |
| /external/autotest/client/site_tests/peerd_DiscoverServices/ |
| peerd_DiscoverServices.py | 27 PEER_SERVICES = [FakeService('test-service-0',
32 FakeService('test-service-1',
42 'services': '.'.join([service.service_id
43 for service in PEER_SERVICES])
95 service = None
98 service = s
101 logging.debug('No service %s found.', service_id)
103 if service.service_info != info:
104 logging.debug('Invalid info found for service %s, '
106 info, service.service_info
[all...] |
| /system/connectivity/shill/cellular/ |
| modem_manager.cc | 36 const string& service,
40 service_(service),
97 const string& service,
100 : ModemManager(control_interface, service, path, modem_info) {}
107 LOG(INFO) << "Start watching modem manager service: " << service();
113 service(),
120 LOG(INFO) << "Stop watching modem manager service: " << service();
140 shared_ptr<ModemClassic> modem(new ModemClassic(service(),
[all...] |
| /cts/tests/tests/os/src/android/os/cts/ |
| SeccompTest.java | 19 import android.app.Service;
189 * service. This will perform various operations in an isolated process under a
206 final ISeccompIsolatedService service = peer.get(); local
209 assertTrue(service.installFilter());
210 assertTrue(service.createThread());
211 assertTrue(service.getSystemInfo());
212 doFileWriteTest(service);
213 assertTrue(service.openAshmem());
214 assertTrue(service.openDevFile());
237 final ISeccompIsolatedService service = peer.get() local
[all...] |
| /external/autotest/client/site_tests/network_3GDisconnectFailure/ |
| network_3GDisconnectFailure.py | 154 @return True, if service is connected.
157 service = self.test_env.shill.find_cellular_service_object()
158 properties = service.GetProperties(utf8_strings=True)
165 @return True, if service is disconnected.
168 service = self.test_env.shill.find_cellular_service_object()
169 properties = service.GetProperties(utf8_strings=True)
202 Fails if the service doesn't remain connected.
210 # Connect to the service.
211 service = self.test_env.shill.find_cellular_service_object()
213 service, CONNECT_DISCONNECT_TIMEOUT
[all...] |
| /cts/tests/tests/security/src/android/security/cts/ |
| ServicePermissionsTest.java | 80 for (String service : services) {
86 .getDeclaredMethod("getService", String.class).invoke(null, service);
95 Log.w(TAG, "Missing service " + service);
99 Log.d(TAG, "Dumping service " + service);
106 // Service correctly checked for DUMP permission, yay
108 // Service is throwing about something else; they're
134 fail("dump() for " + service + " produced several lines of output; this "
143 fail("dump() for " + service + " produced a single line which didn't
[all...] |
| /external/autotest/client/site_tests/documentscan_AppTestWithFakeLorgnette/ |
| mock_lorgnette.py | 7 import dbus.service namespace
21 class LorgnetteManager(dbus.service.Object):
31 dbus.service.Object.__init__(self, bus, object_path)
36 @dbus.service.method('org.chromium.lorgnette.Manager',
47 @dbus.service.method('org.chromium.lorgnette.Manager',
116 name = dbus.service.BusName(self.LORGNETTE, self.bus)
|
| /frameworks/base/core/java/android/view/accessibility/ |
| IAccessibilityManager.aidl | 58 void temporaryEnableAccessibilityStateUntilKeyguardRemoved(in ComponentName service,
63 void enableAccessibilityService(in ComponentName service, int userId);
65 void disableAccessibilityService(in ComponentName service, int userId);
|
