Home

Contribute

Source code


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

/*
 * Copyright (c) 2009, 2011, 2012 Eike Stepper (Berlin, Germany) and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *    Eike Stepper - initial API and implementation
 */
package org.eclipse.net4j.tests.apps;

import org.eclipse.net4j.Net4jUtil;
import org.eclipse.net4j.tcp.ITCPConnector;
import org.eclipse.net4j.tcp.TCPUtil;
import org.eclipse.net4j.util.container.ManagedContainer;
import org.eclipse.net4j.util.lifecycle.ILifecycle;
import org.eclipse.net4j.util.lifecycle.LifecycleEventAdapter;
import org.eclipse.net4j.util.om.OMPlatform;
import org.eclipse.net4j.util.om.log.PrintLogHandler;
import org.eclipse.net4j.util.om.trace.PrintTraceHandler;

import java.util.Date;

/**
 * @author Eike Stepper
 */
public class TCPConnectivityLoss
{
  private static boolean stop;

  public static ManagedContainer createContainer()
  {
    OMPlatform.INSTANCE.addLogHandler(PrintLogHandler.CONSOLE);
    OMPlatform.INSTANCE.addTraceHandler(PrintTraceHandler.CONSOLE);
    OMPlatform.INSTANCE.setDebugging(true);

    ManagedContainer container = new ManagedContainer();
    Net4jUtil.prepareContainer(container);
    TCPUtil.prepareContainer(container);
    container.activate();
    return container;
  }

  public static void sleep() throws Exception
  {
    System.out.println("Started: " + new Date()); //$NON-NLS-1$
    stop = false;
    int count = 0;
    while (System.in.available() == 0)
    {
      Thread.sleep(1000L);
      System.out.print("."); //$NON-NLS-1$
      if (++count % 80 == 0)
      {
        System.out.println();
      }

      if (stop)
      {
        System.out.println("Loss of connectivity: " + new Date()); //$NON-NLS-1$
      }
    }
  }

  /**
   * @author Eike Stepper
   */
  public static class Server
  {
    public static void main(String[] args) throws Exception
    {
      ManagedContainer container = createContainer();
      TCPUtil.getAcceptor(container, null);
      sleep();
      container.deactivate();
    }
  }

  /**
   * @author Eike Stepper
   */
  public static class Client
  {
    public static void main(String[] args) throws Exception
    {
      ManagedContainer container = createContainer();
      ITCPConnector connector = TCPUtil.getConnector(container, "192.168.1.35"); //$NON-NLS-1$
      connector.addListener(new LifecycleEventAdapter()
      {
        @Override
        protected void onDeactivated(ILifecycle lifecycle)
        {
          stop = true;
        }
      });

      sleep();
      container.deactivate();
    }
  }
}