diff options
Diffstat (limited to 'plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/apps/TCPConnectivityLoss.java')
| -rw-r--r-- | plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/apps/TCPConnectivityLoss.java | 204 |
1 files changed, 102 insertions, 102 deletions
diff --git a/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/apps/TCPConnectivityLoss.java b/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/apps/TCPConnectivityLoss.java index 3ce96388e8..ccabea4776 100644 --- a/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/apps/TCPConnectivityLoss.java +++ b/plugins/org.eclipse.net4j.tests/src/org/eclipse/net4j/tests/apps/TCPConnectivityLoss.java @@ -1,102 +1,102 @@ -/*
- * Copyright (c) 2004 - 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();
- }
- }
-}
+/* + * Copyright (c) 2004 - 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(); + } + } +} |