Skip to content
Snippets Groups Projects
Commit f76dea98 authored by Florian Schmaus's avatar Florian Schmaus
Browse files

Merge branch 'reuse-coordinator-port' into 'master'

[Coordinator] allow listen socket port reuse

See merge request i4/manycore/emper!312
parents d222c974 053cc4bf
No related branches found
No related tags found
No related merge requests found
......@@ -41,6 +41,7 @@ void notify() {
for (int conn : conns) emper::io::closeAndForget(conn);
}
// NOLINTNEXTLINE(bugprone-exception-escape)
auto main(int argc, char* argv[]) -> int {
if (argc != 2) {
std::cerr << "Usage: " << argv[0] << " <count>" << std::endl;
......@@ -55,7 +56,7 @@ auto main(int argc, char* argv[]) -> int {
<< " connections" << std::endl;
Runtime runtime;
auto* listener = emper::io::tcp_listener(HOST, PORT, [&](int socket) {
auto coordinator_func = [&](int socket) {
{
std::lock_guard<std::mutex> l(lock);
conns.push_back(socket);
......@@ -70,7 +71,10 @@ auto main(int argc, char* argv[]) -> int {
notify();
runtime.initiateTermination();
}
});
};
auto* listener = emper::io::tcp_listener(HOST, PORT, coordinator_func, scount,
{emper::io::SockOpt::ReusePort});
if (!listener) {
exit(EXIT_FAILURE);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment