public class RapidoidWorker extends AbstractEventLoop<RapidoidWorker>
selector
ownerThread, status
Constructor and Description |
---|
RapidoidWorker(String name,
org.rapidoidx.buffer.BufGroup bufs,
Protocol protocol,
RapidoidHelper helper,
int bufSizeKB,
boolean noNelay) |
Modifier and Type | Method and Description |
---|---|
void |
accept(SocketChannel socketChannel) |
void |
close(RapidoidConnection conn) |
void |
connect(ConnectionTarget target) |
protected void |
connectOP(SelectionKey key) |
protected void |
doProcessing() |
protected void |
failedOP(SelectionKey key,
Throwable e) |
long |
getMessagesProcessed() |
RapidoidConnection |
newConnection() |
void |
process(RapidoidConnection conn) |
protected void |
readOP(SelectionKey key) |
void |
restart(RapidoidConnection conn) |
void |
wantToWrite(RapidoidConnection conn) |
protected void |
writeOP(SelectionKey key) |
acceptOP, insideLoop
afterLoop, assertStatus, beforeLoop, checkOnSameThread, onSameThread, run, shutdown, start, stopLoop, waitToStart, waitToStop
public RapidoidWorker(String name, org.rapidoidx.buffer.BufGroup bufs, Protocol protocol, RapidoidHelper helper, int bufSizeKB, boolean noNelay)
public void accept(SocketChannel socketChannel) throws IOException
IOException
public void connect(ConnectionTarget target) throws IOException
IOException
protected void connectOP(SelectionKey key) throws IOException
connectOP
in class AbstractEventLoop<RapidoidWorker>
IOException
protected void readOP(SelectionKey key) throws IOException
readOP
in class AbstractEventLoop<RapidoidWorker>
IOException
public void process(RapidoidConnection conn)
public void close(RapidoidConnection conn)
protected void writeOP(SelectionKey key) throws IOException
writeOP
in class AbstractEventLoop<RapidoidWorker>
IOException
public void wantToWrite(RapidoidConnection conn)
protected void doProcessing()
doProcessing
in class AbstractEventLoop<RapidoidWorker>
protected void failedOP(SelectionKey key, Throwable e)
failedOP
in class AbstractEventLoop<RapidoidWorker>
public void restart(RapidoidConnection conn)
public RapidoidConnection newConnection()
public long getMessagesProcessed()
Copyright © 2014–2015 Nikolche Mihajlovski. All rights reserved.