queen.cpp File Reference

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

Include dependency graph for queen.cpp:

Functions
int32_t	are_you_out_there (string &request, string &response, Agent *cdata)
int32_t	req_pass_message (string &request, string &response, Agent *)
int	main (int argc, char **argv)

Variables
static Agent *	agent
string	node_name = "queen"
string	agent_name = "elizabeth"
string	node_agent_name = "["+node_name+":"+agent_name+"]"
bool	once = true
string	tel_message = "THIS IS THE QUEEN CALLING"

Function Documentation

int32_t are_you_out_there	(	string &	request,
		string &	response,
		Agent *	cdata
	)

{
    response = "Yes!  I am the one they call " + node_agent_name + ".";
    return 0;
}

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

                                                                     {
    cout<<"\tincoming request          = <"<<request<<">"<<endl;

    // remove function call and space
    request.erase(0,13);

    // read in mjdtime
    string timemjd = request;

    int charidx = rand() % timemjd.size();
    char newchar = rand() % 26 + 65;
    timemjd[charidx] = newchar;
    tel_message = timemjd;

    cout << "\tmessage: " << tel_message << endl;

    once = true;

    return 0;
}

int main	(	int	argc,
		char **	argv
	)

{
    // construct agent
    cout << node_agent_name << " starting..."<<endl;
    agent = new Agent(node_name, agent_name, 1.);

    // exit with error if unable to start agent
    if(agent->last_error() < 0) {
        cerr<<"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("are_you_out_there", are_you_out_there, "\n\t\trequest to determine if specific agent exists");
    agent->add_request("pass_message", req_pass_message, "\n\t\trequest to pass message");

    // cosmosstruc
    cosmosstruc* c = agent->cinfo;

    // set the orbital elements (psuedo ISS orbit)
    c->a = 6738000; // 6738 km
    c->e = 0.0001640; // no units!
    c->i =  51.6407 * (M_PI/180.0); // radians
    c->O = 126.7653 * (M_PI/180.0); // radians
    c->w = 163.1572 * (M_PI/180.0); // radians
    c->tau = 0.00; // seconds since periasis

    // n = mean angular motion (rad/s) [ used to find a in TLEs ]
    c->n = pow( (c->mu / pow(c->a,3.0) ), (0.5) );
    // T = period of orbit (seconds)
    c->T = ( 2.0 * M_PI ) / c->n;

    cout<<"\tPeriod in seconds = "<<setprecision(numeric_limits<double>::digits10)<<c->T<<endl;
    cout<<"\tRevolutions / day = "<<setprecision(numeric_limits<double>::digits10)<<86400.0/c->T<<endl;

    string workernames[3] = {"albeert", "beeber", "corbee"};

    // agent loop
    while (agent->running()) {

        cout<<node_agent_name<<" running..."<<endl;

        // see if you can locate each of the daughters
        string request = "are_you_out_there";
        string response = "";

        // stringify the current time
        double t = currentmjd();
        stringstream sss;
        sss<<setprecision(numeric_limits<double>::digits10)<<t;
        string time = sss.str();

        // calculate position of Mothership
        //double mother_x = 0.0, mother_y = 0.0, mother_z = 0.0;
        if(once) {
            int workernum = rand() % (sizeof(workernames)/sizeof(*workernames));
            string worker = "worker_0" + to_string(workernum+1);
            agent->send_request(agent->find_agent(worker, workernames[workernum], 2.), request, response, 2.);
            if(response.size()) {
                string s = "\t[" + worker + ":" + workernames[workernum] + "]";
                cout<<left<<setw(40)<< s <<setw(16)<<"\033[1;32mFOUND\033[0m"<<endl;
                response.clear();
                agent->send_request(agent->find_agent(worker, workernames[workernum], 2.), "pass_message " + tel_message, response, 2);
                // ask for their location
                //agent->send_request(agent->find_agent("daughter_01", "allison", 2.), "get_position " + time, response, 2.);
                cout<<response<<endl;
                response.clear();
                once = false;
            } else {
                string s = "\t[" + worker + ":" + workernames[workernum] + "]";
                cout<<left<<setw(40) << s <<"\033[1;31mNOT FOUND\033[0m"<<endl;
            }
        }

        // Sleep for 5 sec
        COSMOS_SLEEP(5.);
    }
    return 0;
}

Variable Documentation

Agent* agent

static

string node_name = "queen"

string agent_name = "elizabeth"

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

bool once = true

string tel_message = "THIS IS THE QUEEN CALLING"