org.neo4j.com

Class Server<T,R>

java.lang.Object

org.jboss.netty.channel.SimpleChannelHandler

org.neo4j.com.Server<T,R>

All Implemented Interfaces:

org.jboss.netty.channel.ChannelDownstreamHandler, org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelPipelineFactory, org.jboss.netty.channel.ChannelUpstreamHandler, ChannelCloser, org.neo4j.kernel.lifecycle.Lifecycle

public abstract class Server<T,R>
extends org.jboss.netty.channel.SimpleChannelHandler
implements org.jboss.netty.channel.ChannelPipelineFactory, org.neo4j.kernel.lifecycle.Lifecycle, ChannelCloser

Receives requests from clients. Delegates actual work to an instance of a specified communication interface, injected in the constructor.

frameLength vs. chunkSize: frameLength is the maximum and hardcoded size in each Netty buffer created by this server and handed off to a Client. If the client has got a smaller frameLength than this server it will fail on reading a frame that is bigger than what its frameLength. chunkSize is the max size a buffer will have before it's sent off and a new buffer allocated to continue writing to. frameLength should be a constant for an implementation and must have the same value on server as well as clients connecting to that server, whereas chunkSize very well can be configurable and vary between server and client.

See Also:

Client

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Server.Configuration

Nested classes/interfaces inherited from interface org.neo4j.kernel.lifecycle.Lifecycle

org.neo4j.kernel.lifecycle.Lifecycle.Delegate

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

org.jboss.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAX_NUMBER_OF_CONCURRENT_TRANSACTIONS

Constructor Summary

Constructors

Constructor and Description
Server(T requestTarget, Server.Configuration config, org.neo4j.logging.LogProvider logProvider, int frameLength, ProtocolVersion protocolVersion, TxChecksumVerifier txVerifier, Clock clock, org.neo4j.kernel.monitoring.ByteCounterMonitor byteCounterMonitor, RequestMonitor requestMonitor)

Method Summary

Modifier and Type	Method and Description
void	channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e)
void	channelDisconnected(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e)
void	channelOpen(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ChannelStateEvent e)
void	exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.ExceptionEvent e)
org.jboss.netty.channel.ChannelPipeline	getPipeline()
InetSocketAddress	getSocketAddress()
void	init()
void	messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.MessageEvent event)
void	shutdown()
void	start()
void	stop()
void	tryToCloseChannel(org.jboss.netty.channel.Channel channel)
void	writeComplete(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.WriteCompletionEvent e)

Methods inherited from class org.jboss.netty.channel.SimpleChannelHandler

bindRequested, channelBound, channelConnected, channelInterestChanged, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, handleDownstream, handleUpstream, setInterestOpsRequested, unbindRequested, writeRequested

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAX_NUMBER_OF_CONCURRENT_TRANSACTIONS

public static final int DEFAULT_MAX_NUMBER_OF_CONCURRENT_TRANSACTIONS

See Also:

Constant Field Values

Constructor Detail

Server

public Server(T requestTarget,
              Server.Configuration config,
              org.neo4j.logging.LogProvider logProvider,
              int frameLength,
              ProtocolVersion protocolVersion,
              TxChecksumVerifier txVerifier,
              Clock clock,
              org.neo4j.kernel.monitoring.ByteCounterMonitor byteCounterMonitor,
              RequestMonitor requestMonitor)

Method Detail

init

public void init()
          throws Throwable

Specified by:

init in interface org.neo4j.kernel.lifecycle.Lifecycle

Throws:

Throwable

start

public void start()
           throws Throwable

Specified by:

start in interface org.neo4j.kernel.lifecycle.Lifecycle

Throws:

Throwable

stop

public void stop()
          throws Throwable

Specified by:

stop in interface org.neo4j.kernel.lifecycle.Lifecycle

Throws:

Throwable

shutdown

public void shutdown()
              throws Throwable

Specified by:

shutdown in interface org.neo4j.kernel.lifecycle.Lifecycle

Throws:

Throwable

getSocketAddress

public InetSocketAddress getSocketAddress()

getPipeline

public org.jboss.netty.channel.ChannelPipeline getPipeline()
                                                    throws Exception

Specified by:

getPipeline in interface org.jboss.netty.channel.ChannelPipelineFactory

Throws:

Exception

channelOpen

public void channelOpen(org.jboss.netty.channel.ChannelHandlerContext ctx,
                        org.jboss.netty.channel.ChannelStateEvent e)
                 throws Exception

Overrides:

channelOpen in class org.jboss.netty.channel.SimpleChannelHandler

Throws:

Exception

messageReceived

public void messageReceived(org.jboss.netty.channel.ChannelHandlerContext ctx,
                            org.jboss.netty.channel.MessageEvent event)
                     throws Exception

Overrides:

messageReceived in class org.jboss.netty.channel.SimpleChannelHandler

Throws:

Exception

writeComplete

public void writeComplete(org.jboss.netty.channel.ChannelHandlerContext ctx,
                          org.jboss.netty.channel.WriteCompletionEvent e)
                   throws Exception

Overrides:

writeComplete in class org.jboss.netty.channel.SimpleChannelHandler

Throws:

Exception

channelClosed

public void channelClosed(org.jboss.netty.channel.ChannelHandlerContext ctx,
                          org.jboss.netty.channel.ChannelStateEvent e)
                   throws Exception

Overrides:

channelClosed in class org.jboss.netty.channel.SimpleChannelHandler

Throws:

Exception

channelDisconnected

public void channelDisconnected(org.jboss.netty.channel.ChannelHandlerContext ctx,
                                org.jboss.netty.channel.ChannelStateEvent e)
                         throws Exception

Overrides:

channelDisconnected in class org.jboss.netty.channel.SimpleChannelHandler

Throws:

Exception

exceptionCaught

public void exceptionCaught(org.jboss.netty.channel.ChannelHandlerContext ctx,
                            org.jboss.netty.channel.ExceptionEvent e)
                     throws Exception

Overrides:

exceptionCaught in class org.jboss.netty.channel.SimpleChannelHandler

Throws:

Exception

tryToCloseChannel

public void tryToCloseChannel(org.jboss.netty.channel.Channel channel)

Specified by:

tryToCloseChannel in interface ChannelCloser