HTCondorNegotiatorService.h

#ifndef WRENCH_HTCONDORNEGOTIATORSERVICE_H
#define WRENCH_HTCONDORNEGOTIATORSERVICE_H

#include "wrench/services/Service.h"
#include "wrench/services/compute/ComputeService.h"
#include "wrench/services/compute/htcondor/HTCondorCentralManagerServiceMessagePayload.h"
#include "wrench/workflow/job/StandardJob.h"

namespace wrench {

    /***********************/
    /***********************/
    class HTCondorNegotiatorService : public Service {
    private:
        std::map<std::string, std::string> default_messagepayload_values = {
                {HTCondorCentralManagerServiceMessagePayload::STOP_DAEMON_MESSAGE_PAYLOAD,              "1024"},
                {HTCondorCentralManagerServiceMessagePayload::DAEMON_STOPPED_MESSAGE_PAYLOAD,           "1024"},
                {HTCondorCentralManagerServiceMessagePayload::HTCONDOR_NEGOTIATOR_DONE_MESSAGE_PAYLOAD, "1024"},
        };

    public:

        HTCondorNegotiatorService(std::string &hostname,
                                  std::map<ComputeService *, unsigned long> &compute_resources,
                                  std::map<StandardJob *, ComputeService *> &running_jobs,
                                  std::vector<StandardJob *> &pending_jobs,
                                  std::string &reply_mailbox);

        ~HTCondorNegotiatorService();

    private:
        int main() override;

        struct JobPriorityComparator {
            bool operator()(StandardJob *&lhs, StandardJob *&rhs);
        };

        std::string reply_mailbox;
        std::map<ComputeService *, unsigned long> *compute_resources;
        std::map<StandardJob *, ComputeService *> *running_jobs;
        std::vector<StandardJob *> pending_jobs;
    };

    /***********************/
    /***********************/
}

#endif //WRENCH_HTCONDORNEGOTIATORSERVICE_H