Examples of stop()

Examples of org.apache.tapestry5.test.Jetty7Runner.stop()

224
225
226
227
228
229
230
231
232
233
234
        return new Runnable()
        {
            public void run()
            {
                runner.stop();
            }
        };
    }
}
View Full Code Here

Examples of org.apache.tez.client.TezClient.stop()

214
215
216
217
218
219
220
221
222
223
224
    assertEquals(DAGStatus.State.SUCCEEDED, dagStatus.getState());
    assertNotNull(dagStatus.getDAGCounters());
    assertNotNull(dagStatus.getDAGCounters().getGroup(FileSystemCounter.class.getName()));
    assertNotNull(dagStatus.getDAGCounters().findCounter(TaskCounter.GC_TIME_MILLIS));
    ExampleDriver.printDAGStatus(dagClient, new String[] { "SleepVertex" }, true, true);
    tezSession.stop();
  }

  @Test(timeout = 100000)
  public void testMultipleDAGsWithDuplicateName() throws TezException, IOException,
      InterruptedException {
View Full Code Here

Examples of org.apache.tez.client.TezSession.stop()

389
390
391
392
393
394
395
396
397
398
399
          return false;
        }
        return true;
    } finally {
      fs.delete(stagingDir, true);
      tezSession.stop();
    }
  }

  public static void main(String[] args) throws Exception {
    if ((args.length%2) != 0) {
View Full Code Here

Examples of org.apache.tez.dag.app.rm.TestTaskSchedulerHelpers.TaskSchedulerWithDrainableAppCallback.stop()

979
980
981
982
983
984
985
986
987
988
989
    String appMsg = "success";
    AppFinalStatus finalStatus =
        new AppFinalStatus(FinalApplicationStatus.SUCCEEDED, appMsg, appUrl);
    when(mockApp.getFinalAppStatus()).thenReturn(finalStatus);
    scheduler.stop();
    drainableAppCallback.drain();
    verify(mockRMClient).
                  unregisterApplicationMaster(FinalApplicationStatus.SUCCEEDED,
                                              appMsg, appUrl);
    verify(mockRMClient).stop();
View Full Code Here

Examples of org.apache.thrift.server.TServer.stop()

174
175
176
177
178
179
180
181
182
183
184
    String traces[] = {"my test", "checkTrace", "client:checkTrace", "start"};
    assertTrue(tracer.traces.get(start.traceId()).size() == traces.length);
    for (int i = 0; i < traces.length; i++)
      assertEquals(traces[i], tracer.traces.get(start.traceId()).get(i).description);
   
    tserver.stop();
    t.join(100);
  }

  Callable<Object> callable;
View Full Code Here

Examples of org.apache.thrift.server.TSimpleServer.stop()

49
50
51
52
53
54
55
56
57
58
59
    try {
      server.serve();
    } finally {
      log.info("Closing down everything.");

      server.stop();
    }
  }

  private static enum Protocol {
    JSON(new TJSONProtocol.Factory()),
View Full Code Here

Examples of org.apache.thrift.server.TThreadPoolServer.stop()

174
175
176
177
178
179
180
181
182
183
184
    String traces[] = {"my test", "checkTrace", "client:checkTrace", "start"};
    assertTrue(tracer.traces.get(start.traceId()).size() == traces.length);
    for (int i = 0; i < traces.length; i++)
      assertEquals(traces[i], tracer.traces.get(start.traceId()).get(i).description);
   
    tserver.stop();
    t.join(100);
  }

  Callable<Object> callable;
View Full Code Here

Examples of org.apache.thrift7.server.THsHaServer.stop()

91
92
93
94
95
96
97
98
99
100
101
   
    Runtime.getRuntime().addShutdownHook(new Thread() {
      public void run() {
        service_handler.shutdown();
        scheduExec.shutdown();
        server.stop();
      }

    });
    LOG.info("Starting BlueWhale server...");
    server.serve();
View Full Code Here

Examples of org.apache.tomcat.util.qlog.LogDaemon.stop()

219
220
221
222
223
224
225
226
227
228
229
  // engineShutdown shouldn't be called on local modules anyway !

  LogDaemon logDaemon=(LogDaemon)cm.getNote("tc.LogDaemon");
  if( logDaemon!=null ) {
      try{
    logDaemon.stop();
      } catch( Exception ex ) {
    ex.printStackTrace();
      }
      //      cm.setNote( "tc.LogDaemon", null );
  }
View Full Code Here

Examples of org.apache.tomee.embedded.Container.stop()

78
79
80
81
82
83
84
85
86
87
88
            Runtime.getRuntime().addShutdownHook(new Thread() {
                @Override
                public void run() {
                    try {
                        container.undeploy(warFile.getAbsolutePath());
                        container.stop();
                    } catch (Exception e) {
                        getLog().error("can't stop TomEE", e);
                    } finally {
                        latch.countDown();
                    }
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.