diff --git a/assignments/src/MV3500Cohort2021JulySeptember/homework1/PughTcp2ConnectionCounting b/assignments/src/MV3500Cohort2021JulySeptember/homework1/PughTcp2ConnectionCounting deleted file mode 100644 index 492e78f857cc84ca5d90e986e9ba2cb65c5b6538..0000000000000000000000000000000000000000 --- a/assignments/src/MV3500Cohort2021JulySeptember/homework1/PughTcp2ConnectionCounting +++ /dev/null @@ -1,103 +0,0 @@ -package MV3500Cohort2021JulySeptember.homework1.Pugh; - -import java.io.*; -import java.net.*; - -/** - * Very slightly more complex than example1. The only thing this does - * differently is introduce a loop into the response, so you don't have to - * restart the program after one response. Also, it prints out the socket pair - * the server sees. Run the program via telnet several times and compare the - * socket pairs. - * - * <code>telnet localhost 2317</code> - * - * If you're sophisticated you can contact the instructor's computer while - * running this program. - * - * <code>telnet ipOfServersLaptop 2317</code> - * - * And have that machine display the socket pairs received. - * - * @author pugh - * @author brutzman - */ -public class PughTcp2ConnectionCounting { - - /** - * Program invocation, execution starts here - * - * @param args command-line arguments - */ - public static void main(String[] args) { - try { - System.out.println("TcpExample2ConnectionCounting has started and is waiting for a connection."); - System.out.println("Get Ready To Network!!!"); - System.out.println(" help: https://savage.nps.edu/Savage/developers.html#telnet"); - System.out.println(" enter (nc localhost 2317) or (telnet localhost 2317)..."); - - // ServerSocket waits for a connection from a client. - // Notice that it is outside the loop; ServerSocket needs to be made only once. - int connectionCount = 0; // state variable - - ServerSocket serverSocket = new ServerSocket(2317); // server decides here what port to listen on. - // of interest: often client doesn't care what port it uses locally when connecting to that server port. - - // Loop, infinitely, waiting for client connections. - // Stop the program somewhere else. - while (true) { - // blocks! then proceeds once a connection is "accept"ed - try ( Socket clientConnection = serverSocket.accept()) { - connectionCount++; // got another one! - - OutputStream os = clientConnection.getOutputStream(); - PrintStream ps = new PrintStream(os); - - ps.println("This client response was written by server " + PughTcp2ConnectionCounting.class.getName()); // to remote client - System.out.println("This server response was written by server " + PughTcp2ConnectionCounting.class.getName() + "\n"); // to server console - if (connectionCount % 2 == 1) { - System.out.println("Go\n"); - } - if (connectionCount % 2 == 0) { - System.out.println("Gators!\n"); - } - if (connectionCount % 3 == 1 && connectionCount != 0) { - System.out.println("O'Doyle Rules!!! \n"); - } - ps.println("You were connection #" + connectionCount + ", by my count"); - - // Print some information locally about the Socket connection. - // This includes the port and IP numbers on both sides (the socket pair.) - InetAddress localAddress = clientConnection.getLocalAddress(); - InetAddress remoteAddress = clientConnection.getInetAddress(); - - int localPort = clientConnection.getLocalPort(); - int remotePort = clientConnection.getPort(); // remember the prior question, why are 2 ports different? - - // My socket pair connection looks like this, to localhost: - // Socket pair: (( /0:0:0:0:0:0:0:1, 2317 ), ( /0:0:0:0:0:0:0:1, 54876 )) note IPv6 - // Socket pair: (( /0:0:0:0:0:0:0:1, 2317 ), ( /0:0:0:0:0:0:0:1, 54881 )) - // - // Why is first IP/port the same, while the second set has different ports? - System.out.println("Socket pair: (( " + localAddress.toString() + ", " + localPort + " ), ( " - + remoteAddress.toString() + ", " + remotePort + " ))"); - - System.out.println("got another connection, #" + connectionCount); // report progress - - // Notice the use of flush() and close(). Without - // the close() to Socket object may stay open for - // a while after the client has stopped needing this - // connection. Close() explicitly ends the connection. - ps.flush(); - } - } - } catch (IOException e) { - System.err.println("Problem with " + PughTcp2ConnectionCounting.class.getName() + " networking:"); // describe what is happening - System.err.println("Error: " + e); - // Provide more helpful information to user if exception occurs due to running twice at one time - if (e instanceof java.net.BindException) { - System.err.println("*** Be sure to stop any other running instances of programs using this port!"); - } - } - } -} diff --git a/assignments/src/MV3500Cohort2021JulySeptember/homework1/PughTcp2ConnectionCounting.java b/assignments/src/MV3500Cohort2021JulySeptember/homework1/PughTcp2ConnectionCounting.java index 492e78f857cc84ca5d90e986e9ba2cb65c5b6538..47ccc375d2671a5cf86c545b8c2b77ff1c053698 100644 --- a/assignments/src/MV3500Cohort2021JulySeptember/homework1/PughTcp2ConnectionCounting.java +++ b/assignments/src/MV3500Cohort2021JulySeptember/homework1/PughTcp2ConnectionCounting.java @@ -1,4 +1,4 @@ -package MV3500Cohort2021JulySeptember.homework1.Pugh; +package MV3500Cohort2021JulySeptember.homework1; import java.io.*; import java.net.*; diff --git a/examples/src/OpenDis7Examples/ExampleSimulationProgram.java b/examples/src/OpenDis7Examples/ExampleSimulationProgram.java index aa798ba67e5895baed22ff3f051b015b82189b38..3127dc0d83404980fdcaf9a7d50120cd50b510fe 100644 --- a/examples/src/OpenDis7Examples/ExampleSimulationProgram.java +++ b/examples/src/OpenDis7Examples/ExampleSimulationProgram.java @@ -16,9 +16,104 @@ import java.util.ArrayList; import java.util.logging.Level; import java.util.logging.Logger; -/** The purpose of this program is to provide an easily modifiable example simulation program. */ +/** The purpose of this program is to provide an easily modifiable example simulation program + * that includes DIS-capable entities doing tasks and reporting them. */ public class ExampleSimulationProgram { + /** + * runSimulation is for you! This block is programmer-modifiable method for defining and running a new simulation of interest. + * Support include DIS EntityStatePdu, FirePdu and CommentPdu all available for + * modification and sending in a simulation loop. + */ + @SuppressWarnings("SleepWhileInLoop") + public void runSimulation () + { + try + { + + + final double LOOP_DURATION_SECONDS = 1.0; // seconds + final int MAX_LOOP_COUNT = 10; + int loopCount = 0; + VariableRecordType narrativeType = VariableRecordType.OTHER; // of potential use + boolean simulationComplete = false; // sentinel variable as termination condition + + // TODO reset clock to zero each time for consistent outputs. + + // your model setup: who's who in this zoo? + // create PDU objects and set their values + + EntityID entityID_1 = new EntityID(); + entityID_1.setSiteID(1).setApplicationID(2).setEntityID(3); // made-up example ID + + EntityStatePdu entityStatePdu = pduFactory.makeEntityStatePdu(); + entityStatePdu.setEntityID(entityID_1); + + FirePdu firePdu = pduFactory.makeFirePdu(); + // should we customize this munition? what is it for your simulation? + + // loop the simulation while allowed, programmer can set additional conditions to break out and finish + while (loopCount < MAX_LOOP_COUNT) + { + String narrativeMessage1, narrativeMessage2, narrativeMessage3; + // initialize loop variables + loopCount++; + + // ============================================================================================= + // your own simulation code starts here! + + // compute a track, update an ESPDU, whatever it is that your model is doing... + + // Where is my entity? + entityStatePdu.getEntityLocation().setX(entityStatePdu.getEntityLocation().getX() + 1.0); // 1m per timestep + + // decide whether to fire, and then update the firePdu. Hmmm, you might want a target to shoort at! + + // etc. etc. your code goes here + + // something happens between my simulation entities, la de da de da... + System.out.println ("... My simulation just did something, no really..."); + + + // make your reports: narrative code for CommentPdu here (set all to empty strings to avoid sending) + narrativeMessage1 = "MV3500 ExampleSimulationProgram"; + narrativeMessage2 = "runSimulation() loop " + loopCount; + narrativeMessage3 = ""; // intentionally blank for testing + + // your loop termination condition goes here + if (loopCount > 4) // for example + { + simulationComplete = true; + } + // your own simulation code is finished here! + // ============================================================================================= + + // keep track of timestep: wait duration for elapsed time in this loop + // Thread.sleep needs a (long) parameter for milliseconds, which are clumsy to use sometimes + Thread.sleep((long)(LOOP_DURATION_SECONDS * 1000)); // seconds * (1000 msec/sec) = milliseconds + System.out.println ("... Pausing for " + LOOP_DURATION_SECONDS + " seconds"); + + // send the status PDUs for this loop and continue + System.out.println ("sending PDUs for simulation step " + loopCount + ", monitor loopback to confirm sent"); + sendAllPdus(entityStatePdu, firePdu, null, narrativeMessage1, narrativeMessage2, narrativeMessage3); + System.out.println ("... PDUs successfully sent"); + + // =============================== + // loop now finished, thus terminate if simulation complete, otherwise send latest PDUs and continue + if (simulationComplete || (loopCount > 10000)) // for example; including fail-safe condition is good + { + System.out.println ("... Termination condition met, simulationComplete=" + simulationComplete); + break; + } + } // end of while loop + } + catch (InterruptedException iex) // handle any exception that your code might choose to provoke! + { + Logger.getLogger(ExampleSimulationProgram.class.getName()).log(Level.SEVERE, null, iex); + } + } + /* **************************** infrastructure code, modification is seldom needed ************************* */ + /** * Output prefix to identify this class, helps with logging */ @@ -39,7 +134,7 @@ public class ExampleSimulationProgram */ public ExampleSimulationProgram() { - // Under consideration. Constructor is not currently needed. + // Constructor is under consideration. Constructor is not currently needed. } /** @@ -205,96 +300,4 @@ public class ExampleSimulationProgram System.out.println(TRACE_PREFIX + "complete."); // report successful completion } - - /** - * Programmer-modifiable method for defining and running a new simulation of interest. - * Support include DIS EntityStatePdu, FirePdu and CommentPdu all available for - * modification and sending in a simulation loop. - */ - @SuppressWarnings("SleepWhileInLoop") - public void runSimulation () - { - try - { - - - final double LOOP_DURATION_SECONDS = 1.0; // seconds - final int MAX_LOOP_COUNT = 10; - int loopCount = 0; - VariableRecordType narrativeType = VariableRecordType.OTHER; // of potential use - boolean simulationComplete = false; // sentinel variable as termination condition - - // TODO reset clock to zero each time for consistent outputs. - - // your model setup: who's who in this zoo? - // create PDU objects and set their values - - EntityID entityID_1 = new EntityID(); - entityID_1.setSiteID(1).setApplicationID(2).setEntityID(3); // made-up example ID - - EntityStatePdu entityStatePdu = pduFactory.makeEntityStatePdu(); - entityStatePdu.setEntityID(entityID_1); - - FirePdu firePdu = pduFactory.makeFirePdu(); - // should we customize this munition? what is it for your simulation? - - while (loopCount < MAX_LOOP_COUNT) // loop the simulation while allowed, can set additional conditions to break - { - String narrativeMessage1, narrativeMessage2, narrativeMessage3; - // initialize loop variables - loopCount++; - - // ============================================================================================= - // your own simulation code starts here! - - // compute a track, update an ESPDU, whatever it is that your model is doing... - - // Where is my entity? - entityStatePdu.getEntityLocation().setX(entityStatePdu.getEntityLocation().getX() + 1.0); // 1m per timestep - - // decide whether to fire, and then update the firePdu. Hmmm, you might want a target to shoort at! - - // etc. etc. your code goes here - - - - - - // make your reports: narrative code for CommentPdu here (set all to empty strings to avoid sending) - narrativeMessage1 = "MV3500 ExampleSimulationProgram"; - narrativeMessage2 = "runSimulation() loop " + loopCount; - narrativeMessage3 = ""; // intentionally blank for testing - - // your loop termination condition goes here - if (loopCount > 4) // for example - { - simulationComplete = true; - } - // your own simulation code is finished here! - // ============================================================================================= - - // keep track of timestep: wait duration for elapsed time in this loop - // Thread.sleep needs a (long) parameter for milliseconds, which are clumsy to use sometimes - Thread.sleep((long)(LOOP_DURATION_SECONDS * 1000)); // seconds * (1000 msec/sec) = milliseconds - System.out.println ("... Pausing for " + LOOP_DURATION_SECONDS + " seconds"); - - // send the status PDUs for this loop and continue - System.out.println ("sending PDUs for simulation step " + loopCount + ", monitor loopback to confirm sent"); - sendAllPdus(entityStatePdu, firePdu, null, narrativeMessage1, narrativeMessage2, narrativeMessage3); - System.out.println ("... PDUs successfully sent"); - - // =============================== - // loop now finished, thus terminate if simulation complete, otherwise send latest PDUs and continue - if (simulationComplete || (loopCount > 10000)) // for example; including fail-safe condition is good - { - System.out.println ("... Termination condition met, simulationComplete=" + simulationComplete); - break; - } - } // end of while loop - } - catch (InterruptedException iex) // handle any exception that your code might choose to provoke! - { - Logger.getLogger(ExampleSimulationProgram.class.getName()).log(Level.SEVERE, null, iex); - } - } } diff --git a/examples/src/Simkit/README.md b/examples/src/Simkit/README.md new file mode 100644 index 0000000000000000000000000000000000000000..b68e2b837a30c48d2c446855de4b715103c78e76 --- /dev/null +++ b/examples/src/Simkit/README.md @@ -0,0 +1,8 @@ +# Simkit DIS examples + +This directory will hold a simple pair of basic Simkit programs. + +We will then make a pair of DIS-capable versions corresponding these same programs. + +Design goal: keep any DIS code to be entity oriented, +with focus of the servers to be centered on the production/handling/consumption of entities. diff --git a/examples/src/Simkit/SimkitSimpleDiscreteEventSimulationModelForDIS.docx b/examples/src/Simkit/SimkitSimpleDiscreteEventSimulationModelForDIS.docx new file mode 100644 index 0000000000000000000000000000000000000000..9b53790d0458594f1553db9b99c9cc03bf9b9096 Binary files /dev/null and b/examples/src/Simkit/SimkitSimpleDiscreteEventSimulationModelForDIS.docx differ diff --git a/examples/src/TcpExamples/TcpExample2ConnectionCounting.java b/examples/src/TcpExamples/TcpExample2ConnectionCounting.java index 478508c9f768ba7c8882b3f0327db22ec303f02e..3b99cfa68f3a0fed2c85be70edf23cf7b71843f5 100644 --- a/examples/src/TcpExamples/TcpExample2ConnectionCounting.java +++ b/examples/src/TcpExamples/TcpExample2ConnectionCounting.java @@ -33,16 +33,10 @@ public class TcpExample2ConnectionCounting { System.out.println("TcpExample2ConnectionCounting has started and is waiting for a connection."); System.out.println(" help: https://savage.nps.edu/Savage/developers.html#telnet"); - // Where are we? In other words, what is our host number? Advertise it - // https://stackoverflow.com/questions/9481865/getting-the-ip-address-of-the-current-machine-using-java - String localHostAddress = Inet4Address.getLocalHost().toString(); - System.out.println("Local host address is " + localHostAddress); - if (localHostAddress.contains("/")) - localHostAddress = localHostAddress.substring(localHostAddress.indexOf("/")+1); - // show localhost IP number to facilitate connections over local area network (LAN, WAN) - System.out.println(" enter (nc localhost 2317) or (telnet localhost 2317) for local operation" ); - System.out.println(" enter (nc " + localHostAddress + " 2317) or " + - "(telnet " + localHostAddress + " 2317)..." ); + System.out.println(" Windows ipconfig (or Mac ifconfig) indicates current IPv4_Address (for example local wireless IP address)"); + System.out.println(" Windows enter (telnet localhost 2317) or Mac enter (nc localhost 2317) for loopback operation, or" ); + System.out.println(" Windows enter (telnet IPv4_Address 2317) or Mac enter (nc IPv4_Address 2317) for LAN operation" ); + System.out.println("TcpExample2ConnectionCounting server standing by..." ); // ServerSocket waits for a connection from a client. // Notice that it is outside the loop; ServerSocket needs to be made only once. @@ -51,18 +45,33 @@ public class TcpExample2ConnectionCounting ServerSocket serverSocket = new ServerSocket(2317); // server decides here what port to listen on. // of interest: often client doesn't care what port it uses locally when connecting to that server port. - + // Loop, infinitely, waiting for client connections. // Stop the program somewhere else. while(true) { - // blocks! then proceeds once a connection is "accept"ed + // serverSocket.accept() blocks! then proceeds once a connection is "accept"ed try (Socket clientConnection = serverSocket.accept()) { connectionCount++; // got another one! OutputStream os = clientConnection.getOutputStream(); PrintStream ps = new PrintStream(os); +// if (connectionCount == 1) // first time through, report connection +// { +// // Where are we? In other words, what is our host number? Advertise it. +// // Note that we use the serverSocket to get address, since host may have multiple network connections. +// // https://stackoverflow.com/questions/9481865/getting-the-ip-address-of-the-current-machine-using-java +// String localHostAddress = clientConnection.getInetAddress().getHostAddress(); +// System.out.println("Local host address is " + localHostAddress); +// if (localHostAddress.contains("/")) +// localHostAddress = localHostAddress.substring(localHostAddress.indexOf("/")+1); +// // show localhost IP number to facilitate connections over local area network (LAN, WAN) +// System.out.println(" enter (nc localhost 2317) or (telnet localhost 2317) for local operation" ); +// System.out.println(" enter (nc " + localHostAddress + " 2317) or " + +// "(telnet " + localHostAddress + " 2317)..." ); +// } + ps.println("This client response was written by server " + TcpExample2ConnectionCounting.class.getName()); // to remote client System.out.println("This server response was written by server " + TcpExample2ConnectionCounting.class.getName()); // to server console @@ -83,7 +92,7 @@ public class TcpExample2ConnectionCounting // // Why is first IP/port the same, while the second set has different ports? - System.out.println("Socket pair: (( " + localAddress.toString() + ", " + localPort + " ), ( " + + System.out.println("Socket pair (server, client): (( " + localAddress.toString() + ", " + localPort + " ), ( " + remoteAddress.toString() + ", " + remotePort + " ))"); System.out.println("got another connection, #" + connectionCount); // report progress diff --git a/examples/src/TcpExamples/TcpExample2ConnectionCountingTerminalLog.txt b/examples/src/TcpExamples/TcpExample2ConnectionCountingTerminalLog.txt index 5daf91804f3c0dd2517476281c77ac9b6420e7de..e7324dfea05687f0e3e4130afb6a058a3a994d2d 100644 --- a/examples/src/TcpExamples/TcpExample2ConnectionCountingTerminalLog.txt +++ b/examples/src/TcpExamples/TcpExample2ConnectionCountingTerminalLog.txt @@ -1,47 +1,46 @@ Invocation instructions: -1. run/debug TcpExample2.java -2. console: nc localhost 2317 - alternate: telnet localhost 2217 +1. run/debug TcpExample2ConnectionCounting.java + +2. Windows: ipconfig + MacOS: ifconfig + +3. Windows: telnet localhost 2317 + MacOS: nc localhost 2317 Program responses: =================================================== -run: -TcpExample2ConnectionCounting has started and is waiting for a connection: telnet localhost 2317 -This server response was written by server TcpExample2ConnectionCounting -Socket pair: (( /0:0:0:0:0:0:0:1, 2317 ), ( /0:0:0:0:0:0:0:1, 57630 )) +run-single: +TcpExample2ConnectionCounting has started and is waiting for a connection. + help: https://savage.nps.edu/Savage/developers.html#telnet + Windows ipconfig (or Mac ifconfig) indicates current IPv4_Address (for example local wireless IP address) + Windows enter (telnet localhost 2317) or Mac enter (nc localhost 2317) for loopback operation, or + Windows enter (telnet IPv4_Address 2317) or Mac enter (nc IPv4_Address 2317) for LAN operation +TcpExample2ConnectionCounting server standing by... +This server response was written by server TcpExamples.TcpExample2ConnectionCounting +Socket pair (server, client): (( /172.20.154.38, 2317 ), ( /172.20.153.125, 55424 )) got another connection, #1 -This server response was written by server TcpExample2ConnectionCounting -Socket pair: (( /0:0:0:0:0:0:0:1, 2317 ), ( /0:0:0:0:0:0:0:1, 57631 )) +This server response was written by server TcpExamples.TcpExample2ConnectionCounting +Socket pair (server, client): (( /172.20.154.38, 2317 ), ( /172.20.153.125, 55425 )) got another connection, #2 -This server response was written by server TcpExample2ConnectionCounting -Socket pair: (( /0:0:0:0:0:0:0:1, 2317 ), ( /0:0:0:0:0:0:0:1, 57633 )) +This server response was written by server TcpExamples.TcpExample2ConnectionCounting +Socket pair (server, client): (( /172.20.154.38, 2317 ), ( /172.20.153.125, 55426 )) got another connection, #3 +This server response was written by server TcpExamples.TcpExample2ConnectionCounting +Socket pair (server, client): (( /172.20.154.38, 2317 ), ( /172.20.153.125, 55427 )) +got another connection, #4 +This server response was written by server TcpExamples.TcpExample2ConnectionCounting +Socket pair (server, client): (( /172.20.154.38, 2317 ), ( /172.20.153.125, 55428 )) +got another connection, #5 +This server response was written by server TcpExamples.TcpExample2ConnectionCounting +Socket pair (server, client): (( /172.20.154.38, 2317 ), ( /172.20.154.38, 49308 )) +got another connection, #6 =================================================== -don@it154928 /cygdrive/c/Program Files/NetBeans 8.2 $ telnet localhost 2317 -Trying ::1... -Connected to localhost. -Escape character is '^]'. -This client response was written by server TcpExample2 -You were connection #1, by my count -Connection closed by foreign host. -don@it154928 /cygdrive/c/Program Files/NetBeans 8.2 -$ telnet localhost 2317 -Trying ::1... -Connected to localhost. -Escape character is '^]'. -This client response was written by server TcpExample2 -You were connection #2, by my count -Connection closed by foreign host. - -don@it154928 /cygdrive/c/Program Files/NetBeans 8.2 -$ telnet localhost 2317 -Trying ::1... -Connected to localhost. -Escape character is '^]'. -This client response was written by server TcpExample2 -You were connection #3, by my count -Connection closed by foreign host. +This client response was written by server TcpExamples.TcpExample2ConnectionCounting +You were connection #6, by my count + +Connection to host lost. +=================================================== \ No newline at end of file