Examples of shutdown()

Examples of eu.stratosphere.nephele.jobmanager.JobManager.shutdown()

290
291
292
293
294
295
296
297
298
299
300
        LOG.info("Diagnostics "+status.getDiagnostics());
      }
      Thread.sleep(5000);
    }
    LOG.info("Shutting down JobManager");
    jm.shutdown();
   
    // Un-register with ResourceManager
    rmClient.unregisterApplicationMaster(FinalApplicationStatus.SUCCEEDED, "", "");
   
   
View Full Code Here

Examples of eu.stratosphere.nephele.services.memorymanager.MemoryManager.shutdown()

297
298
299
300
301
302
303
304
305
306
307
    // last, verify all memory is returned and shutdown mem manager
    MemoryManager memMan = getMemoryManager();
    if (memMan != null) {
      Assert.assertTrue("Memory Manager managed memory was not completely freed.", memMan.verifyEmpty());
      memMan.shutdown();
    }
  }
 
  // --------------------------------------------------------------------------------------------
 
View Full Code Here

Examples of fi.jumi.core.ipc.IpcCommandSender.shutdown()

100
101
102
103
104
105
106
107
108
109
110
        // XXX: routing the commands through IPC to make sure that IPC works
        try {
            CommandDir commandDir = daemonDir.createCommandDir();
            IpcCommandSender sender = new IpcCommandSender(commandDir, executor);
            sender.shutdown();
            sender.close();

        } catch (IOException e) {
            e.printStackTrace();
            throw new RuntimeException(e);
View Full Code Here

Examples of freenet.support.MemoryLimitedJobRunner.shutdown()

912
913
914
915
916
917
918
919
920
921
922
                        memoryLimitedJobRunner, jobRunner, ticker, keys, fg, persistentFileTracker, null);
                assertEquals(i, countEncodedCrossSegments(resumed));
                resumed.start();
                // The memoryLimitedJobRunner will only encode one segment at a time.
                // Wait for it to encode one segment.
                memoryLimitedJobRunner.shutdown();
                memoryLimitedJobRunner.waitForShutdown();
                executor.waitForIdle();
                assertEquals(i+1, countEncodedCrossSegments(resumed));
            }
        }
View Full Code Here

Examples of gnu.classpath.jdwp.Jdwp.shutdown()

68
69
70
71
72
73
74
75
76
77
78
                while (up()) {
                    Jdwp jdwp = new Jdwp();
                    jdwp.configure(ps);
                    jdwp.run();
                    jdwp.waitToFinish();
                    jdwp.shutdown();
                }
                // workaround for the restricted capabilities of JDWP support in GNU Classpath.
                JNodeSocketTransport.ServerSocketHolder.close();
            }
        });
View Full Code Here

Examples of groovyx.gpars.group.DefaultPGroup.shutdown()

66
67
68
69
70
71
72
73
74
75
76
                lastActor.send("Hi");
            }

            cdl.await(1000, TimeUnit.SECONDS);

            group.shutdown();
            final long t2 = System.currentTimeMillis();
            System.out.println("Time to process " + latchCount + " messages: " + (t2 - t1) + " ms");
            assertEquals("Latch has not been decreased to 0", 0, cdl.getCount());
        }
View Full Code Here

Examples of groovyx.gpars.group.PGroup.shutdown()

66
67
68
69
70
71
72
73
74
75
76
                lastActor.send("Hi");
            }

            cdl.await(1000, TimeUnit.SECONDS);

            group.shutdown();
            final long t2 = System.currentTimeMillis();
            System.out.println("Time to process " + latchCount + " messages: " + (t2 - t1) + " ms");
            assertEquals("Latch has not been decreased to 0", 0, cdl.getCount());
        }
View Full Code Here

Examples of hudson.plugins.libvirt.lib.IDomain.shutdown()

74
75
76
77
78
79
80
81
82
83
84
                        if (slave.getShutdownMethod().equals("suspend")) {
                            domain.suspend();
                        } else if (slave.getShutdownMethod().equals("destroy")) {
                            domain.destroy();
                        } else {
                      domain.shutdown();
                    }
                    }
                } else {
                    taskListener.getLogger().println("Already suspended, no shutdown required.");
                }
View Full Code Here

Examples of io.crate.http.HttpTestServer.shutDown()

117
118
119
120
121
122
123
124
125
126
127
            assertThat(map, hasKey("crate_version"));
            assertThat(map.get("crate_version"), is(notNullValue()));
            assertThat(map, hasKey("java_version"));
            assertThat(map.get("java_version"), is(notNullValue()));
        }
        testServer.shutDown();
    }

    @Test
    public void testUnsuccessfulPingTaskRun() throws Exception {
        HttpTestServer testServer = new HttpTestServer(18081, true);
View Full Code Here

Examples of io.lumify.core.model.systemNotification.SystemNotificationRepository.shutdown()

156
157
158
159
160
161
162
163
164
165
166
            }

            LOGGER.info("shutdown: Graph");
            if (InjectHelper.hasInjector()) {
                SystemNotificationRepository systemNotificationRepository = InjectHelper.getInstance(SystemNotificationRepository.class);
                systemNotificationRepository.shutdown();
            }

            LOGGER.info("shutdown: Graph");
            if (InjectHelper.hasInjector()) {
                Graph graph = InjectHelper.getInstance(Graph.class);
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.