From 6164d1bf7e03007f0af6b32a9d8f4eeacbc16282 Mon Sep 17 00:00:00 2001
From: Roger Hughston <rogerhughston@users.sourceforge.net>
Date: Tue, 7 Nov 2006 00:58:31 +0000
Subject: [PATCH] add net tests

---
 panda/src/testbed/test_native_net1.py | 38 ++++++++++++++++++++
 panda/src/testbed/test_native_net2.py | 49 ++++++++++++++++++++++++++
 panda/src/testbed/test_native_net3.py | 50 +++++++++++++++++++++++++++
 3 files changed, 137 insertions(+)
 create mode 100644 panda/src/testbed/test_native_net1.py
 create mode 100644 panda/src/testbed/test_native_net2.py
 create mode 100644 panda/src/testbed/test_native_net3.py

diff --git a/panda/src/testbed/test_native_net1.py b/panda/src/testbed/test_native_net1.py
new file mode 100644
index 0000000000..544466aa00
--- /dev/null
+++ b/panda/src/testbed/test_native_net1.py
@@ -0,0 +1,38 @@
+from libpandaexpress import BufferedDatagramConnection
+from libpandaexpress import SocketAddress
+from libpandaexpress import SocketIP
+from libpandaexpress import SocketTCP
+from libpandaexpress import SocketTCPListen
+from libpandaexpress import SocketUDPOutgoing
+from libpandaexpress import SocketUDPIncoming
+
+
+SocketIP.InitNetworkDriver();
+
+addr = SocketAddress()
+addr.setHost("127.0.0.1",8080)
+print addr.getIpPort()
+
+
+inbound = SocketTCPListen()
+inbound.OpenForListen(addr);
+##inbound.SetNonBlocking();
+
+while 1 == 1:
+    newsession = SocketTCP()
+    source = SocketAddress()
+    if inbound.GetIncomingConnection(newsession,source) :
+        #newsession.SetNonBlocking();
+        print source.getIpPort()    
+        newsession.SendData("Hello From the Listener\n\r");    
+        
+        s = newsession.RecvData(10);            
+        print s
+        print newsession.GetLastError()
+        if newsession.ErrorIsWouldBlocking(newsession.GetLastError()) :
+            print  "Reading Would Block"
+        else:
+            print "Not A Blocking Error"            
+        
+        newsession.SendData("GoodBy From the Listener\n\r");    
+        newsession.Close();
diff --git a/panda/src/testbed/test_native_net2.py b/panda/src/testbed/test_native_net2.py
new file mode 100644
index 0000000000..47a23e0501
--- /dev/null
+++ b/panda/src/testbed/test_native_net2.py
@@ -0,0 +1,49 @@
+from libpandaexpress import BufferedDatagramConnection
+from libpandaexpress import SocketAddress
+from libpandaexpress import SocketIP
+from libpandaexpress import SocketTCP
+from libpandaexpress import SocketTCPListen
+from libpandaexpress import SocketUDPOutgoing
+from libpandaexpress import SocketUDPIncoming
+from libpandaexpress import Datagram
+
+import time
+
+
+
+SocketIP.InitNetworkDriver();
+
+addr = SocketAddress()
+addr.setHost("127.0.0.1",6666)
+print addr.getIpPort()
+
+MyConection = BufferedDatagramConnection(0,4096000,4096000,102400);
+#help(BufferedDatagramConnection)
+
+MyConection.AddAddress(addr)
+
+dg = Datagram();
+dg.addUint8(1)
+dg.addUint64(4001)
+dg.addUint16(2001)
+dg.addUint64(123456)
+
+##MyConection.SendMessage(dg);
+
+
+dg1 = Datagram();
+dg1.addUint8(1)
+dg1.addUint64(123456)
+dg1.addUint64(12340)
+dg1.addUint16(1000)
+dg1.addUint16(54321)
+
+
+while 1==1:
+    for x in range(200000):
+        if  not MyConection.SendMessage(dg1):
+            print "Error Sending Message"
+        
+    MyConection.Flush();
+    time.sleep(1)
+    print "loop"
\ No newline at end of file
diff --git a/panda/src/testbed/test_native_net3.py b/panda/src/testbed/test_native_net3.py
new file mode 100644
index 0000000000..4f01aac6d3
--- /dev/null
+++ b/panda/src/testbed/test_native_net3.py
@@ -0,0 +1,50 @@
+from libpandaexpress import BufferedDatagramConnection
+from libpandaexpress import SocketAddress
+from libpandaexpress import SocketIP
+from libpandaexpress import SocketTCP
+from libpandaexpress import SocketTCPListen
+from libpandaexpress import SocketUDPOutgoing
+from libpandaexpress import SocketUDPIncoming
+from libpandaexpress import Datagram
+
+import time
+
+
+
+SocketIP.InitNetworkDriver();
+
+addr = SocketAddress()
+addr.setHost("127.0.0.1",6666)
+print addr.getIpPort()
+
+MyConection = BufferedDatagramConnection(0,4096000,4096000,102400);
+#help(BufferedDatagramConnection)
+
+MyConection.AddAddress(addr)
+
+dg = Datagram();
+dg.addUint8(1)
+dg.addUint64(4001)
+dg.addUint16(2001)
+dg.addUint64(123456)
+
+MyConection.SendMessage(dg);
+
+
+dg1 = Datagram();
+dg1.addUint8(1)
+dg1.addUint64(123456)
+dg1.addUint64(12340)
+dg1.addUint16(1000)
+dg1.addUint16(54321)
+
+
+while 1==1:
+    MyConection.SendMessage(dg);
+    ##for x in range(120000):
+    while MyConection.GetMessage():
+        None
+        
+    MyConection.Flush();
+    time.sleep(1)
+    print "loop"
\ No newline at end of file