agent_generic_device_test.cpp File Reference

#include "configCosmos.h"
#include "elapsedtime.h"
#include "timeutils.hpp"
#include "agentlib.h"
#include <iostream>
#include <string>
#include <sstream>
#include <iomanip>

Include dependency graph for agent_generic_device_test.cpp:

Functions
int	agentloop ()
int	generic_node_test (int telem_num, string type)
int	set_zeros (int telem_num, string type)
int	main (int argc, char *argv[])

Variables
Agent	agent
string	agentname = "generic_device_test"
string	nodename = "telem"
string	agent_neighbor = "generic_device_neighbor"
uint32_t	itemp = 0
beatstruc	beat_agent_neighbour

Function Documentation

int agentloop

(

)

{
    cout << "agent " << agentname <<  " ...online " << endl;

    //int telem_num = 0;

    // reset telemetry streams
    set_zeros(0, "vuint8");
    set_zeros(1, "vint8");
    set_zeros(2, "vuint16");
    set_zeros(3, "vint16");
    set_zeros(4, "vuint32");
    set_zeros(5, "vint32");
    set_zeros(6, "vfloat");
    set_zeros(7, "vdouble");
    set_zeros(8, "vstring");


    // Start executing the agent
    while(agent.isRunning())
    {

        cout << "-------------------" << endl;

        generic_node_test(0,"vuint8");  // test telemetry stream with uint8
        generic_node_test(1,"vint8");   // test telemetry stream with int8
        generic_node_test(2,"vuint16"); // test telemetry stream with uint16
        generic_node_test(3,"vint16");  // test telemetry stream with int16
        generic_node_test(4,"vuint32"); // test telemetry stream with uint32
        generic_node_test(5,"vint32");  // test telemetry stream with int32
        generic_node_test(6,"vfloat");  // test telemetry stream with float
        generic_node_test(7,"vdouble"); // test telemetry stream with double
        generic_node_test(8,"vstring"); // test telemetry stream with string

        COSMOS_SLEEP(0.05);

    }
    return (0);

}

int generic_node_test	(	int	telem_num,
		string	type
	)

                                                 {
    string request;
    string response;
    //char response_c_str[300];
    int iretn;

    // convert device number to string: 2 -> "002"
    ostringstream dev_number_string;
    dev_number_string << setw(3) << setfill('0') << telem_num;

    // command ex.: getvalue {\"device_telem_vuint16_002\"}
    request = "getvalue {\"device_telem_" + type + "_" + dev_number_string.str() + "\"}";

    // makes a request to agent get
    iretn = agent.sendRequest(beat_agent_neighbour, request, response);

    //cout << "return:" << iretn << endl;

    //    response = string(response_c_str);
    json_parse(response,agent.cdata);

    string value_str; //value_str_rep

    if (type == "vuint8"){
        uint8_t value = agent.cdata->devspec.telem[telem_num]->vuint8;
        value_str = to_string((int)value);
        //        value_str_rep = string(cdata->devspec.telem[telem_num]->vstring);
    }

    if (type == "vint8"){
        int8_t value= agent.cdata->devspec.telem[telem_num]->vint8;
        value_str = to_string((int)value);
        //        value_str_rep = string(agent.cdata->devspec.telem[telem_num]->vstring);
    }

    if (type == "vuint16"){
        uint16_t value= agent.cdata->devspec.telem[telem_num]->vuint16;
        value_str = to_string(value);
        //        value_str_rep = string(agent.cdata->devspec.telem[telem_num]->vstring);
    }

    if (type == "vint16"){
        int16_t value= agent.cdata->devspec.telem[telem_num]->vint16;
        value_str = to_string(value);
        //        value_str_rep = string(agent.cdata->devspec.telem[telem_num]->vstring);
    }

    if (type == "vuint32"){
        uint32_t value= agent.cdata->devspec.telem[telem_num]->vuint32;
        value_str = to_string(value);
        //        value_str_rep = string(agent.cdata->devspec.telem[telem_num]->vstring);
    }

    if (type == "vint32"){
        int32_t value= agent.cdata->devspec.telem[telem_num]->vint32;
        value_str = to_string(value);
        //        value_str_rep = string(agent.cdata->devspec.telem[telem_num]->vstring);
    }

    if (type == "vfloat"){
        float value= agent.cdata->devspec.telem[telem_num]->vfloat;
        value_str = to_string(value);
        //        value_str_rep = string(agent.cdata->devspec.telem[telem_num]->vstring);
    }

    if (type == "vdouble"){
        double value= agent.cdata->devspec.telem[telem_num]->vdouble;
        value_str = to_string(value);
        //        value_str_rep = string(agent.cdata->devspec.telem[telem_num]->vstring);
    }

    if (type == "vstring"){
        value_str = string(agent.cdata->devspec.telem[telem_num]->vstring);
        //        value_str_rep = value_str;
    }

    if ( response.size() > 1){

        // print status
        cout << "rx telem stream #" << telem_num
             << " (" << type << ") \t : " <<  value_str << endl; //"  str (" << value_str_rep << ")" << endl;

        // just increment the value by 1

        if (type == "vuint8"){
            agent.cdata->devspec.telem[telem_num]->vuint8 ++;
            value_str = to_string(agent.cdata->devspec.telem[telem_num]->vuint8);
        }

        if (type == "vint8"){
            agent.cdata->devspec.telem[telem_num]->vint8 ++;
            value_str = to_string(agent.cdata->devspec.telem[telem_num]->vint8);
        }

        if (type == "vuint16"){
            agent.cdata->devspec.telem[telem_num]->vuint16 ++;
            value_str = to_string(agent.cdata->devspec.telem[telem_num]->vuint16);
        }

        if (type == "vint16"){
            agent.cdata->devspec.telem[telem_num]->vint16 ++;
            value_str = to_string(agent.cdata->devspec.telem[telem_num]->vint16);
        }

        if (type == "vuint32"){
            agent.cdata->devspec.telem[telem_num]->vuint32 ++;
            value_str = to_string(agent.cdata->devspec.telem[telem_num]->vuint32);
        }

        if (type == "vint32"){
            agent.cdata->devspec.telem[telem_num]->vint32 ++;
            value_str = to_string(agent.cdata->devspec.telem[telem_num]->vint32);
        }

        if (type == "vfloat"){
            agent.cdata->devspec.telem[telem_num]->vfloat += 0.1;
            value_str = to_string(agent.cdata->devspec.telem[telem_num]->vfloat);
        }

        if (type == "vdouble"){
            agent.cdata->devspec.telem[telem_num]->vdouble += 0.1;
            value_str = to_string(agent.cdata->devspec.telem[telem_num]->vdouble);
        }

        if (type == "vstring"){
            //agent.cdata->devspec.telem[telem_num]->vstring = "asd";
            //value_str = to_string(agent.cdata->devspec.telem[telem_num]->vuint8);
            //itemp = atol(value_str.c_str());
            ++itemp;
            sprintf(agent.cdata->devspec.telem[telem_num]->vstring, "\"str%u\"", itemp);
            value_str = string(agent.cdata->devspec.telem[telem_num]->vstring);
        }


        // now send the new value to the neighbour agent
        // command ex.: setvalue {\"device_telem_vuint16_002\"}
        request = "setvalue {\"device_telem_"+type+"_"
                + dev_number_string.str() + "\":"
                + value_str
                + "}";

        // makes a request to agent get
        iretn = agent.sendRequest(beat_agent_neighbour, request, response);

        //cout << "Received from agent_neighbour: " << response.size() << " bytes : " << response << endl;
        response = "";
    }

    return iretn;
}

int set_zeros	(	int	telem_num,
		string	type
	)

                                         {
    string request;
    string response;
    //char response_c_str[300];
    int iretn;

    // convert device number to string: 2 -> "002"
    ostringstream dev_number_string;
    dev_number_string << setw(3) << setfill('0') << telem_num;


    if (type == "vstring"){
        request = "setvalue {\"device_telem_"+type+"_"
                + dev_number_string.str() + "\":"
                + "\"str0\""
                + "}";
    } else {
        // now send the new value to the neighbour agent
        // command ex.: setvalue {\"device_telem_vuint16_002\"}
        request = "setvalue {\"device_telem_"+type+"_"
                + dev_number_string.str() + "\":"
                + to_string(0)
                + "}";
    }

    // makes a request to agent get
    iretn = agent.sendRequest(beat_agent_neighbour, request, response);

    return iretn;
}

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

{

    agent.setupServer(nodename, agentname);

    beat_agent_neighbour = agent.find(agent_neighbor);

    //beat_agent_neighbour = agent_find_server(cdata, nodename, agent_neighbor, 5.);

    if (beat_agent_neighbour.utc > 0){
        cout << "beat agent_neighbour node: " << beat_agent_neighbour.node << endl;
    } else {
        cout << "could not find " << agent_neighbor << endl;
        exit (0);
    }

    // Start agent thread
    agentloop();

    //agent.shutdown();

    return 0;
}

Variable Documentation

Agent agent

string agentname = "generic_device_test"

string nodename = "telem"

string agent_neighbor = "generic_device_neighbor"

uint32_t itemp = 0

beatstruc beat_agent_neighbour