1 files changed, 214 insertions, 0 deletions
diff --git a/libraries/oscP5/src/netP5/TcpClient.java b/libraries/oscP5/src/netP5/TcpClient.java
new file mode 100644
index 0000000..05515ad
--- /dev/null
+++ b/libraries/oscP5/src/netP5/TcpClient.java
@@ -0,0 +1,214 @@
+/**
+ * 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.net.Socket;
+
+
+/**
+ * @author andreas schlegel
+ */
+public class TcpClient
+    extends AbstractTcpClient {
+
+  protected final static int NULL = -1;
+
+  protected final static int LISTENER = 0;
+
+  protected final static int EVENT = 1;
+
+  private int _myMode = NULL;
+
+  private Object _myParent;
+
+  private NetPlug _myNetPlug;
+
+  private String _myName = "";
+
+  /**
+   *
+   * @param theAddress String
+   * @param thePort int
+   */
+
+  public TcpClient(final Object theObject,
+                   final String theAddress,
+                   final int thePort) {
+    super(theAddress, thePort);
+    _myParent = theObject;
+    initEvent();
+  }
+
+
+  /**
+   *
+   * @param theObject Object
+   * @param theAddress String
+   * @param thePort int
+   * @param theMode int
+   */
+  public TcpClient(final Object theObject,
+                   final String theAddress,
+                   final int thePort,
+                   final int theMode
+      ) {
+    super(theAddress, thePort, theMode);
+    _myParent = theObject;
+    initEvent();
+  }
+
+
+  /**
+   *
+   * @param theListener TcpPacketListener
+   * @param theServerAddress String
+   * @param theServerPort int
+   * @param theMode int
+   */
+  public TcpClient(TcpPacketListener theListener,
+                   String theServerAddress,
+                   int theServerPort,
+                   int theMode) {
+    super(theListener, theServerAddress, theServerPort, theMode);
+    _myMode = LISTENER;
+  }
+
+
+
+  /**
+   *
+   * @param theNetAddress NetAddress
+   */
+  public TcpClient(final Object theObject,
+                   final NetAddress theNetAddress) {
+    super(theNetAddress.address(), theNetAddress.port());
+    _myParent = theObject;
+    initEvent();
+  }
+
+
+  /**
+   *
+   * @param theNetAddress NetAddress
+   */
+  public TcpClient(final NetAddress theNetAddress) {
+    super(theNetAddress.address(), theNetAddress.port());
+  }
+
+
+
+  /**
+   *
+   * @param theAddress String
+   * @param thePort int
+   */
+  public TcpClient(final String theAddress,
+                   final int thePort) {
+    super(theAddress, thePort);
+  }
+
+
+
+  /**
+   * @invisible
+   */
+  public TcpClient(AbstractTcpServer theTcpServer,
+                   Socket theSocket,
+                   TcpPacketListener theTcpPacketListener,
+                   int theServerPort,
+                   int theMode) {
+    super(theTcpServer,
+          theSocket,
+          theTcpPacketListener,
+          theServerPort,
+          theMode);
+    _myMode = LISTENER;
+  }
+  
+  
+
+  private void initEvent() {
+    _myMode = EVENT;
+    _myNetPlug = new NetPlug(_myParent);
+  }
+
+
+  /**
+   * @invisible
+   * @param theIndex int
+   */
+  public void handleStatus(int theIndex) {
+    switch (_myMode) {
+      case (EVENT):
+        _myNetPlug.status(theIndex);
+        break;
+      case (LISTENER):
+        _myTcpPacketListener.status(theIndex);
+        break;
+      case (NULL):
+        Logger.printDebug("TcpClient.handleStatus()","net status id " + theIndex);
+        break;
+    }
+  }
+
+
+  /**
+   * @invisible
+   */
+  public void handleInput() {
+    switch (_myMode) {
+      case (EVENT):
+        _myNetPlug.process(new TcpPacket(this, _myStringBuffer, _myBytes),_myServerPort);
+        break;
+      case (LISTENER):
+        _myTcpPacketListener.process(new TcpPacket(this, _myStringBuffer, _myBytes),_myServerPort);
+        break;
+      case (NULL):
+    	  Logger.printDebug("TcpClient.handleInput()","received a message : " + _myStringBuffer.toString());
+        break;
+    }
+  }
+
+
+  /**
+   *
+   * @return String
+   */
+  public String name() {
+    return _myName;
+  }
+
+
+  /**
+   *
+   * @param theName String
+   */
+  public void setName(String theName) {
+    _myName = theName;
+  }
+
+}