|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
openr66.protocol.utils.ChannelUtils
public class ChannelUtils
Channel Utils
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
Thread.State, Thread.UncaughtExceptionHandler |
Field Summary | |
---|---|
static Integer |
NOCHANNEL
|
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
ChannelUtils()
|
Method Summary | |
---|---|
static void |
close(org.jboss.netty.channel.Channel channel)
|
static void |
exit()
Exit global ChannelFactory |
static InetAddress |
getLocalInetAddress(org.jboss.netty.channel.Channel channel)
Get the Local InetAddress |
static InetSocketAddress |
getLocalInetSocketAddress(org.jboss.netty.channel.Channel channel)
Get the Local InetSocketAddress |
static InetAddress |
getRemoteInetAddress(org.jboss.netty.channel.Channel channel)
Get the Remote InetAddress |
static InetSocketAddress |
getRemoteInetSocketAddress(org.jboss.netty.channel.Channel channel)
Get the Remote InetSocketAddress |
static int |
nbCommandChannels(Configuration configuration)
Return the current number of network connections |
void |
run()
This function is the top function to be called when the server is to be shutdown. |
static void |
stopLogger()
|
static long |
willBeWaitingWriting(org.jboss.netty.handler.traffic.ChannelTrafficShapingHandler cts,
int size)
Compute Wait for Traffic in Write (ugly turn around) |
static long |
willBeWaitingWriting(LocalChannelReference localChannelReference,
int size)
Compute Wait for Traffic in Write (ugly turn around) |
static org.jboss.netty.channel.ChannelFuture |
writeAbstractLocalPacket(LocalChannelReference localChannelReference,
AbstractLocalPacket packet,
boolean wait)
Write an AbstractLocalPacket to the network Channel |
static org.jboss.netty.channel.ChannelFuture |
writeAbstractLocalPacketToLocal(LocalChannelReference localChannelReference,
AbstractLocalPacket packet)
Write an AbstractLocalPacket to the Local Channel |
static org.jboss.netty.channel.ChannelFuture |
writeBackDataBlock(LocalChannelReference localChannelReference,
goldengate.common.file.DataBlock block)
|
static void |
writeEndTransfer(LocalChannelReference localChannelReference)
Write the EndTransfer |
Methods inherited from class java.lang.Thread |
---|
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield |
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final Integer NOCHANNEL
Constructor Detail |
---|
public ChannelUtils()
Method Detail |
---|
public static InetAddress getRemoteInetAddress(org.jboss.netty.channel.Channel channel)
channel
-
public static InetAddress getLocalInetAddress(org.jboss.netty.channel.Channel channel)
channel
-
public static InetSocketAddress getRemoteInetSocketAddress(org.jboss.netty.channel.Channel channel)
channel
-
public static InetSocketAddress getLocalInetSocketAddress(org.jboss.netty.channel.Channel channel)
channel
-
public static int nbCommandChannels(Configuration configuration)
configuration
-
public static void close(org.jboss.netty.channel.Channel channel)
channel
- public static org.jboss.netty.channel.ChannelFuture writeBackDataBlock(LocalChannelReference localChannelReference, goldengate.common.file.DataBlock block) throws OpenR66ProtocolPacketException
localChannelReference
- block
-
OpenR66ProtocolPacketException
public static void writeEndTransfer(LocalChannelReference localChannelReference) throws OpenR66ProtocolPacketException
localChannelReference
-
OpenR66ProtocolPacketException
public static org.jboss.netty.channel.ChannelFuture writeAbstractLocalPacket(LocalChannelReference localChannelReference, AbstractLocalPacket packet, boolean wait) throws OpenR66ProtocolPacketException
localChannelReference
- packet
- wait
-
OpenR66ProtocolPacketException
public static org.jboss.netty.channel.ChannelFuture writeAbstractLocalPacketToLocal(LocalChannelReference localChannelReference, AbstractLocalPacket packet) throws OpenR66ProtocolPacketException
localChannelReference
- packet
-
OpenR66ProtocolPacketException
public static final long willBeWaitingWriting(LocalChannelReference localChannelReference, int size)
localChannelReference
- size
-
public static final long willBeWaitingWriting(org.jboss.netty.handler.traffic.ChannelTrafficShapingHandler cts, int size)
cts
- size
-
public static void exit()
public static void stopLogger()
public void run()
run
in interface Runnable
run
in class Thread
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |