public class RapidoidConnection extends Object implements org.rapidoid.util.Resetable, Channel, org.rapidoid.util.Constants
Modifier and Type | Field and Description |
---|---|
boolean |
closed |
boolean |
closing |
org.rapidoidx.buffer.Buf |
input |
SelectionKey |
key |
org.rapidoidx.buffer.Buf |
output |
RapidoidWorker |
worker |
Constructor and Description |
---|
RapidoidConnection(RapidoidWorker worker,
org.rapidoidx.buffer.BufGroup bufs) |
public final RapidoidWorker worker
public final org.rapidoidx.buffer.Buf input
public final org.rapidoidx.buffer.Buf output
public volatile SelectionKey key
public volatile boolean closed
public volatile boolean closing
public RapidoidConnection(RapidoidWorker worker, org.rapidoidx.buffer.BufGroup bufs)
public void reset()
reset
in interface org.rapidoid.util.Resetable
public void log(String msg)
log
in interface CtxConnection<Channel>
public InetSocketAddress getAddress()
getAddress
in interface CtxConnection<Channel>
public Channel write(byte[] bytes, int offset, int length)
public Channel write(ByteBuffer buf)
public boolean closeAfterWrite()
public void done(Object tag)
public void error()
public void close(boolean waitToWrite)
public void wrote(boolean complete)
public boolean onSameThread()
public RapidoidHelper helper()
public CtxListener listener()
public void setListener(CtxListener listener)
public String address()
address
in interface CtxConnection<Channel>
public Channel close()
close
in interface CtxConnection<Channel>
public Channel closeIf(boolean condition)
closeIf
in interface CtxConnection<Channel>
public long connId()
connId
in interface CtxConnection<Channel>
public boolean isInitial()
isInitial
in interface CtxProtocol<Channel>
public void setInitial(boolean initial)
public Channel restart()
restart
in interface CtxProtocol<Channel>
public boolean isAsync()
isAsync
in interface CtxConnection<Channel>
public boolean isClient()
public void setClient(boolean isClient)
public void setProtocol(Protocol protocol)
public Protocol getProtocol()
public boolean isClosing()
isClosing
in interface CtxConnection<Channel>
public boolean isClosed()
isClosed
in interface CtxConnection<Channel>
public void waitUntilClosing()
waitUntilClosing
in interface CtxConnection<Channel>
public ChannelHolderImpl getHolder()
public void setHolder(ChannelHolderImpl holder)
public boolean shouldReconnect()
public void setAutoReconnect(boolean autoReconnect)
public ChannelHolder createHolder()
createHolder
in interface CtxState<Channel>
Copyright © 2014–2015 Nikolche Mihajlovski. All rights reserved.