diff --git a/examples/nbproject/project.properties b/examples/nbproject/project.properties
index dffc8e3c5d7fb220a16d59fe993179ed2ad7aae3..17414dd8367f0ee3faccc308ef8f10ccaa13eb13 100644
--- a/examples/nbproject/project.properties
+++ b/examples/nbproject/project.properties
@@ -35,15 +35,15 @@ endorsed.classpath=
excludes=
file.reference.dis-enums-1.3.jar=../lib/dis-enums-1.3.jar
file.reference.open-dis7-entities-all.jar=../lib/open-dis7-entities-all.jar
-file.reference.open-dis7.jar=../lib/open-dis7.jar
+file.reference.open-dis7-java.jar=../lib/open-dis7-java.jar
file.reference.open-dis_4.16.jar=../lib/open-dis_4.16.jar
includes=**
jar.compress=false
javac.classpath=\
- ${file.reference.open-dis7.jar}:\
+ ${file.reference.open-dis7-java.jar}:\
${file.reference.open-dis7-entities-all.jar}:\
- ${file.reference.dis-enums-1.3.jar}:\
- ${file.reference.open-dis_4.16.jar}
+ ${file.reference.open-dis_4.16.jar}:\
+ ${file.reference.dis-enums-1.3.jar}
# Space-separated list of extra javac options
javac.compilerargs=
javac.deprecation=false
@@ -69,6 +69,7 @@ javadoc.noindex=false
javadoc.nonavbar=false
javadoc.notree=false
javadoc.private=false
+javadoc.reference.open-dis7-java.jar=../lib/open-dis7-javadoc.jar
javadoc.splitindex=true
javadoc.use=true
javadoc.version=false
@@ -95,4 +96,5 @@ run.test.classpath=\
run.test.modulepath=\
${javac.test.modulepath}
source.encoding=UTF-8
+source.reference.open-dis7-java.jar=../lib/open-dis7-source.jar
src.dir=src
diff --git a/examples/src/OpenDis7Examples/EspduReceiver.java b/examples/src/OpenDis7Examples/EspduReceiver.java
old mode 100644
new mode 100755
index ed77750a13dca9f77ea2360412244f7cb67ebb7b..caaa12f8083683e26b4015af6c30c6c5514f95ec
--- a/examples/src/OpenDis7Examples/EspduReceiver.java
+++ b/examples/src/OpenDis7Examples/EspduReceiver.java
@@ -1,84 +1,81 @@
-package OpenDis7Examples;
-
-import java.io.*;
-import java.net.*;
-import java.util.*;
-
-import edu.nps.moves.dis7.*;
-import edu.nps.moves.dis7.util.*;
-import edu.nps.moves.disenum.PduType;
-
-/**
- * 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 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 = "239.1.2.3";
-
- /** Default multicast port used, matches Wireshark DIS capture default */
- public static final int DEFAULT_MULTICAST_PORT = 3000;
-
- 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(EspduSender.DEFAULT_MULTICAST_GROUP);
- // 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());
- if (pduBundle.size() > 1)
- System.out.println("Bundle size is " + pduBundle.size());
- Iterator iterator = pduBundle.iterator();
-
- while(iterator.hasNext())
- {
- Pdu aPdu = (Pdu)iterator.next();
-
- System.out.println("received PDU " + aPdu.getPduType().getValue() + " " + aPdu.getPduType().name() + " of type " + aPdu.getClass().getName());
- if(aPdu instanceof EntityStatePdu)
- {
- EntityID eid = ((EntityStatePdu)aPdu).getEntityID();
- Vector3Double position = ((EntityStatePdu)aPdu).getEntityLocation();
- System.out.println(" ID triplet: [" + eid.getSiteID()+ ", " + eid.getApplicationID()+ ", " + eid.getEntityID()+ "] ");
- System.out.println(" Location in DIS coordinates: [" + position.getX() + ", " + position.getY() + ", " + position.getZ() + "]");
-// TODO fix library!
- System.out.println("** TODO error, 'PDU not implemented' is a library bug");
- }
- } // end iterator loop through PDU bundle
- } // end while
- } // End try
- 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
+package OpenDis7Examples;
+
+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 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 = "239.1.2.3";
+
+ /** Default multicast port used, matches Wireshark DIS capture default */
+ public static final int DEFAULT_MULTICAST_PORT = 3000;
+
+ 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(EspduSender.DEFAULT_MULTICAST_GROUP);
+ // 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();
+
+ System.out.println("received PDU " + aPdu.getPduType().getValue() + " " + aPdu.getPduType().name() + " of type " + aPdu.getClass().getName());
+ if(aPdu instanceof EntityStatePdu)
+ {
+ EntityID eid = ((EntityStatePdu)aPdu).getEntityID();
+ Vector3Double position = ((EntityStatePdu)aPdu).getEntityLocation();
+ System.out.println(" ID triplet: [" + eid.getSiteID()+ ", " + eid.getApplicationID()+ ", " + eid.getEntityID()+ "] ");
+ System.out.println(" Location in DIS coordinates: [" + position.getX() + ", " + position.getY() + ", " + position.getZ() + "]");
+ }
+ } // end iterator loop through PDU bundle
+ } // end while
+ } // End try
+ 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/examples/src/OpenDis7Examples/PduSender.java b/examples/src/OpenDis7Examples/PduSender.java
old mode 100644
new mode 100755
index 2198c129051e6a7bd76352af26c3e6b87304e136..72116cf4f53fe0cda5a6da13cf4432f2834d92bf
--- a/examples/src/OpenDis7Examples/PduSender.java
+++ b/examples/src/OpenDis7Examples/PduSender.java
@@ -1,502 +1,441 @@
-package OpenDis7Examples;
-
-import java.io.*;
-import java.net.*;
-import java.util.*;
-
-import edu.nps.moves.dis7.*;
-import edu.nps.moves.dis7.enumerations.*;
-
-/**
- * This is an example that sends many/most types of PDUs. Useful for testing standards
- * compliance or getting a full set of PDUs. It also writes the generated PDUs to an XML file.
- * Adapted from OpenDIS library example package edu.nps.moves.examples
- *
- * @author DMcG
- * @version $Id:$
- */
-public class PduSender
-{
- /** 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;
-
- private int port;
- InetAddress multicastAddress;
-
- public PduSender(int port, String multicast) {
- try
- {
- this.port = port;
- multicastAddress = InetAddress.getByName(multicast);
- if (!multicastAddress.isMulticastAddress())
- {
- System.out.println("Not a multicast address: " + multicast);
- }
- }
- catch (UnknownHostException e) {
- System.out.println("Unable to open socket: " + e);
- }
- }
-
- public void run()
- {
- System.out.println("DisExamplesOpenDis7.PduSender started...");
- try
- {
- System.out.println("Generate PDUs and note issues (if any)...");
- List<Pdu> generatedPdusList = new ArrayList<>();
-
- // Loop through all the enumerated PDU types, create a PDU for each type,
- // add that PDU to generatedPdusList, and send each one
- for (DISPDUType pdu : DISPDUType.values())
- {
-// System.out.println("PDU " + pdu.getValue() + " " + pdu.name() + " " + pdu.getDescription()); // diagnostic
-
- Pdu aPdu = null; // edu.​nps.​moves7.​dis.PDU superclass for all PDUs, in preparation for custom assignment
-
- try {
- switch (pdu) // using enumeration values from edu.​nps.​moves.​dis7.​enumerations.​DISPDUType
- {
- case OTHER: // 0
- System.out.println ("*** Note: DISPDUType." + pdu.name() + " not supported"); // TODO explain
- // nothing to send
- break;
-
- case ENTITY_STATE: // 1
- aPdu = new EntityStatePdu();
-
- EntityStatePdu espdu = (EntityStatePdu) aPdu;
- EntityMarking entityMarking = new EntityMarking ();
- entityMarking.setCharacters("PduSender".getBytes()); //entityMarking.setCharacters(Byte.valueOf("0")); // 11 characters max?
-
- espdu.setMarking(entityMarking);
- Vector3Double espduLocation = new Vector3Double();
- espduLocation.setX(1.0);
- espduLocation.setY(2.0);
- espduLocation.setZ(3.0);
- espdu.setEntityLocation(espduLocation);
- // it is important to identify questions as you think of them
- // TODO how to set azimuth, i.e. course direction over ground?
- break;
-
- case FIRE: // 2
- aPdu = new FirePdu();
- break;
-
- case DETONATION: // 3
- aPdu = new DetonationPdu();
- break;
-
- case COLLISION: // 4
- aPdu = new CollisionPdu();
- break;
-
- case SERVICE_REQUEST: // 5
- aPdu = new ServiceRequestPdu();
- break;
-
- case RESUPPLY_OFFER: // 6
- aPdu = new ResupplyOfferPdu();
- break;
-
- case RESUPPLY_RECEIVED: // 7
- aPdu = new ResupplyReceivedPdu();
- break;
-
- case RESUPPLY_CANCEL: //8
- aPdu = new ResupplyCancelPdu();
- break;
-
- case REPAIR_COMPLETE: // 9
- aPdu = new RepairCompletePdu();
- break;
-
- case REPAIR_RESPONSE: // 10
- aPdu = new RepairResponsePdu();
- break;
-
- case CREATE_ENTITY: // 11
- aPdu = new CreateEntityPdu();
- break;
-
- case REMOVE_ENTITY: // 12
- aPdu = new RemoveEntityPdu();
- break;
-
- case START_RESUME: // 13
- aPdu = new StartResumePdu();
- break;
-
- case STOP_FREEZE: // 14
- aPdu = new StopFreezePdu();
- break;
-
- case ACKNOWLEDGE: // 15
- aPdu = new AcknowledgePdu();
- break;
-
- case ACTION_REQUEST: // 16
- aPdu = new ActionRequestPdu();
- break;
-
- case ACTION_RESPONSE: // 17
- aPdu = new ActionResponsePdu();
- break;
-
- case DATA_QUERY: // 18
- aPdu = new DataQueryPdu();
- break;
-
- case SET_DATA: // 19
- aPdu = new SetDataPdu();
- break;
-
- case DATA: // 20
- aPdu = new DataPdu();
- break;
-
- case EVENT_REPORT: // 21
- aPdu = new EventReportPdu();
- break;
-
- case ELECTROMAGNETIC_EMISSION: // 23
- aPdu = new ElectromagneticEmissionPdu();
- break;
-
- case DESIGNATOR: // 24
- aPdu = new DesignatorPdu();
- break;
-
- case TRANSMITTER: // 25
- aPdu = new TransmitterPdu();
- break;
-
- case SIGNAL: // 26
- aPdu = new SignalPdu();
- break;
-
- case RECEIVER: // 27
- aPdu = new ReceiverPdu();
- break;
-
- case IDENTIFICATION_FRIEND_OR_FOE: // 28
- aPdu = new IdentificationFriendOrFoePdu();
- break;
- case IFF: // 28
-// aPdu = new IFFPdu(); // ignore, avoid sending duplicate
- break;
-
- case UNDERWATER_ACOUSTIC: // 29
- aPdu = new UnderwaterAcousticPdu();
- break;
-
- case SUPPLEMENTAL_EMISSION_ENTITY_STATE: // 30
- aPdu = new SupplementalEmissionEntityStatePdu();
- break;
-
- case SEES: // 30
-// aPdu = new SEESPdu(); // ignore, avoid sending duplicate
- break;
-
- case INTERCOM_SIGNAL: // 31
- aPdu = new IntercomSignalPdu();
- break;
-
- case INTERCOM_CONTROL: // 32
- aPdu = new IntercomControlPdu();
- break;
-
- case AGGREGATE_STATE: // 33
- aPdu = new AggregateStatePdu();
- break;
-
- case ISGROUPOF: // 34
- aPdu = new IsGroupOfPdu();
- break;
-
- case TRANSFER_OWNERSHIP: // 35
- aPdu = new TransferOwnershipPdu();
- break;
-
- case ISPARTOF: // 36
- aPdu = new IsPartOfPdu();
- break;
-
- case MINEFIELD_STATE: // 37
- aPdu = new MinefieldStatePdu();
- break;
-
- case MINEFIELD_QUERY: // 38
- aPdu = new MinefieldQueryPdu();
- break;
-
- case MINEFIELD_DATA: // 39
- aPdu = new MinefieldDataPdu();
- break;
-
- case MINEFIELD_RESPONSE_NACK: // 40
- aPdu = new MinefieldResponseNACKPdu();
- break;
-
- case ENVIRONMENTAL_PROCESS: // 41
- aPdu = new EnvironmentalProcessPdu();
- break;
-
- case GRIDDED_DATA: // 42
- aPdu = new GriddedDataPdu();
- break;
-
- case POINT_OBJECT_STATE: // 43
- aPdu = new PointObjectStatePdu();
- break;
-
- case LINEAR_OBJECT_STATE: // 44
- aPdu = new LinearObjectStatePdu();
- break;
-
- case AREAL_OBJECT_STATE: // 45
- aPdu = new ArealObjectStatePdu();
- break;
-
- case TIME_SPACE_POSITION_INFORMATION: // 46
- aPdu = new TimeSpacePositionInformationPdu();
- break;
- case TSPI: // 46
-// aPdu = new TSPIPdu(); // ignore, avoid sending duplicate
- break;
-
- case APPEARANCE: // 47
- aPdu = new AppearancePdu();
- break;
-
- case ARTICULATED_PARTS: // 48
- aPdu = new ArticulatedPartsPdu();
- break;
-
- case LIVE_ENTITY_FIRE: // 49
- aPdu = new LiveEntityFirePdu();
- break;
- case LE_FIRE: // 49
-// aPdu = new LEFirePdu(); // ignore, avoid sending duplicate
- break;
-
- case LIVE_ENTITY_DETONATION: // 50
- aPdu = new LiveEntityDetonationPdu();
- break;
- case LE_DETONATION: // 50
-// aPdu = new LEDetonationPdu(); // ignore, avoid sending duplicate
- break;
-
- case CREATE_ENTITY_RELIABLE: // 51
- aPdu = new CreateEntityReliablePdu();
- break;
- case CREATE_ENTITY_R: // 51
-// aPdu = new CreateEntityRPdu(); // ignore, avoid sending duplicate
- break;
-
- case REMOVE_ENTITY_RELIABLE: // 52
- aPdu = new RemoveEntityReliablePdu();
- break;
- case REMOVE_ENTITY_R: // 52
-// aPdu = new RemoveEntityRPdu(); // ignore, avoid sending duplicate
- break;
-
- case START_RESUME_RELIABLE: // 53
- aPdu = new StartResumeReliablePdu();
- break;
- case START_RESUME_R: // 53
-// aPdu = new StartResumeRPdu(); // ignore, avoid sending duplicate
- break;
-
- case STOP_FREEZE_RELIABLE: // 54
- aPdu = new StopFreezeReliablePdu();
- break;
- case STOP_FREEZE_R: // 54
-// aPdu = new StopFreezeRPdu(); // ignore, avoid sending duplicate
- break;
-
- case ACKNOWLEDGE_RELIABLE: // 55
- aPdu = new AcknowledgeReliablePdu();
- break;
- case ACKNOWLEDGE_R: // 55
-// aPdu = new AcknowledgeRPdu(); // ignore, avoid sending duplicate
- break;
-
- case ACTION_REQUEST_RELIABLE: // 56
- aPdu = new ActionRequestReliablePdu();
- break;
- case ACTION_REQUEST_R: // 56
-// aPdu = new ActionRequestRPdu(); // ignore, avoid sending duplicate
- break;
-
- case ACTION_RESPONSE_RELIABLE: // 57
- aPdu = new ActionResponseReliablePdu();
- break;
- case ACTION_RESPONSE_R: // 57
-// aPdu = new ActionResponseRPdu(); // ignore, avoid sending duplicate
- break;
-
- case DATA_QUERY_RELIABLE: // 58
- aPdu = new DataQueryReliablePdu();
- break;
- case DATA_QUERY_R: // 58
-// aPdu = new DataQueryRPdu(); // ignore, avoid sending duplicate
- break;
-
- case SET_DATA_RELIABLE: // 59
- aPdu = new SetDataReliablePdu();
- break;
- case SET_DATA_R: // 59
-// aPdu = new SetDataRPdu(); // ignore, avoid sending duplicate
- break;
-
- case DATA_RELIABLE: // 60
- aPdu = new DataReliablePdu();
- break;
- case DATA_R: // 60
-// aPdu = new DataRPdu(); // ignore, avoid sending duplicate
- break;
-
- case EVENT_REPORT_RELIABLE: // 61
- aPdu = new EventReportReliablePdu();
- break;
- case EVENT_REPORT_R: // 61
-// aPdu = new EventReportRPdu(); // ignore, avoid sending duplicate
- break;
-
- case COMMENT_RELIABLE: // 62
- aPdu = new CommentReliablePdu();
- break;
- case COMMENT_R: // 62
-// aPdu = new CommentRPdu(); // ignore, avoid sending duplicate
- break;
-
- case RECORD_RELIABLE: // 63
- aPdu = new RecordReliablePdu();
- break;
- case RECORD_R: // 63
-// aPdu = new RecordRPdu(); // ignore, avoid sending duplicate
- break;
-
- case SET_RECORD_RELIABLE: // 64
- aPdu = new SetRecordReliablePdu();
- break;
- case SET_RECORD_R: // 64
-// aPdu = new SetRecordRPdu(); // ignore, avoid sending duplicate
- break;
-
- case RECORD_QUERY_RELIABLE: // 65
- aPdu = new RecordQueryReliablePdu();
- break;
- case RECORD_QUERY_R: // 65
-// aPdu = new RecordQueryRPdu(); // ignore, avoid sending duplicate
- break;
-
- case COLLISION_ELASTIC: // 66
- aPdu = new CollisionElasticPdu();
- break;
-
- case ENTITY_STATE_UPDATE: // 67
- aPdu = new EntityStateUpdatePdu();
- break;
-
- case DIRECTED_ENERGY_FIRE: // 68
- aPdu = new DirectedEnergyFirePdu();
- break;
-
- case ENTITY_DAMAGE_STATUS: // 69
- aPdu = new EntityDamageStatusPdu();
- break;
-
- case INFORMATION_OPERATIONS_ACTION: // 70
- aPdu = new InformationOperationsActionPdu();
- break;
-
- case INFORMATION_OPERATIONS_REPORT: // 71
- aPdu = new InformationOperationsReportPdu();
- break;
-
- case ATTRIBUTE: // 72
- aPdu = new AttributePdu();
- break;
-
- case COMMENT:
- aPdu = new CommentPdu();
- CommentPdu newCommentPdu = (CommentPdu)aPdu;
- VariableDatum newVariableDatum = new VariableDatum();
- // etc. see Garrett and Pete's code
- break;
-
- default:
- System.out.println("*** Warning: PDU " + pdu.getValue() + " " + pdu + " not supported, created or sent ");
-
- // code generation block for this class follows:
-// System.out.println(" case " + pdu + ": // " + pdu.getValue());
-// System.out.println(" aPdu = new " + pdu.getDescription().replace(" ","").replace("-","").replace("/","") +
-// "Pdu();");
-// System.out.println(" break;");
-// System.out.println();
- }
- if (aPdu != null)
- {
- generatedPdusList.add(aPdu);
- }
- }
- catch (Exception e)
- {
- System.out.print("Exception thrown for PDU " + pdu.getValue() + " " + pdu);
- System.out.print(Arrays.toString(e.getStackTrace()));
- // continue looping
- }
- }
- // Send the PDUs we created
- System.out.println("Send the " + generatedPdusList.size() + " PDUs we created...");
-
- InetAddress localMulticastAddress = InetAddress.getByName(DEFAULT_MULTICAST_ADDRESS);
- MulticastSocket socket = new MulticastSocket(DEFAULT_MULTICAST_PORT);
- socket.joinGroup(localMulticastAddress);
-
- for (int idx = 0; idx < generatedPdusList.size(); idx++)
- {
- ByteArrayOutputStream baos = new ByteArrayOutputStream();
- DataOutputStream dos = new DataOutputStream(baos);
- byte[] buffer;
-
- Pdu aPdu = generatedPdusList.get(idx);
- aPdu.marshal(dos);
-
- buffer = baos.toByteArray();
- DatagramPacket packet = new DatagramPacket(buffer, buffer.length, localMulticastAddress, DEFAULT_MULTICAST_PORT);
- socket.send(packet);
- System.out.println("Sent PDU " + aPdu.getPduType().getValue() + " " + aPdu.getPduType() + " of type " + aPdu.getClass().getName());
- }
- // write the PDUs out to an XML file.
- //PduContainer container = new PduContainer();
- //container.setPdus(generatedPdus);
- //container.marshallToXml("examplePdus.xml");
- }
- catch (IOException e)
- {
- System.out.println(e);
- }
- }
-
- public static void main(String args[])
- {
- if (args.length == 2)
- {
- PduSender sender = new PduSender(Integer.parseInt(args[0]), args[1]);
- sender.run();
- }
- else
- {
- System.out.println("Usage: PduSender <port> <multicast group>");
- System.out.println("Default: PduSender " + DEFAULT_MULTICAST_PORT + " " + DEFAULT_MULTICAST_ADDRESS);
- PduSender sender = new PduSender(DEFAULT_MULTICAST_PORT, DEFAULT_MULTICAST_ADDRESS);
- sender.run();
- }
- }
-}
+package OpenDis7Examples;
+
+import java.io.*;
+import java.net.*;
+import java.util.*;
+
+import edu.nps.moves.dis7.*;
+import edu.nps.moves.dis7.enumerations.*;
+
+/**
+ * This is an example that sends many/most types of PDUs. Useful for testing standards
+ * compliance or getting a full set of PDUs. It also writes the generated PDUs to an XML file.
+ * Adapted from OpenDIS library example package edu.nps.moves.examples
+ *
+ * @author DMcG
+ * @version $Id:$
+ */
+public class PduSender
+{
+ /** 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;
+
+ private int port;
+ InetAddress multicastAddress;
+
+ public PduSender(int port, String multicast) {
+ try
+ {
+ this.port = port;
+ multicastAddress = InetAddress.getByName(multicast);
+ if (!multicastAddress.isMulticastAddress())
+ {
+ System.out.println("Not a multicast address: " + multicast);
+ }
+ }
+ catch (UnknownHostException e) {
+ System.out.println("Unable to open socket: " + e);
+ }
+ }
+
+ public void run()
+ {
+ System.out.println("DisExamplesOpenDis7.PduSender started...");
+ try
+ {
+ System.out.println("Generate PDUs and note issues (if any)...");
+ List<Pdu> generatedPdusList = new ArrayList<>();
+
+ // Loop through all the enumerated PDU types, create a PDU for each type,
+ // add that PDU to generatedPdusList, and send each one
+ for (DISPDUType pdu : DISPDUType.values())
+ {
+// System.out.println("PDU " + pdu.getValue() + " " + pdu.name() + " " + pdu.getDescription()); // diagnostic
+
+ Pdu aPdu = null; // edu.​nps.​moves7.​dis.PDU superclass for all PDUs, in preparation for custom assignment
+
+ try {
+ switch (pdu) // using enumeration values from edu.​nps.​moves.​dis7.​enumerations.​DISPDUType
+ {
+ case OTHER: // 0
+ System.out.println ("*** Note: DISPDUType." + pdu.name() + " not supported"); // TODO explain
+ // nothing to send
+ break;
+
+ case ENTITY_STATE: // 1
+ aPdu = new EntityStatePdu();
+
+ EntityStatePdu espdu = (EntityStatePdu) aPdu;
+ EntityMarking entityMarking = new EntityMarking ();
+ entityMarking.setCharacters("PduSender".getBytes()); //entityMarking.setCharacters(Byte.valueOf("0")); // 11 characters max?
+
+ espdu.setMarking(entityMarking);
+ Vector3Double espduLocation = new Vector3Double();
+ espduLocation.setX(1.0);
+ espduLocation.setY(2.0);
+ espduLocation.setZ(3.0);
+ espdu.setEntityLocation(espduLocation);
+ // it is important to identify questions as you think of them
+ // TODO how to set azimuth, i.e. course direction over ground?
+ break;
+
+ case FIRE: // 2
+ aPdu = new FirePdu();
+ break;
+
+ case DETONATION: // 3
+ aPdu = new DetonationPdu();
+ break;
+
+ case COLLISION: // 4
+ aPdu = new CollisionPdu();
+ break;
+
+ case SERVICE_REQUEST: // 5
+ aPdu = new ServiceRequestPdu();
+ break;
+
+ case RESUPPLY_OFFER: // 6
+ aPdu = new ResupplyOfferPdu();
+ break;
+
+ case RESUPPLY_RECEIVED: // 7
+ aPdu = new ResupplyReceivedPdu();
+ break;
+
+ case RESUPPLY_CANCEL: //8
+ aPdu = new ResupplyCancelPdu();
+ break;
+
+ case REPAIR_COMPLETE: // 9
+ aPdu = new RepairCompletePdu();
+ break;
+
+ case REPAIR_RESPONSE: // 10
+ aPdu = new RepairResponsePdu();
+ break;
+
+ case CREATE_ENTITY: // 11
+ aPdu = new CreateEntityPdu();
+ break;
+
+ case REMOVE_ENTITY: // 12
+ aPdu = new RemoveEntityPdu();
+ break;
+
+ case START_RESUME: // 13
+ aPdu = new StartResumePdu();
+ break;
+
+ case STOP_FREEZE: // 14
+ aPdu = new StopFreezePdu();
+ break;
+
+ case ACKNOWLEDGE: // 15
+ aPdu = new AcknowledgePdu();
+ break;
+
+ case ACTION_REQUEST: // 16
+ aPdu = new ActionRequestPdu();
+ break;
+
+ case ACTION_RESPONSE: // 17
+ aPdu = new ActionResponsePdu();
+ break;
+
+ case DATA_QUERY: // 18
+ aPdu = new DataQueryPdu();
+ break;
+
+ case SET_DATA: // 19
+ aPdu = new SetDataPdu();
+ break;
+
+ case DATA: // 20
+ aPdu = new DataPdu();
+ break;
+
+ case EVENT_REPORT: // 21
+ aPdu = new EventReportPdu();
+ break;
+
+ case ELECTROMAGNETIC_EMISSION: // 23
+ aPdu = new ElectromagneticEmissionPdu();
+ break;
+
+ case DESIGNATOR: // 24
+ aPdu = new DesignatorPdu();
+ break;
+
+ case TRANSMITTER: // 25
+ aPdu = new TransmitterPdu();
+ break;
+
+ case SIGNAL: // 26
+ aPdu = new SignalPdu();
+ break;
+
+ case RECEIVER: // 27
+ aPdu = new ReceiverPdu();
+ break;
+
+ case IDENTIFICATION_FRIEND_OR_FOE: // 28
+ aPdu = new IdentificationFriendOrFoePdu();
+ break;
+
+ case UNDERWATER_ACOUSTIC: // 29
+ aPdu = new UnderwaterAcousticPdu();
+ break;
+
+ case SUPPLEMENTAL_EMISSION_ENTITY_STATE: // 30
+ aPdu = new SupplementalEmissionEntityStatePdu();
+ break;
+
+ case INTERCOM_SIGNAL: // 31
+ aPdu = new IntercomSignalPdu();
+ break;
+
+ case INTERCOM_CONTROL: // 32
+ aPdu = new IntercomControlPdu();
+ break;
+
+ case AGGREGATE_STATE: // 33
+ aPdu = new AggregateStatePdu();
+ break;
+
+ case ISGROUPOF: // 34
+ aPdu = new IsGroupOfPdu();
+ break;
+
+ case TRANSFER_OWNERSHIP: // 35
+ aPdu = new TransferOwnershipPdu();
+ break;
+
+ case ISPARTOF: // 36
+ aPdu = new IsPartOfPdu();
+ break;
+
+ case MINEFIELD_STATE: // 37
+ aPdu = new MinefieldStatePdu();
+ break;
+
+ case MINEFIELD_QUERY: // 38
+ aPdu = new MinefieldQueryPdu();
+ break;
+
+ case MINEFIELD_DATA: // 39
+ aPdu = new MinefieldDataPdu();
+ break;
+
+ case MINEFIELD_RESPONSE_NACK: // 40
+ aPdu = new MinefieldResponseNACKPdu();
+ break;
+
+ case ENVIRONMENTAL_PROCESS: // 41
+ aPdu = new EnvironmentalProcessPdu();
+ break;
+
+ case GRIDDED_DATA: // 42
+ aPdu = new GriddedDataPdu();
+ break;
+
+ case POINT_OBJECT_STATE: // 43
+ aPdu = new PointObjectStatePdu();
+ break;
+
+ case LINEAR_OBJECT_STATE: // 44
+ aPdu = new LinearObjectStatePdu();
+ break;
+
+ case AREAL_OBJECT_STATE: // 45
+ aPdu = new ArealObjectStatePdu();
+ break;
+
+ case TIME_SPACE_POSITION_INFORMATION: // 46
+ aPdu = new TimeSpacePositionInformationPdu();
+ break;
+
+ case APPEARANCE: // 47
+ aPdu = new AppearancePdu();
+ break;
+
+ case ARTICULATED_PARTS: // 48
+ aPdu = new ArticulatedPartsPdu();
+ break;
+
+ case LIVE_ENTITY_FIRE: // 49
+ aPdu = new LiveEntityFirePdu();
+ break;
+
+ case LIVE_ENTITY_DETONATION: // 50
+ aPdu = new LiveEntityDetonationPdu();
+ break;
+
+ case CREATE_ENTITY_RELIABLE: // 51
+ aPdu = new CreateEntityReliablePdu();
+ break;
+
+ case REMOVE_ENTITY_RELIABLE: // 52
+ aPdu = new RemoveEntityReliablePdu();
+ break;
+
+ case START_RESUME_RELIABLE: // 53
+ aPdu = new StartResumeReliablePdu();
+ break;
+
+ case STOP_FREEZE_RELIABLE: // 54
+ aPdu = new StopFreezeReliablePdu();
+ break;
+
+ case ACKNOWLEDGE_RELIABLE: // 55
+ aPdu = new AcknowledgeReliablePdu();
+ break;
+
+ case ACTION_REQUEST_RELIABLE: // 56
+ aPdu = new ActionRequestReliablePdu();
+ break;
+
+ case ACTION_RESPONSE_RELIABLE: // 57
+ aPdu = new ActionResponseReliablePdu();
+ break;
+
+ case DATA_QUERY_RELIABLE: // 58
+ aPdu = new DataQueryReliablePdu();
+ break;
+
+ case SET_DATA_RELIABLE: // 59
+ aPdu = new SetDataReliablePdu();
+ break;
+
+ case DATA_RELIABLE: // 60
+ aPdu = new DataReliablePdu();
+ break;
+
+ case EVENT_REPORT_RELIABLE: // 61
+ aPdu = new EventReportReliablePdu();
+ break;
+
+ case COMMENT_RELIABLE: // 62
+ aPdu = new CommentReliablePdu();
+ break;
+
+ case RECORD_RELIABLE: // 63
+ aPdu = new RecordReliablePdu();
+ break;
+
+ case SET_RECORD_RELIABLE: // 64
+ aPdu = new SetRecordReliablePdu();
+ break;
+
+ case RECORD_QUERY_RELIABLE: // 65
+ aPdu = new RecordQueryReliablePdu();
+ break;
+
+ case COLLISION_ELASTIC: // 66
+ aPdu = new CollisionElasticPdu();
+ break;
+
+ case ENTITY_STATE_UPDATE: // 67
+ aPdu = new EntityStateUpdatePdu();
+ break;
+
+ case DIRECTED_ENERGY_FIRE: // 68
+ aPdu = new DirectedEnergyFirePdu();
+ break;
+
+ case ENTITY_DAMAGE_STATUS: // 69
+ aPdu = new EntityDamageStatusPdu();
+ break;
+
+ case INFORMATION_OPERATIONS_ACTION: // 70
+ aPdu = new InformationOperationsActionPdu();
+ break;
+
+ case INFORMATION_OPERATIONS_REPORT: // 71
+ aPdu = new InformationOperationsReportPdu();
+ break;
+
+ case ATTRIBUTE: // 72
+ aPdu = new AttributePdu();
+ break;
+
+ case COMMENT:
+ aPdu = new CommentPdu();
+ CommentPdu newCommentPdu = (CommentPdu)aPdu;
+ VariableDatum newVariableDatum = new VariableDatum();
+ // etc. see Garrett and Pete's code
+ break;
+
+ default:
+ System.out.println("*** Warning: PDU " + pdu.getValue() + " " + pdu + " not supported, created or sent ");
+
+ // code generation block for this class follows:
+// System.out.println(" case " + pdu + ": // " + pdu.getValue());
+// System.out.println(" aPdu = new " + pdu.getDescription().replace(" ","").replace("-","").replace("/","") +
+// "Pdu();");
+// System.out.println(" break;");
+// System.out.println();
+ }
+ if (aPdu != null)
+ {
+ generatedPdusList.add(aPdu);
+ }
+ }
+ catch (Exception e)
+ {
+ System.out.print("Exception thrown for PDU " + pdu.getValue() + " " + pdu);
+ System.out.print(Arrays.toString(e.getStackTrace()));
+ // continue looping
+ }
+ }
+ // Send the PDUs we created
+ System.out.println("Send the " + generatedPdusList.size() + " PDUs we created...");
+
+ InetAddress localMulticastAddress = InetAddress.getByName(DEFAULT_MULTICAST_ADDRESS);
+ MulticastSocket socket = new MulticastSocket(DEFAULT_MULTICAST_PORT);
+ socket.joinGroup(localMulticastAddress);
+
+ for (int idx = 0; idx < generatedPdusList.size(); idx++)
+ {
+ ByteArrayOutputStream baos = new ByteArrayOutputStream();
+ DataOutputStream dos = new DataOutputStream(baos);
+ byte[] buffer;
+
+ Pdu aPdu = generatedPdusList.get(idx);
+ aPdu.marshal(dos);
+
+ buffer = baos.toByteArray();
+ DatagramPacket packet = new DatagramPacket(buffer, buffer.length, localMulticastAddress, DEFAULT_MULTICAST_PORT);
+ socket.send(packet);
+ System.out.println("Sent PDU " + aPdu.getPduType().getValue() + " " + aPdu.getPduType() + " of type " + aPdu.getClass().getName());
+ }
+ // write the PDUs out to an XML file.
+ //PduContainer container = new PduContainer();
+ //container.setPdus(generatedPdus);
+ //container.marshallToXml("examplePdus.xml");
+ }
+ catch (IOException e)
+ {
+ System.out.println(e);
+ }
+ }
+
+ public static void main(String args[])
+ {
+ if (args.length == 2)
+ {
+ PduSender sender = new PduSender(Integer.parseInt(args[0]), args[1]);
+ sender.run();
+ }
+ else
+ {
+ System.out.println("Usage: PduSender <port> <multicast group>");
+ System.out.println("Default: PduSender " + DEFAULT_MULTICAST_PORT + " " + DEFAULT_MULTICAST_ADDRESS);
+ PduSender sender = new PduSender(DEFAULT_MULTICAST_PORT, DEFAULT_MULTICAST_ADDRESS);
+ sender.run();
+ }
+ }
+}