Examples of shutdown()

Examples of com.caucho.env.shutdown.ShutdownSystem.shutdown()

105
106
107
108
109
110
111
112
113
114
115
    while (! _resin.isClosing()) {
      try {
        Thread.sleep(10);
       
        if (! checkMemory(runtime)) {
          shutdown.shutdown(ExitCode.MEMORY, "Resin shutdown from out of memory");
          // dumpHeapOnExit();
          return;
        }
       
        if (! checkFileDescriptor()) {
View Full Code Here

Examples of com.cloud.network.guru.NetworkGuru.shutdown()

3412
3413
3414
3415
3416
3417
3418
3419
3420
3421
3422
            if (s_logger.isDebugEnabled()) {
                s_logger.debug("Network id=" + networkId + " is shutdown successfully, cleaning up corresponding resources now.");
            }
            NetworkGuru guru = _networkGurus.get(network.getGuruName());
            NetworkProfile profile = convertNetworkToNetworkProfile(network.getId());
            guru.shutdown(profile, _networkOfferingDao.findById(network.getNetworkOfferingId()));

            applyProfileToNetwork(network, profile);

            network.setState(Network.State.Allocated);
            network.setRestartRequired(false);
View Full Code Here

Examples of com.cloudera.flume.master.FlumeMaster.shutdown()

289
290
291
292
293
294
295
296
297
298
299
    fm.serve();
    LOG.info("flume master 1 open ");
    while (fm.getKnownNodes().size() == 0) {
      Clock.sleep(1000);
    }
    fm.shutdown();
    LOG.info("flume master 1 closed");

    ConfigStore cfgStore2 = FlumeMaster.createConfigStore(cfg);
    FlumeMaster fm2 = new FlumeMaster(new CommandManager(), new ConfigManager(
        cfgStore2), new StatusManager(), new MasterAckManager(), cfg);
View Full Code Here

Examples of com.codahale.metrics.InstrumentedExecutorService.shutdown()

79
80
81
82
83
84
85
86
87
88
89
                public void run() {
                    cacheSynchronizer.waitForEmptyCaches(configuration.getShutdownTimeout(), TimeUnit.MILLISECONDS);
                }
            });

            executorService.shutdown();
            executorService.awaitTermination(configuration.getShutdownTimeout(), TimeUnit.MILLISECONDS);
        } else {
            LOG.warn("Elasticsearch is unavailable. Not waiting to clear buffers and caches, as we have no healthy cluster.");
        }
        LOG.debug("Stopped BufferSynchronizerService");
View Full Code Here

Examples of com.corundumstudio.socketio.store.StoreFactory.shutdown()

188
189
190
191
192
193
194
195
196
197
        log.debug("Client with sessionId: {} disconnected", client.getSessionId());
    }

    public void stop() {
        StoreFactory factory = configuration.getStoreFactory();
        factory.shutdown();
        scheduler.shutdown();
    }

}
View Full Code Here

Examples of com.couchbase.client.ClusterManager.shutdown()

66
67
68
69
70
71
72
73
74
      new ClusterManager(Arrays.asList(new URI(hostUri)), adminUser, adminPass);
    bucketManager.createDefaultBucket(BucketType.COUCHBASE, 128, 0, true);

    logger.info("Finished creating bucket, sleeping for warmup.");
    Thread.sleep(5000);
    bucketManager.shutdown();
  }

}
View Full Code Here

Examples of com.couchbase.client.CouchbaseConnection.shutdown()

230
231
232
233
234
235
236
237
238
239
240
    List<String> configs = getConfigsFromBinaryConnection(connection);

    if (configs.isEmpty()) {
      getLogger().debug("(Carrier Publication) Could not load config from "
        + node.getHostName() + ", trying next node.");
      connection.shutdown();
      return false;
    }

    String appliedConfig = connection.replaceConfigWildcards(
      configs.get(0));
View Full Code Here

Examples of com.couchbase.client.vbucket.ConfigurationProvider.shutdown()

447
448
449
450
451
452
453
454
455
456
457
          Thread.sleep(waitTime);

          ConfigurationProvider oldConfigProvider = getConfigurationProvider();

          if (null != oldConfigProvider) {
            oldConfigProvider.shutdown();
          }

          ConfigurationProvider newConfigProvider =
            new ConfigurationProviderHTTP(storedBaseList, bucket, pass);
          setConfigurationProvider(newConfigProvider);
View Full Code Here

Examples of com.danga.MemCached.SockIOPool.shutDown()

45
46
47
48
49
50
51
52
53
54
55
      for (int j = 0; j < BYTES.length; j++) {
        int repeats = getReapts(i);
        test(memcachedClient, BYTES[j], THREADS[i], repeats, true);
      }
    }
    pool.shutDown();
  }

  private static void warmUp(MemCachedClient memcachedClient)
      throws Exception {
    test(memcachedClient, 100, 100, 10000, false);
View Full Code Here

Examples of com.datastax.driver.core.Cluster.shutdown()

672
673
674
675
676
677
678
679
680
681
682
        try {
            return cluster.connect("rhq");
        } catch (Exception e) {
            log.debug("Failed to connect to the storage cluster.", e);
            cluster.shutdown();
            throw e;
        }
    }

    /**
 
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.