front_processing/extern/TUIO_JAVA/src/com/illposed/osc/OSCPortIn.java
changeset 9 0f44b7360c8d
parent 0 6fefd4afe506
child 10 925b7ee746e3
--- a/front_processing/extern/TUIO_JAVA/src/com/illposed/osc/OSCPortIn.java	Thu Mar 22 16:00:17 2012 +0100
+++ b/front_processing/extern/TUIO_JAVA/src/com/illposed/osc/OSCPortIn.java	Thu Mar 22 18:15:53 2012 +0100
@@ -1,4 +1,4 @@
-/**
+/**
  * @author cramakrishnan
  *
  * Copyright (C) 2004, C. Ramakrishnan / Illposed Software
@@ -8,20 +8,20 @@
  * 
  * 
  * OSCPortIn is the class that listens for OSC messages.
- *	 
+ *     
  * To receive OSC, you need to construct the OSCPort with a 
  *
  * An example based on com.illposed.osc.test.OSCPortTest::testReceiving() :
  
-		receiver = new OSCPort(OSCPort.defaultSCOSCPort());
-		OSCListener listener = new OSCListener() {
-			public void acceptMessage(java.util.Date time, OSCMessage message) {
-				System.out.println("Message received!");
-			}
-		};
-		receiver.addListener("/message/receiving", listener);
-		receiver.startListening();
-		
+        receiver = new OSCPort(OSCPort.defaultSCOSCPort());
+        OSCListener listener = new OSCListener() {
+            public void acceptMessage(java.util.Date time, OSCMessage message) {
+                System.out.println("Message received!");
+            }
+        };
+        receiver.addListener("/message/receiving", listener);
+        receiver.startListening();
+        
  * Then, using a program such as SuperCollider or sendOSC, send a message
  * to this computer, port 57110 (defaultSCOSCPort), with the address /message/receiving
  */
@@ -35,80 +35,80 @@
 
 public class OSCPortIn extends OSCPort implements Runnable {
 
-	// state for listening
-	protected boolean isListening;
-	protected OSCByteArrayToJavaConverter converter = new OSCByteArrayToJavaConverter();
-	protected OSCPacketDispatcher dispatcher = new OSCPacketDispatcher();
-	
-	/**
-	 * Create an OSCPort that listens on port
-	 * @param port
-	 * @throws SocketException
-	 */
-	public OSCPortIn(int port) throws SocketException {
-		socket = new DatagramSocket(port);
-		this.port = port;
-	}
+    // state for listening
+    protected boolean isListening;
+    protected OSCByteArrayToJavaConverter converter = new OSCByteArrayToJavaConverter();
+    protected OSCPacketDispatcher dispatcher = new OSCPacketDispatcher();
+    
+    /**
+     * Create an OSCPort that listens on port
+     * @param port
+     * @throws SocketException
+     */
+    public OSCPortIn(int port) throws SocketException {
+        socket = new DatagramSocket(port);
+        this.port = port;
+    }
 
-	/**
-	 * @see java.lang.Runnable#run()
-	 */
-	public void run() {
-		//maximum UDP packet size
-		byte[] buffer = new byte[65536];
-		DatagramPacket packet = new DatagramPacket(buffer, 65536);
-		while (isListening) {
-			try {
-				packet.setLength(65536);
-				socket.receive(packet);
-				OSCPacket oscPacket = converter.convert(buffer, packet.getLength());
-				dispatcher.dispatchPacket(oscPacket);
-			} catch (java.net.SocketException e) {
-				if (isListening) e.printStackTrace();
-			} catch (IOException e) {
-				if (isListening) e.printStackTrace();
-			} 
-		}
-	}
-	
-	/**
-	 * Start listening for incoming OSCPackets
-	 */
-	public void startListening() {
-		isListening = true;
-		Thread thread = new Thread(this);
-		thread.start();
-	}
-	
-	/**
-	 * Stop listening for incoming OSCPackets
-	 */
-	public void stopListening() {
-		isListening = false;
-	}
-	
-	/**
-	 * Am I listening for packets?
-	 */
-	public boolean isListening() {
-		return isListening;
-	}
-	
-	/**
-	 * Register the listener for incoming OSCPackets addressed to an Address
-	 * @param anAddress  the address to listen for
-	 * @param listener   the object to invoke when a message comes in
-	 */
-	public void addListener(String anAddress, OSCListener listener) {
-		dispatcher.addListener(anAddress, listener);
-	}
-	
-	/**
-	 * Close the socket and free-up resources. It's recommended that clients call
-	 * this when they are done with the port.
-	 */
-	public void close() {
-		socket.close();
-	}
+    /**
+     * @see java.lang.Runnable#run()
+     */
+    public void run() {
+        //maximum UDP packet size
+        byte[] buffer = new byte[65536];
+        DatagramPacket packet = new DatagramPacket(buffer, 65536);
+        while (isListening) {
+            try {
+                packet.setLength(65536);
+                socket.receive(packet);
+                OSCPacket oscPacket = converter.convert(buffer, packet.getLength());
+                dispatcher.dispatchPacket(oscPacket);
+            } catch (java.net.SocketException e) {
+                if (isListening) e.printStackTrace();
+            } catch (IOException e) {
+                if (isListening) e.printStackTrace();
+            } 
+        }
+    }
+    
+    /**
+     * Start listening for incoming OSCPackets
+     */
+    public void startListening() {
+        isListening = true;
+        Thread thread = new Thread(this);
+        thread.start();
+    }
+    
+    /**
+     * Stop listening for incoming OSCPackets
+     */
+    public void stopListening() {
+        isListening = false;
+    }
+    
+    /**
+     * Am I listening for packets?
+     */
+    public boolean isListening() {
+        return isListening;
+    }
+    
+    /**
+     * Register the listener for incoming OSCPackets addressed to an Address
+     * @param anAddress  the address to listen for
+     * @param listener   the object to invoke when a message comes in
+     */
+    public void addListener(String anAddress, OSCListener listener) {
+        dispatcher.addListener(anAddress, listener);
+    }
+    
+    /**
+     * Close the socket and free-up resources. It's recommended that clients call
+     * this when they are done with the port.
+     */
+    public void close() {
+        socket.close();
+    }
 
 }