agent_002.cpp File Reference

#include "support/configCosmos.h"
#include "agent/agentclass.h"
#include "support/stringlib.h"
#include <iostream>
#include <string>

Include dependency graph for agent_002.cpp:

Functions
int32_t	hello_agent_002_request_function (string &request, string &response, Agent *a)
	The function to handle agent_001's request. More...
int	main (int argc, char **argv)
	Program to demonstrate inter-communication between agents. More...

Variables
static uint64_t	request_counter = 0
	number of requests that have been run since restarting agent More...
string	node_name = "sat_001"
	ensure only one agent class instance per process More...
string	agent_name = "agent_002"
string	node_agent_name = "["+node_name+":"+agent_name+"]"
static Agent *	agent

Function Documentation

int32_t hello_agent_002_request_function	(	string &	request,
		string &	response,
		Agent *	a
	)

The function to handle agent_001's request.

Parameters

The	response to send back to agent_001.

Returns

int

{
    // Send response back to agent_001
    response = "hello " + std::to_string(request_counter);

    // agent is set to this pointer?
    //cout << "[" << node_name << ":" << agent_name <<"] received a request from ["<<a->nodeName<<":"<<a->agentName<<"]! Its response is: " << response << endl;
    return 0;
}

int main	(	int	argc,
		char **	argv
	)

Program to demonstrate inter-communication between agents.

{
        //int jah = 420;
        //int jah2 = 240;
    // construct agent 
    cout << node_agent_name <<" starting..."<<endl;
    agent = new Agent(node_name, agent_name, 1.);
    if(agent->last_error() < 0) {
        cout<<"error: unable to start "<<node_agent_name<<" ("<<agent->last_error()<<") "<<cosmos_error_string(agent->last_error())<<endl;
        exit(1);
    } else {
        cout << ""<<node_agent_name<<" started."<<endl;
    }

    // add custom request functions for this agent
    agent->add_request("any_body_out_there", hello_agent_002_request_function, "a request to respond with 'hello'");


    // Start executing the agent
    while(agent->running()) {
        cout<<node_agent_name<<" running..."<<endl;

        // Sleep for 4 sec
        COSMOS_SLEEP(4.);
        // Initiate request to agent_001
        // name of agent target for request
        string agent_target = "agent_001";

/* old tests    
        beatstruc agent_target_heartbeat = agent->find_agent(node_name, agent_target, 2.);
        string target_request_name = "identify_yourself";
        string response;
        agent->send_request(agent_target_heartbeat, target_request_name, response, 2.);
        cout<<node_agent_name<<" transmit <"<<target_request_name<<"> request to ["<<node_name<<":"<<agent_target<<"]..."<<endl;

        if (response.size() > 1) {
            // The case if agent_001 is on and successfully receives the request
            cout << node_agent_name<<" received <"<<target_request_name<<"> response from ["<<agent_target_heartbeat.node<<":"<<agent_target_heartbeat.proc<<"]:"<<endl;
            cout<<"    RX: \""<< response <<"\" ("<<response.size()<<" bytes)"<< endl;
        }

        COSMOS_SLEEP(2.);
        string response2;
        string request2 = "setvalue {\"node_loc_orbit\":"+std::to_string((jah++))+"}";
        // orphan request for testing
        cout<<"attempting setting orbit value..."<<endl;
        agent->send_request(agent->find_agent(node_name, agent_target, 2.), request2, response2, 2.);

        COSMOS_SLEEP(2.);
        // orphan request for testing
        string response1;
        string request1 = "setvalue {\"node_loc_utc\":"+std::to_string((jah2--))+"}";
        cout<<"attempting setting UTC value..."<<endl;
        agent->send_request(agent->find_agent(node_name, agent_target, 2.), request1, response1, 2.);
*/

        // old way
        string response3;
        cout<<"attempting 1.0 way of getting UTC value..."<<endl;
        string request3 = "getvalue {\"node_loc_utc\"}";
        cout<<"  request  = <"<<request3<<">"<<endl;
        agent->send_request(agent->find_agent(node_name, agent_target, 2.), request3, response3, 2.);
        cout<<"  response = <"<<response3<<">"<<endl;

        // new way short name
        string response4;
        cout<<"attempting 2.0 way of getting UTC value with short name..."<<endl;
        string request4 = "get_value \"Short UTC\"";
        cout<<"  request  = <"<<request4<<">"<<endl;
        agent->send_request(agent->find_agent(node_name, agent_target, 2.), request4, response4, 2.);
        cout<<"  response = <"<<response4<<">"<<endl;

        // new way long name
        string response7;
        cout<<"attempting 2.0 way of getting UTC value with long name..."<<endl;
        string request7 = "get_value \"Longest Ever UTC\"";
        cout<<"  request  = <"<<request7<<">"<<endl;
        agent->send_request(agent->find_agent(node_name, agent_target, 2.), request7, response7, 2.);
        cout<<"  response = <"<<response7<<">"<<endl;

        string req = "get_value \"Longest Ever UTC\" \"Short UTC\"";
        cout<<"  request  = <"<<req<<">"<<endl;
        string res;
        agent->send_request(agent->find_agent(node_name, agent_target, 2.), req, res, 2.);
        cout<<"  response = <"<<res<<">"<<endl;

        //req.clear();
        //req = "get_value \"cosmosdata\"";
        //cout<<"  request  = <"<<req<<">"<<endl;
        //res.clear();
        //agent->send_request(agent->find_agent(node_name, agent_target, 2.), req, res, 2.);
        //cout<<"  response = <"<<res<<">"<<endl;

        req.clear();
        req = "set_value {\"Longest Ever UTC\": 215},{\"user[0].tool\": \"Super Tool!\"}";
        cout<<"  request  = <"<<req<<">"<<endl;
        res.clear();
        agent->send_request(agent->find_agent(node_name, agent_target, 2.), req, res, 2.);
        cout<<"  response = <"<<res<<">"<<endl;

        req.clear();
        req = "get_value \"user\"";
        cout<<"  request  = <"<<req<<">"<<endl;
        res.clear();
        agent->send_request(agent->find_agent(node_name, agent_target, 2.), req, res, 2.);
        cout<<"  response = <"<<res<<">"<<endl;

        // try out agent_calc
        //string request5 = "add 3 4";
        //string response5;
        //cout<<"attempting calc..."<<endl;
        //agent->send_request(agent->find_agent("otb", "calc", 2.), request5, response5, 2.);
        //cout<<"  response = <"<<response5<<">"<<endl;

    }
    return 0;
}

Variable Documentation

uint64_t request_counter = 0

static

number of requests that have been run since restarting agent

string node_name = "sat_001"

ensure only one agent class instance per process

string agent_name = "agent_002"

string node_agent_name = "["+node_name+":"+agent_name+"]"

Agent* agent

static