Package org.apache.bookkeeper.client.QuorumEngine.Operation

Examples of org.apache.bookkeeper.client.QuorumEngine.Operation.StopOp

136
137
138
139
140
141
142
143
144
145
146
   
    private synchronized void sendStop(){
        try{
            noreception = true;
            LOG.debug("Sending stop signal");
            incomingQueue.put(new ToSend(null, new SubStopOp(new StopOp()), -1));
            LOG.debug("Sent stop signal");
        } catch(InterruptedException e) {
            LOG.fatal("Interrupted while sending stop signal to bookie handle");
        }      
    }
View Full Code Here
546
547
548
549
550
551
552
553
554
            zk.setData(closePath,
                last.array(), -1);
        }
        lh.close();
        for(QuorumEngine qe : engines.values()){
          StopOp sOp = new StopOp();
          qe.sendOp(sOp);
        }
    }
View Full Code Here
1021
1022
1023
1024
1025
1026
1027
1028
1029
1030
1031
            break;
        case 2:  
            LedgerHandle lh = clop.getLh();
            try{
                lh.closeUp();
                StopOp sOp = new StopOp();
                lh.getQuorumEngine().sendOp(sOp);

            } catch(Exception e) {
                LOG.warn("Exception while stopping quorum engine: " + lh.getId());
            }
View Full Code Here
648
649
650
651
652
653
654
655
656
                   Ids.OPEN_ACL_UNSAFE,
                   CreateMode.PERSISTENT);
        }
       
        closeUp();
        StopOp sOp = new StopOp();
        qe.sendOp(sOp);
        LOG.info("##### CB worker queue size: " + qe.cbWorker.pendingOps.size());
    }
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
   
    private synchronized void sendStop(){
        try{
            noreception = true;
            LOG.debug("Sending stop signal");
            incomingQueue.put(new ToSend(null, new SubStopOp(new StopOp()), -1));
            LOG.debug("Sent stop signal");
        } catch(InterruptedException e) {
            LOG.fatal("Interrupted while sending stop signal to bookie handle");
        }      
    }
View Full Code Here
TOP

Related Classes of org.apache.bookkeeper.client.QuorumEngine.Operation.StopOp

  • org.apache.bookkeeper.client.BookieHandle
  • org.apache.bookkeeper.client.BookKeeper
  • org.apache.bookkeeper.client.LedgerHandle
  • org.apache.bookkeeper.client.LedgerManagementProcessor
    • Copyright © 2018 www.massapicom. 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.