Package etch.util.core.nio

Examples of etch.util.core.nio.Tcp2Listener.start()

141
142
143
144
145
146
147
148
149
150
151
    l.setSession( lh );
   
    assertWhat( null, lh.what );
    assertNull( lh.xsocket );

    l.start();
    l.waitUp( TIMEOUT );

    assertTrue( l.isStarted() );

    assertWhat( What.UP, lh.what );
View Full Code Here
176
177
178
179
180
181
182
183
184
185
186
    l.setSession( lh );
   
    assertWhat( null, lh.what );
    assertNull( lh.xsocket );

    l.start();
    l.waitUp( TIMEOUT );

    assertTrue( l.isStarted() );

    assertWhat( What.UP, lh.what );
View Full Code Here
206
207
208
209
210
211
212
213
214
215
216
    l.setSession( lh );

    assertWhat( null, lh.what );
    assertNull( lh.xsocket );

    l.start();
    l.waitUp( TIMEOUT );
    assertTrue( l.isStarted() );

    assertWhat( What.UP, lh.what );
    assertNull( lh.xsocket );
View Full Code Here
240
241
242
243
244
245
246
247
248
249
250
    l.setSession( lh );

    assertWhat( null, lh.what );
    assertNull( lh.xsocket );

    l.start();
    l.waitUp( TIMEOUT );

    assertTrue( l.isStarted() );

    assertWhat( What.UP, lh.what );
View Full Code Here
273
274
275
276
277
278
279
280
281
282
283
    l.setSession( lh );

    assertWhat( null, lh.what );
    assertNull( lh.xsocket );

    l.start();
  }

  /** @throws Exception */
  @Test
  public void accept1() throws Exception
View Full Code Here
284
285
286
287
288
289
290
291
292
293
294
  {
    MyListenerHandler lh = new MyListenerHandler();
    Tcp2Listener l = new Tcp2Listener( "tcp://0.0.0.0:4995", r );
    l.setSession( lh );

    l.start();
    l.waitUp( TIMEOUT );

    Socket s = new Socket( "127.0.0.1", 4995 );
    assertWhat( What.ACCEPTED, lh.what );
    assertNotNull( lh.xsocket );
View Full Code Here
349
350
351
352
353
354
355
356
357
358
359
  {
    MyOtherListenerHandler lh = new MyOtherListenerHandler();
    Tcp2Listener l = new Tcp2Listener( "tcp://0.0.0.0:0?TcpListener.backlog=100", r );
    l.setSession( lh );

    l.start();
    l.waitUp( TIMEOUT );

    int port = ((InetSocketAddress) l.localAddress()).getPort();

    int n = 1000;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.