Skip to content
Snippets Groups Projects
Commit 14d330b2 authored by adfis's avatar adfis
Browse files

Merge origin/master

parents da86b4ef d1508748
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Showing
with 162 additions and 246 deletions
assignments/src/MV3500Cohort2021JulySeptember/homework1/PughTcp2ConnectionCounting deleted 100644 → 0
+ 0
− 103
View file @ da86b4ef
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!");
}
}
}
}
assignments/src/MV3500Cohort2021JulySeptember/homework1/PughTcp2ConnectionCounting.java
+ 1
− 1
View file @ 14d330b2
package MV3500Cohort2021JulySeptember.homework1.Pugh;
package MV3500Cohort2021JulySeptember.homework1;
import java.io.*;
import java.net.*;
......
examples/src/OpenDis7Examples/ExampleSimulationProgram.java
+ 97
− 94
View file @ 14d330b2
......@@ -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);
}
}
}
examples/src/Simkit/README.md 0 → 100644
+ 8
− 0
View file @ 14d330b2
# 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.
examples/src/Simkit/SimkitSimpleDiscreteEventSimulationModelForDIS.docx 0 → 100644
+ 0
− 0
View file @ 14d330b2
File added
examples/src/TcpExamples/TcpExample2ConnectionCounting.java
+ 22
− 13
View file @ 14d330b2
......@@ -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
......
examples/src/TcpExamples/TcpExample2ConnectionCountingTerminalLog.txt
+ 34
− 35
View file @ 14d330b2
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
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment