Examples of voldemort.store.InsufficientZoneResponsesException

voldemort.store.InsufficientZoneResponsesException
Thrown if an operation fails due to too few reachable nodes.


        int zonesSatisfied = pipelineData.getZoneResponses().size();
        if(zonesSatisfied >= (pipelineData.getZonesRequired() + 1)) {
            pipeline.addEvent(completeEvent);
        } else {
            pipelineData.setFatalError(new InsufficientZoneResponsesException((pipelineData.getZonesRequired() + 1)
                                                                              + " "
                                                                              + pipeline.getOperation()
                                                                                        .getSimpleName()
                                                                              + "s required zone, but only "
                                                                              + zonesSatisfied

View Full Code Here


                    int zonesSatisfied = pipelineData.getZoneResponses().size();
                    if(zonesSatisfied >= (pipelineData.getZonesRequired() + 1)) {
                        pipeline.addEvent(completeEvent);
                    } else {
                        pipelineData.setFatalError(new InsufficientZoneResponsesException((pipelineData.getZonesRequired() + 1)
                                                                                          + " "
                                                                                          + pipeline.getOperation()
                                                                                                    .getSimpleName()
                                                                                          + "s required zone, but only "
                                                                                          + zonesSatisfied

View Full Code Here

                    }


                    if(pipelineData.getZoneResponses().size() >= (pipelineData.getZonesRequired() + 1)) {
                        completePipeline(pipeline);
                    } else {
                        pipelineData.setFatalError(new InsufficientZoneResponsesException((pipelineData.getZonesRequired() + 1)
                                                                                          + " "
                                                                                          + pipeline.getOperation()
                                                                                                    .getSimpleName()
                                                                                          + "s required zone, but only "
                                                                                          + zonesSatisfied

View Full Code Here

                        logger.debug("PUT {key:" + key
                                     + "} failed due to insufficient zones. required="
                                     + pipelineData.getZonesRequired() + 1 + " success="
                                     + pipelineData.getZoneResponses().size());
                    }
                    fatalError = new InsufficientZoneResponsesException((pipelineData.getZonesRequired() + 1)
                                                                        + " "
                                                                        + pipeline.getOperation()
                                                                                  .getSimpleName()
                                                                        + "s required zone, but only "
                                                                        + (pipelineData.getZoneResponses().size())

View Full Code Here

                    // 'zoneCountReads' zones>, <nodes from local zone>, <nodes
                    // from remote zone1>, <nodes from remote zone2>,...
                    // #preferred number of reads may not be able to satisfy
                    // zoneCountReads, if the original read to a remote node
                    // fails in the parallel stage
                    pipelineData.setFatalError(new InsufficientZoneResponsesException((pipelineData.getZonesRequired() + 1)
                                                                                      + " "
                                                                                      + pipeline.getOperation()
                                                                                                .getSimpleName()
                                                                                      + "s required zone, but only "
                                                                                      + zonesSatisfied

View Full Code Here

                                     + " for key " + key);
                    }
                    if (this.insufficientZonesEvent != null) {
                        pipeline.addEvent(this.insufficientZonesEvent);
                    } else {
                        pipelineData.setFatalError(new InsufficientZoneResponsesException((pipelineData.getZonesRequired() + 1)
                                                                                          + " "
                                                                                          + pipeline.getOperation()
                                                                                                    .getSimpleName()
                                                                                          + "s required zone, but only "
                                                                                          + zonesSatisfied

View Full Code Here

TOP

Related Classes of voldemort.store.InsufficientZoneResponsesException

voldemort.store.routed.action.PerformParallelDeleteRequests

voldemort.store.routed.action.PerformParallelPutRequests

voldemort.store.routed.action.PerformParallelRequests

voldemort.store.routed.action.PerformSerialPutRequests

voldemort.store.routed.action.PerformSerialRequests

voldemort.store.routed.action.PerformZoneSerialRequests

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.