Zabbix

/*

** 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 General Public License as published by

** the Free Software Foundation; either version 2 of the License, or

** (at your option) any later version.

**

** 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 General Public License for more details.

**

** You should have received a copy of the GNU General Public License

** along with this program; if not, write to the Free Software

** Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

**/

​

#include "avail_manager.h"

​

#include "log.h"

#include "zbxself.h"

#include "zbxavailability.h"

#include "zbxipcservice.h"

#include "daemon.h"

#include "sighandler.h"

#include "dbcache.h"

#include "avail_protocol.h"

​

​

extern ZBX_THREAD_LOCAL unsigned char   process_type;

extern unsigned char            program_type;

extern ZBX_THREAD_LOCAL int     server_num, process_num;

static sigset_t             orig_mask;

​

#define ZBX_AVAILABILITY_MANAGER_DELAY          1

#define ZBX_AVAILABILITY_MANAGER_FLUSH_DELAY_SEC    5

​

static int  interface_availability_compare(const void *d1, const void *d2)

{

    const zbx_interface_availability_t  *ia1 = *(const zbx_interface_availability_t **)d1;

    const zbx_interface_availability_t  *ia2 = *(const zbx_interface_availability_t **)d2;

​

    ZBX_RETURN_IF_NOT_EQUAL(ia1->interfaceid, ia2->interfaceid);

​

    return ia1->id - ia2->id;

}

​

ZBX_THREAD_ENTRY(availability_manager_thread, args)

{

    zbx_ipc_service_t       service;

    char                *error = NULL;

    zbx_ipc_client_t        *client;

    zbx_ipc_message_t       *message;

    int             ret, processed_num = 0;

    double              time_stat, time_idle = 0, time_now, time_flush, sec;

    zbx_vector_availability_ptr_t   interface_availabilities;

    zbx_timespec_t          timeout = {ZBX_AVAILABILITY_MANAGER_DELAY, 0};

​

#define STAT_INTERVAL   5   /* if a process is busy and does not sleep then update status not faster than */

                /* once in STAT_INTERVAL seconds */

​