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.glassfish.grizzly.memory.MemoryManager

    @SuppressWarnings({ "unchecked" })
    public boolean doHandle(final FilterChainContext ctx, final Request request,
            final HttpRequestPacket requestPacket) throws IOException {


        final byte[] data = request.getByteData();
        final MemoryManager mm = ctx.getMemoryManager();
        final Buffer gBuffer = Buffers.wrap(mm, data);
        if (requestPacket.getContentLength() == -1) {
            requestPacket.setContentLengthLong(data.length);
        }
        final HttpContent content = requestPacket.httpContentBuilder()

View Full Code Here

Examples of org.glassfish.grizzly.memory.MemoryManager

        String charset = request.getBodyEncoding();
        if (charset == null) {
            charset = Charsets.ASCII_CHARSET.name();
        }
        final byte[] data = request.getStringData().getBytes(charset);
        final MemoryManager mm = ctx.getMemoryManager();
        final Buffer gBuffer = Buffers.wrap(mm, data);
        if (requestPacket.getContentLength() == -1) {
            requestPacket.setContentLengthLong(data.length);
        }
        final HttpContent content = requestPacket.httpContentBuilder()

View Full Code Here

Examples of org.glassfish.grizzly.memory.MemoryManager

        generator.setFeeder(new FeedableBodyGenerator.BaseFeeder(generator) {
            @Override
            public void flush() throws IOException {
                final Body bodyLocal = feedableBodyGenerator.createBody();
                try {
                    final MemoryManager mm = ctx.getMemoryManager();
                    boolean last = false;
                    while (!last) {
                        Buffer buffer = mm.allocate(BodyHandler.MAX_CHUNK_SIZE);
                        buffer.allowBufferDispose(true);
                        final long readBytes = bodyLocal.read(buffer.toByteBuffer());
                        if (readBytes > 0) {
                            buffer.position((int) readBytes);
                            buffer.trim();

View Full Code Here

Examples of org.glassfish.grizzly.memory.MemoryManager

            requestPacket.setContentLengthLong(len);
        } else {
            requestPacket.setChunked(true);
        }


        final MemoryManager mm = ctx.getMemoryManager();
        boolean last = false;


        while (!last) {
            Buffer buffer = mm.allocate(MAX_CHUNK_SIZE);
            buffer.allowBufferDispose(true);


            final long readBytes = bodyLocal.read(buffer.toByteBuffer());
            if (readBytes > 0) {
                buffer.position((int) readBytes);

View Full Code Here

Examples of org.hornetq.core.server.MemoryManager


      managementService = new ManagementServiceImpl(mbeanServer, configuration);


      if (configuration.getMemoryMeasureInterval() != -1)
      {
         memoryManager = new MemoryManager(configuration.getMemoryWarningThreshold(),
            configuration.getMemoryMeasureInterval());


         memoryManager.start();
      }

View Full Code Here

Examples of org.hornetq.core.server.MemoryManager


      managementService = new ManagementServiceImpl(mbeanServer, configuration);


      if (configuration.getMemoryMeasureInterval() != -1)
      {
         memoryManager = new MemoryManager(configuration.getMemoryWarningThreshold(),
            configuration.getMemoryMeasureInterval());


         memoryManager.start();
      }

View Full Code Here

Examples of org.hornetq.core.server.MemoryManager


      managementService = new ManagementServiceImpl(mbeanServer, configuration);


      if (configuration.getMemoryMeasureInterval() != -1)
      {
         memoryManager = new MemoryManager(configuration.getMemoryWarningThreshold(),
            configuration.getMemoryMeasureInterval());


         memoryManager.start();
      }

View Full Code Here

Examples of org.hornetq.core.server.MemoryManager


      managementService = new ManagementServiceImpl(mbeanServer, configuration);


      if (configuration.getMemoryMeasureInterval() != -1)
      {
         memoryManager = new MemoryManager(configuration.getMemoryWarningThreshold(),
            configuration.getMemoryMeasureInterval());


         memoryManager.start();
      }

View Full Code Here

Examples of org.hornetq.core.server.MemoryManager


      managementService = new ManagementServiceImpl(mbeanServer, configuration);


      if (configuration.getMemoryMeasureInterval() != -1)
      {
         memoryManager = new MemoryManager(configuration.getMemoryWarningThreshold(),
            configuration.getMemoryMeasureInterval());


         memoryManager.start();
      }

View Full Code Here

Examples of org.hornetq.core.server.MemoryManager


      managementService = new ManagementServiceImpl(mbeanServer, configuration);


      if (configuration.getMemoryMeasureInterval() != -1)
      {
         memoryManager = new MemoryManager(configuration.getMemoryWarningThreshold(),
            configuration.getMemoryMeasureInterval());


         memoryManager.start();
      }

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.