Zabbix

/*

** Copyright (C) 2001-2024 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/>.

**/

​

#include "async_worker.h"

​

#include "async_manager.h"

​

#include "zbxalgo.h"

#include "zbxtime.h"

#include "zbxthreads.h"

#include "zbxcacheconfig.h"

#include "zbxexpression.h"

#include "zbx_availability_constants.h"

#include "zbxpoller.h"

#include "zbxavailability.h"

#include "zbxinterface.h"

​

#define ASYNC_WORKER_INIT_NONE      0x00

#define ASYNC_WORKER_INIT_THREAD    0x01

​

static zbx_poller_item_t    *dc_config_async_get_poller_items(const zbx_async_queue_t *queue)

{

    zbx_poller_item_t   *poller_item;

​

    poller_item = zbx_malloc(NULL, sizeof(zbx_poller_item_t));

    poller_item->items = NULL;

​

    poller_item->num = zbx_dc_config_get_poller_items(queue->poller_type, queue->config_timeout,

            queue->processing_num, queue->processing_limit, &poller_item->items);

​

    if (0 != poller_item->num)

    {

        poller_item->results = zbx_malloc(NULL, (size_t)poller_item->num * sizeof(AGENT_RESULT));

        poller_item->errcodes = zbx_malloc(NULL, (size_t)poller_item->num * sizeof(int));

​

        zbx_prepare_items(poller_item->items, poller_item->errcodes, poller_item->num, poller_item->results,

                ZBX_MACRO_EXPAND_YES);

    }

    else

    {

        zbx_free(poller_item->items);

        zbx_free(poller_item);

    }

​

    return poller_item;

}

​

static void poller_update_interfaces(zbx_vector_interface_status_t *interfaces,

        int config_unavailable_delay, int config_unreachable_period, int config_unreachable_delay)

{

    zbx_interface_status_t  *interface_status;

    unsigned char       *data = NULL;