in spectator/publisher.cc [39:50]
void SpectatordPublisher::local_reconnect(absl::string_view path) {
using endpoint_t = asio::local::datagram_protocol::endpoint;
try {
if (local_socket_.is_open()) {
local_socket_.close();
}
local_socket_.open();
local_socket_.connect(endpoint_t(std::string(path)));
} catch (std::exception& e) {
logger_->warn("Unable to connect to {}: {}", std::string(path), e.what());
}
}