Examples of shutdown()

Examples of org.apache.hadoop.metrics2.impl.MetricsSystemImpl.shutdown()

102
103
104
105
106
107
108
109
110
111
112
    mm1.testMetric1.incr();
    mm1.testMetric2.incr(2);

    ms.publishMetricsNow(); // publish the metrics
    ms.stop();
    ms.shutdown();

    InputStream is = null;
    ByteArrayOutputStream baos = null;
    String outFileContent = null;
    try {
View Full Code Here

Examples of org.apache.hadoop.raid.ParallelStreamReader.shutdown()

412
413
414
415
416
417
418
419
420
421
422
              }
              readNum += result.readBufs[0].length;
            }
          } finally {
            if (null != reader) {
              reader.shutdown();
            }
            reporter.progress();
          }
        }
      } finally {
View Full Code Here

Examples of org.apache.hadoop.util.AsyncDiskService.shutdown()

70
71
72
73
74
75
76
77
78
79
80
      e = ex;
    }
    assertNotNull("Executing a task on a non-existing volume should throw an "
        + "Exception.", e);
   
    service.shutdown();
    if (!service.awaitTermination(5000)) {
      fail("AsyncDiskService didn't shutdown in 5 seconds.");
    }
   
    assertEquals(total, count);
View Full Code Here

Examples of org.apache.hedwig.server.netty.PubSubServer.shutdown()

99
100
101
102
103
104
105
106
107
108
109
        } catch (Exception e) {
            e.printStackTrace();
        }
        Assert.assertNotNull("failed to instantiate hedwig pub sub server", hedwigServer);

        hedwigServer.shutdown();
        serverFactory.shutdown();

        zks.shutdown();

        zkTmpDir.delete();
View Full Code Here

Examples of org.apache.helix.ipc.netty.NettyHelixIPCService.shutdown()

231
232
233
234
235
236
237
238
239
240
241
      Assert.assertEquals(count.get(), 2 * numMessages);
    }

    // Shutdown
    firstIPC.shutdown();
    secondIPC.shutdown();
  }

  @Test
  public void testMessageManager() throws Exception {
    final int numMessages = 1000;
View Full Code Here

Examples of org.apache.helix.messaging.handling.HelixTaskExecutor.shutDown()

516
517
518
519
520
521
522
523
524
525
526
      for(ExecutorService svc : executor._threadpoolMap.values())
      {
        Assert.assertFalse(svc.isShutdown());
      }
      Assert.assertTrue(factory._processedMsgIds.size() > 0);
      executor.shutDown();
      for(ExecutorService svc : executor._threadpoolMap.values())
      {
        Assert.assertTrue(svc.isShutdown());
      }
      System.out.println("END TestCMTaskExecutor.testShutdown()");
View Full Code Here

Examples of org.apache.hivemind.Registry.shutdown()

176
177
178
179
180
181
182
183
        ObjectName objectName = objectNameBuilder.createObjectName(logger.getName(), "logger");

        ObjectInstance instance = mbeanServer.getObjectInstance(objectName);
        assertNotNull(instance);

        registry.shutdown();
    }
}
View Full Code Here

Examples of org.apache.hivemind.ShutdownCoordinator.shutdown()

414
415
416
417
418
419
420
421
422
423
424
        ShutdownCoordinator coordinatorService =
            (ShutdownCoordinator) getService("hivemind.ShutdownCoordinator",
                ShutdownCoordinator.class);

        coordinatorService.shutdown();

        _shutdown = true;

        // Shutdown infrastructure items, such as proxies.
View Full Code Here

Examples of org.apache.hivemind.annotations.TypedRegistry.shutdown()

41
42
43
44
45
46
47
48
        System.out.println("Subtract: " + calculator.subtract(arg0, arg1));
        System.out.println("Multiply: " + calculator.multiply(arg0, arg1));
        System.out.println("Divide:   " + calculator.divide(arg0, arg1));


        registry.shutdown();
    }
}
View Full Code Here

Examples of org.apache.hivemind.impl.ShutdownCoordinatorImpl.shutdown()

52
53
54
55
56
57
58
59
60
61
62
        Fixture f = new Fixture();

        c.addRegistryShutdownListener(f);

        c.shutdown();

        assertEquals(true, f.isShutdown());

        // For good riddens; test no failure if already down.
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.