Saros
Distributed Collaborative Editing and Distributed Party Programming
|
Public Member Functions | |
MockedSXETransmitter (SXENetworkMock network) | |
void | sendAsync (SXEMessage msg) |
SXEMessage | sendAndAwait (IProgressMonitor monitor, SXEMessage msg, SXEMessageType...awaitFor) throws IOException |
void | installRecordReceiver (SXEController controller) |
void | receiveRecords (String msg, String from) |
Static Public Attributes | |
static final Logger | log |
Protected Member Functions | |
void | handleReceiveRecords (final SXEMessage message) |
void | handleReceiveState (final SXEMessage message) |
void | setSender (List< RecordDataObject > rdos, String sender) |
de.fu_berlin.inf.dpp.whiteboard.sxe.net.MockedSXETransmitter.MockedSXETransmitter | ( | SXENetworkMock | network | ) |
void de.fu_berlin.inf.dpp.whiteboard.sxe.net.MockedSXETransmitter.handleReceiveRecords | ( | final SXEMessage | message | ) | [protected] |
void de.fu_berlin.inf.dpp.whiteboard.sxe.net.MockedSXETransmitter.handleReceiveState | ( | final SXEMessage | message | ) | [protected] |
void de.fu_berlin.inf.dpp.whiteboard.sxe.net.MockedSXETransmitter.installRecordReceiver | ( | SXEController | controller | ) |
void de.fu_berlin.inf.dpp.whiteboard.sxe.net.MockedSXETransmitter.receiveRecords | ( | String | msg, |
String | from | ||
) |
SXEMessage de.fu_berlin.inf.dpp.whiteboard.sxe.net.MockedSXETransmitter.sendAndAwait | ( | IProgressMonitor | monitor, |
SXEMessage | msg, | ||
SXEMessageType... | awaitFor | ||
) | throws IOException |
Send a message to the peer provided by the SXEMessage and wait until the requested response has arrived from this peer.
monitor | |
msg | |
awaitFor |
null
if the operation was canceled Implements de.fu_berlin.inf.dpp.whiteboard.sxe.net.ISXETransmitter.
void de.fu_berlin.inf.dpp.whiteboard.sxe.net.MockedSXETransmitter.sendAsync | ( | SXEMessage | msg | ) |
Send asynchronously a message to the peer provided by the SXEMessage
msg |
Implements de.fu_berlin.inf.dpp.whiteboard.sxe.net.ISXETransmitter.
void de.fu_berlin.inf.dpp.whiteboard.sxe.net.MockedSXETransmitter.setSender | ( | List< RecordDataObject > | rdos, |
String | sender | ||
) | [protected] |
final Logger de.fu_berlin.inf.dpp.whiteboard.sxe.net.MockedSXETransmitter.log [static] |
Logger .getLogger(MockedSXETransmitter.class)