Простите за мою тупость и лень самостоятельно разобраться, но может кто-то просто встречался с такой проблемой.
Использую в консольном приложении boost::program_options вместе с libev. Вешаю на ev::sig колбэк для обработки SIGINT. В программе один поток.
Все работает здорово, когда я запускаю приложение без параметров: по ctrl+c приложение благополучно завершается и отдает консоль для дальнейшей работы. Но если запустить, указав в командной строке параметры, то первый ctrl+c останавливает приложение, но процесс продолжает висеть после выхода из main (кажется его держит epoll), второй ctrl+c вырубает процесс окончательно.
Как аргументы могут влиять на обработку сигнала?
код см. ниже
namespace po = boost::program_options;
int main(int argc, char * argv[])
{
FLAGS_logtostderr = true;
FLAGS_colorlogtostderr = true;
google::InitGoogleLogging(argv[0]);
int c_port_no, w_port_no;
po::options_description desc("Allowed options");
desc.add_options()
("help,h", "produce help message.")
("clients-port,cp", po::value<int>(&c_port_no)->default_value(1025), "The port to listen clients on. Must be greater than 1024. Default is 1025.")
("worlds-port,wp", po::value<int>(&w_port_no)->default_value(1026), "The port to listen worlds on. Must be greater than 1024. Default is 1026.")
;
po::variables_map vm;
try {
po::store(po::parse_command_line(argc, argv, desc), vm);
} catch (boost::exception_detail::clone_impl<boost::exception_detail::error_info_injector<po::unknown_option> > e) {
std::cout << "Unknown parameters" << std::endl;
std::cout << desc << std::endl;
return 1;
} catch (...) {
std::cout << desc << std::endl;
return 1;
}
po::notify(vm);
if (vm.count("help")) {
std::cout << desc << std::endl;
return 1;
}
if (c_port_no <= 1024 || w_port_no <= 1024) {
std::stringstream str;
str << desc;
fprintf(stderr, " bad port number: %i\n usage: %s [options]\n%s\n", c_port_no <= 1024 ? c_port_no : w_port_no, argv[0], str.str().c_str());
return 1;
}
ev::default_loop loop;
// Запускаем сервер
Server::instance().start(c_port_no, w_port_no);
// Запускаем цикл ожидания сигналов от сокетов и системы
loop.run(0);
// Останавливаем сервер и завершаем приложение
Server::instance().stop();
LOG(INFO) << "Application terminated normally.";
return 0;
}
так отлавливаю сигналы:
void Server::start(const int c_port, const int w_port)
{
if (active) return;
assert(c_port > 1024);
assert(w_port > 1024);
assert(c_port != w_port);
if (active) stop();
c_portno = c_port;
w_portno = w_port;
c_sockfd = socket(PF_INET, SOCK_STREAM, 0);
w_sockfd = socket(PF_INET, SOCK_STREAM, 0);
struct sockaddr_in addr;
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = INADDR_ANY;
addr.sin_port = htons(c_port);
if (bind(c_sockfd, (struct sockaddr *)&addr, sizeof(addr)) != 0) {
LOG(FATAL) << "Server starting: binding clientside socket with address";
}
fcntl(c_sockfd, F_SETFL, fcntl(c_sockfd, F_GETFL, 0) | O_NONBLOCK);
addr.sin_port = htons(w_port);
if (bind(w_sockfd, (struct sockaddr *)&addr, sizeof(addr)) != 0) {
LOG(FATAL) << "Server starting: binding worldside socket with address";
}
fcntl(w_sockfd, F_SETFL, fcntl(w_sockfd, F_GETFL, 0) | O_NONBLOCK);
listen(c_sockfd, 5);
listen(w_sockfd, 5);
cio.set<Server, &Server::accept_cb>(this);
cio.start(c_sockfd, ev::READ);
wio.set<Server, &Server::accept_w_cb>(this);
wio.start(w_sockfd, ev::READ);
sig.set<&Server::signal_cb>();
sig.start(SIGINT);
active = true;
LOG(INFO) << "Server started. Listening clients on port " << c_port << ", worlds on port " << w_port;
}
void Server::signal_cb(ev::sig &signal, int revents)
{
LOG(INFO) << "Catch interruption.";
signal.loop.break_loop();
}
и так останавливаю приложение:
void Server::stop()
{
if (!active) return;
cio.stop();
shutdown(c_sockfd, SHUT_RDWR);
close(c_sockfd);
wio.stop();
shutdown(w_sockfd, SHUT_RDWR);
close(w_sockfd);
sig.stop();
active = false;
LOG(INFO) << "Server stopped.";
}