etri.sdn.controller.protocol.io

Class ClientChannelWatcher

java.lang.Object

java.lang.Thread

etri.sdn.controller.protocol.io.ClientChannelWatcher

All Implemented Interfaces:

java.lang.Runnable

public final class ClientChannelWatcher
extends java.lang.Thread

Watcher thread that monitors channels which are able to be read.

Author:

bjlee

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private static java.util.Set<IOFHandler>	controllers
private java.lang.Object	guard
private boolean	quit
private java.nio.channels.Selector	read_selector

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ClientChannelWatcher()

Method Summary

Methods

Modifier and Type	Method and Description
(package private) void	addClient(java.nio.channels.SocketChannel client)
static void	deregisterController(IOFHandler controller)
static java.util.Set<IOFHandler>	getHandlersFor(Connection conn)
private boolean	handleConnectedEvent(Connection conn)
private void	handleDisconnectedEvent(Connection conn)
private boolean	handleReadEvent(Connection conn)
static void	registerController(IOFHandler controller)
void	run()
(package private) void	shutdown()
(package private) void	wakeup()

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

quit

private volatile boolean quit

guard

private java.lang.Object guard

read_selector

private java.nio.channels.Selector read_selector

controllers

private static java.util.Set<IOFHandler> controllers

Constructor Detail

ClientChannelWatcher

ClientChannelWatcher()
               throws java.io.IOException

Throws:

java.io.IOException

Method Detail

registerController

public static void registerController(IOFHandler controller)

deregisterController

public static void deregisterController(IOFHandler controller)

getHandlersFor

public static java.util.Set<IOFHandler> getHandlersFor(Connection conn)

shutdown

void shutdown()

addClient

void addClient(java.nio.channels.SocketChannel client)

wakeup

void wakeup()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

handleConnectedEvent

private boolean handleConnectedEvent(Connection conn)

handleReadEvent

private boolean handleReadEvent(Connection conn)

handleDisconnectedEvent

private void handleDisconnectedEvent(Connection conn)