diff --git a/osx_as_ap/TCPReceiver.class b/osx_as_ap/TCPReceiver.class new file mode 100644 index 0000000..4c4769d Binary files /dev/null and b/osx_as_ap/TCPReceiver.class differ diff --git a/osx_as_ap/TCPReceiver.java b/osx_as_ap/TCPReceiver.java new file mode 100644 index 0000000..9227081 --- /dev/null +++ b/osx_as_ap/TCPReceiver.java @@ -0,0 +1,62 @@ +import java.io.IOException; +import java.net.InetSocketAddress; +import java.net.ServerSocket; +import java.nio.ByteBuffer; +import java.nio.channels.ServerSocketChannel; +import java.nio.channels.SocketChannel; + + +public class TCPReceiver { + ServerSocketChannel listener = null; + protected void mySetup() + { + InetSocketAddress listenAddr = new InetSocketAddress(4444); + + try { + listener = ServerSocketChannel.open(); + ServerSocket ss = listener.socket(); + ss.setReuseAddress(true); + ss.bind(listenAddr); + System.out.println("Listening on port : "+ listenAddr.toString()); + } catch (IOException e) { + System.out.println("Failed to bind, is port : "+ listenAddr.toString() + + " already in use ? Error Msg : "+e.getMessage()); + e.printStackTrace(); + } + + } + + public static void main(String[] args) + { + TCPReceiver dns = new TCPReceiver(); + dns.mySetup(); + dns.readData(); + } + + private void readData() { + ByteBuffer dst = ByteBuffer.allocate(4096); + try { + while(true) { + SocketChannel conn = listener.accept(); + System.out.println("Accepted : "+conn); + conn.configureBlocking(true); + int nread = 0; + int data_recv = 0; + while (nread != -1) { + try { + nread = conn.read(dst); + data_recv += nread; + // System.out.println("data: " +nread); + } catch (IOException e) { + e.printStackTrace(); + nread = -1; + } + dst.rewind(); + } + System.out.println("Received data: "+data_recv); + } + } catch (IOException e) { + e.printStackTrace(); + } + } +} \ No newline at end of file diff --git a/osx_as_ap/UDPReceiver.class b/osx_as_ap/UDPReceiver.class new file mode 100644 index 0000000..6981eee Binary files /dev/null and b/osx_as_ap/UDPReceiver.class differ diff --git a/osx_as_ap/UDPReceiver.java b/osx_as_ap/UDPReceiver.java new file mode 100644 index 0000000..05b648a --- /dev/null +++ b/osx_as_ap/UDPReceiver.java @@ -0,0 +1,25 @@ +import java.io.*; +import java.net.*; + + +public class UDPReceiver { + public static void main(String args[]) throws Exception + { + DatagramSocket serverSocket = new DatagramSocket(8888); + byte[] receiveData = new byte[1024]; + byte[] sendData = new byte[1024]; + while(true) + { + DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length); + serverSocket.receive(receivePacket); + //String sentence = new String( receivePacket.getData()); + //System.out.println("RECEIVED: " + sentence); + //InetAddress IPAddress = receivePacket.getAddress(); + //int port = receivePacket.getPort(); + //String capitalizedSentence = sentence.toUpperCase(); + //sendData = capitalizedSentence.getBytes(); + //DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, port); + //serverSocket.send(sendPacket); + } + } +} \ No newline at end of file