- // this.serverSession.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
- // assertEquals(1, this.serverSession.unknownMessagesTimes.size());
- // Thread.sleep(10000);
- // this.serverSession.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
- // assertEquals(2, this.serverSession.unknownMessagesTimes.size());
- // Thread.sleep(10000);
- // this.serverSession.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
- // assertEquals(3, this.serverSession.unknownMessagesTimes.size());
- // Thread.sleep(20000);
- // this.serverSession.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
- // assertEquals(4, this.serverSession.unknownMessagesTimes.size());
- // Thread.sleep(30000);
- // this.serverSession.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
- // assertEquals(3, this.serverSession.unknownMessagesTimes.size());
- // Thread.sleep(10000);
- // this.serverSession.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
- // assertEquals(3, this.serverSession.unknownMessagesTimes.size());
- // Thread.sleep(5000);
- // this.serverSession.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
- // assertEquals(4, this.serverSession.unknownMessagesTimes.size());
- // Thread.sleep(1000);
- // this.serverSession.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
- // assertEquals(5, this.serverSession.unknownMessagesTimes.size());
- // Thread.sleep(1000);
- // this.serverSession.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
- // synchronized (this.client) {
- // while (!this.client.down) {
- // try {
- // this.client.wait();
- // } catch (final InterruptedException e) {
- // e.printStackTrace();
- // }
- // }
- // }
- // assertTrue(this.client.down);
+ final SimpleSessionListener client = new SimpleSessionListener();
+ final PCEPSessionImpl s = new PCEPSessionImpl(new HashedWheelTimer(), client, 5, this.clientListener, this.openmsg.getOpenMessage().getOpen(), this.openmsg.getOpenMessage().getOpen());
+ s.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
+ assertEquals(1, s.unknownMessagesTimes.size());
+ Thread.sleep(10000);
+ s.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
+ assertEquals(2, s.unknownMessagesTimes.size());
+ Thread.sleep(10000);
+ s.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
+ assertEquals(3, s.unknownMessagesTimes.size());
+ Thread.sleep(20000);
+ s.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
+ assertEquals(4, s.unknownMessagesTimes.size());
+ Thread.sleep(30000);
+ s.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
+ assertEquals(3, s.unknownMessagesTimes.size());
+ Thread.sleep(10000);
+ s.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
+ assertEquals(3, s.unknownMessagesTimes.size());
+ Thread.sleep(5000);
+ s.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
+ assertEquals(4, s.unknownMessagesTimes.size());
+ Thread.sleep(1000);
+ s.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
+ assertEquals(5, s.unknownMessagesTimes.size());
+ Thread.sleep(1000);
+ s.handleMalformedMessage(PCEPErrors.CAPABILITY_NOT_SUPPORTED);
+ synchronized (client) {
+ while (client.up) {
+ try {
+ client.wait();
+ } catch (final InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ assertTrue(!client.up);