From 97599db0d2ad1ebcb872ad64e61ecc4567d73f4a Mon Sep 17 00:00:00 2001
From: HappyZ <zhuyanzi@gmail.com>
Date: Wed, 1 Mar 2017 22:12:57 -0800
Subject: [PATCH] add mac tcp and udp receiver (as backup)

---
 osx_as_ap/TCPReceiver.class | Bin 0 -> 2191 bytes
 osx_as_ap/TCPReceiver.java  |  62 ++++++++++++++++++++++++++++++++++++
 osx_as_ap/UDPReceiver.class | Bin 0 -> 570 bytes
 osx_as_ap/UDPReceiver.java  |  25 +++++++++++++++
 4 files changed, 87 insertions(+)
 create mode 100644 osx_as_ap/TCPReceiver.class
 create mode 100644 osx_as_ap/TCPReceiver.java
 create mode 100644 osx_as_ap/UDPReceiver.class
 create mode 100644 osx_as_ap/UDPReceiver.java

diff --git a/osx_as_ap/TCPReceiver.class b/osx_as_ap/TCPReceiver.class
new file mode 100644
index 0000000000000000000000000000000000000000..4c4769d0733f81fe433cc1356884c5e7aae6b4f7
GIT binary patch
literal 2191
zcma)8TUQfT6#gazCJaO67Ll8dQYAnn79~|stbkhD1TCT7+d3qNIFQW5$poeL`Xl<>
zN1yF#gR8F9AJE7Cfc}y$>33!V8CzFZAF`P_XJ5bl?LGYd`q$q8oW=JVMv-pEVZ5*6
zyoMHB&@hWRDK2Wbgn210x8nm`QL&&wLpp{<`FBZbUzJZ3*Kl3MhcPV2@R5dYd@Myq
zMOLHhv=l2++|Y0npGfDcG32D}nubqtON!g_?oJGM<?%fg_Z7rSR@D=>a21SYHqC7_
zWm`@v|H!m$QL3hL!rc~b&dF~HZ!tKWQ_yzNvMq03K}%x%mV)S_QxFOcWh`5))XM9^
zT{G89JW<O#IpNhR3OaM1ncvEq75|1w6AD&C+p=ld3Jxdk2hmHWT}<UX*RqRq(s#@i
zW?{+nOcf7Qe5OFlIW;#gu30ib*V^LERgo7Klbn*->o|om9q;0#g2A91;iZ;s;RQ8Z
zDHL2$txC1eReYi2A!xIXyo!Pjfejr+JW^rl*u<8Ce&0tZsfC(VDoC{YGCpw3({OB~
z;<%nMYv?GUtiy(*qN3w5sMzbfAgIeXu0G9+if1`2c<`FZ3JQkj80(f@NE%jk--&{w
zhFOwz?--VC)T+X`Y+Q9+$2GFmq93ISM~8<o1sx#-bWF(N-@_Qe(ow^<jwg6Zr7L+E
znBjsHcZj5pFY!#rSNK}TH~5zAYXDg=3WPgQ{EiSe5xB9wDe~TaMUp2AJDymmZEQ$D
zjs<YP!JaU0*z3fyZ0X6jDE^yfRCg+ZNR21P|35LSenbTW2S#jvn8ajnJc$2~3j$CT
z-l`zn4U))&@A>?e9a1oqXyhR+{WuLppQs_6ayuNUGN;3-5v_P&MO<!@)gHMm%(5IJ
zv%>o5_jJQ=h-Gt)l0!!g;?XeXIl+LCg!^TN6sd7Qxllw-V@1X<5z_eEBC<1DQFvL7
zhgp>4?5q28yXKmCp2W;j$;q1@ACIt=&8{?Q;Me7oO~L4Xa&K;wFej+~M)d*1{<He-
zykl=z#hNP?n9LUEPeFoxYGxB!UM2EXuA=7Zipsf?`8V}L*^e)?FRpmv_q#Wof539)
zJA6=i2=o2s;5aw%DA&HiAD0kil+WBrlnK6_Ld3t*CU&7rD8C@`!q*<B)OZK9(?a8q
zquj9hgCBtw-aLMVmb=~E4|WmFOuR%ZjVFFaq>i?1GFpe4oU9}E6WU)vySs~y9=(oE
z9=*dqbsVar>p9M3L-#$+`<`AtC+p}t(B(_~1rzAtXK9finh0cyQ+x+HDZ9|a(?QB(
z=w+#W)El5?97}|tgd?b62$R(AMP!c`5fw=lr=h5rO0von&NS+qp>tVz_bVJ`;{6#W
zePnVM15Idp2nZM{1_L@l?!pP0aM1-Wlzsx#MvZ6PU3iJXOn}Q!xZ2^M!jS+93E0uw
zE%Pnu=t$&8j7sc|&Bvo757W`-&}Ul*S_wd8p2x=R=X-yKU^`AnahjiKfV%fXHUKMv
z^DO>4VNtnzYX_jM5CV`3Dj9HyFecdBDME7wN&b6qnpP>y^KA(;w4TN?Pgih`pXxO3
y@YclzdYi>I=D4#j`JkRc+h0&sOuxpYinEH6BdjrX55o<hr+uIa&pF19VCHY${0goB

literal 0
HcmV?d00001

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 0000000000000000000000000000000000000000..6981eee7a8090280fbf3f2f934eb2756a11f005f
GIT binary patch
literal 570
zcmZuuO;5r=5Pe$;iv<)!#Si?%LscRNZ)!Z?M`D6VL`@8*rEW+O3aQ2Tk34%3qsAZL
zkMSp<vuz?AY_>DAGqdl#+5H;4eFE6Qx`8NWI5Gw_%yP^b&@rzz3mjRFMTW?}?bzM{
zL&)5?X3!5iw~}F^WIM9lYuBZFDe5iC=xt#;3^Qh})D#b*&=O9gQ1x8fY3!+kiK-{8
zyED=C`-zfciNQF2v}D(_JI+1FGVQCKo@>byTR|qTjw%<@lJ<jiw-sm{V=x#pK7k{>
z!jbSq!ximn$GVfADzE%kt`KujUX5c7IfmE>G!YFIpVynx@))#Qks&?I|LLSj%~Lf{
z#H<zlfV+W4hO8OPJ}NEXrYpcIINi4TG%z&@*%<8>$usid%|6&O1q^YrkswKp35?Sb
z)!L%x36syiL%T_>z4j3*rF48m&wN{chkldKfA$gH)wkyK7et<ZzNugH5$6dLBq2ta
kDWcC1a*nV!D4L+kIM_hFOOhi+3zL-7Nky9eDIaC}7pnAfB>(^b

literal 0
HcmV?d00001

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