Cosmos::Support::Scheduler Class Reference

#include <scheduler.h>

Collaboration diagram for Cosmos::Support::Scheduler:

Public Member Functions
	Scheduler (string node_name)
	~Scheduler ()
void	addEvent (string name, string data, double utc, string condition, uint32_t flag)
void	addEvent (Event event)
void	deleteEvent (string name, string data, double utc, string condition, uint32_t flag)
void	deleteEvent (Event event)
int	getEventQueueSize ()
void	getEventQueue ()

Private Attributes
Agent *	agent
beatstruc	agent_exec_soh

Constructor & Destructor Documentation

Cosmos::Support::Scheduler::Scheduler

(

string

node_name

)

                                             {

            agent = new Agent(node_name, "test");
            agent_exec_soh = agent->find_agent(node_name, "exec");

        }

Cosmos::Support::Scheduler::~Scheduler

(

)

                              {

        }

Member Function Documentation

void Cosmos::Support::Scheduler::addEvent	(	string	name,
		string	data,
		double	utc,
		string	condition,
		uint32_t	flag
	)

                                                {

            Event event;
            event.generator(name, data, mjd, condition, flag);

            //com.set_command(line);

            if (!agent_exec_soh.exists) { // TODO: change the way to find if another beat exists (no mjd)
                cout << "could not find agent exec" << endl;
                return;
            }

            string out;
            agent->send_request(agent_exec_soh, "add_event "+ event.event_string, out, 0);

            cout << "event set: " << endl;
            cout << out << endl;

        }

void Cosmos::Support::Scheduler::addEvent

(

Event

event

)

                                            {
            addEvent(event.name, event.data, event.mjd, event.condition, event.flag);
        }

void Cosmos::Support::Scheduler::deleteEvent	(	string	name,
		string	data,
		double	utc,
		string	condition,
		uint32_t	flag
	)

                                                   {

            Event event;

            // set the event_string
            // JIMNOTE: this could be done in a constructor
            event.generator(name, data, mjd, condition, flag);

            if (!agent_exec_soh.exists) {
                cout << "could not find agent exec" << endl;
                return;
            }

            string out;
            agent->send_request(agent_exec_soh, "del_event "+ event.event_string, out, 0);

            cout << "event deleted: " << out << endl;

        }

void Cosmos::Support::Scheduler::deleteEvent

(

Event

event

)

                                               {
            deleteEvent(event.name,event.data, event.mjd, event.condition, event.flag);
        }

int Cosmos::Support::Scheduler::getEventQueueSize

(

)

                                         {
            if (!agent_exec_soh.exists) {
                cout << "could not find agent exec" << endl;
                return 0 ;
            }

            string out;
            agent->send_request(agent_exec_soh, "get_queue_size", out, 0);

            StringParser str(out,'[');
            int queue_size = str.getFieldNumberAsInteger(1);
            cout << "Event queue size: " << queue_size << endl;

            return queue_size;
        }

void Cosmos::Support::Scheduler::getEventQueue

(

)

                                      {
            if (!agent_exec_soh.exists) {
                cout << "could not find agent exec" << endl;
                return ;
            }

            string out;
            agent->send_request(agent_exec_soh, "get_event", out, 0);

            //StringParser str(out,'[');
            //int queue_size = str.getFieldNumberAsInteger(1);
            cout << endl << "queue list: " << endl << out << endl;

            //    return queue_size;
        }

Member Data Documentation

Agent* Cosmos::Support::Scheduler::agent

private

beatstruc Cosmos::Support::Scheduler::agent_exec_soh

private

---

The documentation for this class was generated from the following files:

• scheduler.h
• scheduler.cpp