voldemort.server.rest
Class StorageExecutionHandler

java.lang.Object
  extended by org.jboss.netty.handler.execution.ExecutionHandler
      extended by voldemort.server.rest.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, StoreStats performanceStats, 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,
                               StoreStats performanceStats,
                               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()


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu