Package org.apache.hadoop.service

Examples of org.apache.hadoop.service.Service

186
187
188
189
190
191
192
193
194
195
196
197
198
199
  /**
   * Return the latest forked process service that ran
   * @return the forkes service
   */
  protected ForkedProcessService latestProcess() {
    Service current = getActiveService();
    Service prev = getPreviousService();

    Service latest = current != null ? current : prev;
    if (latest instanceof ForkedProcessService) {
      return (ForkedProcessService) latest;
    } else {
      //its a composite object, so look inside it for a process
      if (latest instanceof ServiceParent) {
View Full Code Here
29
30
31
32
33
34
35
36
  private static final Logger
      log = LoggerFactory.getLogger(TestWorkflowCompositeService.class);

  @Test
  public void testSingleChild() throws Throwable {
    Service parent = startService(new MockService());
    parent.stop();
  }
View Full Code Here
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
   * Get the service name via {@link Service#getName()}.
   * If the service is not instantiated, the classname is returned instead.
   * @return the service name
   */
  public String getServiceName() {
    Service s = service;
    String name = null;
    if (s != null) {
      try {
        name = s.getName();
      } catch (Exception ignored) {
        // ignored
      }
    }
    if (name != null) {
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
    }
  }

  @Override
  public void run() {
    Service service;
    synchronized (this) {
      service = serviceRef.get();
      serviceRef.clear();
    }
    if (service == null) {
      return;
    }
    try {
      // Stop the  Service
      service.stop();
    } catch (Throwable t) {
      LOG.info("Error stopping {}: {}", service.getName(), t);
    }
  }
View Full Code Here
220
221
222
223
224
225
226
227
228
   */
  private void assertInState(STATE expected,
                             CompositeServiceImpl[] services,
                             int start, int finish) {
    for (int i = start; i < finish; i++) {
      Service service = services[i];
      assertInState(expected, service);
    }
  }
View Full Code Here
779
780
781
782
783
784
785
786
787
788
789
790
    }
  }

  protected void addIfServiceDependency(Object object, Object dependency) {
    if (object instanceof Service && dependency instanceof Service) {
      Service service = (Service) object;
      Service dependencyService = (Service) dependency;
      ServiceWithDependency sd = services.get(service);
      sd.dependencies.add(dependencyService);
      dependencyService.registerServiceListener(sd);
    }
  }
View Full Code Here
1402
1403
1404
1405
1406
1407
1408
1409
1410
1411
1412
1413
1414
1415
1416
1417
1418
    for (ServiceWithDependency sd : services.values()) {
      serviceList.add(sd.service);
    }
    Exception firstException = null;
    for (int i = services.size() - 1; i >= 0; i--) {
      Service service = serviceList.get(i);
      if (LOG.isDebugEnabled()) {
        LOG.debug("Stopping service : " + service);
      }
      Exception ex = ServiceOperations.stopQuietly(LOG, service);
      if (ex != null && firstException == null) {
        LOG.warn("Failed to stop service, name=" + service.getName(), ex);
        firstException = ex;
      }
    }
    //after stopping all services, rethrow the first exception raised
    if (firstException != null) {
View Full Code Here
768
769
770
771
772
773
774
775
776
777
778
    }
  }

  protected void addIfService(Object object, boolean addDispatcher) {
    if (object instanceof Service) {
      Service service = (Service) object;
      ServiceWithDependency sd = new ServiceWithDependency(service);
      services.put(service, sd);
      if(addDispatcher) {
        addIfServiceDependency(service, dispatcher);
      }
View Full Code Here
217
218
219
220
221
222
223
224
225
   */
  private void assertInState(STATE expected,
                             CompositeServiceImpl[] services,
                             int start, int finish) {
    for (int i = start; i < finish; i++) {
      Service service = services[i];
      assertInState(expected, service);
    }
  }
View Full Code Here
222
223
224
225
226
227
228
229
230
231
232
        ServiceB.class, Service.class);
    final AuxServices aux = new AuxServices();
    aux.init(conf);
    aux.start();

    Service s = aux.getServices().iterator().next();
    s.stop();
    assertEquals("Auxiliary service stopped, but AuxService unaffected.",
        STOPPED, aux.getServiceState());
    assertTrue(aux.getServices().isEmpty());
  }
View Full Code Here
TOP

Related Classes of org.apache.hadoop.service.Service

  • org.apache.hadoop.service.TestServiceLifecycle
  • org.apache.hadoop.yarn.server.nodemanager.containermanager.TestAuxServices
  • org.apache.hadoop.yarn.util.TestCompositeService
  • org.apache.slider.core.main.ServiceLauncher
  • org.apache.slider.core.main.ServiceShutdownHook
  • org.apache.slider.providers.AbstractProviderService
  • org.apache.slider.providers.accumulo.AccumuloProviderService
  • org.apache.slider.server.services.utility.SequenceService
  • org.apache.slider.server.services.workflow.TestWorkflowCompositeService
  • org.apache.slider.server.services.workflow.WorkflowSequenceService
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.