Watchdog на основе таймеров POSIX

@squareroot · Регистрация: 19.10.2019

Студворк — интернет-сервис помощи студентам

Добрый день, решил написать watchdog для сервера и чтобы не тратить зазря процессрное время решил реализовать это на основе таймеров POSIX, а не через создание отдельного потока.

Почитал документацию и остались некоторые вопросы:

1)Как должна быть организована проверка что сигнал пришёл от созданного мною таймера, а не от стороннего приложения ?
Сечас в обработчик приходит _si->si_pid == 0

2)Как сделать сброс таймера т.е. чтоб начинал считать по новому ? это всётаки watchdog.

3)Как подружить мой watchdog и std::getline(cin, str_command ?

4)Надо ли вызывать предыдущие обработчики если я их не создавал ?

5)Надо ли делать задержку после вызова timer_settime ?

6)Какой тип таймера выбрать ? CLOCK_REALTIME меня смущает что ктото мжет перевести время.

код внизу

watchdog.cpp

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
#include "../include/error.h"
#include "../include/watchdog.h"
 
// (с) http://man7.org/linux/man-pages/man2/timer_create.2.html
#define CLOCKID CLOCK_REALTIME
#define SIG SIGRTMIN + 10
 
IWatcher* callback = nullptr;
 
typedef void (*TSigFunc1)(int, siginfo_t *, void *);
typedef void (*TSigFunc2)(int);
TSigFunc1 prev_handler1 = nullptr;
TSigFunc2 prev_handler2 = nullptr;
pid_t current_pid = getpid();
 
void IWatcher::reset()
{
    //
}
 
static void signal_handler(int _sig, siginfo_t * _si, void * _uc)
{
    bool result = false;
    if ((_sig == SIG) && (_si))
    {
        if ((callback) && (_si->si_pid == current_pid))
        {
            //errspace::show_errmsg("caught valid signal");
            //(*callback)(_si);
            result = true;
        }
    }
    if (!result)
    {
        //errspace::show_errmsg("caught invalid signal");
    }
    //if (prev_handler1) prev_handler1(_sig, _si, _uc);
    //if (prev_handler2) prev_handler2(_sig);
    //signal(_sig, SIG_IGN);
}
 
timer_t timerid;
 
bool start_wd(std::size_t _msecs, IWatcher* _cback)
{
   static constexpr auto billion = 1'000'000'000;
   static constexpr auto million = 1'000'000;
   callback = _cback;
   bool result = false;
   struct sigevent sev;
   struct itimerspec its;
   long long freq_nanosecs;
   sigset_t mask;
   struct sigaction sa;
   struct sigaction old_sa;
   // Establish handler for timer signal
   sa.sa_flags = SA_SIGINFO;
   sa.sa_sigaction = signal_handler;
   sigemptyset(&sa.sa_mask);
   if (sigaction(SIG, &sa, &old_sa) == -1)
   {
       errspace::show_errmsg("Failed to setup watchdog: Establish handler");
       return result;
   }
   prev_handler1 =  old_sa.sa_sigaction;
   prev_handler2 =  old_sa.sa_handler;
   // Block timer signal temporarily
   sigemptyset(&mask);
   sigaddset(&mask, SIG);
   if (sigprocmask(SIG_SETMASK, &mask, NULL) == -1)
   {
       errspace::show_errmsg("Failed to setup watchdog: Blocking signal");
       return result;
   }
 
   // Create the timer
   sev.sigev_notify = SIGEV_SIGNAL;
   sev.sigev_signo = SIG;
   sev.sigev_value.sival_ptr = &timerid;
   if (timer_create(CLOCKID, &sev, &timerid) == -1)
   {
       errspace::show_errmsg("Failed to setup watchdog: create timer");
       return result;
   }
 
   // Start the timer
   freq_nanosecs = million*_msecs;
   its.it_value.tv_sec = freq_nanosecs / billion;
   its.it_value.tv_nsec = freq_nanosecs % billion;
   its.it_interval.tv_sec = its.it_value.tv_sec;
   its.it_interval.tv_nsec = its.it_value.tv_nsec;
 
   if (timer_settime(timerid, 0, &its, NULL) == -1)
   {
       errspace::show_errmsg("Failed to setup watchdog: set time");
       return result;
   }
   // ????
   // std::this_thread::sleep_for(std::chrono::milliseconds(_msecs*2));
   /* Sleep for a while; meanwhile, the timer may expire
      multiple times */
 
   //printf("Sleeping for %d seconds\n", atoi(argv[1]));
   //sleep(atoi(argv[1]));
 
   // Unlock the timer signal, so that timer notification can be delivered
   if (sigprocmask(SIG_UNBLOCK, &mask, NULL) == -1)
   {
       errspace::show_errmsg("Failed to setup watchdog: Unblocking signal");
       return result;
   }
    result = true;
    return result;
}
 
void stop_wd()
{
    sigset_t mask;
    struct sigaction action;
 
    // Block timer signal temporarily
    sigemptyset(&mask);
    sigaddset(&mask, SIG);
    if (sigprocmask(SIG_SETMASK, &mask, NULL) == -1)
    {
        errspace::show_errmsg("Failed to reset watchdog: Blocking signal");
        return;
    }
    timer_delete(timerid);
    action.sa_handler = SIG_DFL;
    action.sa_flags   = SA_RESETHAND;
 
    if (sigaction(SIGINT, &action, NULL) == -1)
    {
        errspace::show_errmsg("Failed to reset watchdog: reset handler");
        return;
    }
 
    // Unlock the timer signal, so that timer notification
    //   can be delivered
    if (sigprocmask(SIG_UNBLOCK, &mask, NULL) == -1)
    {
        errspace::show_errmsg("Failed to reset watchdog: Unblocking signal");
        return;
    }
}

main.cpp

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
#include <iostream>
#include "../include/common.h"
#include "../include/error.h"
#include "../include/watchdog.h"
#include "../include/mng_thread.h"
 
class Watcher : public IWatcher
{
public:
    template<typename ...Args>
    Watcher(Args... _args)
    {
        auto tpack = std::make_tuple(_args...);
    }
protected:
    virtual void operator ()(siginfo_t *si)
    {
        //printf("Caught signal %d\n", sig);
        //print_siginfo(si);
        //#define errExit(msg)    do { perror(msg); exit(EXIT_FAILURE); \
        //                           } while (0)
        errspace::show_errmsg("watchdog timeout");
        timer_t tidp;
        int _or;
 
        tidp = si->si_value.sival_ptr;
 
        //printf("    sival_ptr = %p; ", si->si_value.sival_ptr);
        //printf("    *sival_ptr = 0x%lx\n", (long) tidp);
 
        _or = timer_getoverrun(tidp);
        //if (_or == -1)
        //    errExit("timer_getoverrun");
        //else
         //   printf("    overrun count = %d\n", _or);
    }
};
 
int main(int argc, char *argv[])
{
    static Watcher w{};
    IWatcher* iw = &w;
 
    const char * FUNCTION = __FUNCTION__;
    try
    {
        using std::cout;
        using std::cin;
        using std::endl;
        cout << "Server is started" << endl;
        std::string str_command;
        while(1)
        {
            LOG << "enter command:";
            if (std::getline(cin, str_command))
            {
                LOG << "command:" << str_command << " was got";
                if (str_command == "q") break;
                if (str_command == "e") throw 0;
                if (str_command == "s")
                {
                    start_wd(1000, iw );
                }
                if (str_command == "p") stop_wd();
            }
            str_command = "";
        }
    }
    catch (...)
    {
        errspace::show_errmsg(FUNCTION);
    }
    return EXIT_SUCCESS;
}
#endif

@DrOffset · 09.01.2020, 17:03

Сообщение от squareroot

Мой нерабочий это несколько тысяч строк кода

Ну это вполне естественно. У многих так.
Обычно, в таких ситуациях делают минимальный пример, в котором воспроизводится проблема большого кода.
Если во время подготовки такого примера внезапно выясняется, что он работает, то проблема, очевидно, в окружении в большом проекте. А это, в свою очередь, означает, что при невозможности проект этот показать, идти на форум с этой проблемой бессмысленно. Угадать в чем проблема можно только случайно. Если же проблема воспроизводится и на маленьком примере, и вы все равно не поняли как ее решить, то вот этот код уже можно постить на форум. Шансы, что вам после этого помогут - 100%.

Добавлено через 43 секунды

Сообщение от squareroot

Вы не против если я вернусь к этой теме чуть позже ?

Это же ваше дело, не мое

Как угодно.

@squareroot · 09.01.2020, 17:07 **[ТС]**

Сообщение от DrOffset

Это же ваше дело, не мое

Как угодно.

Я беспокоюсь что Вам будет некомфортно возвращаться к этой теме, когда пройдёт время.

@DrOffset · 09.01.2020, 17:10

Сообщение от squareroot

Я беспокоюсь что Вам будет некомфортно возвращаться к этой теме, когда пройдёт время.

Не стоит

@squareroot · 13.01.2020, 06:47 **[ТС]**

Сообщение от DrOffset

Мне бы для начала ваш, "нерабочий", увидеть, чтобы можно было запустить у себя.

Если убрать всё лишнее, то вот:

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
typedef void (*TCalbackWD )(siginfo_t *si) noexcept;
 
class TWatchDogImpl
{
public:
    bool start_wd(std::size_t _msecs, TCalbackWD _cback)
    {
     if (is_started) return false;
       static constexpr auto billion = 1'000'000'000;
       static constexpr auto million = 1'000'000;
       //callback = _cback;
       msecs = _msecs;
       bool result = false;
    #ifdef POSIX_TIMER
       isWDTimeout = false;
       struct sigevent sev;
       sigset_t mask;
       struct sigaction sa;
       struct sigaction old_sa;
       // Establish handler for timer signal
       sa.sa_flags = SA_SIGINFO;
       sa.sa_sigaction = signal_handler;
       sigemptyset(&sa.sa_mask);
       if (sigaction(SIG, &sa, &old_sa) == m_error_code)
       {
           errspace::show_errmsg("Failed to setup watchdog: Establish handler");
           return result;
       }
       prev_handler1 =  old_sa.sa_sigaction;
       prev_handler2 =  old_sa.sa_handler;
       // Block timer signal temporarily
       sigemptyset(&mask);
       sigaddset(&mask, SIG);
       if (sigprocmask(SIG_SETMASK, &mask, nullptr) == m_error_code)
       {
           errspace::show_errmsg("Failed to setup watchdog: Blocking signal");
           return result;
       }
 
       // Create the timer
       sev.sigev_notify = SIGEV_SIGNAL;
       sev.sigev_signo = SIG;
       sev.sigev_value.sival_ptr = &m_timerid;
       struct itimerspec its;
       if (timer_create(CLOCKID, &sev, &m_timerid) == m_error_code)
       {
           errspace::show_errmsg("Failed to setup watchdog: create timer");
           return result;
       }
 
       // Start the timer
       long long freq_nanosecs;
       freq_nanosecs = million*_msecs;
       its.it_value.tv_sec = freq_nanosecs / billion;
       its.it_value.tv_nsec = freq_nanosecs % billion;
       its.it_interval.tv_sec = its.it_value.tv_sec;
       its.it_interval.tv_nsec = its.it_value.tv_nsec;
 
       if (timer_settime(m_timerid, 0, &its, nullptr) == m_error_code)
       {
           errspace::show_errmsg("Failed to setup watchdog: set time");
           return result;
       }
       /* Sleep for a while; meanwhile, the timer may expire
          multiple times */
        //std::this_thread::sleep_for(std::chrono::milliseconds(msecs*2));
 
       // Unlock the timer signal, so that timer notification can be delivered
       if (sigprocmask(SIG_UNBLOCK, &mask, nullptr) == m_error_code)
       {
           errspace::show_errmsg("Failed to setup watchdog: Unblocking signal");
           return result;
       }
    #else
        //
    #endif
        result = true;
        is_started = true;
        return result;
    }
    void stop_wd()
    {
        if (!is_started) return;
        bool result = false;
    #ifdef POSIX_TIMER
        sigset_t mask;
        struct sigaction action;
        struct itimerspec its;
        // Stop the timer
        its.it_value.tv_sec = 0;
        its.it_value.tv_nsec = 0;
        its.it_interval.tv_sec = 0;
        its.it_interval.tv_nsec = 0;
        // Block timer signal temporarily
 
        sigemptyset(&mask);
        sigaddset(&mask, SIG);
        if (sigprocmask(SIG_SETMASK, &mask, nullptr) == m_error_code)
        {
            errspace::show_errmsg("Failed to reset watchdog: Blocking signal");
            return;
        }
 
 
        if (timer_settime(m_timerid, 0, &its, nullptr) == m_error_code)
        {
            errspace::show_errmsg("Failed to setup watchdog: set time");
            return;
        }
        std::this_thread::sleep_for(std::chrono::milliseconds(msecs));
        errno = 0;
        action.sa_handler = SIG_DFL;
        action.sa_sigaction = nullptr;
        action.sa_flags   = SA_RESETHAND;
 
        if (sigaction(SIG, &action, nullptr) == m_error_code)
        {
            errspace::show_errmsg("Failed to stop watchdog: reset handler");
            return;
        }
 
        // Unlock the timer signal, so that timer notification
        // can be delivered
 
        if (sigprocmask(SIG_UNBLOCK, &mask, nullptr) == m_error_code)
        {
            errspace::show_errmsg("Failed to reset watchdog: Unblocking signal");
            return;
        }
        // error here
 
 
        if (timer_delete(m_timerid) == m_error_code);
        {
            perror("timer_delete error:");
            errspace::show_errmsg("Failed to stop watchdog: delete timer");
        }
    #else
        //
    #endif
        is_started = false;
    }
    void reset_wd(const native_handle_type& _th)
    {
    }
 
    ~TWatchDogImpl()
    {
        if (is_started) assert("watchdog should be spoped manually");
    }
private:
#ifdef POSIX_TIMER
    timer_t m_timerid;
    static constexpr auto m_error_code = -1;
#else
    //
#endif
    static std::atomic_bool isWDTimeout;
    std::size_t msecs = 0;
    static bool is_started;
};
bool TWatchDogImpl::is_started = false;
std::atomic_bool TWatchDogImpl::isWDTimeout = false;

Но проблема, только с кодом возврата timer_delete

Добавлено через 8 минут
Вот более незавтсимы код:

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
typedef void (*TCalbackWD )(siginfo_t *si) noexcept;
 
class TWatchDogImpl
{
public:
    bool start_wd(std::size_t _msecs, TCalbackWD _cback)
    {
     if (is_started) return false;
       static constexpr auto billion = 1'000'000'000;
       static constexpr auto million = 1'000'000;
       //callback = _cback;
       msecs = _msecs;
       bool result = false;
    #ifdef POSIX_TIMER
       isWDTimeout = false;
       struct sigevent sev;
       sigset_t mask;
       struct sigaction sa;
       struct sigaction old_sa;
       // Establish handler for timer signal
       sa.sa_flags = SA_SIGINFO;
       sa.sa_sigaction = signal_handler;
       sigemptyset(&sa.sa_mask);
       if (sigaction(SIG, &sa, &old_sa) == m_error_code)
       {
           std::cerr << "Failed to setup watchdog: Establish handler";
           return result;
       }
       prev_handler1 =  old_sa.sa_sigaction;
       prev_handler2 =  old_sa.sa_handler;
       // Block timer signal temporarily
       sigemptyset(&mask);
       sigaddset(&mask, SIG);
       if (sigprocmask(SIG_SETMASK, &mask, nullptr) == m_error_code)
       {
           std::cerr << "Failed to setup watchdog: Blocking signal";
           return result;
       }
 
       // Create the timer
       sev.sigev_notify = SIGEV_SIGNAL;
       sev.sigev_signo = SIG;
       sev.sigev_value.sival_ptr = &m_timerid;
       struct itimerspec its;
       if (timer_create(CLOCKID, &sev, &m_timerid) == m_error_code)
       {
           std::cerr << "Failed to setup watchdog: create timer";
           return result;
       }
 
       // Start the timer
       long long freq_nanosecs;
       freq_nanosecs = million*_msecs;
       its.it_value.tv_sec = freq_nanosecs / billion;
       its.it_value.tv_nsec = freq_nanosecs % billion;
       its.it_interval.tv_sec = its.it_value.tv_sec;
       its.it_interval.tv_nsec = its.it_value.tv_nsec;
 
       if (timer_settime(m_timerid, 0, &its, nullptr) == m_error_code)
       {
           std::cerr << "Failed to setup watchdog: set time";
           return result;
       }
       /* Sleep for a while; meanwhile, the timer may expire
          multiple times */
        //std::this_thread::sleep_for(std::chrono::milliseconds(msecs*2));
 
       // Unlock the timer signal, so that timer notification can be delivered
       if (sigprocmask(SIG_UNBLOCK, &mask, nullptr) == m_error_code)
       {
          std::cerr << "Failed to setup watchdog: Unblocking signal";
           return result;
       }
    #else
        //
    #endif
        result = true;
        is_started = true;
        return result;
    }
    void stop_wd()
    {
        if (!is_started) return;
        bool result = false;
    #ifdef POSIX_TIMER
        sigset_t mask;
        struct sigaction action;
        struct itimerspec its;
        // Stop the timer
        its.it_value.tv_sec = 0;
        its.it_value.tv_nsec = 0;
        its.it_interval.tv_sec = 0;
        its.it_interval.tv_nsec = 0;
        // Block timer signal temporarily
 
        sigemptyset(&mask);
        sigaddset(&mask, SIG);
        if (sigprocmask(SIG_SETMASK, &mask, nullptr) == m_error_code)
        {
            std::cerr << "Failed to reset watchdog: Blocking signal";
            return;
        }
 
 
        if (timer_settime(m_timerid, 0, &its, nullptr) == m_error_code)
        {
            std::cerr << "Failed to setup watchdog: set time";
            return;
        }
        std::this_thread::sleep_for(std::chrono::milliseconds(msecs));
        errno = 0;
        action.sa_handler = SIG_DFL;
        action.sa_sigaction = nullptr;
        action.sa_flags   = SA_RESETHAND;
 
        if (sigaction(SIG, &action, nullptr) == m_error_code)
        {
            std::cerr << "Failed to stop watchdog: reset handler";
            return;
        }
 
        // Unlock the timer signal, so that timer notification
        // can be delivered
 
        if (sigprocmask(SIG_UNBLOCK, &mask, nullptr) == m_error_code)
        {
            std::cerr << "Failed to reset watchdog: Unblocking signal";
            return;
        }
        // error here
 
 
        if (timer_delete(m_timerid) == m_error_code);
        {
            perror("timer_delete error:");
            std::cerr << "Failed to stop watchdog: delete timer"
        }
    #else
        //
    #endif
        is_started = false;
    }
    void reset_wd(const native_handle_type& _th)
    {
    }
 
    ~TWatchDogImpl()
    {
        if (is_started) assert("watchdog should be spoped manually");
    }
private:
#ifdef POSIX_TIMER
    timer_t m_timerid;
    static constexpr auto m_error_code = -1;
#else
    //
#endif
    static std::atomic_bool isWDTimeout;
    std::size_t msecs = 0;
    static bool is_started;
};
bool TWatchDogImpl::is_started = false;
std::atomic_bool TWatchDogImpl::isWDTimeout = false;

Добавлено через 5 минут

C++
1
2
3
4
void signal_handler(int _sig, siginfo_t * _si, void * _uc)
{
 
}

@DrOffset · 13.01.2020, 09:21

Сообщение от squareroot

C++
1
if (timer_delete(m_timerid) == m_error_code);

Точку с запятой уберите.

@squareroot · 13.01.2020, 15:22 **[ТС]**

Сообщение от DrOffset

Точку с запятой уберите.

Спасибо, уже "глаз замылился"

Новые блоги и статьи Все статьи Все блоги /
Запустил конкурс "тем и промптов для текстовых квестов созданных почти чисто ИИ" Adler 06.10.2026 Всем привет! За последние три-четыре дня я создал более 16 текстовых квестовых игр используя преимущественно по одному запросу к ИИ на игру. Мне так понравилось смотреть все ветки/ сцены во всех. . .	ИИ не может найти нужный язык в списке Supersumestria 05.10.2026 Я ему даю вот такое изображение и прошу найти и подчеркнуть немецкий язык. Возвращает он вот это: https:/ / i. **********/ vqBWLe2. png Нужную строчку в 3й колонке просто выдумал. . Это. . .	Новая последняя моя музыка в SUNO zorxor 05.10.2026 Здравствуйте, дорогие мои друзья! С большой радостью я хотел бы представить вам свою новую последнею музыку, которую сгенерировала мне по моей просьбе нейросеть SUNO. С уважением, zorxor. Это. . .	Программный домашний кинотеатр russiannick 27.09.2026 Сподобился на программный домашний кинотеатр. В качестве ЯВУ по традиции выбрал js. В помощники взял Яндекс-Алису. Было создано три зала на разные интересы. исторические и ретро сериал Хичкок. . .
Беседа с ИИ о программистах, недопускающих к созданию и правке кода генеративные ИИ и причины этого zorxor 21.09.2026 Раньше я радовался или получал некоторые эмоции, пусть небольшие, но всё же, от самого процесса написания кода, рекомпиляции и запуска, видя постепенное развитие программы и прочее. А теперь лень. . .	Мобильное приложение ColorStep pavlinmavlin 17.09.2026 Реализовал приложение Красный, Зеленый, Синий в Unity3d + c#. Название изменил на ColorStep. Приложение прошло модерацию и теперь доступно для скачивания. Делал его сам, шаг за шагом — и вот,. . .	Запрет дублирования строк в табличной части Maks 13.09.2026 Реализация из решения ниже выполнена на нетиповом справочнике "Нормы ТО" с табличной часть "Виды ТО", разработанного в КА2, со следующими реквизитами: - ВидТО (СправочникСсылка. ВидыТО); - ВидГСМ. . .	Скрипты Tampermonkey для CyberForum, ChatGPT, Claude и пр. Jin X 06.09.2026 Скрипты Tampermonkey для CyberForum, ChatGPT, Claude и пр. Работая с форумом и нейросетями в браузере часто хочется что-то подкорректировать или добавить какого-то функционала. Ниже прикреплён. . .