Zabbix

/*

** Copyright (C) 2001-2025 Zabbix SIA

**

** This program is free software: you can redistribute it and/or modify it under the terms of

** the GNU Affero General Public License as published by the Free Software Foundation, version 3.

**

** This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;

** without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

** See the GNU Affero General Public License for more details.

**

** You should have received a copy of the GNU Affero General Public License along with this program.

** If not, see <https://www.gnu.org/licenses/>.

**/

​

#ifndef ZABBIX_THREADS_H

#define ZABBIX_THREADS_H

​

#include "zbxcommon.h"

​

#if defined(_WINDOWS) || defined(__MINGW32__)

    /* the ZBXEndThread function is implemented in service.c file */

    void    CALLBACK ZBXEndThread(ULONG_PTR dwParam);

​

    #define ZBX_THREAD_ERROR        0

​

    #define ZBX_THREAD_HANDLE       HANDLE

    #define ZBX_THREAD_HANDLE_NULL      NULL

​

    #define ZBX_THREAD_PRIORITY_NONE    0

​

    #define ZBX_THREAD_ENTRY_POINTER(pointer_name)      \

        unsigned (__stdcall *pointer_name)(void *)

​

    #define ZBX_THREAD_ENTRY(entry_name, arg_name)      \

        unsigned __stdcall entry_name(void *arg_name)

​

    #define zbx_thread_exit(status)             \

        _endthreadex((unsigned int)(status));       \

        return ((unsigned)(status))

​

    #define zbx_sleep(sec)          SleepEx(((DWORD)(sec)) * ((DWORD)1000), TRUE)

​

    #define zbx_thread_kill(h)      QueueUserAPC(ZBXEndThread, h, 0)

    #define zbx_thread_kill_fatal(h)    QueueUserAPC(ZBXEndThread, h, 0)

#else   /* not _WINDOWS */

​

    int zbx_fork(void);

    void    zbx_child_fork(pid_t *pid);

    int zbx_is_child_pid(pid_t pid, const pid_t *child_pids, size_t child_pids_num);

​

    #define ZBX_THREAD_ERROR        -1

​

    #define ZBX_THREAD_HANDLE       pid_t

    #define ZBX_THREAD_HANDLE_NULL      0

​

    #define ZBX_THREAD_PRIORITY_NONE    0

    #define ZBX_THREAD_PRIORITY_FIRST   1

    #define ZBX_THREAD_PRIORITY_SECOND  2

    #define ZBX_THREAD_PRIORITY_COUNT   3

​

    #define ZBX_THREAD_ENTRY_POINTER(pointer_name)  \

        unsigned (* pointer_name)(void *)

​

    #define ZBX_THREAD_ENTRY(entry_name, arg_name)  \

        unsigned entry_name(void *arg_name)

​

    /* Calling _exit() to terminate child process immediately is important. See ZBX-5732 for details. */

    #define zbx_thread_exit(status)         \

        _exit((int)(status));           \

        return ((unsigned)(status))

​

    #define zbx_sleep(sec)          sleep((sec))

​

    #define zbx_thread_kill(h)      kill(h, SIGUSR2)

    #define zbx_thread_kill_fatal(h)    kill(h, SIGHUP)

#endif  /* _WINDOWS */

​

typedef struct

{

    unsigned char   program_type;

    int     server_num;

    int     process_num;

    unsigned char   process_type;

}

zbx_thread_info_t;

​

typedef struct

{

    zbx_thread_info_t   info;

    void            *args;

#if defined(_WINDOWS) || defined(__MINGW32__)