1 files changed, 0 insertions, 235 deletions
diff --git a/plugins/org.eclipse.net4j/src/org/eclipse/net4j/util/Net4jUtil.java b/plugins/org.eclipse.net4j/src/org/eclipse/net4j/util/Net4jUtil.java
deleted file mode 100644
index 86afa5a8ff..0000000000
--- a/plugins/org.eclipse.net4j/src/org/eclipse/net4j/util/Net4jUtil.java
+++ /dev/null
@@ -1,235 +0,0 @@
-/***************************************************************************
- * Copyright (c) 2004, 2005, 2006 Eike Stepper, Germany.
- * 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.util;
-
-import org.eclipse.net4j.transport.BufferPool;
-import org.eclipse.net4j.transport.BufferProvider;
-import org.eclipse.net4j.transport.Channel;
-import org.eclipse.net4j.transport.ChannelID;
-import org.eclipse.net4j.transport.Connector;
-import org.eclipse.net4j.transport.Protocol;
-import org.eclipse.net4j.transport.ProtocolFactory;
-import org.eclipse.net4j.transport.ProtocolFactoryID;
-import org.eclipse.net4j.transport.TransportContainer;
-import org.eclipse.net4j.transport.Connector.Type;
-import org.eclipse.net4j.transport.tcp.TCPAcceptor;
-import org.eclipse.net4j.transport.tcp.TCPConnectorDescription;
-import org.eclipse.net4j.transport.tcp.TCPSelector;
-import org.eclipse.net4j.util.registry.HashMapRegistry;
-import org.eclipse.net4j.util.registry.IRegistry;
-
-import org.eclipse.internal.net4j.transport.BufferFactoryImpl;
-import org.eclipse.internal.net4j.transport.BufferPoolImpl;
-import org.eclipse.internal.net4j.transport.BufferUtil;
-import org.eclipse.internal.net4j.transport.ProtocolFactoryIDImpl;
-import org.eclipse.internal.net4j.transport.embedded.ClientEmbeddedConnectorImpl;
-import org.eclipse.internal.net4j.transport.tcp.ClientTCPConnectorImpl;
-import org.eclipse.internal.net4j.transport.tcp.TCPAcceptorImpl;
-import org.eclipse.internal.net4j.transport.tcp.TCPConnectorDescriptionImpl;
-import org.eclipse.internal.net4j.transport.tcp.TCPSelectorImpl;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Map;
-import java.util.Set;
-import java.util.Map.Entry;
-
-/**
- * @author Eike Stepper
- */
-public final class Net4jUtil
-{
-  private Net4jUtil()
-  {
-  }
-
-  public static BufferProvider createBufferFactory(short bufferCapacity)
-  {
-    return new BufferFactoryImpl(bufferCapacity);
-  }
-
-  public static BufferProvider createBufferFactory()
-  {
-    return new BufferFactoryImpl(BufferUtil.DEFAULT_BUFFER_CAPACITY);
-  }
-
-  public static BufferPool createBufferPool(BufferProvider factory)
-  {
-    return new BufferPoolImpl(factory);
-  }
-
-  public static BufferPool createBufferPool(short bufferCapacity)
-  {
-    return createBufferPool(createBufferFactory(bufferCapacity));
-  }
-
-  public static BufferPool createBufferPool()
-  {
-    return createBufferPool(createBufferFactory());
-  }
-
-  public static ProtocolFactoryID createProtocolFactoryID(Type type, String protocolID)
-  {
-    return new ProtocolFactoryIDImpl(type, protocolID);
-  }
-
-  public static Connector createEmbeddedConnector(BufferProvider bufferProvider)
-  {
-    ClientEmbeddedConnectorImpl connector = new ClientEmbeddedConnectorImpl();
-    connector.setBufferProvider(bufferProvider);
-    return connector;
-  }
-
-  public static TCPAcceptor createTCPAcceptor(BufferProvider bufferProvider, TCPSelector selector, String address,
-      int port)
-  {
-    TCPAcceptorImpl acceptor = new TCPAcceptorImpl();
-    acceptor.setBufferProvider(bufferProvider);
-    acceptor.setSelector(selector);
-    acceptor.setListenPort(port);
-    acceptor.setListenAddr(address);
-    return acceptor;
-  }
-
-  public static TCPAcceptor createTCPAcceptor(BufferProvider bufferProvider, TCPSelector selector)
-  {
-    return createTCPAcceptor(bufferProvider, selector, TCPAcceptor.DEFAULT_ADDRESS, TCPAcceptor.DEFAULT_PORT);
-  }
-
-  public static Connector createTCPConnector(BufferProvider bufferProvider, TCPSelector selector, String host, int port)
-  {
-    ClientTCPConnectorImpl connector = new ClientTCPConnectorImpl();
-    connector.setBufferProvider(bufferProvider);
-    connector.setSelector(selector);
-    connector.setDescription(new TCPConnectorDescriptionImpl(host, port));
-    return connector;
-  }
-
-  public static Connector createTCPConnector(BufferProvider bufferProvider, TCPSelector selector, String host)
-  {
-    return createTCPConnector(bufferProvider, selector, host, TCPConnectorDescription.DEFAULT_PORT);
-  }
-
-  public static TCPSelector createTCPSelector()
-  {
-    return new TCPSelectorImpl();
-  }
-
-  public static Collection<Channel> getChannels(TransportContainer container, String protocolID, Set<Type> types)
-  {
-    if (types == null)
-    {
-      types = ProtocolFactory.SYMMETRIC;
-    }
-
-    IRegistry<ChannelID, Channel> channelRegistry = container.getChannelRegistry();
-    if (channelRegistry == null)
-    {
-      return null;
-    }
-
-    Collection<Channel> channels = channelRegistry.values();
-    Collection<Channel> result = new ArrayList(channels.size());
-    for (Channel channel : channels)
-    {
-      if (types.contains(channel.getConnector().getType()))
-      {
-        if (protocolID == null || protocolID.length() == 0)
-        {
-          result.add(channel);
-        }
-        else
-        {
-          if (channel.getReceiveHandler() instanceof Protocol)
-          {
-            Protocol protocol = (Protocol)channel.getReceiveHandler();
-            if (protocolID.equals(protocol.getProtocolID()))
-            {
-              result.add(channel);
-            }
-          }
-        }
-      }
-    }
-
-    return result;
-  }
-
-  public static Collection<Channel> getChannels(TransportContainer container, String protocolID)
-  {
-    return getChannels(container, protocolID, null);
-  }
-
-  public static Collection<Channel> getChannels(TransportContainer container, Set<Type> types)
-  {
-    return getChannels(container, null, types);
-  }
-
-  public static Map<Type, IRegistry<ProtocolFactoryID, ProtocolFactory>> createProtocolFactoryRegistries(Set<Type> types)
-  {
-    Map<Type, IRegistry<ProtocolFactoryID, ProtocolFactory>> result = new HashMap();
-    for (Type type : types)
-    {
-      result.put(type, new HashMapRegistry());
-    }
-
-    return result;
-  }
-
-  public static Set<Type> registerProtocolFactory(ProtocolFactory factory,
-      Map<Type, IRegistry<ProtocolFactoryID, ProtocolFactory>> registries)
-  {
-    Set<Type> result = new HashSet();
-    for (Entry<Type, IRegistry<ProtocolFactoryID, ProtocolFactory>> entry : registries.entrySet())
-    {
-      Type type = entry.getKey();
-      IRegistry<ProtocolFactoryID, ProtocolFactory> registry = entry.getValue();
-      if (factory.getConnectorTypes().contains(type))
-      {
-        ProtocolFactoryID id = factory.createID(type);
-        if (!registry.containsKey(id))
-        {
-          registry.put(id, factory);
-        }
-        else
-        {
-          result.add(type);
-        }
-      }
-    }
-
-    return result;
-  }
-
-  public static Set<Type> deregisterProtocolFactory(ProtocolFactory factory,
-      Map<Type, IRegistry<ProtocolFactoryID, ProtocolFactory>> registries)
-  {
-    Set<Type> result = new HashSet();
-    for (Entry<Type, IRegistry<ProtocolFactoryID, ProtocolFactory>> entry : registries.entrySet())
-    {
-      Type type = entry.getKey();
-      IRegistry<ProtocolFactoryID, ProtocolFactory> registry = entry.getValue();
-      if (factory.getConnectorTypes().contains(type))
-      {
-        ProtocolFactoryID id = factory.createID(type);
-        ProtocolFactory old = registry.remove(id);
-        if (old != null)
-        {
-          result.add(type);
-        }
-      }
-    }
-
-    return result;
-  }
-}