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/>.

**/

​

#include "zbxasyncpoller.h"

#include "zbxcommon.h"

​

#ifdef HAVE_LIBCURL

​

#include "async_http.h"

#include "discoverer_int.h"

#include "zbxsysinc.h"

#include "zbxip.h"

#include "zbx_discoverer_constants.h"

​

static int  process_task_http(short event, void *data, int *fd, zbx_vector_address_t *addresses,

        const char *reverse_dns, char *dnserr, struct event *timeout_event)

{

    int                  task_ret = ZBX_ASYNC_TASK_STOP;

    zbx_discovery_async_http_context_t  *http_context = (zbx_discovery_async_http_context_t *)data;

​

    ZBX_UNUSED(fd);

    ZBX_UNUSED(dnserr);

    ZBX_UNUSED(timeout_event);

    ZBX_UNUSED(addresses);

​

    if (ZBX_ASYNC_HTTP_STEP_RDNS == http_context->step)

    {

        if (NULL != reverse_dns)

            http_context->reverse_dns = zbx_strdup(NULL, reverse_dns);

​

        goto stop;

    }

​

    if (0 != (event & EV_TIMEOUT))

        goto stop;

​

    if (ZABBIX_ASYNC_RESOLVE_REVERSE_DNS_YES == http_context->resolve_reverse_dns)

    {

        task_ret = ZBX_ASYNC_TASK_RESOLVE_REVERSE;

        http_context->step = ZBX_ASYNC_HTTP_STEP_RDNS;

    }

stop:

    return task_ret;

}

​

void    process_http_response(CURL *easy_handle, CURLcode err, void *arg)

{

    zbx_discovery_async_http_context_t  *http_context;

    discovery_poller_config_t       *poller_config = (discovery_poller_config_t *)arg;

    CURLcode                err_info;

​

    if (CURLE_OK != (err_info = curl_easy_getinfo(easy_handle, CURLINFO_PRIVATE, &http_context)))