add priority_queue

src/host.cpp

@@ -2,9 +2,10 @@
 
 namespace sk {
 host::host(const std::string &ip, unsigned int connectionsMax)
-    : ip{ip}, connections{0}, connectionsMax{connectionsMax} {}
+    : ip{ip}, connections{0}, connectionsMax{connectionsMax}, runners{} {}
 
-void host::addConnection() {
+void host::addConnection(sk::runner& runner) {
+    runners.push(runner);
     connections += 1;
 }
 

src/host.hpp

@@ -1,6 +1,8 @@
 #pragma once
 
 #include <string>
+#include <queue>
+#include "runner.hpp" 
 
 namespace sk {
 class host {
@@ -9,9 +11,11 @@ class host {
     unsigned int connections;
     unsigned int connectionsMax;
 
+    std::queue<sk::runner> runners;
+
   public:
     host(const std::string &ip, unsigned int connectionsMax);
-    void addConnection();
+    void addConnection(sk::runner& runner);
 
     const std::string &getIp() const;
 

src/main.cpp

@@ -32,15 +32,15 @@ sk::runner_backend detect_backend() {
 }
 
 int main() {
-    std::vector<sk::host> hosts = sk::config::loadHostsFromToml("../conf.toml");
+    std::vector<sk::host> listsHosts = sk::config::loadHostsFromToml("../conf.toml");
+    std::priority_queue<sk::host> hosts(listsHosts.begin(), listsHosts.end());
 
     if (hosts.empty()) {
         std::cerr << "Pas de host" << std::endl;
     }
 
     std::queue<sk::program> queue;
-    queue.push(sk::program{"echo $(( 1 + 2 ))",
-                           "ghcr.io/moshell-lang/moshell:master"});
+    queue.push(sk::program{"echo $(( 1 + 2 ))", "ghcr.io/moshell-lang/moshell:master"});
 
     sk::runner runner(detect_backend());
     while (!queue.empty()) {