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

**/

​

#ifndef ZABBIX_COMMS_H

#define ZABBIX_COMMS_H

​

#include "config.h"

#include "zbxtime.h"

​

/* socket polling timeout in milliseconds */

#define ZBX_SOCKET_POLL_TIMEOUT 1000

​

#ifdef _WINDOWS

#   define ZBX_TCP_WRITE(s, b, bl)      ((ssize_t)send((s), (b), (int)(bl), 0))

#   define ZBX_TCP_READ(s, b, bl)       ((ssize_t)recv((s), (b), (int)(bl), 0))

#   define ZBX_TCP_RECV(s, b, bl, f)        ((ssize_t)recv((s), (b), (int)(bl), f))

#   define zbx_socket_close(s)      if (ZBX_SOCKET_ERROR != (s)) closesocket(s)

#   define zbx_bind(s, a, l)        (bind((s), (a), (int)(l)))

#   define zbx_sendto(fd, b, n, f, a, l)    (sendto((fd), (b), (int)(n), (f), (a), (l)))

#   define ZBX_PROTO_AGAIN          WSAEINTR

#   define ZBX_SOCKET_ERROR         INVALID_SOCKET

#else

#   define ZBX_TCP_WRITE(s, b, bl)      ((ssize_t)write((s), (b), (bl)))

#   define ZBX_TCP_READ(s, b, bl)       ((ssize_t)read((s), (b), (bl)))

#   define ZBX_TCP_RECV(s, b, bl, f)    ((ssize_t)recv((s), (b), (bl), f))

#   define zbx_socket_close(s)      if (ZBX_SOCKET_ERROR != (s)) close(s)

#   define zbx_bind(s, a, l)        (bind((s), (a), (l)))

#   define zbx_sendto(fd, b, n, f, a, l)    (sendto((fd), (b), (n), (f), (a), (l)))

#   define ZBX_PROTO_AGAIN          EINTR

#   define ZBX_SOCKET_ERROR         -1

#   define zbx_socket_poll(x, y, z)     poll(x, y, z)

#endif

​

char    *socket_poll_error(short revents);

​

#endif /* ZABBIX_COMMS_H */