agent_arduino.cpp File Reference

#include "support/configCosmos.h"
#include <stdio.h>
#include "agent/agentclass.h"
#include "device/cpu/devicecpu.h"
#include "device/general/cssl_lib.h"

Include dependency graph for agent_arduino.cpp:

Macros
#define	MAXBUFFERSIZE   2560
#define	REQUEST_RUN_PROGRAM   0

Functions
int32_t	request_run_program (string &request, string &response, Agent *)
int	main (int argc, char *argv[])

Variables
std::string	agentname = "arduino"
std::string	node = "null"
std::string	comport = "//./"
int	waitsec = 5
Agent *	agent
int32_t	stateflag
int32_t	myport
uint8_t	buffer [400]

Macro Definition Documentation

#define MAXBUFFERSIZE   2560

#define REQUEST_RUN_PROGRAM   0

Function Documentation

int32_t request_run_program	(	string &	request,
		string &	response,
		Agent *
	)

{
    int i;
    int32_t iretn = 0;
    FILE *pd;
    bool flag;

    // Run Program
    flag = false;
    for (i=0; i<AGENTMAXBUFFER-1; i++)
    {
        if (flag)
        {
            if (request[i] != ' ')
                break;
        }
        else
        {
            if (request[i] == ' ')
                flag = true;
        }
    }

    if (i == AGENTMAXBUFFER-1)
    {
        response = "unmatched";
    }
    else
    {
        // open process and read response
#ifdef COSMOS_WIN_BUILD_MSVC
        if ((pd=_popen(&request[i], "r")) != NULL)
#else
        if ((pd=popen(&request[i],"r")) != NULL)
#endif
        {
            response.resize(AGENTMAXBUFFER);
            iretn = fread(&response[0],1,AGENTMAXBUFFER-1,pd);
            response[iretn] = 0;
            iretn = 1;
#ifdef COSMOS_WIN_BUILD_MSVC
            _pclose(pd);
#else
            pclose(pd); // close process
#endif
        }
        else
        {
            response.clear();
            iretn = 0;
        }
    }

    return iretn;
}

int main	(	int	argc,
		char *	argv[]
	)

{
    int32_t iretn;

    if (argc == 3)
    {
        node = argv[1];
        comport += argv[2];
    }
    else
    {
        printf("Usage: arduino_agent node comport\n");
        exit (1);
    }

    // Initialize the Agent
    if (!(agent = new Agent(node, agentname, 1., MAXBUFFERSIZE, true)))
    {
        printf("Error starting server\n");
        exit (AGENT_ERROR_JSON_CREATE);
    }

    // Add additional requests
    if ((iretn=agent->add_request("runprogram", request_run_program)))
        exit (iretn);

    // Setup Heartbeat information
    char arduino_soh[2000] = "{\"device_imu_utc_000\",\"device_imu_accel_000\",\"device_imu_omega_000\",\"device_imu_mag_000\",\"device_imu_temp_000\"}";
    agent->set_sohstring(arduino_soh);

    // Start main thread
    double nmjd;
//  int32_t sleept;

    // Initialize connection to arduino
    cssl_start();
    cssl_t *serial = cssl_open(comport.c_str(), 115200, 8, 0, 1);
    cssl_settimeout(serial, 0, .1);

    // Start performing the body of the agent
    nmjd = currentmjd(0.);
    uint32_t counter = 0;
    while(agent->running())
    {
        // Set beginning of next cycle;
        nmjd += agent->cinfo->agent[0].aprd/86400.;

        // Gather arduino data
        iretn = cssl_getdata(serial, buffer, 400);
        if (iretn > 0)
        {
            std::string message = (char *)buffer;
            json_parse(message, agent->cinfo);
            printf("%u: %s\n", ++counter, buffer);
        }

//      sleept = (int32_t)((nmjd - currentmjd(0.))*86400000000.);
//      if (sleept < 0) sleept = 0;
//      COSMOS_USLEEP(sleept);
    }
    return 0;
}

Variable Documentation

std::string agentname = "arduino"

std::string node = "null"

std::string comport = "//./"

int waitsec = 5

Agent* agent

int32_t stateflag

int32_t myport

uint8_t buffer[400]