diff --git a/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/EspduTerminalLog.txt b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/EspduTerminalLog.txt
new file mode 100644
index 0000000000000000000000000000000000000000..4dba55c8530bae5461a83ec84f731824570291d1
--- /dev/null
+++ b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/EspduTerminalLog.txt
@@ -0,0 +1,136 @@
+Invocation instructions:
+1. run/debug EspduReceiver.java (since sender does not block, first be ready to listen)
+2. run/debug EspduSender.java
+
+Program responses, sender and receiver:
+
+===================================================
+run:
+
+
+DisExamplesOpenDis7.EspduSender started...
+Sending 5 sets of packets:
+===============
+Create new PDUs
+ latitude, longitude: [36.595517, -121.87693999999999]
+ coordinate conversion: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+Espdu #0 entityID=[1,2,3]
+Sending espdu datagram packet to /127.255.255.255
+Sending fire datagram packet to /127.255.255.255
+Sending espdu datagram packet to /172.20.221.218
+Sending fire datagram packet to /172.20.221.218
+Sending espdu datagram packet to /10.0.0.255
+Sending fire datagram packet to /10.0.0.255
+===============
+Create new PDUs
+ latitude, longitude: [36.595517, -121.877]
+ coordinate conversion: [-2707492.9269245286, -4353663.899966802, 3781450.3202754413]
+Espdu #1 entityID=[1,2,3]
+Sending espdu datagram packet to /127.255.255.255
+Sending fire datagram packet to /127.255.255.255
+Sending espdu datagram packet to /172.20.221.218
+Sending fire datagram packet to /172.20.221.218
+Sending espdu datagram packet to /10.0.0.255
+Sending fire datagram packet to /10.0.0.255
+===============
+Create new PDUs
+ latitude, longitude: [36.595517, -121.87693999999999]
+ coordinate conversion: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+Espdu #2 entityID=[1,2,3]
+Sending espdu datagram packet to /127.255.255.255
+Sending fire datagram packet to /127.255.255.255
+Sending espdu datagram packet to /172.20.221.218
+Sending fire datagram packet to /172.20.221.218
+Sending espdu datagram packet to /10.0.0.255
+Sending fire datagram packet to /10.0.0.255
+===============
+Create new PDUs
+ latitude, longitude: [36.595517, -121.877]
+ coordinate conversion: [-2707492.9269245286, -4353663.899966802, 3781450.3202754413]
+Espdu #3 entityID=[1,2,3]
+Sending espdu datagram packet to /127.255.255.255
+Sending fire datagram packet to /127.255.255.255
+Sending espdu datagram packet to /172.20.221.218
+Sending fire datagram packet to /172.20.221.218
+Sending espdu datagram packet to /10.0.0.255
+Sending fire datagram packet to /10.0.0.255
+===============
+Create new PDUs
+ latitude, longitude: [36.595517, -121.87693999999999]
+ coordinate conversion: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+Espdu #4 entityID=[1,2,3]
+Sending espdu datagram packet to /127.255.255.255
+Sending fire datagram packet to /127.255.255.255
+Sending espdu datagram packet to /172.20.221.218
+Sending fire datagram packet to /172.20.221.218
+Sending espdu datagram packet to /10.0.0.255
+Sending fire datagram packet to /10.0.0.255
+===============
+DisExamplesOpenDis7.EspduSender complete.
+BUILD SUCCESSFUL (total time: 8 seconds)
+
+===================================================
+
+DisExamplesOpenDis7.EspduReceiver started...
+===============
+received PDU type 1=ENTITY_STATE edu.nps.moves.dis7.EntityStatePdu
+ entityID triplet: [1, 2, 3]
+ Location in DIS coordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+received PDU type 2=FIRE edu.nps.moves.dis7.FirePdu
+ FirePdu locationInWorldCoordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+===============
+received PDU type 1=ENTITY_STATE edu.nps.moves.dis7.EntityStatePdu
+ entityID triplet: [1, 2, 3]
+ Location in DIS coordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+received PDU type 2=FIRE edu.nps.moves.dis7.FirePdu
+ FirePdu locationInWorldCoordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+===============
+received PDU type 1=ENTITY_STATE edu.nps.moves.dis7.EntityStatePdu
+ entityID triplet: [1, 2, 3]
+ Location in DIS coordinates: [-2707492.9269245286, -4353663.899966802, 3781450.3202754413]
+received PDU type 2=FIRE edu.nps.moves.dis7.FirePdu
+ FirePdu locationInWorldCoordinates: [-2707492.9269245286, -4353663.899966802, 3781450.3202754413]
+===============
+received PDU type 1=ENTITY_STATE edu.nps.moves.dis7.EntityStatePdu
+ entityID triplet: [1, 2, 3]
+ Location in DIS coordinates: [-2707492.9269245286, -4353663.899966802, 3781450.3202754413]
+received PDU type 2=FIRE edu.nps.moves.dis7.FirePdu
+ FirePdu locationInWorldCoordinates: [-2707492.9269245286, -4353663.899966802, 3781450.3202754413]
+===============
+received PDU type 1=ENTITY_STATE edu.nps.moves.dis7.EntityStatePdu
+ entityID triplet: [1, 2, 3]
+ Location in DIS coordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+received PDU type 2=FIRE edu.nps.moves.dis7.FirePdu
+ FirePdu locationInWorldCoordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+===============
+received PDU type 1=ENTITY_STATE edu.nps.moves.dis7.EntityStatePdu
+ entityID triplet: [1, 2, 3]
+ Location in DIS coordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+received PDU type 2=FIRE edu.nps.moves.dis7.FirePdu
+ FirePdu locationInWorldCoordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+===============
+received PDU type 1=ENTITY_STATE edu.nps.moves.dis7.EntityStatePdu
+ entityID triplet: [1, 2, 3]
+ Location in DIS coordinates: [-2707492.9269245286, -4353663.899966802, 3781450.3202754413]
+received PDU type 2=FIRE edu.nps.moves.dis7.FirePdu
+ FirePdu locationInWorldCoordinates: [-2707492.9269245286, -4353663.899966802, 3781450.3202754413]
+===============
+received PDU type 1=ENTITY_STATE edu.nps.moves.dis7.EntityStatePdu
+ entityID triplet: [1, 2, 3]
+ Location in DIS coordinates: [-2707492.9269245286, -4353663.899966802, 3781450.3202754413]
+received PDU type 2=FIRE edu.nps.moves.dis7.FirePdu
+ FirePdu locationInWorldCoordinates: [-2707492.9269245286, -4353663.899966802, 3781450.3202754413]
+===============
+received PDU type 1=ENTITY_STATE edu.nps.moves.dis7.EntityStatePdu
+ entityID triplet: [1, 2, 3]
+ Location in DIS coordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+received PDU type 2=FIRE edu.nps.moves.dis7.FirePdu
+ FirePdu locationInWorldCoordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+===============
+received PDU type 1=ENTITY_STATE edu.nps.moves.dis7.EntityStatePdu
+ entityID triplet: [1, 2, 3]
+ Location in DIS coordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+received PDU type 2=FIRE edu.nps.moves.dis7.FirePdu
+ FirePdu locationInWorldCoordinates: [-2707488.3677768684, -4353666.735244378, 3781450.3202754413]
+
+===================================================
\ No newline at end of file
diff --git a/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/PduListenerSaver.java b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/PduListenerSaver.java
new file mode 100644
index 0000000000000000000000000000000000000000..4fc9370b799f10ac9eeeccf09731b83928b7ba8b
--- /dev/null
+++ b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/PduListenerSaver.java
@@ -0,0 +1,82 @@
+/**
+ * Copyright (c) 2008-2019, MOVES Institute, Naval Postgraduate School. All rights reserved.
+ * This work is licensed under the BSD open source license, available at https://www.movesinstitute.org/licenses/bsd.html
+ */
+package MV3500Cohort2019JulySeptember.homework4.Yurkovich;
+
+import edu.nps.moves.dis7.util.playerrecorder.Recorder;
+import java.io.IOException;
+import java.util.Scanner;
+
+/**
+ * PduSaver.java created on Aug 21, 2019
+ * MOVES Institute Naval Postgraduate School, Monterey, CA, USA www.nps.edu
+ *
+ * @author Mike Bailey, jmbailey@nps.edu
+ * @version $Id$
+ */
+public class PduListenerSaver
+{
+ private final static String DEFAULT_OUTPUTDIR = "./pduLog";
+ private final static String MCAST_ADDR = "239.1.2.3";
+ private final static int DIS_PORT = 3000;
+
+ private enum mystate
+ {
+ RUNNING,
+ PAUSED;
+ }
+
+ public static void main(String[] args)
+ {
+ String outDir = DEFAULT_OUTPUTDIR;
+ String mcast = MCAST_ADDR;
+ int port = DIS_PORT;
+
+ switch (args.length) {
+ case 0:
+ break;
+ case 1:
+ outDir = args[0];
+ break;
+ case 3:
+ outDir = args[0];
+ mcast = args[1];
+ port = Integer.parseInt(args[2]);
+ break;
+ default:
+ System.err.println("Usage: PduListener() or PduListener(\"outputdir\") or PduListener(\"outputdir\",\"multicast address\", ipPort");
+ System.exit(1);
+ }
+
+ System.out.println("Beginning pdu save to directory " + outDir);
+ try {
+ Recorder recorder = new Recorder(outDir, mcast, port);
+
+ recorder.startResume();
+ mystate state = mystate.RUNNING;
+ Scanner scan = new Scanner(System.in);
+
+ while (true) {
+ System.out.println("Type p/enter to pause, r/enter to resume, q/enter to quit");
+ String line = scan.nextLine();
+ if (line.equalsIgnoreCase("p") && state == mystate.RUNNING) {
+ recorder.stopPause();
+ state = mystate.PAUSED;
+ }
+ else if (line.equalsIgnoreCase("r") && state == mystate.PAUSED) {
+ recorder.startResume();
+ state = mystate.RUNNING;
+ }
+ else if (line.equalsIgnoreCase("q")) {
+ recorder.end();
+ break;
+ }
+ }
+ System.out.println("Ending pdu save to "+recorder.getLogFile());
+ }
+ catch (IOException ex) {
+ System.err.println("Exception: " + ex.getClass().getSimpleName() + ": " + ex.getLocalizedMessage());
+ }
+ }
+}
diff --git a/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/PduReaderPlayer.java b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/PduReaderPlayer.java
new file mode 100644
index 0000000000000000000000000000000000000000..62f917bd55fb301ef7671fc1d3793c708c232eb4
--- /dev/null
+++ b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/PduReaderPlayer.java
@@ -0,0 +1,86 @@
+/**
+ * Copyright (c) 2008-2019, MOVES Institute, Naval Postgraduate School. All rights reserved.
+ * This work is licensed under the BSD open source license, available at https://www.movesinstitute.org/licenses/bsd.html
+ */
+package MV3500Cohort2019JulySeptember.homework4.Yurkovich;
+
+import edu.nps.moves.dis7.util.playerrecorder.Player;
+import java.io.File;
+import java.io.IOException;
+import java.util.Scanner;
+
+/**
+ * PduSaver.java created on Aug 21, 2019
+ * MOVES Institute Naval Postgraduate School, Monterey, CA, USA www.nps.edu
+ *
+ * @author Mike Bailey, jmbailey@nps.edu
+ * @version $Id$
+ */
+public class PduReaderPlayer
+{
+ private final static String DEFAULT_OUTPUTDIR = "pduLog";
+ private final static String MCAST_ADDR = "239.1.2.3";
+ private final static int DIS_PORT = 3000;
+
+ private enum mystate
+ {
+ RUNNING,
+ PAUSED;
+ }
+
+ public static void main(String[] args)
+ {
+ String outDir = DEFAULT_OUTPUTDIR;
+ String mcast = MCAST_ADDR;
+ int port = DIS_PORT;
+
+ System.out.println("DisExamplesOpenDis7.PduReaderPlayer started...");
+
+ switch (args.length) {
+ case 0:
+ break;
+ case 1:
+ outDir = args[0];
+ break;
+ case 3:
+ outDir = args[0];
+ mcast = args[1];
+ port = Integer.parseInt(args[2]);
+ break;
+ default:
+ System.err.println("Usage: PduReaderPlayer() or PduReaderPlayer(\"outputdir\") or PduReaderPlayer(\"outputdir\",\"multicast address\", ipPort");
+ System.exit(1);
+ }
+
+ System.out.println("Beginning pdu playback from directory " + outDir);
+ try {
+ Player player = new Player(mcast, port, new File(outDir).toPath());
+ player.startResume();
+ mystate state = mystate.RUNNING;
+ Scanner scan = new Scanner(System.in);
+
+ while (true) {
+ System.out.println("Type p/enter to pause, r/enter to resume, q/enter to quit");
+ String line = scan.nextLine();
+ if (line.equalsIgnoreCase("p") && state == mystate.RUNNING) {
+ player.stopPause();
+ state = mystate.PAUSED;
+ }
+ else if (line.equalsIgnoreCase("r") && state == mystate.PAUSED) {
+ player.startResume();
+ state = mystate.RUNNING;
+ }
+ else if (line.equalsIgnoreCase("q")) {
+ player.end();
+ break;
+ }
+ }
+ System.out.println("Ending pdu files playback for directory " + outDir);
+ System.out.println("DisExamplesOpenDis7.PduReaderPlayer complete.");
+ System.exit(0); // not sure why this is necessary with Netbeans...
+ }
+ catch (IOException ex) {
+ System.err.println("Exception: " + ex.getClass().getSimpleName() + ": " + ex.getLocalizedMessage());
+ }
+ }
+}
diff --git a/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/PduReaderPlayerLog.txt b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/PduReaderPlayerLog.txt
new file mode 100644
index 0000000000000000000000000000000000000000..7c6a4361a8bd52edb1b201b3d1fa30f04e886f5a
--- /dev/null
+++ b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/PduReaderPlayerLog.txt
@@ -0,0 +1,24 @@
+Invocation instructions:
+
+0. check for existence of recorded files in directory, e.g. examples/pduLog/Pdusave.dislog
+1. first running AllPduReceiver can confirm that DIS replay actually occurs.
+2. run or debug PduReaderPlayer.java
+3. Type p/enter to pause, r/enter to resume, q/enter to quit
+
+Program response:
+
+===================================================
+
+DisExamplesOpenDis7.PduReaderPlayer started...
+Beginning pdu playback from directory pduLog
+Replaying DIS logs.
+Replaying C:\x-nps-gitlab\NetworkedGraphicsMV3500\examples\pduLog\Pdusave.dislog
+Beginning of DIS capture file, Pdusave.dislog.
+Type p/enter to pause, r/enter to resume, q/enter to quit
+72
+End of replay from Pdusave.dislog
+End of DIS capture file, Pdusave.dislog.
+q
+Ending pdu files playback for directory pduLog
+DisExamplesOpenDis7.PduReaderPlayer complete.
+BUILD SUCCESSFUL (total time: 20 seconds)
\ No newline at end of file
diff --git a/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/README.md b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/README.md
new file mode 100644
index 0000000000000000000000000000000000000000..89d90724bc17cff98112589508dcace4ba72345a
--- /dev/null
+++ b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/README.md
@@ -0,0 +1,7 @@
+# DIS Protocol Examples using Open-DIS-Java Library v7
+
+TODO under development!
+
+Course examples using the [Open-DIS-Java](https://github.com/open-dis/open-dis-java) library are presented in this package.
+
+See [specifications](../../../specifications) directory to obtain reference copies of DIS and RPRFOM standards.
diff --git a/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/Yurk_EspduReceiver.java b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/Yurk_EspduReceiver.java
new file mode 100755
index 0000000000000000000000000000000000000000..85a551a80a517c291f756cce38514d5620be0dfb
--- /dev/null
+++ b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/Yurk_EspduReceiver.java
@@ -0,0 +1,93 @@
+package MV3500Cohort2019JulySeptember.homework4.Yurkovich;
+
+import java.io.*;
+import java.net.*;
+import java.util.*;
+
+import edu.nps.moves.dis7.*;
+import edu.nps.moves.dis7.util.*;
+
+/**
+ * Receives PDUs from the network in IEEE DIS format.
+ * Adapted from OpenDIS library example package edu.nps.moves.examples
+ *
+ * @author DMcG
+ * @version $Id:$
+ */
+public class Yurk_EspduReceiver
+{
+ /** Max size of a PDU in binary format that we can receive. This is actually
+ * somewhat outdated--PDUs can be larger--but this is a reasonable starting point.
+ */
+ public static final int MAX_PDU_SIZE = 8192;
+
+ /** Default multicast group address we send on. */
+ public static final String DEFAULT_MULTICAST_ADDRESS = Yurk_EspduSender.DEFAULT_MULTICAST_ADDRESS;
+
+ /** Default multicast port used, matches Wireshark DIS capture default */
+ public static final int DEFAULT_MULTICAST_PORT = Yurk_EspduSender.DEFAULT_MULTICAST_PORT;
+
+ public static void main(String args[])
+ {
+ System.out.println("DisExamplesOpenDis7.EspduReceiver started...");
+
+ MulticastSocket socket;
+ DatagramPacket packet;
+ InetAddress address;
+ PduFactory pduFactory = new PduFactory();
+
+ try {
+ // Specify the socket to receive data
+ socket = new MulticastSocket(DEFAULT_MULTICAST_PORT);
+// socket.setBroadcast(true);
+
+ address = InetAddress.getByName(DEFAULT_MULTICAST_ADDRESS);
+ socket.joinGroup(address);
+
+ while (true) // Loop infinitely, receiving datagrams
+ {
+ byte buffer[] = new byte[MAX_PDU_SIZE];
+ packet = new DatagramPacket(buffer, buffer.length);
+
+ socket.receive(packet);
+
+ List<Pdu> pduBundle = pduFactory.getPdusFromBundle(packet.getData(),packet.getLength());
+ if (pduBundle.size() > 1)
+ System.out.println("Bundle size is " + pduBundle.size());
+ Iterator iterator = pduBundle.iterator();
+
+ while (iterator.hasNext())
+ {
+ Pdu aPdu = (Pdu)iterator.next();
+ String receiptMessage = "received PDU type " + aPdu.getPduType().getValue() + "=" + aPdu.getPduType().name() + " " + aPdu.getClass().getName();
+ if (aPdu instanceof EntityStatePdu)
+ {
+ System.out.println("===============");
+ System.out.println(receiptMessage);
+ EntityID entityID = ((EntityStatePdu)aPdu).getEntityID();
+ Vector3Double position = ((EntityStatePdu)aPdu).getEntityLocation();
+ System.out.println(" entityID triplet: [" + entityID.getSiteID()+ ", " + entityID.getApplicationID()+ ", " + entityID.getEntityID()+ "] ");
+ System.out.println(" Location in DIS coordinates: [" + position.getX() + ", " + position.getY() + ", " + position.getZ() + "]");
+ }
+ else if (aPdu instanceof FirePdu)
+ {
+ System.out.println(receiptMessage);
+ Vector3Double position = ((FirePdu)aPdu).getLocationInWorldCoordinates();
+ System.out.println(" FirePdu locationInWorldCoordinates: [" + position.getX() + ", " + position.getY() + ", " + position.getZ() + "]");
+
+ }
+ else
+ {
+ System.out.println(receiptMessage);
+ }
+ } // end iterator loop through PDU bundle
+ } // end while
+ } // end try block
+ catch (IOException e)
+ {
+ System.out.println("Problem with DisExamplesOpenDis7.EspduReceiver, see exception trace:");
+ System.out.println(e);
+ }
+ System.out.println("DisExamplesOpenDis7.EspduReceiver complete.");
+ } // end main
+} // end class
diff --git a/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/Yurk_EspduSender.java b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/Yurk_EspduSender.java
new file mode 100644
index 0000000000000000000000000000000000000000..a8c48acce82c22e19d19ab20c5bf4e6e90b634e7
--- /dev/null
+++ b/assignments/src/MV3500Cohort2019JulySeptember/homework4/Yurkovich/Yurk_EspduSender.java
@@ -0,0 +1,347 @@
+package MV3500Cohort2019JulySeptember.homework4.Yurkovich;
+
+import java.io.*;
+import java.net.*;
+import java.util.*;
+
+import edu.nps.moves.dis7.*;
+import edu.nps.moves.dis7.util.*;
+import edu.nps.moves.dis7.enumerations.Country;
+import edu.nps.moves.dis7.enumerations.EntityKind;
+import edu.nps.moves.dis7.enumerations.PlatformDomain;
+
+/**
+ * Creates and sends ESPDUs in IEEE binary format. Adapted from OpenDIS library
+ * example package edu.nps.moves.examples
+ *
+ * @author Don McGregor
+ * @author Don Brutzman
+ */
+public class Yurk_EspduSender
+{
+ public static final int NUMBER_TO_SEND = 5; // 5000
+
+ /**
+ * Default multicast group address we send on.
+ */
+ public static final String DEFAULT_MULTICAST_ADDRESS = "239.1.2.3";
+
+ /**
+ * Default multicast port used, matches Wireshark DIS capture default
+ */
+ public static final int DEFAULT_MULTICAST_PORT = 3000;
+
+ public enum NetworkMode {
+ UNICAST, MULTICAST, BROADCAST
+ };
+
+ /**
+ * Possible system properties, passed in via -Dattr=val networkMode:
+ * unicast, broadcast, multicast destinationIp: where to send the packet. If
+ * in multicast mode, this can be multicast. To determine broadcast
+ * destination IP, use an online broadcast address calculator, for example
+ * http://www.remotemonitoringsystems.ca/broadcast.php If in multicast mode,
+ * a join() will be done on the multicast address. port: port used for both
+ * source and destination.
+ *
+ * @param args
+ */
+ public static void main(String args[])
+ {
+ System.out.println("DisExamplesOpenDis7.EspduSender started...");
+
+ // Default settings. These are used if no system properties are set.
+ // If system properties are passed in, these are overridden later.
+ NetworkMode networkMode = NetworkMode.BROADCAST;
+ InetAddress address = null; // must be initialized, even if null
+ int port = DEFAULT_MULTICAST_PORT;
+ MulticastSocket socket = null; // must be initialized to avoid later error, even if null;
+ EntityStatePdu espdu = new EntityStatePdu();
+ DisTime disTime = new DisTime();
+
+ // ICBM coordinates for my office
+ double latitude = 36.595517;
+ double longitude = -121.877000;
+ try
+ {
+ address = InetAddress.getByName(DEFAULT_MULTICAST_ADDRESS);
+ }
+ catch (UnknownHostException e)
+ {
+ System.out.println(e + " Cannot create multicast address");
+ System.exit(0);
+ }
+
+ // All system properties, passed in on the command line via -Dattribute=value
+ Properties systemProperties = System.getProperties();
+
+ // IP address we send to
+ String destinationIpString = systemProperties.getProperty("destinationIp");
+
+ // Port we send to, and local port we open the socket on
+ String portString = systemProperties.getProperty("port");
+
+ // Network mode: unicast, multicast, broadcast
+ String networkModeString = systemProperties.getProperty("networkMode"); // unicast or multicast or broadcast
+
+ // Set up socket to send information
+ try
+ {
+ if (portString != null) // Update port we send to, if provided
+ {
+ port = Integer.parseInt(portString);
+ }
+ socket = new MulticastSocket(port);
+
+ // Where we send packets to, the destination IP address
+ if (destinationIpString != null)
+ {
+ address = InetAddress.getByName(destinationIpString);
+ }
+
+ // Type of transport: unicast, broadcast, or multicast
+ if (networkModeString != null)
+ {
+ if (networkModeString.equalsIgnoreCase("unicast"))
+ {
+ networkMode = NetworkMode.UNICAST;
+ }
+ else if (networkModeString.equalsIgnoreCase("broadcast"))
+ {
+ networkMode = NetworkMode.BROADCAST;
+ }
+ else if (networkModeString.equalsIgnoreCase("multicast"))
+ {
+ networkMode = NetworkMode.MULTICAST;
+ if (!address.isMulticastAddress())
+ {
+ throw new RuntimeException("*** Error: sending to multicast address, but destination address " + address.toString() + "is not multicast");
+ }
+ socket.joinGroup(address);
+ }
+ } // end networkModeString
+ }
+ catch (IOException | RuntimeException e)
+ {
+ System.out.println("Unable to initialize network correctly, exiting.");
+ System.out.println(e);
+ System.exit(-1); // outta here
+ }
+
+ // Initialize values in the Entity State PDU object. The exercise ID is
+ // a way to differentiate between different virtual worlds on one network.
+ // Note that some values (such as the PDU type and PDU family) are set
+ // automatically when you create the ESPDU.
+ espdu.setExerciseID((byte)1); //(short) 1);
+
+ // The EID is the unique identifier for objects in the world. This
+ // EID should match up with the ID for the object specified in the
+ // VMRL/x3d/virtual world.
+
+ EntityID entityID = espdu.getEntityID(); // initialize, reset, override
+ // TODO check: 0 is apparently not a valid site number, per DIS specification
+ entityID.setSiteID ((short)1); // TODO utility method to allow int values
+ entityID.setApplicationID((short)2);
+ entityID.setEntityID ((short)3);
+ espdu.setEntityID(entityID);
+
+ // Set the entity type. SISO has a big list of enumerations, so that by
+ // specifying various numbers we can say this is an M1A2 American tank,
+ // the USS Enterprise, and so on. We'll make this a tank. There is a
+ // separate project elsehwhere in this project that implements DIS
+ // enumerations in C++ and Java, but to keep things simple we just use
+ // numbers here.
+
+ // New way using entity jar(s)
+ espdu.setEntityType(new edu.nps.moves.dis7.entities.usa.platform.land.M1A2());
+
+ // Manual way:
+ /*
+ EntityType entityType = espdu.getEntityType();
+ entityType.setEntityKind(EntityKind.PLATFORM); //(short) 1); // Platform (vs lifeform, munition, sensor, etc.)
+ entityType.setCountry(Country.UNITED_STATES_OF_AMERICA_USA); //225); // USA
+ entityType.setDomain(Domain.inst(PlatformDomain.LAND)); // Land (vs air, surface, subsurface, space)
+ entityType.setCategory((byte) 1); // Tank
+ entityType.setSubCategory((byte) 1); // M1 Abrams
+ entityType.setSpecific((byte) 3); // M1A2 Abrams
+ */
+ Set<InetAddress> broadcastAddresses;
+
+ try // Loop through sending N ESPDUs
+ {
+ System.out.println("Sending " + NUMBER_TO_SEND + " sets of packets:"); // + address.toString()
+
+ for (int index = 0; index < NUMBER_TO_SEND; index++) {
+ // DIS time is a pain in the uh, neck. DIS time units are 2^31-1 units per
+ // hour, and time is set to DIS time units from the top of the hour.
+ // This means that if you start sending just before the top of the hour
+ // the time units can roll over to zero as you are sending. The receivers
+ // (escpecially homegrown ones) are often not able to detect rollover
+ // and may start discarding packets as dupes or out of order. We use
+ // an NPS timestamp here, hundredths of a second since the start of the
+ // year. The DIS standard for time is often ignored in the wild; I've seen
+ // people use Unix time (seconds since 1970) and more. Or you can
+ // just stuff idx into the timestamp field to get something that is monotonically
+ // increasing.
+
+ // Note that timestamp is used to detect duplicate and out of order packets.
+ // That means if you DON'T change the timestamp, many implementations will simply
+ // discard subsequent packets that have an identical timestamp. Also, if they
+ // receive a PDU with an timestamp lower than the last one they received, they
+ // may discard it as an earlier, out-of-order PDU. So it is a good idea to
+ // update the timestamp on ALL packets sent.
+ // An alterative approach: actually follow the standard. It's a crazy concept,
+ // but it might just work.
+ int timestamp = disTime.getDisAbsoluteTimestamp();
+ espdu.setTimestamp(timestamp);
+
+ // Set the position of the entity in the world. DIS uses a cartesian
+ // coordinate system with the origin at the center of the earth, the x
+ // axis out at the equator and prime meridian, y out at the equator and
+ // 90 deg east, and z up and out the north pole. To place an object on
+ // the earth's surface you also need a model for the shape of the earth
+ // (it's not a sphere.) All the fancy math necessary to do this is in
+ // the SEDRIS SRM package. There are also some one-off formulas for
+ // doing conversions from, for example, lat/lon/altitude to DIS coordinates.
+ // Here we use those one-off formulas.
+ // Modify the position of the object. This will send the object a little
+ // due east by adding some to the longitude every iteration. Since we
+ // are on the Pacific coast, this sends the object east. Assume we are
+ // at zero altitude. In other worlds you'd use DTED to determine the
+ // local ground altitude at that lat/lon, or you'd just use ground clamping.
+ // The x and y values will change, but the z value should not.
+ //lon = lon + (double)((double)idx / 100000.0);
+ //System.out.println("lla=" + lat + "," + lon + ", 0.0");
+ double direction = Math.pow((double) (-1.0), (double) (index));
+ longitude = longitude + (direction * 0.00006);
+
+ double disCoordinates[] = CoordinateConversions.getXYZfromLatLonDegrees(latitude, longitude, 1.0);
+ Vector3Double location = espdu.getEntityLocation();
+ location.setX(disCoordinates[0]);
+ location.setY(disCoordinates[1]);
+ location.setZ(disCoordinates[2]);
+ System.out.println("===============");
+ System.out.println("Create new PDUs");
+ System.out.println(" latitude, longitude: [" + latitude + ", " + longitude + "]");
+ System.out.println(" coordinate conversion: [" + disCoordinates[0] + ", " + disCoordinates[1] + ", " + disCoordinates[2] + "]");
+
+ location = espdu.getEntityLocation();
+
+ System.out.println("Espdu #" + index + " entityID=[" + entityID.getSiteID()+ "," + entityID.getApplicationID()+ "," + entityID.getEntityID()+ "]");
+ double c[] = {location.getX(), location.getY(), location.getZ()};
+ double lla[] = CoordinateConversions.xyzToLatLonDegrees(c);
+// System.out.println(" DIS entityLocation: [" + location.getX() + "," + location.getY() + "," + location.getZ() + "]");
+ String debugString = " Location (latitude/longitude/altitude): [" + lla[0] + ", " + lla[1] + ", " + lla[2] + "]";
+// System.out.println(debugString);
+
+ // Optionally, we can do some rotation of the entity
+ /*
+ Orientation orientation = espdu.getEntityOrientation();
+ float psi = orientation.getPsi();
+ psi = psi + idx;
+ orientation.setPsi(psi);
+ orientation.setTheta((float)(orientation.getTheta() + idx /2.0));
+ */
+ // You can set other ESPDU values here, such as the velocity, acceleration,
+ // and so on.
+ // Marshal out the espdu object to a byte array, then send a datagram
+ // packet with that data in it.
+ ByteArrayOutputStream baos = new ByteArrayOutputStream();
+ DataOutputStream dos = new DataOutputStream(baos);
+ DatagramPacket packet;
+
+ // The byte array here is the packet in DIS format. We put that into a
+ // datagram and send it.
+ espdu.marshal(dos);
+ byte[] espduArray = baos.toByteArray();
+
+ FirePdu firePdu = new FirePdu();
+ firePdu.setLocationInWorldCoordinates(espdu.getEntityLocation());
+ byte[] fireArray = firePdu.marshal();
+
+ broadcastAddresses = getBroadcastAddresses();
+ Iterator iterator = broadcastAddresses.iterator();
+ while (iterator.hasNext())
+ {
+ InetAddress broadcast = (InetAddress) iterator.next();
+ if (espduArray.length > 0)
+ {
+ System.out.println("Sending espdu datagram packet to " + broadcast);
+ packet = new DatagramPacket(espduArray, espduArray.length, broadcast, port);
+ socket.send(packet);
+ }
+ // TODO experiment with these! 8)
+ if (fireArray.length > 0)
+ {
+ System.out.println("Sending fire datagram packet to " + broadcast);
+ packet = new DatagramPacket(fireArray, fireArray.length, broadcast, port); // alternate
+ socket.send(packet);
+ }
+ }
+
+ // Send every 1 second within loop. Otherwise all this will be all over in a fraction of a second.
+ Thread.sleep(1000); // msec
+ }
+ }
+ catch (Exception e)
+ {
+ System.out.println("Problem with DisExamplesOpenDis7.EspduSender, see exception trace:");
+ System.out.println(e);
+ }
+ System.out.println("===============");
+ System.out.println("DisExamplesOpenDis7.EspduSender complete.");
+ }
+
+ /**
+ * A number of sites get all snippy about using 255.255.255.255 for a
+ * broadcast address; it trips their security software and they kick you off
+ * their network. (Comcast, NPS, etc.) This determines the broadcast address for
+ * all connected interfaces, based on the IP and subnet mask. If you have a
+ * dual-homed host it will return a broadcast address for both. If you have
+ * some VMs running on your host this will pick up the addresses for those
+ * as well--e.g. running VMWare on your laptop with a local IP this will also
+ * pick up a 192.168 address assigned to the VM by the host OS.
+ *
+ * @return set of all broadcast addresses
+ */
+ public static Set<InetAddress> getBroadcastAddresses()
+ {
+ Set<InetAddress> broadcastAddresses = new HashSet<>();
+ Enumeration interfaces;
+
+ try {
+ interfaces = NetworkInterface.getNetworkInterfaces();
+
+ while (interfaces.hasMoreElements())
+ {
+ NetworkInterface anInterface = (NetworkInterface) interfaces.nextElement();
+
+ if (anInterface.isUp())
+ {
+ Iterator iterator = anInterface.getInterfaceAddresses().iterator();
+ while (iterator.hasNext())
+ {
+ InterfaceAddress anAddress = (InterfaceAddress) iterator.next();
+ if ((anAddress == null || anAddress.getAddress().isLinkLocalAddress()))
+ {
+ continue;
+ }
+
+ //System.out.println("Getting broadcast address for " + anAddress);
+ InetAddress broadcastAddress = anAddress.getBroadcast();
+ if (broadcastAddress != null)
+ {
+ broadcastAddresses.add(broadcastAddress);
+ }
+ }
+ }
+ }
+ }
+ catch (SocketException e)
+ {
+ System.out.println("Problem with DisExamplesOpenDis7.EspduSender.getBroadcastAddresses(), see exception trace:");
+ System.out.println(e);
+ }
+ return broadcastAddresses;
+ }
+}
diff --git a/examples/src/OpenDis7Examples/PduListenerSaver.java b/examples/src/OpenDis7Examples/PduListenerSaver.java
index 88be82c203c1ab9e3a70a53c5cee01b4c3378a30..63c382bb2b19d0031a39b4649f26243ad2f50d6b 100644
--- a/examples/src/OpenDis7Examples/PduListenerSaver.java
+++ b/examples/src/OpenDis7Examples/PduListenerSaver.java
@@ -17,7 +17,7 @@ import java.util.Scanner;
*/
public class PduListenerSaver
{
- private final static String DEFAULT_OUTPUTDIR = "./pduLog";
+ private final static String DEFAULT_OUTPUTDIR = "pduLog";
private final static String MCAST_ADDR = "239.1.2.3";
private final static int DIS_PORT = 3000;
@@ -32,6 +32,8 @@ public class PduListenerSaver
String outDir = DEFAULT_OUTPUTDIR;
String mcast = MCAST_ADDR;
int port = DIS_PORT;
+
+ System.out.println("DisExamplesOpenDis7.PduListenerSaver started...");
switch (args.length) {
case 0:
@@ -55,28 +57,33 @@ public class PduListenerSaver
recorder.startResume();
mystate state = mystate.RUNNING;
+ System.out.println("* recorder.startResume(), state=RUNNING, recording in progress...");
Scanner scan = new Scanner(System.in);
while (true) {
- System.out.println("Type p/enter to pause, r/enter to resume, q/enter to quit");
+ System.out.println("Warning: you must quit when complete, otherwise recorded PDUs are lost!");
+ System.out.println("Type p/enter to pause, r/enter to resume, q/enter to stop recording, save and quit");
String line = scan.nextLine();
if (line.equalsIgnoreCase("p") && state == mystate.RUNNING) {
recorder.stopPause();
state = mystate.PAUSED;
+ System.out.println("* recorder.stopPause(), state=PAUSED, recording paused...");
}
else if (line.equalsIgnoreCase("r") && state == mystate.PAUSED) {
recorder.startResume();
state = mystate.RUNNING;
+ System.out.println("* recorder.startResume(), state=RUNNING, recording in progress...");
}
else if (line.equalsIgnoreCase("q")) {
recorder.end();
+ System.out.println("* recorder.end(), recording complete.");
break;
}
}
System.out.println("Ending pdu save to "+recorder.getLogFile());
}
catch (IOException ex) {
- System.err.println("Exception: " + ex.getClass().getSimpleName() + ": " + ex.getLocalizedMessage());
+ System.err.println("*** Exception: " + ex.getClass().getSimpleName() + ": " + ex.getLocalizedMessage());
}
}
}
diff --git a/examples/src/OpenDis7Examples/PduListenerSaverLog.txt b/examples/src/OpenDis7Examples/PduListenerSaverLog.txt
new file mode 100644
index 0000000000000000000000000000000000000000..81a25d029e4b071344000167aa16232be6576ce6
--- /dev/null
+++ b/examples/src/OpenDis7Examples/PduListenerSaverLog.txt
@@ -0,0 +1,25 @@
+Invocation instructions:
+
+1. run or debug PduListenerSaver.java
+2. send PDUs from another program such as AllPduSender.java (used here)
+3. also running AllPduReceiver can confirm that DIS replay actually occurs.
+4. Type p/enter to pause, r/enter to resume, q/enter to quit
+5. if Pdusave.dislog file(s) already exist, your recording will be added.
+6. note existence of recorded files in directory, e.g. examples/pduLog/Pdusave.dislog
+7. rename/cut/paste your recording file to keep track of your results.
+
+Program response:
+
+===================================================
+
+DisExamplesOpenDis7.PduListenerSaver started...
+Beginning pdu save to directory pduLog
+* recorder.startResume(), state=RUNNING
+Warning: you must quit when complete, otherwise recorded PDUs are lost!
+Type p/enter to pause, r/enter to resume, q/enter to quit
+q
+
+Recorder log file closed
+* recorder.end(), recording complete.
+Ending pdu save to C:\x-nps-gitlab\NetworkedGraphicsMV3500\examples\pduLog\Pdusave2.dislog
+BUILD SUCCESSFUL (total time: 33 seconds)
diff --git a/presentations/09_HLA_HighLevelArchitecture.pptx b/presentations/09_HLA_HighLevelArchitecture.pptx
index ee69369518d4f2ad450bb2d51d390361196c7066..f11a791bd79df548179e9c057cc902576d02c65d 100644
Binary files a/presentations/09_HLA_HighLevelArchitecture.pptx and b/presentations/09_HLA_HighLevelArchitecture.pptx differ