commit
continuous-integration/drone/push Build is passing Details

rpc
Bastien OLLIER 2 years ago
parent 061135e2b3
commit e634bc9f48

@ -1,6 +1,4 @@
#include "config.hpp"
#include "program.hpp"
#include "runner.hpp"
#include <filesystem> #include <filesystem>
#include <iostream> #include <iostream>
#include <queue> #include <queue>
@ -9,12 +7,18 @@
#include <toml++/toml.h> #include <toml++/toml.h>
#include <vector> #include <vector>
#include <wait.h> #include <wait.h>
#include <thread>
#include "host.hpp" #include "host.hpp"
#include "rpc/server.h" #include "rpc/server.h"
#include "rpc/this_handler.h" #include "rpc/this_handler.h"
#include "config.hpp"
#include "program.hpp"
#include "runner.hpp"
#include <chrono> #include <chrono>
namespace fs = std::filesystem; namespace fs = std::filesystem;
sk::runner_backend detect_backend() { sk::runner_backend detect_backend() {
@ -45,7 +49,6 @@ void mainLoop(std::queue<sk::program>& programLists){
} }
} }
#include <thread>
int main() { int main() {
std::vector<sk::host> listsHosts = 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()); std::priority_queue<sk::host> hosts(listsHosts.begin(), listsHosts.end());
@ -57,8 +60,6 @@ int main() {
exit(1); exit(1);
} }
//std::thread threadMainLoop(mainLoop,programLists);
//threadMainLoop.join();
std::thread workerThread(mainLoop, std::ref(programLists)); std::thread workerThread(mainLoop, std::ref(programLists));
rpc::server srv(9000); rpc::server srv(9000);

Loading…
Cancel
Save