| Methods Summary |
|---|
| public void | close()
if (orb.transportDebugFlag) {
dprint(".close: " + connection);
}
keepRunning = false;
|
| public void | doWork()
try {
if (orb.transportDebugFlag) {
dprint(".doWork: Start ReaderThread: " + connection);
}
while (keepRunning) {
try {
if (orb.transportDebugFlag) {
dprint(".doWork: Start ReaderThread cycle: "
+ connection);
}
if (connection.read()) {
// REVISIT - put in pool;
return;
}
if (orb.transportDebugFlag) {
dprint(".doWork: End ReaderThread cycle: "
+ connection);
}
} catch (Throwable t) {
if (orb.transportDebugFlag) {
dprint(".doWork: exception in read: " + connection,t);
}
orb.getTransportManager().getSelector(0)
.unregisterForEvent(getConnection().getEventHandler());
getConnection().close();
}
}
} finally {
if (orb.transportDebugFlag) {
dprint(".doWork: Terminated ReaderThread: " + connection);
}
}
|
| private void | dprint(java.lang.String msg)
ORBUtility.dprint("ReaderThreadImpl", msg);
|
| protected void | dprint(java.lang.String msg, java.lang.Throwable t)
dprint(msg);
t.printStackTrace(System.out);
|
| public com.sun.corba.se.pept.transport.Connection | getConnection()
return connection;
|
| public long | getEnqueueTime()
return enqueueTime;
|
| public java.lang.String | getName() return "ReaderThread";
|
| public void | setEnqueueTime(long timeInMillis)
enqueueTime = timeInMillis;
|
