agent_example.cpp File Reference

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

Include dependency graph for agent_example.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
char	agentname [COSMOS_MAX_NAME+1] = "example"
char	node [50] = "null"
int	waitsec = 5
Agent *	agent
int32_t	diskfree
int32_t	stateflag
int32_t	myport
DeviceCpu	cpu

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.clear();
            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;

    // Check for other instance of this agent
    if (argc == 2)
        strcpy(node,argv[1]);

    // Initialization stuff


    // Initialize the Agent
    // near future: support cubesat space protocol
    // port number = 0 in this case, automatic assignment of port
    if (!(agent = new Agent(node, agentname, 1., MAXBUFFERSIZE, (bool)true)))
        exit (AGENT_ERROR_JSON_CREATE);

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

    // Start main thread
#if !defined(COSMOS_WIN_OS)
//  FILE *fp;
//  struct statfs fsbuf;
#endif
    double nmjd;
    int32_t sleept;

    // Start performing the body of the agent
    nmjd = currentmjd(0.);
    while(agent->running())
    {
        // Set beginning of next cycle;
        nmjd += agent->cinfo->agent[0].aprd/86400.;
        // Gather system information
        if (agent->cinfo->devspec.cpu_cnt)
        {
            agent->cinfo->device[agent->cinfo->devspec.cpu[0]].cpu.load = cpu.getLoad();
            agent->cinfo->device[agent->cinfo->devspec.cpu[0]].cpu.gib = cpu.getVirtualMemoryTotal();
        }

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

Variable Documentation

char agentname[COSMOS_MAX_NAME+1] = "example"

char node[50] = "null"

int waitsec = 5

Agent* agent

int32_t diskfree

int32_t stateflag

int32_t myport

DeviceCpu cpu