Skip to content
Snippets Groups Projects
Commit 3464fa18 authored by coltonfetterolf's avatar coltonfetterolf
Browse files

Corrected improper rename of classes.

parent 6eee4301
No related branches found
No related tags found
No related merge requests found
...@@ -9,81 +9,76 @@ import java.io.IOException; ...@@ -9,81 +9,76 @@ import java.io.IOException;
import java.util.Scanner; import java.util.Scanner;
/** /**
* PduSaver.java created on Aug 21, 2019 * PduSaver.java created on Aug 21, 2019 MOVES Institute Naval Postgraduate
* MOVES Institute Naval Postgraduate School, Monterey, CA, USA www.nps.edu * School, Monterey, CA, USA www.nps.edu
* *
* @author Mike Bailey, jmbailey@nps.edu * @author Mike Bailey, jmbailey@nps.edu
* @version $Id$ * @version $Id$
*/ */
public class PduListenerSaver public class FetterolfPduListenerSaver {
{
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 private final static String DEFAULT_OUTPUTDIR = "pduLog";
{ private final static String MCAST_ADDR = "239.1.2.3";
RUNNING, private final static int DIS_PORT = 3000;
PAUSED;
}
public static void main(String[] args) private enum mystate {
{ RUNNING,
String outDir = DEFAULT_OUTPUTDIR; PAUSED;
String mcast = MCAST_ADDR;
int port = DIS_PORT;
System.out.println("DisExamplesOpenDis7.PduListenerSaver 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: PduListener() or PduListener(\"outputdir\") or PduListener(\"outputdir\",\"multicast address\", ipPort");
System.exit(1);
} }
System.out.println("Beginning pdu save to directory " + outDir); public static void main(String[] args) {
try { String outDir = DEFAULT_OUTPUTDIR;
Recorder recorder = new Recorder(outDir, mcast, port); String mcast = MCAST_ADDR;
int port = DIS_PORT;
recorder.startResume(); System.out.println("DisExamplesOpenDis7.PduListenerSaver started...");
mystate state = mystate.RUNNING;
System.out.println("* recorder.startResume(), state=RUNNING, recording in progress...");
Scanner scan = new Scanner(System.in);
while (true) { switch (args.length) {
System.out.println("Warning: you must quit when complete, otherwise recorded PDUs are lost!"); case 0:
System.out.println("Type p/enter to pause, r/enter to resume, q/enter to stop recording, save and quit"); break;
String line = scan.nextLine(); case 1:
if (line.equalsIgnoreCase("p") && state == mystate.RUNNING) { outDir = args[0];
recorder.stopPause(); break;
state = mystate.PAUSED; case 3:
System.out.println("* recorder.stopPause(), state=PAUSED, recording paused..."); outDir = args[0];
} mcast = args[1];
else if (line.equalsIgnoreCase("r") && state == mystate.PAUSED) { port = Integer.parseInt(args[2]);
recorder.startResume(); break;
state = mystate.RUNNING; default:
System.out.println("* recorder.startResume(), state=RUNNING, recording in progress..."); System.err.println("Usage: PduListener() or PduListener(\"outputdir\") or PduListener(\"outputdir\",\"multicast address\", ipPort");
System.exit(1);
} }
else if (line.equalsIgnoreCase("q")) {
recorder.end(); System.out.println("Beginning pdu save to directory " + outDir);
System.out.println("* recorder.end(), recording complete."); try {
break; Recorder recorder = new Recorder(outDir, mcast, port);
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("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.out.println("Ending pdu save to "+recorder.getLogFile());
}
catch (IOException ex) {
System.err.println("*** Exception: " + ex.getClass().getSimpleName() + ": " + ex.getLocalizedMessage());
} }
}
} }
...@@ -8,87 +8,82 @@ import edu.nps.moves.dis7.enumerations.*; ...@@ -8,87 +8,82 @@ import edu.nps.moves.dis7.enumerations.*;
import edu.nps.moves.dis7.util.*; import edu.nps.moves.dis7.util.*;
import java.util.ArrayList; import java.util.ArrayList;
public class AllPduReceiver public class FetterolfPduReceiver {
{
public static final int DEFAULT_MULTICAST_PORT = AllPduSender.DEFAULT_MULTICAST_PORT;
public static final String DEFAULT_MULTICAST_ADDRESS = AllPduSender.DEFAULT_MULTICAST_ADDRESS;
public static final boolean USE_FAST_ESPDU = false;
public static void main(String args[]) public static final int DEFAULT_MULTICAST_PORT = FetterolfPduReceiver.DEFAULT_MULTICAST_PORT;
{ public static final String DEFAULT_MULTICAST_ADDRESS = FetterolfPduReceiver.DEFAULT_MULTICAST_ADDRESS;
PduFactory factory; public static final boolean USE_FAST_ESPDU = false;
MulticastSocket socket;
InetAddress address;
DatagramPacket packet;
try { public static void main(String args[]) {
System.out.println("DisExamplesOpenDis7.AllPduReceiver started..."); PduFactory factory;
if (args.length == 2) { MulticastSocket socket;
socket = new MulticastSocket(Integer.parseInt(args[0])); InetAddress address;
address = InetAddress.getByName(args[1]); DatagramPacket packet;
}
else {
System.out.println("Usage: AllPduReceiver <port> <multicast group>");
System.out.println("Default: AllPduReceiver " + DEFAULT_MULTICAST_PORT + " " + DEFAULT_MULTICAST_ADDRESS);
socket = new MulticastSocket(DEFAULT_MULTICAST_PORT);
address = InetAddress.getByName(DEFAULT_MULTICAST_ADDRESS);
}
socket.joinGroup(address);
factory = new PduFactory(); try {
System.out.println("DisExamplesOpenDis7.AllPduReceiver started...");
if (args.length == 2) {
socket = new MulticastSocket(Integer.parseInt(args[0]));
address = InetAddress.getByName(args[1]);
} else {
System.out.println("Usage: AllPduReceiver <port> <multicast group>");
System.out.println("Default: AllPduReceiver " + DEFAULT_MULTICAST_PORT + " " + DEFAULT_MULTICAST_ADDRESS);
socket = new MulticastSocket(DEFAULT_MULTICAST_PORT);
address = InetAddress.getByName(DEFAULT_MULTICAST_ADDRESS);
}
socket.joinGroup(address);
while (true) // Loop infinitely, receiving datagrams factory = new PduFactory();
{
byte buffer[] = new byte[1500]; // typical MTU size
packet = new DatagramPacket(buffer, buffer.length); // reset while (true) // Loop infinitely, receiving datagrams
{
byte buffer[] = new byte[1500]; // typical MTU size
socket.receive(packet); packet = new DatagramPacket(buffer, buffer.length); // reset
Pdu pdu = factory.createPdu(packet.getData()); socket.receive(packet);
if (pdu != null)
{
DISPDUType currentPduType = pdu.getPduType(); //short currentPduType = pdu.getPduType();
String currentPduTypeName = pdu.getClass().getName();
DISProtocolFamily currentProtocolFamilyID = pdu.getProtocolFamily(); //short currentProtocolFamilyID = pdu.getProtocolFamily();
String currentPduFamilyName = pdu.getClass().getSuperclass().getSimpleName();
StringBuilder message = new StringBuilder(); Pdu pdu = factory.createPdu(packet.getData());
message.append("received DIS PDU "); if (pdu != null) {
if (currentPduType.getValue() < 10) DISPDUType currentPduType = pdu.getPduType(); //short currentPduType = pdu.getPduType();
message.append(" "); // column spacing String currentPduTypeName = pdu.getClass().getName();
message.append(currentPduType.getValue()); DISProtocolFamily currentProtocolFamilyID = pdu.getProtocolFamily(); //short currentProtocolFamilyID = pdu.getProtocolFamily();
String currentPduTypePadded = String.format("%-34s", currentPduType); // - indicates right padding of whitespace String currentPduFamilyName = pdu.getClass().getSuperclass().getSimpleName();
message.append(" " ).append(currentPduTypePadded);
String currentPduTypeNamePadded = String.format("%-49s", currentPduTypeName); // - indicates right padding of whitespace
message.append(" of type ").append(currentPduTypeNamePadded); // package.class name
message.append(" (protocolFamily ").append(currentProtocolFamilyID);
// message.append(" ").append(currentPduFamilyName); // class name is also available
message.append(")");
System.out.println(message.toString());
switch (currentPduType) // using enumeration values from edu.​nps.​moves.​dis7.​enumerations.​DISPDUType StringBuilder message = new StringBuilder();
{ message.append("received DIS PDU ");
case COMMENT: if (currentPduType.getValue() < 10) {
CommentPdu commentPdu = (CommentPdu)pdu; // cast to precise type message.append(" "); // column spacing
ArrayList<VariableDatum> payloadList = (ArrayList)commentPdu.getVariableDatums(); }
for (VariableDatum variableDatum : payloadList) message.append(currentPduType.getValue());
String currentPduTypePadded = String.format("%-34s", currentPduType); // - indicates right padding of whitespace
message.append(" ").append(currentPduTypePadded);
String currentPduTypeNamePadded = String.format("%-49s", currentPduTypeName); // - indicates right padding of whitespace
message.append(" of type ").append(currentPduTypeNamePadded); // package.class name
message.append(" (protocolFamily ").append(currentProtocolFamilyID);
// message.append(" ").append(currentPduFamilyName); // class name is also available
message.append(")");
System.out.println(message.toString());
switch (currentPduType) // using enumeration values from edu.​nps.​moves.​dis7.​enumerations.​DISPDUType
{ {
String nextComment = new String(variableDatum.getVariableDatumValue()); // convert byte[] to String case COMMENT:
System.out.println("\"" + nextComment + "\""); CommentPdu commentPdu = (CommentPdu) pdu; // cast to precise type
ArrayList<VariableDatum> payloadList = (ArrayList) commentPdu.getVariableDatums();
for (VariableDatum variableDatum : payloadList) {
String nextComment = new String(variableDatum.getVariableDatumValue()); // convert byte[] to String
System.out.println("\"" + nextComment + "\"");
}
} }
} else {
System.out.println("received packet but pdu is null, packet.getData().length=" + packet.getData().length + ", error...");
}
} }
} catch (IOException e) {
System.out.println("Problem with DisExamplesOpenDis7.AllPduReceiver, see exception trace:");
System.out.println(e);
} finally {
System.out.println("DisExamplesOpenDis7.AllPduReceiver complete.");
} }
else
System.out.println("received packet but pdu is null, packet.getData().length=" + packet.getData().length + ", error...");
}
}
catch (IOException e) {
System.out.println("Problem with DisExamplesOpenDis7.AllPduReceiver, see exception trace:");
System.out.println(e);
}
finally {
System.out.println("DisExamplesOpenDis7.AllPduReceiver complete.");
} }
}
} }
...@@ -8,68 +8,67 @@ import edu.nps.moves.dis7.*; ...@@ -8,68 +8,67 @@ import edu.nps.moves.dis7.*;
import edu.nps.moves.dis7.enumerations.*; import edu.nps.moves.dis7.enumerations.*;
/** /**
* This is an example that sends many/most types of PDUs. Useful for testing standards * This is an example that sends many/most types of PDUs. Useful for testing
* compliance or getting a full set of PDUs. It also writes the generated PDUs to an XML file. * standards compliance or getting a full set of PDUs. It also writes the
* Adapted from OpenDIS library example package edu.nps.moves.examples * generated PDUs to an XML file. Adapted from OpenDIS library example package
* edu.nps.moves.examples
* *
* @author DMcG * @author DMcG
* @version $Id:$ * @version $Id:$
*/ */
public class AllPduSender public class FetterolfPduSender {
{
/** Default multicast group address we send on. */ /**
* Default multicast group address we send on.
*/
public static final String DEFAULT_MULTICAST_ADDRESS = "239.1.2.3"; 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; * Default multicast port used, matches Wireshark DIS capture default
*/
public static final int DEFAULT_MULTICAST_PORT = 3000;
private int port; private int port;
InetAddress multicastAddress; InetAddress multicastAddress;
public AllPduSender(int port, String multicast) { public FetterolfPduSender(int port, String multicast) {
try try {
{
this.port = port; this.port = port;
multicastAddress = InetAddress.getByName(multicast); multicastAddress = InetAddress.getByName(multicast);
if (!multicastAddress.isMulticastAddress()) if (!multicastAddress.isMulticastAddress()) {
{
System.out.println("Not a multicast address: " + multicast); System.out.println("Not a multicast address: " + multicast);
} }
} } catch (UnknownHostException e) {
catch (UnknownHostException e) {
System.out.println("Unable to open socket: " + e); System.out.println("Unable to open socket: " + e);
} }
} }
public void run() public void run() {
{ System.out.println("DisExamplesOpenDis7.AllPduSender started...");
System.out.println("DisExamplesOpenDis7.AllPduSender started..."); try {
try
{
System.out.println("Generate PDUs and note issues, if any..."); System.out.println("Generate PDUs and note issues, if any...");
List<Pdu> generatedPdusList = new ArrayList<>(); List<Pdu> generatedPdusList = new ArrayList<>();
// Loop through all the enumerated PDU types, create a PDU for each type, // Loop through all the enumerated PDU types, create a PDU for each type,
// add that PDU to generatedPdusList, and send each one // add that PDU to generatedPdusList, and send each one
for (DISPDUType pdu : DISPDUType.values()) for (DISPDUType pdu : DISPDUType.values()) {
{
// System.out.println("PDU " + pdu.getValue() + " " + pdu.name() + " " + pdu.getDescription()); // diagnostic // 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 Pdu aPdu = null; // edu.​nps.​moves7.​dis.PDU superclass for all PDUs, in preparation for custom assignment
try { try {
switch (pdu) // using enumeration values from edu.​nps.​moves.​dis7.​enumerations.​DISPDUType switch (pdu) // using enumeration values from edu.​nps.​moves.​dis7.​enumerations.​DISPDUType
{ {
case OTHER: // 0 case OTHER: // 0
System.out.println ("*** Note: DISPDUType." + pdu.name() + " not supported"); // TODO why was this received? System.out.println("*** Note: DISPDUType." + pdu.name() + " not supported"); // TODO why was this received?
// nothing to send // nothing to send
break; break;
case ENTITY_STATE: // 1 case ENTITY_STATE: // 1
aPdu = new EntityStatePdu(); aPdu = new EntityStatePdu();
EntityStatePdu espdu = (EntityStatePdu) aPdu; EntityStatePdu espdu = (EntityStatePdu) aPdu;
EntityMarking entityMarking = new EntityMarking (); EntityMarking entityMarking = new EntityMarking();
entityMarking.setCharacters("AllPduSender".getBytes()); //entityMarking.setCharacters(Byte.valueOf("0")); // 11 characters max? entityMarking.setCharacters("AllPduSender".getBytes()); //entityMarking.setCharacters(Byte.valueOf("0")); // 11 characters max?
espdu.setMarking(entityMarking); espdu.setMarking(entityMarking);
...@@ -82,73 +81,67 @@ public class AllPduSender ...@@ -82,73 +81,67 @@ public class AllPduSender
// TODO how to set azimuth, i.e. course direction over ground? // TODO how to set azimuth, i.e. course direction over ground?
break; break;
//added in different PDUs from the jar file. //added in different PDUs from the jar file.
case COLLISION: case COLLISION:
aPdu = new CollisionPdu(); aPdu = new CollisionPdu();
break; break;
case TRANSMITTER: case TRANSMITTER:
aPdu = new TransmitterPdu(); aPdu = new TransmitterPdu();
break; break;
case ACKNOWLEDGE: case ACKNOWLEDGE:
aPdu = new AcknowledgePdu(); aPdu = new AcknowledgePdu();
break; break;
case RECEIVER: case RECEIVER:
aPdu = new ReceiverPdu(); aPdu = new ReceiverPdu();
break; break;
case COMMENT: case COMMENT:
// aPdu = new CommentPdu(); // default for this switch logic // aPdu = new CommentPdu(); // default for this switch logic
// see Garrett Loffelman and Pete Severson's code for OpenDis version 4 example // see Garrett Loffelman and Pete Severson's code for OpenDis version 4 example
// https://gitlab.nps.edu/Savage/NetworkedGraphicsMV3500/tree/master/assignments/src/MV3500Cohort2018JulySeptember/projects/LoeffelmanSeverson // https://gitlab.nps.edu/Savage/NetworkedGraphicsMV3500/tree/master/assignments/src/MV3500Cohort2018JulySeptember/projects/LoeffelmanSeverson
CommentPdu newCommentPdu = new CommentPdu();
CommentPdu newCommentPdu = new CommentPdu();
ArrayList<VariableDatum> payloadList = new ArrayList<VariableDatum>(); ArrayList<VariableDatum> payloadList = new ArrayList<VariableDatum>();
ArrayList<String> commentsList = new ArrayList<>(); ArrayList<String> commentsList = new ArrayList<>();
commentsList.add("Hello CommentPDU"); commentsList.add("Hello CommentPDU");
commentsList.add("Here is a new message"); commentsList.add("Here is a new message");
if (!commentsList.isEmpty()) if (!commentsList.isEmpty()) {
System.out.println("Preparing CommentPDU:"); System.out.println("Preparing CommentPDU:");
}
for (String comment : commentsList) for (String comment : commentsList) {
{
VariableDatum newVariableDatum = new VariableDatum(); VariableDatum newVariableDatum = new VariableDatum();
newVariableDatum.setVariableDatumValue (comment.getBytes()); // conversion newVariableDatum.setVariableDatumValue(comment.getBytes()); // conversion
newVariableDatum.setVariableDatumLength(comment.getBytes().length * 8); // bits, not bytes, see spec and javadoc newVariableDatum.setVariableDatumLength(comment.getBytes().length * 8); // bits, not bytes, see spec and javadoc
// alternatively, you do not need to set this and the marshaller will figure it out from the byte array // alternatively, you do not need to set this and the marshaller will figure it out from the byte array
// (see javadoc for VariableDatum.setVariableDatumLength()) // (see javadoc for VariableDatum.setVariableDatumLength())
payloadList.add(newVariableDatum); payloadList.add(newVariableDatum);
System.out.println(" \"" + comment + "\""); System.out.println(" \"" + comment + "\"");
} }
newCommentPdu.setVariableDatums(payloadList); newCommentPdu.setVariableDatums(payloadList);
aPdu = newCommentPdu; // hand off for sending aPdu = newCommentPdu; // hand off for sending
break; break;
//commented out this warning message //commented out this warning message
// default: // default:
// System.out.println("*** Warning: PDU " + pdu.getValue() + " " + pdu + " not supported, created or sent "); // System.out.println("*** Warning: PDU " + pdu.getValue() + " " + pdu + " not supported, created or sent ");
// code generation block for this class follows: // code generation block for this class follows:
// System.out.println(" case " + pdu + ": // " + pdu.getValue()); // System.out.println(" case " + pdu + ": // " + pdu.getValue());
// System.out.println(" aPdu = new " + pdu.getDescription().replace(" ","").replace("-","").replace("/","") + // System.out.println(" aPdu = new " + pdu.getDescription().replace(" ","").replace("-","").replace("/","") +
// "Pdu();"); // "Pdu();");
// System.out.println(" break;"); // System.out.println(" break;");
// System.out.println(); // System.out.println();
} }
if (aPdu != null) if (aPdu != null) {
{
generatedPdusList.add(aPdu); generatedPdusList.add(aPdu);
} }
} } catch (Exception e) {
catch (Exception e)
{
System.out.print("Exception thrown for PDU " + pdu.getValue() + " " + pdu); System.out.print("Exception thrown for PDU " + pdu.getValue() + " " + pdu);
System.out.print(Arrays.toString(e.getStackTrace())); System.out.print(Arrays.toString(e.getStackTrace()));
// continue looping // continue looping
...@@ -161,15 +154,13 @@ public class AllPduSender ...@@ -161,15 +154,13 @@ public class AllPduSender
MulticastSocket socket = new MulticastSocket(DEFAULT_MULTICAST_PORT); MulticastSocket socket = new MulticastSocket(DEFAULT_MULTICAST_PORT);
socket.joinGroup(localMulticastAddress); socket.joinGroup(localMulticastAddress);
for (int idx = 0; idx < generatedPdusList.size(); idx++) for (int idx = 0; idx < generatedPdusList.size(); idx++) {
{
ByteArrayOutputStream baos = new ByteArrayOutputStream(); ByteArrayOutputStream baos = new ByteArrayOutputStream();
DataOutputStream dos = new DataOutputStream(baos); DataOutputStream dos = new DataOutputStream(baos);
byte[] buffer; byte[] buffer;
Pdu aPdu = generatedPdusList.get(idx); Pdu aPdu = generatedPdusList.get(idx);
try try {
{
aPdu.marshal(dos); aPdu.marshal(dos);
buffer = baos.toByteArray(); buffer = baos.toByteArray();
...@@ -181,10 +172,9 @@ public class AllPduSender ...@@ -181,10 +172,9 @@ public class AllPduSender
} }
String currentPduTypeValuePadded = String.format("%2s", aPdu.getPduType().getValue()); String currentPduTypeValuePadded = String.format("%2s", aPdu.getPduType().getValue());
String currentPduTypePadded = String.format("%-34s", aPdu.getPduType()); // - indicates right padding of whitespace String currentPduTypePadded = String.format("%-34s", aPdu.getPduType()); // - indicates right padding of whitespace
System.out.print ("Sent DIS PDU " + currentPduTypeValuePadded + " " + currentPduTypePadded ); System.out.print("Sent DIS PDU " + currentPduTypeValuePadded + " " + currentPduTypePadded);
System.out.println(" of type " + aPdu.getClass().getName()); System.out.println(" of type " + aPdu.getClass().getName());
} } catch (Exception ex) {
catch (Exception ex) {
System.out.println("Marshaling error" + ex); System.out.println("Marshaling error" + ex);
} }
} }
...@@ -192,25 +182,19 @@ public class AllPduSender ...@@ -192,25 +182,19 @@ public class AllPduSender
//PduContainer container = new PduContainer(); //PduContainer container = new PduContainer();
//container.setPdus(generatedPdus); //container.setPdus(generatedPdus);
//container.marshallToXml("examplePdus.xml"); //container.marshallToXml("examplePdus.xml");
} } catch (IOException e) {
catch (IOException e)
{
System.out.println(e); System.out.println(e);
} }
} }
public static void main(String args[]) public static void main(String args[]) {
{ if (args.length == 2) {
if (args.length == 2) FetterolfPduSender sender = new FetterolfPduSender(Integer.parseInt(args[0]), args[1]);
{
AllPduSender sender = new AllPduSender(Integer.parseInt(args[0]), args[1]);
sender.run(); sender.run();
} } else {
else
{
System.out.println("Usage: AllPduSender <port> <multicast group>"); System.out.println("Usage: AllPduSender <port> <multicast group>");
System.out.println("Default: AllPduSender " + DEFAULT_MULTICAST_PORT + " " + DEFAULT_MULTICAST_ADDRESS); System.out.println("Default: AllPduSender " + DEFAULT_MULTICAST_PORT + " " + DEFAULT_MULTICAST_ADDRESS);
AllPduSender sender = new AllPduSender(DEFAULT_MULTICAST_PORT, DEFAULT_MULTICAST_ADDRESS); FetterolfPduSender sender = new FetterolfPduSender(DEFAULT_MULTICAST_PORT, DEFAULT_MULTICAST_ADDRESS);
sender.run(); sender.run();
} }
System.out.println("DisExamplesOpenDis7.AllPduSender complete."); System.out.println("DisExamplesOpenDis7.AllPduSender complete.");
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment