com.bigdata.service

Class ManagedResourceService

java.lang.Object

com.bigdata.service.ResourceService

com.bigdata.service.ManagedResourceService

public abstract class ManagedResourceService
extends ResourceService

This class manages a pool of direct ByteBuffers. The application can create which are exposed for retrieval by remote services.

Version:

$Id: ManagedResourceService.java 3515 2010-09-08 13:16:30Z thompsonbry $

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.service.ResourceService

ResourceService.Counters, ResourceService.FetchResourceTask<S,T>, ResourceService.ReadBufferTask, ResourceService.ReadResourceTask, ResourceService.ResourceTypeEnum, ResourceService.StatusEnum

Field Summary

Fields inherited from class com.bigdata.service.ResourceService

counters, log

Constructor Summary

Constructors

Constructor and Description
ManagedResourceService(InetSocketAddress addr, int requestServicePoolSize) Create and start the service.

Method Summary

Methods

Modifier and Type	Method and Description
DirectBufferPoolAllocator	getAllocator() The object used to make, resolve, and release allocations against a DirectBufferPool.
protected ByteBuffer	getBuffer(UUID uuid) Return ByteBuffer identified by the UUID.
void	shutdown()
void	shutdownNow()

Methods inherited from class com.bigdata.service.ResourceService

awaitRunning, finalize, getAddr, getResource, isOpen

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ManagedResourceService

public ManagedResourceService(InetSocketAddress addr,
                      int requestServicePoolSize)
                       throws IOException

Create and start the service.

Parameters:

addr - The IP address and port at which the service will accept connections. The port MAY be zero to use an ephemeral port.

requestServicePoolSize - The size of the thread pool that will handle requests. When ZERO (0) a cached thread pool will be used with no specific size limit.

Throws:

IOException

Method Detail

getAllocator

public DirectBufferPoolAllocator getAllocator()

The object used to make, resolve, and release allocations against a DirectBufferPool.

shutdown

public void shutdown()

Overrides:

shutdown in class ResourceService

shutdownNow

public void shutdownNow()

Overrides:

shutdownNow in class ResourceService

getBuffer

protected ByteBuffer getBuffer(UUID uuid)
                        throws Exception

Return ByteBuffer identified by the UUID.

Specified by:

getBuffer in class ResourceService

Returns:

The ByteBuffer -or- null if there is no buffer associated with that UUID.

Throws:

Exception - if the resource may not be served.