public class ReplicaServerHandler
extends org.jboss.netty.channel.SimpleChannelUpstreamHandler
Modifier and Type | Field and Description |
---|---|
protected int |
freq |
protected int |
maxQueue |
protected int |
maxThreads |
protected Utils.ServerState |
serverState |
protected Executor |
threadPools |
Constructor and Description |
---|
ReplicaServerHandler() |
ReplicaServerHandler(Map<String,voldemort.store.cachestore.impl.CacheStore> storeMap) |
ReplicaServerHandler(Map<String,voldemort.store.cachestore.impl.CacheStore> storeMap,
int maxThreads) |
Modifier and Type | Method and Description |
---|---|
void |
exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ExceptionEvent e) |
int |
getFreq() |
void |
handleUpstream(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.ChannelEvent e) |
void |
messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
org.jboss.netty.channel.MessageEvent e) |
void |
processParaList(Request req,
org.jboss.netty.channel.ChannelHandlerContext ctx) |
protected void |
processRequest(voldemort.store.cachestore.impl.CacheStore store,
StoreParas paras) |
protected void |
setError(ParaList paraList,
String message) |
void |
setFreq(int freq) |
void |
shutdown() |
protected Utils.ServerState serverState
protected int freq
protected int maxThreads
protected int maxQueue
protected Executor threadPools
public ReplicaServerHandler()
public ReplicaServerHandler(Map<String,voldemort.store.cachestore.impl.CacheStore> storeMap)
public void shutdown()
public void handleUpstream(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelEvent e) throws Exception
handleUpstream
in interface org.jboss.netty.channel.ChannelUpstreamHandler
handleUpstream
in class org.jboss.netty.channel.SimpleChannelUpstreamHandler
Exception
public int getFreq()
public void setFreq(int freq)
public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent e)
messageReceived
in class org.jboss.netty.channel.SimpleChannelUpstreamHandler
public void processParaList(Request req, org.jboss.netty.channel.ChannelHandlerContext ctx)
public void exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ExceptionEvent e)
exceptionCaught
in class org.jboss.netty.channel.SimpleChannelUpstreamHandler
protected void processRequest(voldemort.store.cachestore.impl.CacheStore store, StoreParas paras)
Copyright © 2016. All rights reserved.