List of halt() Examples

Examples of halt()

com.linkedin.databus2.core.container.netty.ServerContainer.GlobalStatsCalc.halt()
com.lmax.disruptor.dsl.stubs.StubPublisher.halt()
javax.isolate.Isolate.halt()
Force termination of this isolate. @param status
net.tomp2p.p2p.Peer.halt()
org.apache.accumulo.server.master.LiveTServerSet.TServerConnection.halt()
org.apache.bookkeeper.client.BookieHandle.halt()
Halts if there is no ledger using this object. @return int reference counter
org.apache.zookeeper.server.quorum.QuorumCnxManager.halt()
Flag that it is time to wrap up all activities and interrupt the listener.
org.drools.StatefulSession.halt()
org.drools.core.StatefulSession.halt()
org.drools.runtime.StatefulKnowledgeSession.halt()
org.exoplatform.services.jcr.impl.util.io.FileCleaner.halt()
org.jboss.bootstrap.spi.ServerProcess.halt()
Forcibly terminates the currently running Java virtual machine. @param exitcode The exit code returned to the operating system.
org.kie.api.runtime.KieSession.halt()
org.kie.internal.runtime.StatefulKnowledgeSession.halt()
org.kie.runtime.KieSession.halt()
org.kie.runtime.StatefulKnowledgeSession.halt()

Examples of com.linkedin.databus2.core.container.netty.ServerContainer.GlobalStatsCalc.halt()

        sw.interrupt();
      }
      //Give a chance to catch up
      Thread.sleep(1000);


      agg.halt();
      aggThread.interrupt();


      //final tally aggregatedEventTotalStats = sum of all individual statsWriter objects in a thread free way


      AggregatedDbusEventsTotalStats myTotalStats = new AggregatedDbusEventsTotalStats(StatsWriter.OWNERID, "mytotal", true, false, null);

View Full Code Here

Examples of com.lmax.disruptor.dsl.stubs.StubPublisher.halt()


            assertProducerReaches(stubPublisher, 5, false);
        }
        finally
        {
            stubPublisher.halt();
        }
    }


    @Test
    public void shouldBeAbleToOverrideTheExceptionHandlerForAEventProcessor()

View Full Code Here

Examples of javax.isolate.Isolate.halt()

        child.start();


        try {
            Thread.sleep(100);
        } finally {
            child.halt(0);
        }


    }


    private static Isolate runChild(Class<?> clazz)

View Full Code Here

Examples of net.tomp2p.p2p.Peer.halt()

        } finally {
            if (peer1 != null) {
                peer1.halt();
            }
            if (peer2 != null) {
                peer2.halt();
            }
        }
    }


    @Test

View Full Code Here

Examples of org.apache.accumulo.server.master.LiveTServerSet.TServerConnection.halt()

        if (badServers.get(server).incrementAndGet() > MAX_BAD_STATUS_COUNT) {
          log.warn("attempting to stop " + server);
          try {
            TServerConnection connection = tserverSet.getConnection(server);
            if (connection != null)
              connection.halt(masterLock);
          } catch (TTransportException e) {
            // ignore: it's probably down
          } catch (Exception e) {
            log.info("error talking to troublesome tablet server ", e);
          }

View Full Code Here

Examples of org.apache.accumulo.server.master.LiveTServerSet.TServerConnection.halt()

      if (connection != null) {
        try {
          TabletServerStatus status = connection.getTableMap(false);
          if (status.tableMap != null && status.tableMap.isEmpty()) {
            log.info("tablet server hosts no tablets " + server);
            connection.halt(master.getMasterLock());
            log.info("tablet server asked to halt " + server);
            break;
          }
        } catch (TTransportException ex) {
          // expected

View Full Code Here

Examples of org.apache.accumulo.server.master.LiveTServerSet.TServerConnection.halt()

        if (badServers.get(server).incrementAndGet() > MAX_BAD_STATUS_COUNT) {
          log.warn("attempting to stop " + server);
          try {
            TServerConnection connection = tserverSet.getConnection(server);
            if (connection != null)
              connection.halt(masterLock);
          } catch (TTransportException e) {
            // ignore: it's probably down
          } catch (Exception e) {
            log.info("error talking to troublesome tablet server ", e);
          }

View Full Code Here

Examples of org.apache.accumulo.server.master.LiveTServerSet.TServerConnection.halt()

      if (connection != null) {
        try {
          TabletServerStatus status = connection.getTableMap(false);
          if (status.tableMap != null && status.tableMap.isEmpty()) {
            log.info("tablet server hosts no tablets " + server);
            connection.halt(m.getMasterLock());
            log.info("tablet server asked to halt " + server);
            break;
          }
        } catch (TTransportException ex) {
          // expected

View Full Code Here

Examples of org.apache.bookkeeper.client.BookieHandle.halt()

     */
    
    synchronized void haltBookieHandles(LedgerHandle lh, ArrayList<BookieHandle> bookies){
        while(bookies.size() > 0){
            BookieHandle bh = bookies.remove(0);
            if(bh.halt(lh) <= 0)
                bhMap.remove(bh.addr);
        }
    }
    
    /**

View Full Code Here

Examples of org.apache.zookeeper.server.quorum.QuorumCnxManager.halt()

            fail("Socket has not been closed");
        } catch (Exception e) {
            LOG.info("Socket has been closed as expected");
        }
        peer.shutdown();
        cnxManager.halt();
    }   


    /*
     * Test if Worker threads are getting killed after connection loss
     */

View Full Code Here

0 1 2 3 4 5

TOP

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.