|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--universal.communication.Receiver
This subclass implements the crash stop model receiver. It waits for connection to the socket and then after each time a connection has been accepted, it starts a new thread to wait for the packet and treat the message.
Field Summary | |
java.util.Vector |
AckBuffer
Contain the AckRead,NackRead,AckWrite and NackWrite messages that have been received but not yet analize in AckListenner. |
java.util.Vector |
ReadBuffer
Contains the Read messages that have been received but not yet analize in ReadListenner |
(package private) universal.Universal |
uni
The Universal object this receiver is linked to. |
java.util.Vector |
WriteBuffer
Contains the Write messages that have been recived but not yet analize in WriteListenner |
Constructor Summary | |
Receiver(universal.Universal univ)
It starts the thread that is going to listen for connection. |
Method Summary | |
universal.leader.Leader |
leader()
|
universal.consensus.register.Register |
reg()
|
void |
run()
Waits for connection to the socket. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public java.util.Vector ReadBuffer
public java.util.Vector WriteBuffer
public java.util.Vector AckBuffer
universal.Universal uni
Constructor Detail |
public Receiver(universal.Universal univ)
univ
- the universal object this receuiver is linked to.Method Detail |
public universal.leader.Leader leader()
public universal.consensus.register.Register reg()
public void run()
run
in interface java.lang.Runnable
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |