Зачем активировать обработчик сигнала asio немедленно?

Question

У меня есть следующий фрагмент кода:

#include <signal.h> 
#include <boost/asio.hpp> 
#include <iostream> 

void startAsyncWaitForSignal(boost::asio::io_service& ioService) 
{ 
    boost::asio::signal_set signals{ioService}; 
    signals.add(SIGTERM); 
    signals.async_wait(
     [&ioService](boost::system::error_code errorCode, int signalNumber) 
     { 
      std::cerr << errorCode.message() << std::endl; 
      if (!errorCode) { 
       std::cerr << "received signal " << signalNumber << std::endl; 
       startAsyncWaitForSignal(ioService); 
      } 
     } 
    ); 
} 

int main() { 
    boost::asio::io_service ioService; 
    startAsyncWaitForSignal(ioService); 
    ioService.run(); 
} 

Я бы ожидать, что эта программа ждать, пока первый SIGTERM не прибыл, а затем ждать до следующего, а затем снова на следующий ...

Однако программа немедленно завершается следующий вывод:

Operation canceled 

Что является причиной этой немедленной операции отменить? Я попытался создать объект io_service :: work, но это только изменило тот факт, что ioService.run() не был закончен, но signal_set все равно был отменен немедленно.

Я использую boost 1.54. Существует bug fix related to asio/signals in 1.55, но это похоже на другую проблему.

Answer 1

При удалении startAsyncWaitForSignal() изменяется местная signal_set, а вызов async_wait() отменяется. signal_set должен жить немного дольше. Переместить его из startAsyncWaitForSignal() и передать его в качестве параметра, например:

#include <signal.h> 
#include <boost/asio.hpp> 
#include <iostream> 

void startAsyncWaitForSignal(boost::asio::io_service& ioService, boost::asio::signal_set& signals) 
{ 
    signals.async_wait(
     [&ioService, &signals](boost::system::error_code errorCode, int signalNumber) 
     { 
      std::cerr << errorCode.message() << std::endl; 
      if (!errorCode) { 
       std::cerr << "received signal " << signalNumber << std::endl; 
       startAsyncWaitForSignal(ioService, signals); 
      } 
     } 
    ); 
} 

int main() { 
    boost::asio::io_service ioService; 
    boost::asio::signal_set signals{ioService}; 
    signals.add(SIGTERM); 
    startAsyncWaitForSignal(ioService, signals); 
    ioService.run(); 
}