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 "zbxpoller.h"

​

#include "zbxasyncpoller.h"

#include "zbxtimekeeper.h"

#include "zbxcacheconfig.h"

#include "zbxcommon.h"

#include "zbxcomms.h"

#include "zbxself.h"

#include "zbxagentget.h"

#include "zbxversion.h"

​

#if defined(HAVE_GNUTLS) || defined(HAVE_OPENSSL)

#   include "zbxip.h"

#endif

​

static const char   *get_agent_step_string(zbx_zabbix_agent_step_t step)

{

    switch (step)

    {

        case ZABBIX_AGENT_STEP_CONNECT_INIT:

            return "init";

        case ZABBIX_AGENT_STEP_CONNECT_WAIT:

            return "connect";

        case ZABBIX_AGENT_STEP_TLS_WAIT:

            return "tls";

        case ZABBIX_AGENT_STEP_SEND:

            return "send";

        case ZABBIX_AGENT_STEP_RECV:

            return "receive";

        case ZABBIX_AGENT_STEP_RECV_CLOSE:

            return "receive close notify";

        default:

            return "unknown";

    }

}

​

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

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

{

    zbx_agent_context   *agent_context = (zbx_agent_context *)data;

    short           event_new = 0;

    zbx_async_task_state_t  state = ZBX_ASYNC_TASK_STOP;

    zbx_poller_config_t *poller_config = (zbx_poller_config_t *)agent_context->arg_action;

    int         errnum = 0;

    socklen_t       optlen = sizeof(int);

​

    ZBX_UNUSED(fd);

    ZBX_UNUSED(timeout_event);

​

    zabbix_log(LOG_LEVEL_DEBUG, "In %s() step '%s' '%s' event:%d itemid:" ZBX_FS_UI64 " addr:%s", __func__,

                get_agent_step_string(agent_context->step), zbx_get_event_string(event), event,

                agent_context->item.itemid, 0 != addresses->values_num ? addresses->values[0].ip : "");

​

    if (NULL != poller_config && ZBX_PROCESS_STATE_IDLE == poller_config->state)

    {

        zbx_update_selfmon_counter(poller_config->info, ZBX_PROCESS_STATE_BUSY);

        poller_config->state = ZBX_PROCESS_STATE_BUSY;

    }

​

    if (ZABBIX_ASYNC_STEP_REVERSE_DNS == agent_context->rdns_step)

    {

        if (NULL != reverse_dns)

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

​

        goto stop;

    }

​

    if (0 != (event & EV_TIMEOUT))

    {

        agent_context->item.ret = TIMEOUT_ERROR;

​

        if (NULL != dnserr)

        {

            SET_MSG_RESULT(&agent_context->item.result, zbx_dsprintf(NULL, "Get value from agent"

                    " failed: Cannot resolve address: %s", dnserr));

            return ZBX_ASYNC_TASK_STOP;

        }