Skip to content
Snippets Groups Projects
Commit 00d721f8 authored by brutzman's avatar brutzman
Browse files

move earlier duplicates to archive location

parent 25b5b0c6
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
Showing
with 0 additions and 1067 deletions
deliverables/src/MV3500Cohort2018JulySeptember/FinalProject/FriscoFurrProject/FDCSendRecieve.java deleted 100644 → 0
+ 0
− 281
View file @ 25b5b0c6
package MV3500Cohort2018JulySeptember.FinalProject.FriscoFurrProject;
import java.net.*;
import java.io.*;
import java.util.*;
import edu.nps.moves.dis.*;
import java.io.IOException;
import edu.nps.moves.disutil.PduFactory;
import edu.nps.moves.disutil.DisTime;
public class FDCSendRecieve {
/**
* 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 static final int MULTICAST_PORT = 3000;
public static final String MULTICAST_GROUP = "239.1.2.3";
public static final boolean USE_FAST_ESPDU = false;
public long[] sentBuffer = new long[100];
public static List sentBufferList;
DisTime disTime = DisTime.getInstance();
public FDCSendRecieve(int port, String multicast) {
this.sentBufferList = new ArrayList<>();
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(Pdu... pdupass) throws UnknownHostException, IOException {
List<Pdu> generatedPdus = new ArrayList<>();
Pdu aPdu = null;
System.out.println("\nFDC Sender started...");
// Send the PDUs we created
InetAddress localMulticastAddress = InetAddress.getByName(DEFAULT_MULTICAST_ADDRESS);
MulticastSocket socket = new MulticastSocket(DEFAULT_MULTICAST_PORT);
socket.joinGroup(localMulticastAddress);
for (Pdu i : pdupass) {
Pdu pdu = i;
if (sentBufferList.contains(pdu.getTimestamp())) {
break;
}
short currentPduType = pdu.getPduType();
System.out.println("in sender, recived PDU type: " + currentPduType);
switch (currentPduType) // using enumeration values from edu.nps.moves.disenum.*
{
case 1: //ENTITY_STATE:
aPdu = pdu;
break;
case 2: //FIRE
aPdu = pdu;
break;
//
case 15: //AcknowledgePdu
aPdu = pdu;
break;
case 17:
aPdu = pdu;
break;
case 14:
aPdu = pdu;
break;
default:
System.out.print("PDU of type " + pdu + " not supported, created or sent ");
System.out.println();
}
if (aPdu != null) {
generatedPdus.add(aPdu);
System.out.println("APDU container count " + generatedPdus.size());
}
}
for (int idx = 0; idx < generatedPdus.size(); idx++) {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
DataOutputStream dos = new DataOutputStream(baos);
byte[] buffer;
aPdu = generatedPdus.get(idx);
aPdu.marshal(dos);
buffer = baos.toByteArray();
DatagramPacket packet = new DatagramPacket(buffer, buffer.length, localMulticastAddress, DEFAULT_MULTICAST_PORT);
socket.send(packet);
sentBufferList.add(aPdu.getTimestamp());
System.out.println("Sent PDU of type " + aPdu.getClass().getName()+ "\n");
}
}
public static void main(String[] args) throws IOException, InterruptedException {
DisTime disTime = DisTime.getInstance();
FDCSendRecieve sender = new FDCSendRecieve(DEFAULT_MULTICAST_PORT, DEFAULT_MULTICAST_ADDRESS); //initalize the sender
EntityStatePdu FDCespdu = new EntityStatePdu();
Marking marking = new Marking();
marking.setCharactersString("FDC");
FDCespdu.setMarking(marking);
FDCespdu.setExerciseID((short) 1);
EntityID FDCID = FDCespdu.getEntityID();
FDCID.setSite(1); // 0 is apparently not a valid site number, per the spec
FDCID.setApplication(1);
FDCID.setEntity(1); //change for each person I think??? - JMF
EntityType entityType = FDCespdu.getEntityType();
//
//Need to update the info below to match the unit type IAW SISO-REF-010-2015 V.21
// https://www.sisostds.org/DesktopModules/Bring2mind/DMX/Download.aspx?Command=Core_Download&EntryId=42916&PortalId=0&TabId=105
//
entityType.setEntityKind((short) 1); // Platform (vs lifeform, munition, sensor, etc.) TGT=1, OBS = 1
entityType.setCountry(225); // USA TGT = 222 (Russia), OBS = 225
entityType.setDomain((short) 1); // Land (vs air, surface, subsurface, space) both TGT and OBS are 1
entityType.setCategory((short) 3); // FDC TGT = 1, Tank OBS=40 OP
entityType.setSubcategory((short) 12); // M1068 TGT = 2, T72 tank NONE FOR OP
entityType.setSpec((short) 1); // M1068 w/ SICUP Tent NONE FOR TGT OR OP
Vector3Double location = new Vector3Double();
location.setX(0.0); //TGT = 150 OBS = 75
location.setY(0.0); //TGT = 150 OBS = 75
location.setZ(10.0); //TGT = 20 OBS = 50
FDCespdu.setEntityLocation(location);
int timestamp = disTime.getDisAbsoluteTimestamp();
FDCespdu.setTimestamp(timestamp);
sender.run(FDCespdu); //sends inital here I am and who I am
//Set up other players to look for:
EntityID OBSEntityID = new EntityID(); // need to figure out what this is....and then just put into if statement below
OBSEntityID.setEntity(2);
OBSEntityID.setApplication(1);
OBSEntityID.setSite(1);
EntityID TGTEntityID = new EntityID(); // need to figure out what this is....and then just put into if statement below
TGTEntityID.setEntity(3);
TGTEntityID.setApplication(1);
TGTEntityID.setSite(1);
/* BELOW IS THE RECIEVE CODE //
// //
// //
*/ //
PduFactory factory;
MulticastSocket socket = null;
InetAddress address = null;
DatagramPacket packet;
short currentPduType = 0; //will use the curentPduType as the check for sending other packets.
try {
System.out.println("FDC is alive and ready to recieve fire missions...\n\n");
socket = new MulticastSocket(MULTICAST_PORT);
address = InetAddress.getByName(MULTICAST_GROUP);
socket.joinGroup(address);
factory = new PduFactory();
while (true) // Loop infinitely, receiving datagrams
{
byte buffer[] = new byte[1500]; // typical MTU size
packet = new DatagramPacket(buffer, buffer.length); // reset
socket.receive(packet);
String marking2 = new String();
Pdu pdu = factory.createPdu(packet.getData());
currentPduType = pdu.getPduType();
if (currentPduType == 14) //stop/freeze PDU
{
System.out.println("recieved Stop/Freeze packet...");
return;
}
// pdu.setExerciseID((short)5);
if (pdu != null) {
if (sentBufferList.contains(pdu.getTimestamp())) {
pdu = null;
}
if (pdu != null) {
String currentPduTypeName = pdu.getClass().getName();
if (currentPduType == 1) {
EntityStatePdu pdu2 = (EntityStatePdu) pdu;
marking2 = pdu2.getMarking().getCharactersString();
}
StringBuilder message = new StringBuilder();
message.append("received DIS PDU: ");
message.append("pduType ");
if (currentPduType < 10) {
message.append(" ");
}
message.append(currentPduType).append(" ").append(currentPduTypeName);
message.append(" ");
message.append(marking2);
System.out.println(message.toString());
//Reference for PDU Types:
// http://faculty.nps.edu/brutzman/vrtp/mil/navy/nps/disEnumerations/JdbeHtmlFiles/pdu/8.htm
//
if (currentPduType == 1) //EntityState
{
EntityStatePdu entityPDU = (EntityStatePdu) pdu;
EntityType PduEntityType = entityPDU.getEntityType();
if (PduEntityType.getCountry() == 225) {
Thread.sleep((long) 200);
timestamp = disTime.getDisAbsoluteTimestamp();
FDCespdu.setTimestamp(timestamp);
System.out.println("Talking to the Observer, sending a radio check ");
sender.run(FDCespdu);
}
}
if (currentPduType == 16) //Action request
{
// Action response is sending a Null PDU, not sure why...
AcknowledgePdu ack = new AcknowledgePdu();
ack.setExerciseID((short) 1);
ack.setRequestID((long) 1);
timestamp = disTime.getDisAbsoluteTimestamp();
ack.setTimestamp(timestamp);
FirePdu fire = new FirePdu();
fire.setExerciseID((short) 1);
fire.setFireMissionIndex(1000);
fire.setRangeToTarget((float) Math.sqrt(Math.pow(150, 2) + Math.pow(150, 2))); //would pass in target info, but here we know location of tgt is (150,150) and FDC (0,0)
fire.setFiringEntityID(FDCID);
fire.setTargetEntityID(TGTEntityID);
timestamp = disTime.getDisAbsoluteTimestamp();
fire.setTimestamp(timestamp);
sender.run(ack, fire);
}
if (currentPduType == 22) //Comment PDU
{
AcknowledgePdu ack = new AcknowledgePdu();
ack.setExerciseID((short) 1);
ack.setRequestID((long) 1);
timestamp = disTime.getDisAbsoluteTimestamp();
ack.setTimestamp(timestamp);
StopFreezePdu stop = new StopFreezePdu();
stop.setExerciseID((short) 1);
stop.setRequestID((long) 1);
sender.run(ack, stop);
}
} else {
System.out.println("received packet but pdu is null and originated from FDC. Still standing by...");
}
}
}
} catch (IOException e) {
System.out.println("Problem with FDC.PduReceiver, see exception trace:");
System.out.println(e);
} finally {
System.out.println("FDC.PduReceiver complete. - OUT!");
}
}
}
deliverables/src/MV3500Cohort2018JulySeptember/FinalProject/FriscoFurrProject/FriscoFurrPduSender.java deleted 100644 → 0
+ 0
− 226
View file @ 25b5b0c6
package MV3500Cohort2018JulySeptember.FinalProject.FriscoFurrProject;
import java.io.*;
import java.net.*;
import java.util.*;
import edu.nps.moves.dis.*;
import edu.nps.moves.disenum.*;
import edu.nps.moves.examples.ClassNameComparator;
/**
* 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 FriscoFurrPduSender
{
/** 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 FriscoFurrPduSender(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("DisExamples.PduSender started...");
try {
List<Pdu> generatedPdus = new ArrayList<>();
// Loop through all the enumerated PDU types, create a PDU for each type,
// and add that PDU to a list.
System.out.println("number of PDU types in pduType is " + PduType.values().length);
for (PduType pdu : PduType.values()) {
Pdu aPdu = null;
System.out.println(pdu);
switch (pdu) // using enumeration values from edu.nps.moves.disenum.*
{
//
// case ENTITY_STATE:
// System.out.println("Case: Enitity_State "+pdu+"\n");
// aPdu = new EntityStatePdu();
// EntityStatePdu espdu = (EntityStatePdu) aPdu;
// Marking marking = new Marking();
// marking.setCharactersString("TEST DUDE");
// espdu.setMarking(marking);
// Vector3Double espduLocation = new Vector3Double();
// espduLocation.setX(1.0);
// espduLocation.setY(2.0);
// espduLocation.setZ(3.0);
// EntityType entityType = espdu.getEntityType();
// entityType.setCountry(222);
//
// break;
// case COMMENT:
// aPdu = new CommentPdu();
// CommentPdu comment = (CommentPdu) aPdu;
// EntityID OBSEntityID = new EntityID(); // need to figure out what this is....and then just put into if statement below
// OBSEntityID.setEntity(2);
// OBSEntityID.setApplication(1);
// OBSEntityID.setSite(1);
// comment.setOriginatingEntityID(OBSEntityID);
//
// long number = 1;
// //comment.setNumberOfFixedDatumRecords(number);
//
// comment.setNumberOfVariableDatumRecords(number);
// List datum = new ArrayList<FixedDatum>();
// FixedDatum superDatum = new FixedDatum();
// superDatum.setFixedDatumID((long)5);
// superDatum.setFixedDatumValue((long) 54321);
// datum.add(10);
// datum.add(superDatum);
// comment.setFixedDatums(datum);
// List Vdatum = new ArrayList<VariableDatum>();
// VariableDatum testBitch = new VariableDatum();
// testBitch.setVariableDatumID(1);
// Vdatum.add(15);
// comment.setVariableDatums(Vdatum);
// break;
// case FIRE:
// aPdu = new FirePdu();
// break;
case DETONATION:
aPdu = new DetonationPdu();
System.out.println("detonationPdu type " + aPdu.getPduType());
break;
//
// case COLLISION:
// aPdu = new CollisionPdu();
// break;
//
// case SERVICE_REQUEST:
// aPdu = new ServiceRequestPdu();
// break;
//
// case RESUPPLY_OFFER:
// aPdu = new ResupplyOfferPdu();
// break;
//
// case RESUPPLY_RECEIVED:
// aPdu = new ResupplyReceivedPdu();
// break;
//
// case RESUPPLY_CANCEL:
// aPdu = new ResupplyCancelPdu();
// break;
//
// case REPAIR_COMPLETE:
// aPdu = new RepairCompletePdu();
// break;
//
// case REPAIR_RESPONSE:
// aPdu = new RepairResponsePdu();
// break;
//
// case CREATE_ENTITY:
// aPdu = new CreateEntityPdu();
// break;
//
// case REMOVE_ENTITY:
// aPdu = new RemoveEntityPdu();
// break;
//
// case START_RESUME:
// aPdu = new StartResumePdu();
// break;
//
// case STOP_FREEZE:
// aPdu = new StopFreezePdu();
// break;
//
// case ACKNOWLEDGE:
// aPdu = new AcknowledgePdu();
// break;
//
// case ACTION_REQUEST:
// aPdu = new ActionRequestPdu();
// ActionRequestPdu action = (ActionRequestPdu) aPdu;
// EntityID OBSEntityID = new EntityID(); // need to figure out what this is....and then just put into if statement below
// OBSEntityID.setEntity(2);
// OBSEntityID.setApplication(1);
// OBSEntityID.setSite(1);
// action.setOriginatingEntityID(OBSEntityID);
// break;
default:
System.out.print("PDU of type " + pdu + " not supported, created or sent ");
System.out.println();
}
if (aPdu != null)
{
generatedPdus.add(aPdu);
System.out.println("APDU container count "+generatedPdus.size());
}
}
// Sort the created PDUs by class name
Collections.sort(generatedPdus, new ClassNameComparator());
// Send the 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 < generatedPdus.size(); idx++)
{
ByteArrayOutputStream baos = new ByteArrayOutputStream();
DataOutputStream dos = new DataOutputStream(baos);
byte[] buffer;
Pdu aPdu = generatedPdus.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 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) {
FriscoFurrPduSender sender = new FriscoFurrPduSender(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);
FriscoFurrPduSender sender = new FriscoFurrPduSender(DEFAULT_MULTICAST_PORT, DEFAULT_MULTICAST_ADDRESS);
sender.run();
}
}
}
deliverables/src/MV3500Cohort2018JulySeptember/FinalProject/FriscoFurrProject/OBSSendRecieve1.java deleted 100644 → 0
+ 0
− 310
View file @ 25b5b0c6
package MV3500Cohort2018JulySeptember.FinalProject.FriscoFurrProject;
import java.net.*;
import java.io.*;
import java.util.*;
import edu.nps.moves.dis.*;
import java.io.IOException;
import edu.nps.moves.disutil.PduFactory;
import edu.nps.moves.disutil.DisTime;
public class OBSSendRecieve1 {
/**
* 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 static final int MULTICAST_PORT = 3000;
public static final String MULTICAST_GROUP = "239.1.2.3";
public static final boolean USE_FAST_ESPDU = false;
public long[] sentBuffer = new long[100];
public static List sentBufferList;
DisTime disTime = DisTime.getInstance();
int transmission =1;
public OBSSendRecieve1(int port, String multicast) {
this.sentBufferList = new ArrayList<>();
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(Pdu... pdupass) throws UnknownHostException, IOException {
List<Pdu> generatedPdus = new ArrayList<>();
Pdu aPdu = null;
if(transmission ==1){
System.out.println("\nInitalizing OP coms...");
transmission++;
}
if(transmission>1){
System.out.println("\nObserver Sending traffic...");
}
// Send the PDUs we created
InetAddress localMulticastAddress = InetAddress.getByName(DEFAULT_MULTICAST_ADDRESS);
MulticastSocket socket = new MulticastSocket(DEFAULT_MULTICAST_PORT);
socket.joinGroup(localMulticastAddress);
for (Pdu i : pdupass) {
Pdu pdu = i;
if (sentBufferList.contains(pdu.getTimestamp())) {
break;
}
short currentPduType = pdu.getPduType();
System.out.println("in observer sender, processing PDU type: " + currentPduType);
// String currentPduTypeName = pdu.getClass().getName();
// short currentProtocolFamilyID = pdu.getProtocolFamily();
// String currentPduFamilyName = pdu.getClass().getSuperclass().getSimpleName();
// Loop through all the enumerated PDU types, create a PDU for each type,
// and add that PDU to a list.
//System.out.println(pdu);
//Change the switch statement to the currentPduType from the recieve portion, then when a packet we want comes in, send the CASE file.
switch (currentPduType) // using enumeration values from edu.nps.moves.disenum.*
{
case 1: //ENTITY_STATE:
aPdu = pdu;
break;
// case COMMENT:
// aPdu = new CommentPdu();
// break;
//
// case 2: //FIRE
// aPdu = pdu;
// break;
//
// case DETONATION:
// aPdu = new DetonationPdu();
// break;
//
// case 15: //AcknowledgePdu
// aPdu = pdu;
// break;
////
case 16: //ACTION_REQUEST:
aPdu = new ActionRequestPdu();
break;
case 22: //CommentPdu
aPdu = pdu;
break;
// case 14:
// aPdu = pdu;
// break;
default:
//add some shit that makes sense here.
System.out.print("PDU of type " + pdu + " not supported by Observer, created or sent ");
System.out.println();
}
if (aPdu != null) {
generatedPdus.add(aPdu);
System.out.println("APDU container count " + generatedPdus.size());
}
}
for (int idx = 0; idx < generatedPdus.size(); idx++) {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
DataOutputStream dos = new DataOutputStream(baos);
byte[] buffer;
aPdu = generatedPdus.get(idx);
aPdu.marshal(dos);
buffer = baos.toByteArray();
DatagramPacket packet = new DatagramPacket(buffer, buffer.length, localMulticastAddress, DEFAULT_MULTICAST_PORT);
socket.send(packet);
//sentBuffer[sentBuffer.length] = aPdu.getTimestamp();
sentBufferList.add(aPdu.getTimestamp());
System.out.println("Observer Sent PDU of type " + aPdu.getClass().getName()+"/n");
}
}
public static void main(String[] args) throws IOException {
DisTime disTime = DisTime.getInstance();
//turns on the sender code - might need to move around down into the recieve with the if statements...
//
// ORIGINAL SENDING CODE MAIN CLASS:
//
//
// if (args.length == 2) {
// FDCSendRecieve sender = new FDCSendRecieve(Integer.parseInt(args[0]), args[1]);
// // sender.run(); //needs to be sender.run(pdu)
// } else {
// System.out.println("Usage: PduSender <port> <multicast group>");
// System.out.println("Default: PduSender " + DEFAULT_MULTICAST_PORT + " " + DEFAULT_MULTICAST_ADDRESS);
// FDCSendRecieve sender = new FDCSendRecieve(DEFAULT_MULTICAST_PORT, DEFAULT_MULTICAST_ADDRESS);
// sender.run();
// }
//
// Inital Hello world from entity:
//
OBSSendRecieve1 sender = new OBSSendRecieve1(DEFAULT_MULTICAST_PORT, DEFAULT_MULTICAST_ADDRESS); //initalize the sender
EntityStatePdu OBSespdu = new EntityStatePdu();
Marking marking = new Marking();
marking.setCharactersString("Observer");
OBSespdu.setMarking(marking);
OBSespdu.setExerciseID((short) 1);
EntityID OBSID = OBSespdu.getEntityID();
OBSID.setSite(1); // 0 is apparently not a valid site number, per the spec
OBSID.setApplication(1);
OBSID.setEntity(2); //change for each person I think??? - JMF
EntityType entityType = OBSespdu.getEntityType();
//
//Need to update the info below to match the unit type IAW SISO-REF-010-2015 V.21
// https://www.sisostds.org/DesktopModules/Bring2mind/DMX/Download.aspx?Command=Core_Download&EntryId=42916&PortalId=0&TabId=105
//
entityType.setEntityKind((short) 1); // Platform (vs lifeform, munition, sensor, etc.) TGT=1, OBS = 1
entityType.setCountry(225); // USA TGT = 222 (Russia), OBS = 225
entityType.setDomain((short) 1); // Land (vs air, surface, subsurface, space) both TGT and OBS are 1
entityType.setCategory((short) 40); // FDC TGT = 1, Tank OBS=40 OP
// entityType.setSubcategory((short) 12); // M1068 TGT = 2, T72 tank NONE FOR OP
// entityType.setSpec((short) 1); // M1068 w/ SICUP Tent NONE FOR TGT OR OP
Vector3Double location = new Vector3Double();
location.setX(75.0); //TGT = 150 OBS = 75
location.setY(75.0); //TGT = 150 OBS = 75
location.setZ(50.0); //TGT = 20 OBS = 50
OBSespdu.setEntityLocation(location);
int timestamp = disTime.getDisAbsoluteTimestamp();
OBSespdu.setTimestamp(timestamp);
//FDCespdu.setTimestamp(System.currentTimeMillis());
sender.run(OBSespdu); //sends inital here I am and who I am
//other player to look out for:
EntityID FDCEntityID = new EntityID();
FDCEntityID.setEntity(1);
FDCEntityID.setApplication(1);
FDCEntityID.setSite(1);
EntityID TGTEntityID = new EntityID();
TGTEntityID.setEntity(3);
TGTEntityID.setApplication(1);
TGTEntityID.setSite(1);
/* BELOW IS THE RECIEVE CODE //
// //
// //
*/ //
PduFactory factory;
MulticastSocket socket = null;
InetAddress address = null;
DatagramPacket packet;
short currentPduType; //will use the curentPduType as the check for sending other packets.
try {
// TODO: Change the line below to make sense for each class
System.out.println("Observer is in the OP and looking for targets...\n\n");
socket = new MulticastSocket(MULTICAST_PORT);
address = InetAddress.getByName(MULTICAST_GROUP);
socket.joinGroup(address);
factory = new PduFactory();
while (true) // Loop infinitely, receiving datagrams
{
byte buffer[] = new byte[1500]; // typical MTU size
packet = new DatagramPacket(buffer, buffer.length); // reset
socket.receive(packet);
//
//TODO: NEED IF STATEMENT IF THE SENDER IS THIS CLASS TO DELETE.
//
String marking2 = new String();
Pdu pdu = factory.createPdu(packet.getData());
currentPduType = pdu.getPduType();
if (currentPduType == 14) //stop/freeze PDU
{
System.out.println("recieved Stop/Freeze packet...");
return;
}
// pdu.setExerciseID((short)5);
if (pdu != null) {
if (sentBufferList.contains(pdu.getTimestamp())) {
pdu = null;
}
if (pdu != null) {
String currentPduTypeName = pdu.getClass().getName();
if (currentPduType == 1) {
EntityStatePdu pdu2 = (EntityStatePdu) pdu;
marking2 = pdu2.getMarking().getCharactersString();
}
//Keep adding any if statements as needed for the class you are building.
StringBuilder message = new StringBuilder();
message.append("received DIS PDU: ");
message.append("pduType ");
if (currentPduType < 10) {
message.append(" ");
}
message.append(currentPduType).append(" ").append(currentPduTypeName);
message.append(" ");
message.append(marking2);
System.out.println(message.toString());
//Reference for PDU Types:
// http://faculty.nps.edu/brutzman/vrtp/mil/navy/nps/disEnumerations/JdbeHtmlFiles/pdu/8.htm
//
if (currentPduType == 1) //EntityState
{
EntityStatePdu entityPDU = (EntityStatePdu) pdu;
EntityType PduEntityType = entityPDU.getEntityType();
if (PduEntityType.getCountry() == 222) {
ActionRequestPdu action = new ActionRequestPdu();
action.setExerciseID((short) 1);
action.setRequestID((long) 2);
action.setOriginatingEntityID(OBSID);
action.setReceivingEntityID(FDCEntityID);
timestamp = disTime.getDisAbsoluteTimestamp();
action.setTimestamp(timestamp);
System.out.println("\n Got a Russian SOB! Preparing CFF to send.");
sender.run(action);
}
}
if (currentPduType == 3) //Detination
{
CommentPdu comment = new CommentPdu();
comment.setExerciseID((short) 1);
comment.setOriginatingEntityID(TGTEntityID);
timestamp = disTime.getDisAbsoluteTimestamp();
comment.setTimestamp(timestamp);
sender.run(comment);
}
} else {
System.out.println("received packet but pdu is null and originated from Observer. Still searching for other Targets...");
}
}
}
} catch (IOException e) {
System.out.println("Problem with Observer.PduReceiver, see exception trace:");
System.out.println(e);
} finally {
System.out.println("Observer.PduReceiver complete. - OUT!");
}
}
}
deliverables/src/MV3500Cohort2018JulySeptember/FinalProject/FriscoFurrProject/TGTSendRecieve.java deleted 100644 → 0
+ 0
− 250
View file @ 25b5b0c6
package MV3500Cohort2018JulySeptember.FinalProject.FriscoFurrProject;
import java.net.*;
import java.io.*;
import java.util.*;
import edu.nps.moves.dis.*;
import java.io.IOException;
import edu.nps.moves.disutil.PduFactory;
import edu.nps.moves.disutil.DisTime;
public class TGTSendRecieve {
/**
* 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 static final int MULTICAST_PORT = 3000;
public static final String MULTICAST_GROUP = "239.1.2.3";
public static final boolean USE_FAST_ESPDU = false;
public long[] sentBuffer = new long[100];
public static List sentBufferList;
DisTime disTime = DisTime.getInstance();
int transmission = 1;
public TGTSendRecieve(int port, String multicast) {
this.sentBufferList = new ArrayList<>();
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(Pdu... pdupass) throws UnknownHostException, IOException {
List<Pdu> generatedPdus = new ArrayList<>();
Pdu aPdu = null;
if (transmission == 1) {
System.out.println("\nTarget is rolling out...");
transmission++;
}
if (transmission > 1) {
System.out.println("\nDeath from above everywhere! (sending function started)...");
}
// Send the PDUs we created
InetAddress localMulticastAddress = InetAddress.getByName(DEFAULT_MULTICAST_ADDRESS);
MulticastSocket socket = new MulticastSocket(DEFAULT_MULTICAST_PORT);
socket.joinGroup(localMulticastAddress);
for (Pdu i : pdupass) {
Pdu pdu = i;
if (sentBufferList.contains(pdu.getTimestamp())) {
break;
}
short currentPduType = pdu.getPduType();
System.out.println("in Target sender, processing PDU type: " + currentPduType);
//
switch (currentPduType) // using enumeration values from edu.nps.moves.disenum.*
{
case 1: //ENTITY_STATE:
aPdu = pdu;
break;
case 3: //detination PDU
aPdu = pdu;
break;
default:
//add some shit that makes sense here.
System.out.print("PDU of type " + pdu + " not supported by Observer, created or sent ");
System.out.println();
}
if (aPdu != null) {
generatedPdus.add(aPdu);
System.out.println("APDU container count " + generatedPdus.size());
}
}
for (int idx = 0; idx < generatedPdus.size(); idx++) {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
DataOutputStream dos = new DataOutputStream(baos);
byte[] buffer;
aPdu = generatedPdus.get(idx);
aPdu.marshal(dos);
buffer = baos.toByteArray();
DatagramPacket packet = new DatagramPacket(buffer, buffer.length, localMulticastAddress, DEFAULT_MULTICAST_PORT);
socket.send(packet);
//sentBuffer[sentBuffer.length] = aPdu.getTimestamp();
sentBufferList.add(aPdu.getTimestamp());
System.out.println("Observer Sent PDU of type " + aPdu.getClass().getName() + "/n");
}
}
public static void main(String[] args) throws IOException {
DisTime disTime = DisTime.getInstance();
//turns on the sender code - might need to move around down into the recieve with the if statements...
//
// Inital Hello world from entity:
//
TGTSendRecieve sender = new TGTSendRecieve(DEFAULT_MULTICAST_PORT, DEFAULT_MULTICAST_ADDRESS); //initalize the sender
EntityStatePdu TGTespdu = new EntityStatePdu();
Marking marking = new Marking();
marking.setCharactersString("Target");
TGTespdu.setMarking(marking);
TGTespdu.setExerciseID((short) 1);
EntityID OBSID = TGTespdu.getEntityID();
OBSID.setSite(1); // 0 is apparently not a valid site number, per the spec
OBSID.setApplication(1);
OBSID.setEntity(3); //change for each person I think??? - JMF
EntityType entityType = TGTespdu.getEntityType();
//
//Need to update the info below to match the unit type IAW SISO-REF-010-2015 V.21
// https://www.sisostds.org/DesktopModules/Bring2mind/DMX/Download.aspx?Command=Core_Download&EntryId=42916&PortalId=0&TabId=105
//
entityType.setEntityKind((short) 1); // Platform (vs lifeform, munition, sensor, etc.) TGT=1, OBS = 1
entityType.setCountry(222); // USA TGT = 222 (Russia), OBS = 225
entityType.setDomain((short) 1); // Land (vs air, surface, subsurface, space) both TGT and OBS are 1
entityType.setCategory((short) 1); // FDC TGT = 1, Tank OBS=40 OP
entityType.setSubcategory((short) 2); // M1068 TGT = 2, T72 tank NONE FOR OP
Vector3Double location = new Vector3Double();
location.setX(150.0); //TGT = 150 OBS = 75
location.setY(150.0); //TGT = 150 OBS = 75
location.setZ(20.0); //TGT = 20 OBS = 50
TGTespdu.setEntityLocation(location);
int timestamp = disTime.getDisAbsoluteTimestamp();
TGTespdu.setTimestamp(timestamp);
sender.run(TGTespdu); //sends inital here I am and who I am
//other player to look out for:
EntityID FDCEntityID = new EntityID();
FDCEntityID.setEntity(1);
FDCEntityID.setApplication(1);
FDCEntityID.setSite(1);
EntityID OBSEntityID = new EntityID();
OBSEntityID.setEntity(2);
OBSEntityID.setApplication(1);
OBSEntityID.setSite(1);
/* BELOW IS THE RECIEVE CODE //
// //
// //
*/ //
PduFactory factory;
MulticastSocket socket = null;
InetAddress address = null;
DatagramPacket packet;
short currentPduType; //will use the curentPduType as the check for sending other packets.
try {
// TODO: Change the line below to make sense for each class
System.out.println("Russian T72 out on the prowl...\n\n");
socket = new MulticastSocket(MULTICAST_PORT);
address = InetAddress.getByName(MULTICAST_GROUP);
socket.joinGroup(address);
factory = new PduFactory();
while (true) // Loop infinitely, receiving datagrams
{
byte buffer[] = new byte[1500]; // typical MTU size
packet = new DatagramPacket(buffer, buffer.length); // reset
socket.receive(packet);
//
//TODO: NEED IF STATEMENT IF THE SENDER IS THIS CLASS TO DELETE.
//
String marking2 = new String();
Pdu pdu = factory.createPdu(packet.getData());
currentPduType = pdu.getPduType();
if (currentPduType == 14) //stop/freeze PDU
{
System.out.println("recieved Stop/Freeze packet...");
return;
}
// pdu.setExerciseID((short)5);
if (pdu != null) {
if (sentBufferList.contains(pdu.getTimestamp())) {
pdu = null;
}
if (pdu != null) {
String currentPduTypeName = pdu.getClass().getName();
if (currentPduType == 1) {
EntityStatePdu pdu2 = (EntityStatePdu) pdu;
marking2 = pdu2.getMarking().getCharactersString();
}
//Keep adding any if statements as needed for the class you are building.
StringBuilder message = new StringBuilder();
message.append("received DIS PDU: ");
message.append("pduType ");
if (currentPduType < 10) {
message.append(" ");
}
message.append(currentPduType).append(" ").append(currentPduTypeName);
message.append(" ");
message.append(marking2);
System.out.println(message.toString());
//Reference for PDU Types:
// http://faculty.nps.edu/brutzman/vrtp/mil/navy/nps/disEnumerations/JdbeHtmlFiles/pdu/8.htm
//
if (currentPduType == 2) //FirePDU
{
DetonationPdu det = new DetonationPdu();
det.setExerciseID((short) 1);
det.setDetonationResult((short)1);
timestamp = disTime.getDisAbsoluteTimestamp();
det.setTimestamp(timestamp);
sender.run(det);
}
} else {
System.out.println("received packet but pdu is null and originated from Target. Still doing sketchy Russian things...");
}
}
}
} catch (IOException e) {
System.out.println("Problem with Target.PduReceiver, see exception trace:");
System.out.println(e);
} finally {
System.out.println("Target.PduReceiver complete. - T-72 DESTROYED!");
}
}
}
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