Examples of org.apache.cassandra.utils.concurrent.OpOrder

org.apache.cassandra.utils.concurrent.OpOrder

} public void consume() { SharedState state = this.state; state.setReplacement(new State()) state.doSomethingToPrepareForBarrier(); state.barrier = order.newBarrier(); // seal() MUST be called after newBarrier() else barrier.isAfter() // will always return true, and barrier.await() will fail state.barrier.issue(); // wait for all producer work started prior to the barrier to complete state.barrier.await(); // change the shared state to its replacement, as the current state will no longer be used by producers this.state = state.getReplacement(); state.doSomethingWithExclusiveAccess(); } public void produce() { Group opGroup = order.start(); try { SharedState s = state; while (s.barrier != null && !s.barrier.isAfter(opGroup)) s = s.getReplacement(); s.doProduceWork(); } finally { opGroup.finishOne(); } } }

    private static final Pool POOL = new HeapPool(Integer.MAX_VALUE, 1f, null);


    /** Allocates 1 byte from a new SlabAllocator and returns it. */
    private AbstractAllocator bumpedSlab()
    {
        AbstractAllocator allocator = POOL.newAllocator(new OpOrder());
        allocator.allocate(1);
        return allocator;
    }

    }


    private static int estimateRowOverhead(final int count)
    {
        // calculate row overhead
        final OpOrder.Group group = new OpOrder().start();
        int rowOverhead;
        MemtableAllocator allocator = MEMORY_POOL.newAllocator();
        ConcurrentNavigableMap<RowPosition, Object> rows = new ConcurrentSkipListMap<>();
        final Object val = new Object();
        for (int i = 0 ; i < count ; i++)

    }


    private static int estimateRowOverhead(final int count)
    {
        // calculate row overhead
        final OpOrder.Group group = new OpOrder().start();
        int rowOverhead;
        MemtableAllocator allocator = MEMORY_POOL.newAllocator();
        ConcurrentNavigableMap<RowPosition, Object> rows = new ConcurrentSkipListMap<>();
        final Object val = new Object();
        for (int i = 0 ; i < count ; i++)

Examples of org.apache.cassandra.utils.concurrent.OpOrder

Related Classes of org.apache.cassandra.utils.concurrent.OpOrder