You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
114 lines
2.8 KiB
114 lines
2.8 KiB
package mock.app;
|
|
|
|
|
|
|
|
import network.Messages.*;
|
|
import shared.model.RunnableWithFramePeriod;
|
|
|
|
import java.util.List;
|
|
import java.util.concurrent.BlockingQueue;
|
|
import java.util.logging.Level;
|
|
import java.util.logging.Logger;
|
|
|
|
/**
|
|
* TCP server to send race information to connected clients.
|
|
*/
|
|
public class MockOutput implements RunnableWithFramePeriod {
|
|
|
|
|
|
|
|
/**
|
|
* A queue to send messages to client.
|
|
*/
|
|
private BlockingQueue<AC35Data> outgoingMessages;
|
|
|
|
|
|
/**
|
|
* An object containing the set of latest messages to send.
|
|
* Every server frame, MockOutput reads messages from this, and send them.
|
|
*/
|
|
private LatestMessages latestMessages;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
* Ctor.
|
|
* @param latestMessages Latest Messages that the Mock is to send out
|
|
* @param outgoingMessages A queue to place outgoing messages on.
|
|
*/
|
|
public MockOutput(LatestMessages latestMessages, BlockingQueue<AC35Data> outgoingMessages) {
|
|
this.outgoingMessages = outgoingMessages;
|
|
this.latestMessages = latestMessages;
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
* Sending loop of the Server
|
|
*/
|
|
public void run() {
|
|
|
|
|
|
//Wait until all of the xml files have been set.
|
|
while (!this.latestMessages.hasAllXMLMessages()) {
|
|
|
|
try {
|
|
Thread.sleep(500);
|
|
|
|
} catch (InterruptedException e) {
|
|
//If we get interrupted, exit the function.
|
|
Logger.getGlobal().log(Level.WARNING, "MockOutput.run().sleep(waitForXMLs) was interrupted on thread: " + Thread.currentThread(), e);
|
|
|
|
//Re-set the interrupt flag.
|
|
Thread.currentThread().interrupt();
|
|
return;
|
|
|
|
}
|
|
}
|
|
|
|
|
|
long previousFrameTime = System.currentTimeMillis();
|
|
boolean sentXMLs = false;
|
|
|
|
|
|
|
|
while (!Thread.interrupted()) {
|
|
|
|
try {
|
|
|
|
long currentFrameTime = System.currentTimeMillis();
|
|
waitForFramePeriod(previousFrameTime, currentFrameTime, 16);
|
|
previousFrameTime = currentFrameTime;
|
|
|
|
|
|
//Send XML messages.
|
|
if (!sentXMLs) {
|
|
|
|
outgoingMessages.put(latestMessages.getRaceXMLMessage());
|
|
outgoingMessages.put(latestMessages.getRegattaXMLMessage());
|
|
outgoingMessages.put(latestMessages.getBoatXMLMessage());
|
|
|
|
sentXMLs = true;
|
|
}
|
|
|
|
List<AC35Data> snapshot = latestMessages.getSnapshot();
|
|
for (AC35Data message : snapshot) {
|
|
outgoingMessages.put(message);
|
|
}
|
|
|
|
} catch (InterruptedException e) {
|
|
Logger.getGlobal().log(Level.WARNING, "MockOutput.run() interrupted while putting message in queue.", e);
|
|
Thread.currentThread().interrupt();
|
|
return;
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
}
|