Mtp2 implements Runnable { public void start() throws IOException { layer1.open(); started = true; logger.info("Link(" + name + ") is out of service now"); poll = mtpThread.scheduleAtFixedRate(this, 0, POLL_DELAY, TimeUnit.MILLISECONDS); state = Mtp2.MTP2_OUT_OF_SERVICE; queueLSSU(FRAME_STATUS_INDICATION_OS); processTx(); startInitialAlignment(); } Mtp2(String name); void setLayer1(Mtp1 layer1); int getSpan(); void setSpan(int span); int getTimeslot(); void setTimeslot(int timeslot); void start(); void queue(byte[] msg); void stop(); int PPP_FCS(int fcs, int c); void run(); final static int NORMAL_AERM_THRESHOLD; final static int EMERGENCY_AERM_THRESHOLD; }
@Test public void testLink() throws Exception { link1.start(); link2.start(); Thread.currentThread().sleep(180000); }