xt_socket.h

浏览该文件的文档.

 
#ifndef __XT_SOCKET_H__
#define __XT_SOCKET_H__
 
/* ==================== [Includes] ========================================== */
 
#if defined(XT_SDK_PLATFORM_WINDOWS)
 
#include <winsock2.h>
#include <ws2tcpip.h>
 
#elif defined(XT_SDK_PLATFORM_LINUX)
 
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <sys/time.h>
#include <unistd.h>
#include <fcntl.h>
 
#else
 
#include "lwip/sockets.h"
#include "lwip/netdb.h"
 
#endif
 
#include <stdint.h>
#include "xt_utils.h"
 
#ifdef __cplusplus
extern "C" {
#endif

 
/* ==================== [Defines] =========================================== */
 
#if defined(XT_SDK_PLATFORM_WINDOWS)
 
#ifndef SHUT_RD
#define SHUT_RD     SD_RECEIVE
#endif
#ifndef SHUT_WR
#define SHUT_WR     SD_SEND
#endif
#ifndef SHUT_RDWR
#define SHUT_RDWR   SD_BOTH
#endif
 
typedef SOCKET xt_socket_t;
#define XT_SOCKET_INVALID   INVALID_SOCKET
#define XT_SOCKET_ERROR     SOCKET_ERROR
 
#elif defined(XT_SDK_PLATFORM_LINUX)
 
#ifndef closesocket
#define closesocket(s)          close(s)
#endif
 
typedef int xt_socket_t;
#define XT_SOCKET_INVALID   (-1)
#define XT_SOCKET_ERROR     (-1)
 
#else
/* 默认 lwip 平台（lm620_internal、quectel 等嵌入式平台） */
 
#ifndef errno
#error "xt_socket: lwip platform requires errno - check LWIP_PROVIDE_ERRNO in lwipopts.h"
#endif
 
typedef int xt_socket_t;
#define XT_SOCKET_INVALID   (-1)
#define XT_SOCKET_ERROR     (-1)
 
#ifndef closesocket
#define closesocket(s)          lwip_close(s)
#endif
 
#endif
 
/* ==================== [Defines] =========================================== */
 
/*
 * select() 的 nfds 参数跨平台安全计算。
 * Windows 忽略此参数，传入 0 避免 SOCKET→int 截断。
 * POSIX 需传入最大 fd + 1。
 */
#if !defined(XT_SELECT_NFDS)
#if defined(XT_SDK_PLATFORM_WINDOWS)
#define XT_SELECT_NFDS(fd)  0
#else
#define XT_SELECT_NFDS(fd)  ((int)(fd) + 1)
#endif
#endif
 
/* ==================== [Global Prototypes] ================================= */

xt_err_t xt_socket_setup(void);

void xt_socket_cleanup(void);

int xt_socket_errno(void);

const char *xt_socket_strerror(int err);

xt_err_t xt_socket_set_nonblock(xt_socket_t s, int nonblock);

static inline int xt_socket_read(xt_socket_t s, void *buf, size_t len)
{
#if defined(XT_SDK_PLATFORM_WINDOWS)
    return recv(s, buf, (int)len, 0);
#else
    int ret;
    do {
        ret = (int)read(s, buf, len);
    } while (ret < 0 && errno == EINTR);
    return ret;
#endif
}

static inline int xt_socket_write(xt_socket_t s, const void *buf, size_t len)
{
#if defined(XT_SDK_PLATFORM_WINDOWS)
    return send(s, buf, (int)len, 0);
#else
    int ret;
    do {
        ret = (int)write(s, buf, len);
    } while (ret < 0 && errno == EINTR);
    return ret;
#endif
}
 
/* ==================== [Macros] ============================================ */
  /* xt_socket */
 
#ifdef __cplusplus
} /* extern "C" */
#endif
 
#endif /* __XT_SOCKET_H__ */