edu.iu.dsc.tws.common.net.tcp

Class Progress

java.lang.Object

edu.iu.dsc.tws.common.net.tcp.Progress

public class Progress
extends java.lang.Object

The communicationProgress loop

Constructor Summary

Constructors

Constructor and Description
Progress()

Method Summary

Modifier and Type	Method and Description
boolean	isAcceptRegistered(java.nio.channels.SelectableChannel channel)
boolean	isConnectRegistered(java.nio.channels.SelectableChannel channel)
boolean	isReadRegistered(java.nio.channels.SelectableChannel channel)
boolean	isWriteRegistered(java.nio.channels.SelectableChannel channel)
void	loop()
void	loopBlocking()
void	loopBlocking(long blockingDuration)
void	registerAccept(java.nio.channels.SelectableChannel channel, SelectHandler callback)
void	registerConnect(java.nio.channels.SelectableChannel channel, SelectHandler callback)
void	registerRead(java.nio.channels.SelectableChannel channel, SelectHandler callback)
void	registerWrite(java.nio.channels.SelectableChannel channel, SelectHandler callback)
void	removeAllInterest(java.nio.channels.SelectableChannel channel)
void	unregisterAccept(java.nio.channels.SelectableChannel channel)
void	unregisterConnect(java.nio.channels.SelectableChannel channel)
void	unregisterRead(java.nio.channels.SelectableChannel channel)
void	unregisterWrite(java.nio.channels.SelectableChannel channel)
void	wakeup()

Methods inherited from class java.lang.Object

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

Constructor Detail

Progress

public Progress()

Method Detail

loop

public void loop()

loopBlocking

public void loopBlocking()

loopBlocking

public void loopBlocking(long blockingDuration)

wakeup

public void wakeup()

registerRead

public void registerRead(java.nio.channels.SelectableChannel channel,
                         SelectHandler callback)
                  throws java.nio.channels.ClosedChannelException

Throws:

java.nio.channels.ClosedChannelException

unregisterRead

public void unregisterRead(java.nio.channels.SelectableChannel channel)

isReadRegistered

public boolean isReadRegistered(java.nio.channels.SelectableChannel channel)

registerConnect

public void registerConnect(java.nio.channels.SelectableChannel channel,
                            SelectHandler callback)
                     throws java.nio.channels.ClosedChannelException

Throws:

java.nio.channels.ClosedChannelException

unregisterConnect

public void unregisterConnect(java.nio.channels.SelectableChannel channel)

isConnectRegistered

public boolean isConnectRegistered(java.nio.channels.SelectableChannel channel)

registerAccept

public void registerAccept(java.nio.channels.SelectableChannel channel,
                           SelectHandler callback)
                    throws java.nio.channels.ClosedChannelException

Throws:

java.nio.channels.ClosedChannelException

unregisterAccept

public void unregisterAccept(java.nio.channels.SelectableChannel channel)

isAcceptRegistered

public boolean isAcceptRegistered(java.nio.channels.SelectableChannel channel)

registerWrite

public void registerWrite(java.nio.channels.SelectableChannel channel,
                          SelectHandler callback)
                   throws java.nio.channels.ClosedChannelException

Throws:

java.nio.channels.ClosedChannelException

unregisterWrite

public void unregisterWrite(java.nio.channels.SelectableChannel channel)

isWriteRegistered

public boolean isWriteRegistered(java.nio.channels.SelectableChannel channel)

removeAllInterest

public void removeAllInterest(java.nio.channels.SelectableChannel channel)