agent_cpu_device_test.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 agent_cpu_device_test.cpp:

Macros
#define	MAXBUFFERSIZE   256

Functions
int	myagent ()
int32_t	request_start (string &request, string &response_r, Agent *agent)
int	main (int argc, char *argv[])

Variables
string	agentname = "agent_cpu_device_test"
string	nodename = "computer"
int	waitsec = 5
int	loopmsec = 1
char	buf4 [512]
beatstruc	beat_agent_cpu
Agent *	agent
ElapsedTime	et

Macro Definition Documentation

#define MAXBUFFERSIZE   256

Function Documentation

int myagent

(

)

{
    cout << "agent " << agentname <<  " ...online " << endl;
    string response;
    int count = 1;

    // Start executing the agent
    while(agent->running())
    {
        cout << "-------------------" << endl;
        cout << "Cycle: \t\t\t\t" << count << endl;


        agent->send_request(beat_agent_cpu,
                                   "mem",
                                   response,
                                   2);
        cout << "Memory used in KB: \t\t" << response << endl;

        agent->send_request(beat_agent_cpu,
                                   "disk",
                                   response,
                                   2);
        cout << "Disk used in KB: \t\t" << response << endl;


        agent->send_request(beat_agent_cpu,
                                   "load",
                                   response,
                                   2);
        cout << "Load data in %: \t\t" << response << endl;

        count++;
        COSMOS_SLEEP(2.00);

    }
    return (0);

}

int32_t request_start	(	string &	request,
		string &	response_r,
		Agent *	agent
	)

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

{
    int32_t iretn;
    cout << "Starting agent CPU Device Test" << endl;

    // Establish the command channel and heartbeat
    agent = new Agent(nodename, agentname);
    if ((iretn = agent->wait()) < 0)
    {
        fprintf(agent->get_debug_fd(), "%16.10f %s Failed to start Agent %s on Node %s Dated %s : %s\n",currentmjd(), mjd2iso8601(currentmjd()).c_str(), agent->getAgent().c_str(), agent->getNode().c_str(), utc2iso8601(data_ctime(argv[0])).c_str(), cosmos_error_string(iretn).c_str());
        exit(iretn);
    }
    else
    {
        fprintf(agent->get_debug_fd(), "%16.10f %s Started Agent %s on Node %s Dated %s\n",currentmjd(), mjd2iso8601(currentmjd()).c_str(), agent->getAgent().c_str(), agent->getNode().c_str(), utc2iso8601(data_ctime(argv[0])).c_str());
    }

    beat_agent_cpu = agent->find_agent(nodename, "agent_cpu", 10.);

    // Start our own thread
    myagent();

    return 0;
}

Variable Documentation

string agentname = "agent_cpu_device_test"

string nodename = "computer"

int waitsec = 5

int loopmsec = 1

char buf4[512]

beatstruc beat_agent_cpu

Agent* agent

ElapsedTime et