Examples of MemoryManager

com.sun.messaging.jmq.jmsserver.util.memory.MemoryManager
class which handles the broker memory management
eu.stratosphere.nephele.services.memorymanager.MemoryManager
Interface for a memory manager that assigns portions of memory to different tasks. Each allocated segment of memory is specific to a task. Memory segments can be freed individually, or all memory allocated by a task can be freed as a whole.
Internally, memory is represented as byte arrays. The memory manager acts like a distributer for memory, which means it assigns portions of the arrays to tasks. If memory is released, it means that this part of the memory can be assigned to other tasks.
jnr.ffi.provider.MemoryManager
Manages access to various types of java and native memory.
org.apache.flink.runtime.memorymanager.MemoryManager
Interface for a memory manager that assigns portions of memory to different tasks. Each allocated segment of memory is specific to a task. Memory segments can be freed individually, or all memory allocated by a task can be freed as a whole.
Internally, memory is represented as byte arrays. The memory manager acts like a distributer for memory, which means it assigns portions of the arrays to tasks. If memory is released, it means that this part of the memory can be assigned to other tasks.
org.apache.phoenix.memory.MemoryManager
Memory manager used to track memory usage. Either throttles memory usage by blocking when the max memory is reached or allocates up to a maximum without blocking. @since 0.1
org.glassfish.grizzly.memory.MemoryManager
MemoryManager, responsible for allocating and releasing memory, required during application runtime. MemoryManager implementations work with Grizzly {@link Buffer}s. @see Buffer @author Alexey Stashok
org.hornetq.core.server.MemoryManager
A memory usage watcher.
This class will run a thread monitoring memory usage and log warnings in case we are low on memory. @author Tim Fox

Examples of org.apache.flink.runtime.memorymanager.MemoryManager

      UnilateralSortMerger<String> sorter = null;
      BufferedReader reader = null;
      BufferedReader verifyReader = null;
      
      try {
        MemoryManager mm = new DefaultMemoryManager(1024 * 1024, 1);
        IOManager ioMan = new IOManager();
          
        TypeSerializer<String> serializer = StringSerializer.INSTANCE;
        TypeComparator<String> comparator = new StringComparator(true);

View Full Code Here

Examples of org.apache.flink.runtime.memorymanager.MemoryManager

      UnilateralSortMerger<Tuple2<String, String[]>> sorter = null;
      BufferedReader reader = null;
      BufferedReader verifyReader = null;
      
      try {
        MemoryManager mm = new DefaultMemoryManager(1024 * 1024, 1);
        IOManager ioMan = new IOManager();
          
        TupleTypeInfo<Tuple2<String, String[]>> typeInfo = (TupleTypeInfo<Tuple2<String, String[]>>) (TupleTypeInfo<?>) TypeInfoParser.parse("Tuple2<String, String[]>");


        TypeSerializer<Tuple2<String, String[]>> serializer = typeInfo.createSerializer();

View Full Code Here

Examples of org.apache.phoenix.memory.MemoryManager

        Tuple[] expectedResults = new Tuple[] {
                new SingleKeyValueTuple(new KeyValue(A, SINGLE_COLUMN_FAMILY, SINGLE_COLUMN, Bytes.toBytes(1))),
                new SingleKeyValueTuple(new KeyValue(B, SINGLE_COLUMN_FAMILY, SINGLE_COLUMN, Bytes.toBytes(1))),
            };


        MemoryManager memoryManager = new DelegatingMemoryManager(new GlobalMemoryManager(threshold, 0));
        ResultIterator scanner = new SpoolingResultIterator(iterator, memoryManager, threshold, maxSizeSpool);
        AssertResults.assertResults(scanner, expectedResults);
    }

View Full Code Here

Examples of org.glassfish.grizzly.memory.MemoryManager

        final AtomicInteger counter = new AtomicInteger();
        
        return new ThreadFactory() {
            @Override
            public Thread newThread(Runnable r) {
                final MemoryManager mm = config.getMemoryManager();
                final ThreadLocalPoolProvider threadLocalPoolProvider;
                
                if (mm instanceof ThreadLocalPoolProvider) {
                    threadLocalPoolProvider = (ThreadLocalPoolProvider) mm;
                } else {

View Full Code Here

Examples of org.glassfish.grizzly.memory.MemoryManager

    }


    public static Buffer allocateAndReadBuffer(final TCPNIOConnection connection)
            throws IOException {
        
        final MemoryManager memoryManager =
                connection.getTransport().getMemoryManager();
        
        int read;
        Throwable error = null;
        Buffer buffer = null;
        
        try {
            final int receiveBufferSize =
                    Math.min(TCPNIOTransport.MAX_RECEIVE_BUFFER_SIZE,
                            connection.getReadBufferSize());
        
            if (!memoryManager.willAllocateDirect(receiveBufferSize)) {
                final DirectByteBufferRecord ioRecord = 
                        DirectByteBufferRecord.get();
                final ByteBuffer directByteBuffer =
                        ioRecord.allocate(receiveBufferSize);
                
                try {
                    read = readSimpleByteBuffer(connection, directByteBuffer);
                    if (read > 0) {
                        directByteBuffer.flip();
                        buffer = memoryManager.allocate(read);
                        buffer.put(directByteBuffer);
                    }
                } finally {
                    ioRecord.release();
                }
            } else {
                buffer = memoryManager.allocateAtLeast(receiveBufferSize);
                read = readBuffer(connection, buffer);
            }
        } catch (Throwable e) {
            error = e;
            read = -1;

View Full Code Here

Examples of org.glassfish.grizzly.memory.MemoryManager

        return new SslResult(output, sslEngineResult);
    }


    Buffer wrapAll(final Buffer input,
            final Allocator allocator) throws SSLException {
        final MemoryManager memoryManager =
                connection.getTransport().getMemoryManager();
        
        final ByteBufferArray bba =
                input.toByteBufferArray(inputByteBufferArray);
        final ByteBuffer[] inputArray = bba.getArray();

View Full Code Here

Examples of org.glassfish.grizzly.memory.MemoryManager

    }




    @Override
    protected TransformationResult<Buffer, Buffer> transformImpl(AttributeStorage storage, Buffer input) throws TransformationException {
        final MemoryManager memoryManager = obtainMemoryManager(storage);
        final LZMAOutputState state = (LZMAOutputState) obtainStateObject(storage);


        if (!state.isInitialized()) {
            initializeOutput(state);
        }

View Full Code Here

Examples of org.glassfish.grizzly.memory.MemoryManager

        return input.hasRemaining();
    }


    @Override
    protected TransformationResult<Buffer, Buffer> transformImpl(AttributeStorage storage, Buffer input) throws TransformationException {
        final MemoryManager memoryManager = obtainMemoryManager(storage);


        final LZMAInputState state = (LZMAInputState) obtainStateObject(storage);
        state.setMemoryManager(memoryManager);


        Buffer decodedBuffer = null;

View Full Code Here

Examples of org.glassfish.grizzly.memory.MemoryManager

    }


    @Override
    protected TransformationResult<Buffer, Buffer> transformImpl(
            AttributeStorage storage, Buffer input) throws TransformationException {
        final MemoryManager memoryManager = obtainMemoryManager(storage);


        final GZipInputState state = (GZipInputState) obtainStateObject(storage);


        if (!state.isInitialized()) {
            if (!initializeInput(input, state)) {

View Full Code Here

Examples of org.glassfish.grizzly.memory.MemoryManager

     */
    @Override
    protected TransformationResult<Buffer, Buffer> transformImpl(
            AttributeStorage storage, Buffer input) throws TransformationException {


        final MemoryManager memoryManager = obtainMemoryManager(storage);
        final GZipOutputState state = (GZipOutputState) obtainStateObject(storage);


        if (!state.isInitialized) {
            state.initialize();
        }

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.