voldemort.rest.server
Class StorageExecutionHandler

java.lang.Object
  org.jboss.netty.handler.execution.ExecutionHandler
      voldemort.rest.server.StorageExecutionHandler

All Implemented Interfaces:

org.jboss.netty.channel.ChannelDownstreamHandler, org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler, org.jboss.netty.util.ExternalResourceReleasable

public class StorageExecutionHandler
extends org.jboss.netty.handler.execution.ExecutionHandler

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler

org.jboss.netty.channel.ChannelHandler.Sharable

Constructor Summary

StorageExecutionHandler(java.util.concurrent.Executor executor, java.util.concurrent.ConcurrentHashMap<java.lang.String,StoreStats> storeStatsMap, StoreStats aggregateStoreStats, boolean isJmxEnabled, int localZoneId)

Method Summary

int	getActiveThreadsInWorkerPool()
int	getAllThreadInWorkerPool()
int	getQueuSize()
void	handleUpstream(org.jboss.netty.channel.ChannelHandlerContext context, org.jboss.netty.channel.ChannelEvent channelEvent)

Methods inherited from class org.jboss.netty.handler.execution.ExecutionHandler

getExecutor, handleDownstream, handleReadSuspend, releaseExternalResources

Methods inherited from class java.lang.Object

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

Constructor Detail

StorageExecutionHandler

public StorageExecutionHandler(java.util.concurrent.Executor executor,
                               java.util.concurrent.ConcurrentHashMap<java.lang.String,StoreStats> storeStatsMap,
                               StoreStats aggregateStoreStats,
                               boolean isJmxEnabled,
                               int localZoneId)

Method Detail

handleUpstream

public void handleUpstream(org.jboss.netty.channel.ChannelHandlerContext context,
                           org.jboss.netty.channel.ChannelEvent channelEvent)
                    throws java.lang.Exception

Specified by:

handleUpstream in interface org.jboss.netty.channel.ChannelUpstreamHandler

Overrides:

handleUpstream in class org.jboss.netty.handler.execution.ExecutionHandler

Throws:

java.lang.Exception

getQueuSize

public int getQueuSize()

getActiveThreadsInWorkerPool

public int getActiveThreadsInWorkerPool()

getAllThreadInWorkerPool

public int getAllThreadInWorkerPool()