wrench::HTCondorNegotiatorService

class HTCondorNegotiatorService : public wrench::Service

A HTCondor negotiator service.

Public Functions

HTCondorNegotiatorService(std::string &hostname, double startup_overhead, double grid_pre_overhead, double non_grid_pre_overhead, bool instant_resource_availabilities, bool fcfs, std::set<std::shared_ptr<ComputeService>> &compute_services, std::map<std::shared_ptr<CompoundJob>, std::shared_ptr<ComputeService>> &running_jobs, std::vector<std::tuple<std::shared_ptr<CompoundJob>, std::map<std::string, std::string>>> &pending_jobs, S4U_CommPort *reply_commport)

Constructor.

Parameters:

  • hostname – the hostname on which to start the service

  • startup_overhead – a startup overhead, in seconds

  • grid_pre_overhead – a pre-job overhead for grid jobs, in seconds

  • non_grid_pre_overhead – a pre-job overhead for non-grid jobs, in seconds

  • instant_resource_availabilities – true is instant resource availabilities to used

  • fcfs – true if FCFS scheduling should be enforced

  • compute_services – a set of ‘child’ compute services available to and via the HTCondor pool

  • running_jobs – a list of currently running jobs

  • pending_jobs – a list of pending jobs

  • reply_commport – the commport to which the “done/failed” message should be sent

~HTCondorNegotiatorService() override

Destructor.