From db605dd18b11ecfb5cd9f92c721c52cb70543384 Mon Sep 17 00:00:00 2001
From: "David A. Mellis" <d.mellis@arduino.cc>
Date: Mon, 1 Jun 2009 08:32:11 +0000
Subject: First integration of the Arduino code in Processing 5503:
 PreProcessor and Compiler have been integrated with changes to the Sketch.
 Compilation still has problems (Thread error on success, and can't handle
 non-pde files in a sketch). Modified the Mac OS X make.sh to copy the
 hardware, avr tools, and example over. Removing some of the antlr stuff.
 Disabling the Commander (command-line execution) for now. Added Library,
 LibraryManager, and Target. Added support for prefixed preferences (e.g. for
 boards and programmers).

---
 libraries/Ethernet/Server.cpp | 91 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 91 insertions(+)
 create mode 100644 libraries/Ethernet/Server.cpp

(limited to 'libraries/Ethernet/Server.cpp')

diff --git a/libraries/Ethernet/Server.cpp b/libraries/Ethernet/Server.cpp
new file mode 100644
index 0000000..d17a5d3
--- /dev/null
+++ b/libraries/Ethernet/Server.cpp
@@ -0,0 +1,91 @@
+extern "C" {
+  #include "types.h"
+  #include "w5100.h"
+  #include "socket.h"
+  #include "string.h"
+}
+
+#include "Ethernet.h"
+#include "Client.h"
+#include "Server.h"
+
+Server::Server(uint16_t port)
+{
+  _port = port;
+}
+
+void Server::begin()
+{
+  for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
+    Client client(sock);
+    if (client.status() == SOCK_CLOSED) {
+      socket(sock, Sn_MR_TCP, _port, 0);
+      listen(sock);
+      EthernetClass::_server_port[sock] = _port;
+      break;
+    }
+  }  
+}
+
+void Server::accept()
+{
+  int listening = 0;
+  
+  for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
+    Client client(sock);
+    
+    if (EthernetClass::_server_port[sock] == _port) {
+      if (client.status() == SOCK_LISTEN) {
+        listening = 1;
+      } else if (client.status() == SOCK_CLOSE_WAIT && !client.available()) {
+        client.stop();
+      }
+    } 
+  }
+  
+  if (!listening) {
+    begin();
+  }
+}
+
+Client Server::available()
+{
+  accept();
+  
+  for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
+    Client client(sock);
+    if (EthernetClass::_server_port[sock] == _port &&
+        client.status() == SOCK_ESTABLISHED) {
+      if (client.available()) {
+        // XXX: don't always pick the lowest numbered socket.
+        return client;
+      }
+    }
+  }
+  
+  return Client(255);
+}
+
+void Server::write(uint8_t b) 
+{
+  write(&b, 1);
+}
+
+void Server::write(const char *str) 
+{
+  write((const uint8_t *)str, strlen(str));
+}
+
+void Server::write(const uint8_t *buffer, size_t size) 
+{
+  accept();
+  
+  for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
+    Client client(sock);
+    
+    if (EthernetClass::_server_port[sock] == _port &&
+        client.status() == SOCK_ESTABLISHED) {
+      client.write(buffer, size);
+    }
+  }
+}
-- 
cgit v1.2.3-18-g5258