List of total() Examples

Examples of total()

com.esotericsoftware.kryo.io.Output.total()
Returns the total number of bytes written. This may include bytes that have not been flushed.
com.googlecode.javacv.cpp.opencv_core.CvSeq.total()
er.grouping.DRValue.total()
freenet.node.RequestTracker.CountedRequests.total()
io.fabric8.utils.CountingMap.total()
Returns the total of all counters
net.tomp2p.message.CountConnectionOutboundHandler.total()
org.apache.cassandra.db.context.CounterContext.total()
Returns the aggregated count across all node ids. @param context a counter context @return the aggregated count represented by {@code context}
org.apache.hadoop.chukwa.datacollection.sender.RetryListOfCollectors.total()
@return total number of collectors in list
org.elasticsearch.search.facet.statistical.StatisticalFacet.total()
The total (sum) of values.
org.jboss.aerogear.controller.router.rest.pagination.PaginationProperties.total()
org.locationtech.geogig.remote.BinaryPackedObjects.IngestResults.total()
org.sonar.wsclient.base.Paging.total()
prevaylerjr.tests.somador.Somador.total()

Examples of org.apache.cassandra.db.context.CounterContext.total()

        catch (RuntimeException e) {}


        NodeId.renewLocalId();
        ByteBuffer merger = ctx.computeOldShardMerger(state.context, Collections.<NodeId.NodeIdRecord>emptyList(), 0);
        ByteBuffer cleaned = ctx.removeOldShards(ctx.merge(state.context, merger), now);
        assert ctx.total(cleaned) == 11;


        // Check it is not corrupted anymore
        ContextState state2 = new ContextState(cleaned);
        while (state2.hasRemaining())
        {

View Full Code Here

Examples of org.apache.cassandra.db.context.CounterContext.total()

            state2.moveToNext();
        }


        // Check that if we merge old and clean on another node, we keep the right count
        ByteBuffer onRemote = ctx.merge(ctx.clearAllDelta(state.context), ctx.clearAllDelta(cleaned));
        assert ctx.total(onRemote) == 11;
    }
}

View Full Code Here

Examples of org.apache.cassandra.db.context.CounterContext.total()

        ContextState state = ContextState.allocate(3, 2);
        state.writeElement(CounterId.fromInt(1), 1, 4, false);
        state.writeElement(id1, 3, 2, true);
        state.writeElement(id2, -100, 5, true); // corrupted!


        assert ctx.total(state.context) == 11;


        try
        {
            ByteBuffer merger = ctx.computeOldShardMerger(state.context, Collections.<CounterId.CounterIdRecord>emptyList(), 0);
            ctx.removeOldShards(ctx.merge(state.context, merger, HeapAllocator.instance), now);

View Full Code Here

Examples of org.apache.cassandra.db.context.CounterContext.total()

        catch (RuntimeException e) {}


        CounterId.renewLocalId();
        ByteBuffer merger = ctx.computeOldShardMerger(state.context, Collections.<CounterId.CounterIdRecord>emptyList(), 0);
        ByteBuffer cleaned = ctx.removeOldShards(ctx.merge(state.context, merger, HeapAllocator.instance), now);
        assert ctx.total(cleaned) == 11;


        // Check it is not corrupted anymore
        ContextState state2 = new ContextState(cleaned);
        while (state2.hasRemaining())
        {

View Full Code Here

Examples of org.apache.cassandra.db.context.CounterContext.total()

            state2.moveToNext();
        }


        // Check that if we merge old and clean on another node, we keep the right count
        ByteBuffer onRemote = ctx.merge(ctx.clearAllDelta(state.context), ctx.clearAllDelta(cleaned), HeapAllocator.instance);
        assert ctx.total(onRemote) == 11;
    }
}

View Full Code Here

Examples of org.apache.cassandra.db.context.CounterContext.total()

        ContextState state = ContextState.allocate(3, 2);
        state.writeElement(NodeId.fromInt(1), 1, 4, false);
        state.writeElement(id1, 3, 2, true);
        state.writeElement(id2, -100, 5, true); // corrupted!


        assert ctx.total(state.context) == 11;


        try
        {
            ByteBuffer merger = ctx.computeOldShardMerger(state.context, Collections.<NodeId.NodeIdRecord>emptyList(), 0);
            ctx.removeOldShards(ctx.merge(state.context, merger, HeapAllocator.instance), now);

View Full Code Here

Examples of org.apache.cassandra.db.context.CounterContext.total()

        catch (RuntimeException e) {}


        NodeId.renewLocalId();
        ByteBuffer merger = ctx.computeOldShardMerger(state.context, Collections.<NodeId.NodeIdRecord>emptyList(), 0);
        ByteBuffer cleaned = ctx.removeOldShards(ctx.merge(state.context, merger, HeapAllocator.instance), now);
        assert ctx.total(cleaned) == 11;


        // Check it is not corrupted anymore
        ContextState state2 = new ContextState(cleaned);
        while (state2.hasRemaining())
        {

View Full Code Here

Examples of org.apache.cassandra.db.context.CounterContext.total()

            state2.moveToNext();
        }


        // Check that if we merge old and clean on another node, we keep the right count
        ByteBuffer onRemote = ctx.merge(ctx.clearAllDelta(state.context), ctx.clearAllDelta(cleaned), HeapAllocator.instance);
        assert ctx.total(onRemote) == 11;
    }
}

View Full Code Here

Examples of org.apache.cassandra.db.context.CounterContext.total()

        ContextState state = ContextState.allocate(3, 2);
        state.writeElement(CounterId.fromInt(1), 1, 4, false);
        state.writeElement(id1, 3, 2, true);
        state.writeElement(id2, -100, 5, true); // corrupted!


        assert ctx.total(state.context) == 11;


        try
        {
            ByteBuffer merger = ctx.computeOldShardMerger(state.context, Collections.<CounterId.CounterIdRecord>emptyList(), 0);
            ctx.removeOldShards(ctx.merge(state.context, merger, HeapAllocator.instance), now);

View Full Code Here

Examples of org.apache.cassandra.db.context.CounterContext.total()

        catch (RuntimeException e) {}


        CounterId.renewLocalId();
        ByteBuffer merger = ctx.computeOldShardMerger(state.context, Collections.<CounterId.CounterIdRecord>emptyList(), 0);
        ByteBuffer cleaned = ctx.removeOldShards(ctx.merge(state.context, merger, HeapAllocator.instance), now);
        assert ctx.total(cleaned) == 11;


        // Check it is not corrupted anymore
        ContextState state2 = new ContextState(cleaned);
        while (state2.hasRemaining())
        {

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.