1 files changed, 177 insertions, 0 deletions
diff --git a/libraries/oscP5/src/netP5/TcpServer.java b/libraries/oscP5/src/netP5/TcpServer.java
new file mode 100644
index 0000000..af832a3
--- /dev/null
+++ b/libraries/oscP5/src/netP5/TcpServer.java
@@ -0,0 +1,177 @@
+/**
+ * A network library for processing which supports UDP, TCP and Multicast.
+ *
+ * (c) 2004-2012
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ * 
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ * 
+ * You should have received a copy of the GNU Lesser General
+ * Public License along with this library; if not, write to the
+ * Free Software Foundation, Inc., 59 Temple Place, Suite 330,
+ * Boston, MA  02111-1307  USA
+ * 
+ * @author		Andreas Schlegel http://www.sojamo.de
+ * @modified	12/23/2012
+ * @version		0.9.9
+ */
+
+package netP5;
+
+import java.util.Vector;
+
+
+
+/**
+ * @author andreas schlegel
+ */
+public class TcpServer
+    extends AbstractTcpServer {
+
+  protected NetPlug _myNetPlug;
+
+  protected Object _myParent;
+
+  protected final static int NULL = -1;
+
+  protected final static int LISTENER = 0;
+
+  protected final static int EVENT = 1;
+
+  protected int _myMode = NULL;
+
+  /**
+   * @invisible
+   * @param thePort int
+   */
+  public TcpServer(final int thePort) {
+    super(thePort, AbstractTcpServer.MODE_READLINE);
+  }
+
+
+  /**
+   *
+   * @param theObject Object
+   * @param thePort int
+   */
+  public TcpServer(final Object theObject,
+                   final int thePort) {
+    super(thePort, AbstractTcpServer.MODE_READLINE);
+    _myParent = theObject;
+    initEvent();
+  }
+
+
+  /**
+   *
+   * @param theObject Object
+   * @param thePort int
+   * @param theMode int
+   */
+  public TcpServer(final Object theObject,
+                   final int thePort,
+                   final int theMode) {
+    super(thePort, theMode);
+    _myParent = theObject;
+    initEvent();
+  }
+
+
+  /**
+   *
+   * @param thePort int
+   * @param theMode int
+   */
+  public TcpServer(final int thePort,
+                   final int theMode) {
+    super(thePort, theMode);
+  }
+
+
+  /**
+   * @invisible
+   * @param theTcpPacketListener TcpPacketListener
+   * @param thePort int
+   * @param theMode int
+   */
+  public TcpServer(final TcpPacketListener theTcpPacketListener,
+                   final int thePort,
+                   final int theMode) {
+    super(theTcpPacketListener, thePort, theMode);
+    _myMode = LISTENER;
+  }
+
+
+
+  private void initEvent() {
+    _myMode = EVENT;
+    _myNetPlug = new NetPlug(_myParent);
+//    _myEventListener.checkMethod();
+
+  }
+
+
+  /**
+   * @invisible
+   * @param thePacket TcpPacket
+   * @param thePort int
+   */
+  public void handleInput(final TcpPacket thePacket,
+                          final int thePort) {
+    switch (_myMode) {
+      case (EVENT):
+        _myNetPlug.process(thePacket, thePort);
+        break;
+      case (LISTENER):
+        break;
+      case (NULL):
+        System.out.println("received a message : " + thePacket.getString());
+        break;
+    }
+  }
+
+
+  /**
+   * @invisible
+   * @param theIndex int
+   */
+  public void status(final int theIndex) {
+    switch (_myMode) {
+      case (EVENT):
+        _myNetPlug.status(theIndex);
+        break;
+      case (LISTENER):
+      case (NULL):
+        System.out.println("### status id : " + theIndex);
+        break;
+    }
+  }
+  
+  
+	
+	public void addListener(NetListener theListener) {
+		_myNetPlug.addListener(theListener);
+	}
+	
+	
+	public void removeListener(NetListener theListener) {
+		_myNetPlug.removeListener(theListener);
+	}
+	
+	public NetListener getListener(int theIndex) {
+		return _myNetPlug.getListener(theIndex);
+	}
+
+	public Vector getListeners() {
+		return _myNetPlug.getListeners();
+	}
+	
+	
+}