command_queue.h

Go to the documentation of this file.

/*!******************************************************************
* Copyright (C) 2015 by Interstel Technologies, Inc.
*   and Hawaii Space Flight Laboratory.
*
* This file is part of the COSMOS/core that is the central
* module for COSMOS. For more information on COSMOS go to
* <http://cosmos-project.com>
*
* The COSMOS/core software is licenced under the
* GNU Lesser General Public License (LGPL) version 3 licence.
*
* You should have received a copy of the
* GNU Lesser General Public License
* If not, go to <http://www.gnu.org/licenses/>
*
* COSMOS/core is free software: you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public License
* as published by the Free Software Foundation, either version 3 of
* the License, or (at your option) any later version.
*
* COSMOS/core is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
* Lesser General Public License for more details.
*
* Refer to the "licences" folder for further information on the
* condititons and terms to use this software.
********************************************************************/

#ifndef COSMOS_CommandQueue_H
#define COSMOS_CommandQueue_H


#include "support/configCosmos.h"
#include "support/jsonlib.h"
#include "agent/agentclass.h"
#include "agent/event.h"

namespace Cosmos
{
    namespace Support
    {
        namespace Command
        {
            int32_t Shell(string command_line="", string outpath="", string inpath="", string errpath="");
        }

        class CommandQueue
        {
        private:
            std::list<Event> commands;
            std::deque<Event> events;
            vector<std::thread> event_threads;
            bool queue_changed = false;

            bool queue_blocked = false;

        public:
            ~CommandQueue();

            size_t join_event_threads();


            size_t get_event_size() { return events.size(); }


            Event& get_event(int i)
            {
                std::deque<Event>::iterator ii = events.begin();
                std::advance(ii,i);
                return *ii;
            }


            size_t get_command_size() { return commands.size(); }


            Event& get_command(int i)
            {
                std::list<Event>::iterator ii = commands.begin();
                std::advance(ii,i);
                return *ii;
            }


            int32_t load_commands(string incoming_dir);


            int32_t save_commands(string temp_dir, string name=".queue");


            int32_t restore_commands(string temp_dir, string name=".queue");


            int32_t run_command(Event &cmd, string nodename, double logdate_exec);


//            int32_t flush_commands();


            int32_t run_commands(Agent *agent, string nodename, double logdate_exec);


            int32_t add_command(Event& c);


            int32_t del_command(Event& c);


            int32_t del_command(int pos);


            void sort() { commands.sort([](Event & c1, Event & c2) { return c1.getTime() < c2.getTime(); });    }

            friend std::ostream& operator<<(std::ostream& out, CommandQueue& cmdq);


        }; // end of Command Queue Class
    } // end of namespace Support
} // end of namepsace Cosmos

#endif // COSMOS_CommandQueue_H