etri.sdn.controller

Class OFController.QP

java.lang.Object

java.lang.Thread

etri.sdn.controller.OFController.QP

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

OFController

private class OFController.QP
extends java.lang.Thread

Queue Item Processor, which is a thread that pulls QI object from the queue that is associated with the thread. Each QP thread has one queue to receive QI object. Through the experiment, we have found out that TransferQueue is the most effective queueing mechanism for this thread.

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 MessageContext	context
private OFController	controller
private java.util.concurrent.TransferQueue<OFController.QI>	queue
private boolean	quit

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
OFController.QP(OFController ctrl) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
boolean	handleReadEvent(Connection conn, java.util.List<org.openflow.protocol.OFMessage> msgs) This function delivers a read event to the QP thread.
private boolean	process(Connection conn, java.util.List<org.openflow.protocol.OFMessage> msgs) process a list of OFMessage objects received from the connection.
private boolean	processFeaturesReply(Connection conn, MessageContext context, org.openflow.protocol.OFFeaturesReply m) This function returns false when there is no switch object in connection.
void	run() Read one read event from the queue, and process it.
void	shutdown() Shutdown this thread to stop.

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

queue

private java.util.concurrent.TransferQueue<OFController.QI> queue

context

private MessageContext context

controller

private OFController controller

Constructor Detail

OFController.QP

public OFController.QP(OFController ctrl)

Constructor

Parameters:

ctrl - reference to the OFController object

Method Detail

shutdown

public void shutdown()

Shutdown this thread to stop.

handleReadEvent

public boolean handleReadEvent(Connection conn,
                      java.util.List<org.openflow.protocol.OFMessage> msgs)

This function delivers a read event to the QP thread.

Parameters:

conn -

msgs -

Returns:

run

public void run()

Read one read event from the queue, and process it.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

process

private boolean process(Connection conn,
              java.util.List<org.openflow.protocol.OFMessage> msgs)

process a list of OFMessage objects received from the connection.

Parameters:

conn - connection to switch

msgs - messages received through the connection

Returns:

true if successfully processed. However, currently the return value of this function is not used by run().

processFeaturesReply

private boolean processFeaturesReply(Connection conn,
                           MessageContext context,
                           org.openflow.protocol.OFFeaturesReply m)

This function returns false when there is no switch object in connection.

Parameters:

conn - connection that the OFFeaturesReply object is received

context - message context object

m - OFFeaturesReply object

Returns:

true if the message m has been correctly processed