acceptor = deserialized_acceptor_it->second;
deserialized_acceptors->erase(deserialized_acceptor_it);
} else {
- int server_sock = create_server_socket(port);
+ int server_sock = create_server_socket(port, TCP_SOCKET);
acceptor = new Acceptor(server_sock, port);
}
acceptor->run();
if (input->get_url() != src) {
fprintf(stderr, "INFO: Stream '%s' has changed URL from '%s' to '%s', restarting input.\n",
stream_id.c_str(), input->get_url().c_str(), src.c_str());
+ input->close_socket();
delete input;
input = NULL;
}