Package one.nio.rpc

Class RpcSession<S,M>

java.lang.Object

one.nio.net.Session

one.nio.rpc.RpcSession<S,M>

All Implemented Interfaces:

Closeable, AutoCloseable

public class RpcSession<S,M>
extends Session

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	RpcSession.AsyncRequest

Nested classes/interfaces inherited from class one.nio.net.Session

Session.ArrayQueueItem, Session.QueueItem

Field Summary

Fields

Modifier and Type	Field	Description
protected byte[]	buffer
protected static final int	BUFFER_SIZE
protected int	bytesRead
protected static final byte	HTTP_REQUEST_UID
protected static final org.slf4j.Logger	logSerialize
protected InetSocketAddress	peer
protected boolean	proxyProtocol
protected int	requestSize
protected long	requestStartTime
protected final RpcServer<S>	server

Fields inherited from class one.nio.net.Session

ACTIVE, closing, CLOSING, EVENT_MASK, events, eventsToListen, IDLE, lastAccessTime, log, queueHead, READABLE, selector, slot, socket, SSL, STALE, wasSelected, WRITEABLE

Constructor Summary

Constructors

Constructor	Description
RpcSession(Socket socket, RpcServer<S> server)

Method Summary

Modifier and Type	Method	Description
private byte[]	expandBuffer(int requestSize)
protected void	handleDeserializationException(Exception e)
protected void	handleRejectedExecution(RejectedExecutionException e, Object request)
protected void	invoke(Object request, M meta)
protected boolean	isAsyncRequest(Object request)
protected M	onRequestRead()
private void	parseProxyProtocol()
protected void	processRead(byte[] unusedBuffer)
private int	readHttpHeader()
private static boolean	startsWith(byte[] buffer, int from, String s)
protected void	streamCommunicate(StreamProxy streamProxy)
protected int	writeResponse(Object response)

Methods inherited from class one.nio.net.Session

checkStatus, close, getQueueStats, getRemoteHost, handleException, isSsl, lastAccessTime, listen, process, processWrite, read, readRaw, scheduleClose, socket, write, write, write

Methods inherited from class java.lang.Object

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

Field Details

logSerialize

protected static final org.slf4j.Logger logSerialize

BUFFER_SIZE

protected static final int BUFFER_SIZE

See Also:

• Constant Field Values

HTTP_REQUEST_UID

protected static final byte HTTP_REQUEST_UID

server

protected final RpcServer<S> server

peer

protected InetSocketAddress peer

proxyProtocol

protected boolean proxyProtocol

buffer

protected byte[] buffer

bytesRead

protected int bytesRead

requestSize

protected int requestSize

requestStartTime

protected long requestStartTime

Constructor Details

RpcSession

public RpcSession(Socket socket,
 RpcServer<S> server)

Method Details

processRead

protected void processRead(byte[] unusedBuffer)
                    throws Exception

Overrides:

processRead in class Session

Throws:

Exception

parseProxyProtocol

private void parseProxyProtocol()
                         throws IOException

Throws:

IOException

expandBuffer

private byte[] expandBuffer(int requestSize)

readHttpHeader

private int readHttpHeader()
                    throws IOException

Throws:

IOException

startsWith

private static boolean startsWith(byte[] buffer,
 int from,
 String s)

isAsyncRequest

protected boolean isAsyncRequest(Object request)

onRequestRead

protected M onRequestRead()

writeResponse

protected int writeResponse(Object response)
                     throws IOException

Throws:

IOException

streamCommunicate

protected void streamCommunicate(StreamProxy streamProxy)
                          throws IOException

Throws:

IOException

invoke

protected void invoke(Object request,
 M meta)
               throws Exception

Throws:

Exception

handleDeserializationException

protected void handleDeserializationException(Exception e)
                                       throws IOException

Throws:

IOException

handleRejectedExecution

protected void handleRejectedExecution(RejectedExecutionException e,
 Object request)
                                throws IOException

Throws:

IOException