Examples of voldemort.store.nonblockingstore.NonblockingStoreCallback

Package voldemort.store.nonblockingstore

Examples of voldemort.store.nonblockingstore.NonblockingStoreCallback

voldemort.store.nonblockingstore.NonblockingStoreCallback
A NonblockingStoreCallback is provided as an argument to the submit methods of the {@link NonblockingStore} API. When the response from the request isreceived, the {@link #requestComplete} method is invoked with the result ofthe request and the time (in milliseconds) it took between issuing the request and receiving the response. @see NonblockingStore


        for (Map.Entry<Node, List<ByteArray>> entry: pipelineData.getNodeToKeysMap().entrySet()) {
            final Node node = entry.getKey();
            final Collection<ByteArray> keys = entry.getValue();


            NonblockingStoreCallback callback = new NonblockingStoreCallback() {


                public void requestComplete(Object result, long requestTime) {
                    if (logger.isTraceEnabled())
                        logger.trace(pipeline.getOperation().getSimpleName()
                                     + " response received (" + requestTime + " ms.) from node "

View Full Code Here


        for(int i = 0; i < attempts; i++) {
            final Node node = nodes.get(i);
            pipelineData.incrementNodeIndex();


            NonblockingStoreCallback callback = new NonblockingStoreCallback() {


                public void requestComplete(Object result, long requestTime) {
                    if(logger.isTraceEnabled())
                        logger.trace(pipeline.getOperation().getSimpleName()
                                     + " response received (" + requestTime + " ms.) from node "

View Full Code Here

        // initiate parallel puts
        for(int i = numNodesTouchedInSerialPut; i < nodes.size(); i++) {
            final Node node = nodes.get(i);
            pipelineData.incrementNodeIndex();


            NonblockingStoreCallback callback = new NonblockingStoreCallback() {


                @Override
                public void requestComplete(Object result, long requestTime) {
                    boolean responseHandledByMaster = false;
                    if(logger.isDebugEnabled())

View Full Code Here

            final Node node = nodes.get(i);
            pipelineData.incrementNodeIndex();


            final long startMs = logger.isDebugEnabled() ? System.currentTimeMillis() : -1;


            NonblockingStoreCallback callback = new NonblockingStoreCallback() {


                public void requestComplete(Object result, long requestTime) {
                    if (logger.isTraceEnabled())
                        logger.trace(pipeline.getOperation().getSimpleName()
                                     + " response received (" + requestTime + " ms.) from node "

View Full Code Here


        NonblockingStore nonblockingStore = nonblockingSlopStores.get(nodeId);
        Utils.notNull(nonblockingStore);


        final Long startNs = System.nanoTime();
        NonblockingStoreCallback callback = new NonblockingStoreCallback() {


            @Override
            public void requestComplete(Object result, long requestTime) {
                Slop slop = null;
                boolean loggerDebugEnabled = logger.isDebugEnabled();

View Full Code Here

TOP

Related Classes of voldemort.store.nonblockingstore.NonblockingStoreCallback

voldemort.store.routed.action.PerformParallelDeleteRequests

voldemort.store.routed.action.PerformParallelGetAllRequests

voldemort.store.routed.action.PerformParallelPutRequests

voldemort.store.routed.action.PerformParallelRequests

voldemort.store.slop.HintedHandoff

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.