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 "../sysinfo.h"

#include "net.h"

​

#include "zbxcomms.h"

#include "zbxcfg.h"

#include "zbxstr.h"

#include "zbxnum.h"

​

int tcp_expect(const char *host, unsigned short port, int timeout, const char *request,

        int (*validate_func)(const char *), const char *sendtoclose, int *value_int)

{

    zbx_socket_t    s;

    const char  *buf;

    int     net, val = ZBX_TCP_EXPECT_OK;

​

    *value_int = 0;

​

    if (SUCCEED != (net = zbx_tcp_connect(&s, sysinfo_get_config_source_ip(), host, port, timeout,

            ZBX_TCP_SEC_UNENCRYPTED, NULL, NULL)))

    {

        goto out;

    }

​

    if (NULL != request)

        net = zbx_tcp_send_raw(&s, request);

​

    if (NULL != validate_func && SUCCEED == net)

    {

        val = ZBX_TCP_EXPECT_FAIL;

​

        while (NULL != (buf = zbx_tcp_recv_line(&s)))

        {

            val = validate_func(buf);

​

            if (ZBX_TCP_EXPECT_OK == val)

                break;

​

            if (ZBX_TCP_EXPECT_FAIL == val)

            {

                zabbix_log(LOG_LEVEL_DEBUG, "TCP expect content error, received [%s]", buf);

                break;

            }

        }

    }

​

    if (NULL != sendtoclose && SUCCEED == net && ZBX_TCP_EXPECT_OK == val)

        (void)zbx_tcp_send_raw(&s, sendtoclose);

​

    if (SUCCEED == net && ZBX_TCP_EXPECT_OK == val)