Loading javasrc/adapter/org/etsi/its/adapter/ports/AdapterControlPort.java +1 −10 Original line number Diff line number Diff line Loading @@ -106,7 +106,7 @@ public class AdapterControlPort extends AdapterPort implements IPort, IObservabl Management.getInstance(getComponentName()).stopBeaconing(); break; case AcStartPassBeaconing: ProcessAcStartPassBeaconing(data); Management.getInstance(getComponentName()).startEnqueueingBeacons(data); break; case AcStopPassBeaconing: Management.getInstance(getComponentName()).stopEnqueueingBeacons(); Loading Loading @@ -231,15 +231,6 @@ public class AdapterControlPort extends AdapterPort implements IPort, IObservabl }).start(); } private void ProcessAcStartPassBeaconing(final byte[] beacon) { byte[] response = {(byte)AcGnResponse, (byte)AcGnResponseFailure, (byte)AcFalse}; Management.getInstance(getComponentName()).startEnqueueingBeacons(beacon); setChanged(); notifyObservers(new PortEvent(response, getPortName(), getComponentName())); } private void LoadScenario(final int scenario) { new Thread(new Runnable() { @Override Loading javasrc/adapter/org/etsi/its/adapter/ports/GnPort.java +2 −4 Original line number Diff line number Diff line Loading @@ -98,9 +98,8 @@ public class GnPort extends ProtocolPort implements Runnable, IEthernetSpecific long currentTime = System.currentTimeMillis(); byte[] tst = ByteHelper.intToByteArray((int)(((currentTime - 1072915200000L) % modulo) - 3000), 4); System.arraycopy(tst, 0, beaconHeader, 20, 4); /* TODO Uncomment to get secured beacon*/if (!management.isSecuredModeSet()) { // Secure mode disabled if (!management.isSecuredModeSet()) { // Secure mode disabled send(beaconHeader, params); /* TODO Uncomment to get secured beacon*/ } else { // Send a secured beacon byte[] securedBeaconHeader = buildSecuredBeacon(beaconHeader, tst, currentTime, false); // triggerTime = currentTime; Loading @@ -108,7 +107,6 @@ public class GnPort extends ProtocolPort implements Runnable, IEthernetSpecific //TERFactory.getInstance().logDebug("GnPort: Call send " + ByteHelper.byteArrayToString(securedBeaconHeader)); send(securedBeaconHeader, params); } /* TODO Uncomment to get secured beacon*/ try { Thread.sleep(management.getGnBeaconInterval()); } catch (InterruptedException e) { Loading Loading
javasrc/adapter/org/etsi/its/adapter/ports/AdapterControlPort.java +1 −10 Original line number Diff line number Diff line Loading @@ -106,7 +106,7 @@ public class AdapterControlPort extends AdapterPort implements IPort, IObservabl Management.getInstance(getComponentName()).stopBeaconing(); break; case AcStartPassBeaconing: ProcessAcStartPassBeaconing(data); Management.getInstance(getComponentName()).startEnqueueingBeacons(data); break; case AcStopPassBeaconing: Management.getInstance(getComponentName()).stopEnqueueingBeacons(); Loading Loading @@ -231,15 +231,6 @@ public class AdapterControlPort extends AdapterPort implements IPort, IObservabl }).start(); } private void ProcessAcStartPassBeaconing(final byte[] beacon) { byte[] response = {(byte)AcGnResponse, (byte)AcGnResponseFailure, (byte)AcFalse}; Management.getInstance(getComponentName()).startEnqueueingBeacons(beacon); setChanged(); notifyObservers(new PortEvent(response, getPortName(), getComponentName())); } private void LoadScenario(final int scenario) { new Thread(new Runnable() { @Override Loading
javasrc/adapter/org/etsi/its/adapter/ports/GnPort.java +2 −4 Original line number Diff line number Diff line Loading @@ -98,9 +98,8 @@ public class GnPort extends ProtocolPort implements Runnable, IEthernetSpecific long currentTime = System.currentTimeMillis(); byte[] tst = ByteHelper.intToByteArray((int)(((currentTime - 1072915200000L) % modulo) - 3000), 4); System.arraycopy(tst, 0, beaconHeader, 20, 4); /* TODO Uncomment to get secured beacon*/if (!management.isSecuredModeSet()) { // Secure mode disabled if (!management.isSecuredModeSet()) { // Secure mode disabled send(beaconHeader, params); /* TODO Uncomment to get secured beacon*/ } else { // Send a secured beacon byte[] securedBeaconHeader = buildSecuredBeacon(beaconHeader, tst, currentTime, false); // triggerTime = currentTime; Loading @@ -108,7 +107,6 @@ public class GnPort extends ProtocolPort implements Runnable, IEthernetSpecific //TERFactory.getInstance().logDebug("GnPort: Call send " + ByteHelper.byteArrayToString(securedBeaconHeader)); send(securedBeaconHeader, params); } /* TODO Uncomment to get secured beacon*/ try { Thread.sleep(management.getGnBeaconInterval()); } catch (InterruptedException e) { Loading