| /external/guava/guava/src/com/google/common/util/concurrent/ |
| AbstractScheduledService.java | 46 * the {@link #startUp} and {@link #shutDown} methods and also uses that service to schedule the
48 * {@link Scheduler}. When this service is asked to stop via {@link #stopAsync} it will cancel the
61 * <p>Here is a sketch of a service which crawls a website and uses the scheduling capabilities to
96 public abstract class AbstractScheduledService implements Service {
105 * service with a fixed schedule. If more flexibility is needed then consider subclassing
125 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
144 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
151 /** Schedules the task to run on the provided executor on behalf of the service. */
152 abstract Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
180 "Error while attempting to shut down the service after failure.", ignored)
[all...] |
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/bluetooth/ |
| BluetoothHealthFacade.java | 19 import android.app.Service;
56 private final Service mService;
68 mBluetoothManager = (BluetoothManager) mContext.getSystemService(Service.BLUETOOTH_SERVICE);
|
| /libcore/ojluni/src/main/java/java/security/ |
| SecureRandom.java | 31 import java.security.Provider.Service;
425 Service service = cryptoProvider.getService("SecureRandom", algorithm); local
426 Instance instance = GetInstance.getInstance(service, SecureRandomSpi.class);
649 for (Service s : p.getServices()) {
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/btservice/ |
| ProfileService.java | 23 import android.app.Service;
31 public abstract class ProfileService extends Service {
49 private static final int PROFILE_SERVICE_MODE=Service.START_NOT_STICKY;
123 Log.w(mName, "Stopping profile service: device does not have BT");
134 Log.d(mName, "Restarting profile service...");
184 if (DBG) log("Destroying service.");
204 //Start service
229 //Notify adapter service
|
| /device/linaro/bootloader/edk2/MdeModulePkg/Universal/Network/Mtftp4Dxe/ |
| Mtftp4Driver.c | 67 @retval EFI_SUCCESS The controller has UDP service binding protocol
128 Create then initialize a MTFTP service binding instance.
130 @param Controller The controller to install the MTFTP service
133 @param Service The variable to receive the created service
139 @retval EFI_SUCCESS The service instance is created for the
147 OUT MTFTP4_SERVICE **Service
153 *Service = NULL;
219 *Service = MtftpSb;
225 Release all the resource used the MTFTP service binding instance.
[all...] |
| Mtftp4Impl.h | 50 /// Some constant value of Mtftp service.
66 /// Mtftp service block
103 MTFTP4_SERVICE *Service;
|
| /libcore/luni/src/test/java/org/apache/harmony/security/tests/java/security/ |
| Signature2Test.java | 500 private Set<Provider.Service> services = null;
510 services = new HashSet<Service>();
519 services = new HashSet<Service>();
523 public void putService(Provider.Service s) {
528 public void removeService(Provider.Service s) {
|
| /libcore/support/src/test/java/org/apache/harmony/security/tests/support/ |
| TestCertUtils.java | 586 private Provider.Service serv;
590 serv = new Provider.Service(this, "CertificateFactory", "X.509",
594 public synchronized Set<Provider.Service> getServices() {
595 HashSet<Provider.Service> s = new HashSet<Service>();
|
| /frameworks/native/libs/vr/libpdx/ |
| service_tests.cpp | 1 #include <pdx/service.h>
22 using android::pdx::Service;
87 class MockService : public Service {
89 using Service::Service;
122 info->service = service_.get();
160 // Service class tests
231 EXPECT_TRUE(service_->Service::HandleMessage(message));
248 EXPECT_TRUE(service_->Service::HandleMessage(message));
261 EXPECT_TRUE(service_->Service::HandleMessage(message))
[all...] |
| /libcore/luni/src/test/java/libcore/java/security/ |
| KeyPairGeneratorTest.java | 30 import java.security.Provider.Service;
136 Set<Provider.Service> services = provider.getServices();
137 for (Provider.Service service : services) {
138 String type = service.getType();
142 String algorithm = service.getAlgorithm();
320 Set<Provider.Service> services = p.getServices();
321 for (Provider.Service service : services) {
322 if (!"KeyFactory".equals(service.getType()))
[all...] |
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| ExperimentingRunnerModule.java | 37 import com.google.common.util.concurrent.Service;
64 static Service provideServerSocketService(ServerSocketService impl) {
69 static Service provideTrialOutputFactoryService(TrialOutputFactoryService impl) {
|
| /external/jmdns/src/javax/jmdns/impl/ |
| DNSQuestion.java | 125 * Service question.
127 private static class Service extends DNSQuestion {
128 Service(String name, DNSRecordType type, DNSRecordClass recordClass, boolean unique) {
140 // Service type request
201 // Service type request
251 return new Service(name, type, recordClass, unique);
|
| DNSRecord.java | 495 // The service name is in the alias
637 * Service record.
639 public static class Service extends DNSRecord {
640 private static Logger logger1 = Logger.getLogger(Service.class.getName());
646 public Service(String name, DNSRecordClass recordClass, boolean unique, int ttl, int priority, int weight, int port, String server) {
711 if (! (other instanceof Service) ) {
714 Service s = (Service) other;
728 DNSRecord.Service localService = new DNSRecord.Service(info.getQualifiedName(), DNSRecordClass.CLASS_IN, DNSRecordClass.UNIQUE, DNSConstants.DNS_TTL, inf (…)
[all...] |
| /frameworks/base/tests/OneMedia/src/com/android/onemedia/ |
| NotificationHelper.java | 8 import android.app.Service;
35 private final Service mService;
46 public NotificationHelper(Service service, MediaSession session) {
47 mService = service;
|
| /development/samples/ApiDemos/src/com/example/android/apis/app/ |
| JobWorkService.java | 23 import android.app.Service;
46 * to it. The {@link JobWorkServiceActivity} class shows how to interact with the service.
48 //BEGIN_INCLUDE(service)
133 * Show a notification while this service is running.
149 // We show this for as long as our service is processing a command.
161 //END_INCLUDE(service)
|
| /device/linaro/bootloader/edk2/MdeModulePkg/Universal/Network/Dhcp4Dxe/ |
| Dhcp4Impl.h | 48 // The state of the DHCP service. It starts as UNCONFIGED. If
49 // and active child configures the service successfully, it
64 DHCP_SERVICE *Service;
80 // has a service binding, there can be only one active child.
150 Give up the control of the DHCP service to let other child
151 resume. Don't change the service's DHCP state and the Client
154 @param DhcpSb The DHCP service instance.
|
| /device/linaro/bootloader/edk2/NetworkPkg/Ip6Dxe/ |
| Ip6If.h | 115 IP6_SERVICE *Service;
147 @param[in] IpSb The IP6 service binding instance.
208 @param[in] IpSb Points to the IP6 service binding instance.
252 The heartbeat timer of IP6 service instance. It times out
256 @param[in] Event The IP6 service instance's heart beat timer.
257 @param[in] Context The IP6 service instance.
|
| /external/autotest/client/cros/tendo/n_faced_peerd/ |
| peer.py | 6 import dbus.service
12 from autotest_lib.client.cros.tendo.n_faced_peerd import service
46 # for creating child service objects.
92 """Update a service associated with this peer.
94 @param service_id: string peerd service ID.
96 the metadata for the service.
97 @param ip_info: an instance of IpInfo defined in service.py.
106 self.services[service_id] = service.Service(
109 logging.info('service=%s has info %r.', service_id, service_info
[all...] |
| /external/flatbuffers/grpc/tests/ |
| grpctest.cpp | 28 class ServiceImpl final : public MyGame::Example::MonsterStorage::Service {
67 ServiceImpl service; local
70 builder.RegisterService(&service);
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractScheduledServiceTest.java | 20 import com.google.common.util.concurrent.Service.State;
60 NullService service = new NullService(); local
61 service.startAsync().awaitRunning();
63 service.stopAsync().awaitTerminated();
74 TestService service = new TestService(); local
75 service.runException = new Exception();
76 service.startAsync().awaitRunning();
77 service.runFirstBarrier.await();
78 service.runSecondBarrier.await();
85 assertEquals(service.runException, e.getCause().getCause())
91 TestService service = new TestService(); local
104 TestService service = new TestService(); local
120 TestService service = new TestService(); local
134 TestService service = new TestService(); local
153 AbstractScheduledService service = new AbstractScheduledService() { local
176 AbstractScheduledService service = new AbstractScheduledService() { local
202 TestService service = new TestService(); local
364 TestAbstractScheduledCustomService service = new TestAbstractScheduledCustomService(); local
377 TestAbstractScheduledCustomService service = new TestAbstractScheduledCustomService() { local
434 TestFailingCustomScheduledService service = new TestFailingCustomScheduledService(); local
[all...] |
| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| versioning_test_service.cc | 16 #include "services/shell/public/cpp/service.h"
98 : public shell::Service,
103 // shell::Service implementation.
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/activity/ |
| FutureActivity.java | 20 import android.app.Service;
39 * {@link Service} is unable to do. For example: start another activity for result, show dialogs,
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/doze/ |
| DozeService.java | 22 import android.service.dreams.DreamService;
34 implements DozeMachine.Service, RequestDoze, PluginListener<DozeServicePlugin> {
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/phone/ |
| ManagedProfileControllerImpl.java | 67 .getSystemService(android.app.Service.STATUS_BAR_SERVICE);
|
| /frameworks/native/libs/vr/libpdx/private/pdx/ |
| mock_service_endpoint.h | 13 MOCK_METHOD1(SetService, Status<void>(Service* service));
|
