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 |
int |
mode |
int |
nextOp |
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 volatile int nextOp
public volatile int mode
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 ProtocolContext<Channel>
public InetSocketAddress getAddress()
getAddress
in interface ProtocolContext<Channel>
public Channel write(String s)
write
in interface ProtocolContext<Channel>
public Channel writeln(String s)
writeln
in interface ProtocolContext<Channel>
public Channel write(byte[] bytes)
write
in interface ProtocolContext<Channel>
public Channel write(byte[] bytes, int offset, int length)
write
in interface ProtocolContext<Channel>
public Channel write(ByteBuffer buf)
write
in interface ProtocolContext<Channel>
public Channel write(File file)
write
in interface ProtocolContext<Channel>
public boolean closeAfterWrite()
public Channel done()
done
in interface ProtocolContext<Channel>
public void done(Object tag)
public Channel send()
send
in interface ProtocolContext<Channel>
public void error()
public void close(boolean waitToWrite)
public void wrote(boolean complete)
public org.rapidoidx.buffer.Buf input()
input
in interface ProtocolContext<Channel>
public org.rapidoidx.buffer.Buf output()
output
in interface ProtocolContext<Channel>
public boolean onSameThread()
public RapidoidHelper helper()
helper
in interface ProtocolContext<Channel>
public CtxListener listener()
public void setListener(CtxListener listener)
public String address()
address
in interface ProtocolContext<Channel>
public Channel close()
close
in interface ProtocolContext<Channel>
public Channel closeIf(boolean condition)
closeIf
in interface ProtocolContext<Channel>
public String readln()
readln
in interface ProtocolContext<Channel>
public String readN(int count)
readN
in interface ProtocolContext<Channel>
public long connId()
connId
in interface ProtocolContext<Channel>
public ConnState state()
state
in interface ProtocolContext<Channel>
public boolean isInitial()
isInitial
in interface ProtocolContext<Channel>
public void setInitial(boolean initial)
public Channel restart()
restart
in interface ProtocolContext<Channel>
public Channel async()
async
in interface ProtocolContext<Channel>
public boolean isAsync()
isAsync
in interface ProtocolContext<Channel>
public boolean isClient()
public void setClient(boolean isClient)
public void setProtocol(Protocol protocol)
public Protocol getProtocol()
public boolean isClosing()
isClosing
in interface ProtocolContext<Channel>
public boolean isClosed()
isClosed
in interface ProtocolContext<Channel>
public void waitUntilClosing()
waitUntilClosing
in interface ProtocolContext<Channel>
public ChannelHolderImpl getHolder()
public void setHolder(ChannelHolderImpl holder)
public boolean shouldReconnect()
public void setAutoReconnect(boolean autoReconnect)
public ChannelHolder createHolder()
createHolder
in interface ProtocolContext<Channel>
public Channel nextOp(int nextOp)
nextOp
in interface ProtocolContext<Channel>
public Channel nextWrite()
nextWrite
in interface ProtocolContext<Channel>
public Channel mode(int mode)
mode
in interface ProtocolContext<Channel>
Copyright © 2014–2015 Nikolche Mihajlovski and contributors. All rights reserved.