|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--java.lang.Thread | +--universal.communication.SocketReceiver
Wait for packet to arrive to the socket. Then depending on the type of the message, it adds it to the vector AckBuffer, ReadBuffer or WriteBuffer if it is respectively an acknowledgement, read or write messages. If it is an Amalive message it inform the leader part of our algorithm that an AmAlive message has arrived.
Field Summary | |
(package private) java.net.Socket |
clientSocket
|
(package private) java.io.InputStream |
in
The InputStream that arrive via the socket. |
(package private) universal.communication.Receiver |
rec
|
Fields inherited from class java.lang.Thread |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
(package private) |
SocketReceiver(java.net.Socket clientSocket,
universal.communication.Receiver rec)
|
Method Summary | |
java.lang.Object |
receive()
|
void |
run()
Depending on the type of the message, it adds it to the vector AckBuffer, ReadBuffer or WriteBuffer if it is respectively an acknowledgement, read or write messages. |
Methods inherited from class java.lang.Thread |
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
java.net.Socket clientSocket
java.io.InputStream in
universal.communication.Receiver rec
Constructor Detail |
SocketReceiver(java.net.Socket clientSocket, universal.communication.Receiver rec)
Method Detail |
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public java.lang.Object receive() throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |