Diff: ExperimentServer.cpp

Revision:

0:85e387719efd

Child:

1:63635482312f

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/ExperimentServer.cpp	Tue Aug 11 21:11:10 2015 +0000
@@ -0,0 +1,92 @@
+#include "ExperimentServer.h"
+#include "EthernetInterface.h"
+
+ExperimentServer::ExperimentServer() {
+    _terminal = NULL;  
+    _data_cnt = 0;
+}
+
+void ExperimentServer::attachTerminal( Serial & terminal)
+{
+    _terminal = &terminal;
+} 
+
+void ExperimentServer::init(const char * ip_addr, const char * subnet_mask, const char * gateway, unsigned int port)
+{
+    if(_terminal!=NULL)
+    {
+        _terminal->printf("\n==============================\nStarting Server\n");
+        _terminal->printf("...Intializing Ethernet\n");
+    }
+    _eth.init(ip_addr,subnet_mask,gateway);
+    
+    if(_terminal!=NULL)
+        _terminal->printf("...Connecting\n");    
+    _eth.connect();
+    
+    if(_terminal!=NULL)
+        _terminal->printf("...Ethernet IP Address is %s\n", _eth.getIPAddress());
+    
+    _server.bind(port);
+    if(_terminal!=NULL)
+        _terminal->printf("...Listening on Port %d\n", port);
+}
+
+
+
+
+int ExperimentServer::getParams(float params[], int num_params)
+{
+    if(_terminal!=NULL)
+    {
+        _terminal->printf("\n========================\nNew Experiment\n");
+        _terminal->printf("...Waiting for parameters...\n");
+    }
+        
+    int n = _server.receiveFrom(_client,(char *) params, sizeof(params)*sizeof(float));    
+    if ( (n% 4) > 0 )
+    {
+        if(_terminal!=NULL)
+            _terminal->printf("ERROR: input data bad size\n");
+        return false;    
+    }
+    if ( n / 4 != num_params)
+    {
+        if(_terminal!=NULL)
+            _terminal->printf("ERROR: input data bad size\n");
+            
+        return false;    
+    }
+    
+    if(_terminal!=NULL)
+    {
+        _terminal->printf("...Received input from: %s\n", _client.get_address());
+        _terminal->printf("...Parameters: \n");
+        for ( int j = 0 ; j < n/sizeof(float) ; j++)
+        {
+            _terminal->printf("      %d) %f\n",j+1,params[j]);
+        }
+    }
+    return true;
+}
+void ExperimentServer::flushBuffer() {
+    if(_data_cnt > 0) {
+         _server.sendTo(_client,(char*) _buffer, 4*_data_cnt );    
+        _data_cnt = 0;
+    }
+}
+
+void ExperimentServer::sendData(float data_output[], int data_size) {
+    if( data_size + _data_cnt > _MAX_BUFFER_SIZE)
+    {
+        //_terminal->printf("@%d + %d, flushing\n");
+        flushBuffer();
+    }
+        
+    for(int j = 0; j < data_size; j++) {
+        _buffer[ _data_cnt++ ] = data_output[j];    
+    }
+}
+void ExperimentServer::setExperimentComplete() {
+    flushBuffer();
+}   
\ No newline at end of file