Diff: main.cpp

Revision:

0:30562abde493

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/main.cpp	Thu Sep 24 22:24:28 2015 +0000
@@ -0,0 +1,100 @@
+#include "main.h"
+
+char rxBuffer[BUF_LEN];
+int rxChars;
+bool rxDone;
+long rxTime;
+RtosTimer *rxTimer;
+
+char txBuffer[BUF_LEN];
+int txChars;
+
+Serial sp(SP_RX, SP_TX);
+EthernetInterface eth;
+TCPSocketServer serv;
+TCPSocketConnection client;
+
+int main ( void )
+{
+    // Initalize serial port
+    sp.baud(SP_BAUD);
+    sp.attach(&rxInt);
+    rxTimer = new RtosTimer(&timerTask, osTimerPeriodic, NULL);
+    rxTimer->start(SP_TIMER_PERIOD);
+    
+    // Initalize server
+    serv.bind(SERV_PORT);
+    serv.listen();
+    while (true)
+    {
+        serv.accept(client);
+        client.set_blocking(false, 1500);
+        
+        while (client.is_connected())
+        {
+            txChars = client.receive(txBuffer, BUF_LEN);
+            if (txChars <= 0) break;
+            
+            sendBuffer(txBuffer, txChars);
+        }
+        client.close();
+    }
+}
+
+void timerTask ( void const *arg )
+{
+    if (!rxDone)
+    {
+        if (client.is_connected())
+        {
+            client.send_all(rxBuffer, rxChars);
+            resetRX();
+        }
+    }
+    else
+    {
+        if (rxChars > 0)
+        {
+            if (rxTime++ >= SP_TIMEOUT) rxDone = true;
+        }
+    }
+}
+
+void rxInt ( void )
+{
+    if (!rxDone)
+    {
+        if (rxChars < BUF_LEN)
+        {
+            rxBuffer[rxChars++] = SP_UART->D;
+            rxTime = 0;
+        }
+        else rxDone = true;
+    }
+}
+
+void sendBuffer (char *buffer, int len)
+{
+    for (int i = 0; i < len; i++)
+    {
+        sp.putc(buffer[i]);
+    }
+}
+
+void clearBuffer ( char *buffer, int len )
+{
+    for (int i = 0; i < len; i++) buffer[i] = 0;
+}
+
+void resetRX ( void )
+{
+    clearBuffer(rxBuffer, BUF_LEN);
+    rxChars = 0;
+    rxDone = false;
+}
+
+void resetTX ( void )
+{
+    clearBuffer(txBuffer, BUF_LEN);
+    txChars = 0;
+}
\ No newline at end of file