/*
|
* Copyright (c) 2015-2020 QXSI. All rights reserved.
|
*/
|
|
#ifndef QXWZ_USER_IMPL_H__
|
#define QXWZ_USER_IMPL_H__
|
|
#ifdef __cplusplus
|
extern "C" {
|
#endif
|
|
#include "qxwz_types.h"
|
/*
|
* Log
|
*/
|
qxwz_int32_t qxwz_printf(const qxwz_char_t *fmt, ...);
|
/*
|
* Mutex lock
|
*/
|
typedef struct {
|
qxwz_void_t *mutex_entity;
|
} qxwz_mutex_t;
|
|
qxwz_int32_t qxwz_mutex_init(qxwz_mutex_t *mutex);
|
qxwz_int32_t qxwz_mutex_trylock(qxwz_mutex_t *mutex);
|
qxwz_int32_t qxwz_mutex_lock(qxwz_mutex_t *mutex);
|
qxwz_int32_t qxwz_mutex_unlock(qxwz_mutex_t *mutex);
|
qxwz_int32_t qxwz_mutex_destroy(qxwz_mutex_t *mutex);
|
/*
|
* Memory
|
*/
|
qxwz_void_t *qxwz_malloc(qxwz_uint32_t size);
|
qxwz_void_t *qxwz_calloc(qxwz_uint32_t nmemb, qxwz_uint32_t size);
|
qxwz_void_t *qxwz_realloc(qxwz_void_t *ptr, qxwz_uint32_t size);
|
qxwz_void_t qxwz_free(qxwz_void_t *ptr);
|
|
#define QXWZ_ERR_SOCK_DISCONNECTED -1 /* socket is closed by peer */
|
#define QXWZ_ERR_SOCK_CONNECT -2 /* something wrong happens when try to connect to the server */
|
#define QXWZ_ERR_SOCK_SEND -3 /* something wrong happens when try to send data to server */
|
#define QXWZ_ERR_SOCK_RECV -4 /* something wrong happens when try to receive data from server */
|
#define QXWZ_ERR_SOCK_UNKNOWN -5 /* unknown error happens to socket */
|
|
typedef struct {
|
const qxwz_char_t *hostname;
|
qxwz_uint16_t port;
|
} qxwz_sock_host_t;
|
|
|
/*
|
* Create a socket handler.
|
*
|
* @return:
|
* >= 0: succeeds, identifier of the socket handler;
|
* -1: failed;
|
*/
|
qxwz_int32_t qxwz_sock_create();
|
|
/*
|
* Establish a connection to the server specified by the argument `serv` in a blocking way.
|
* @param[in] sock: socket handler;
|
* @param[in] serv: the server info, see `qxwz_sock_host_t`;
|
*
|
* @return:
|
* 0: connecting succeeded;
|
* -1: connecting failed;
|
*/
|
qxwz_int32_t qxwz_sock_connect(qxwz_int32_t sock, qxwz_sock_host_t *serv);
|
|
/*
|
* Send data in a non-blocking way.
|
* @param[in] sock: socket handler;
|
* @param[in] send_buf: pointer of the buffer to be sent;
|
* @param[in] len: length of the buffer;
|
*
|
* @return:
|
* >=0: the number of bytes sent;
|
* -1: fails;
|
*/
|
qxwz_int32_t qxwz_sock_send(qxwz_int32_t sock, const qxwz_uint8_t *send_buf, qxwz_uint32_t len);
|
|
/*
|
* Receive data in a non-blocking way.
|
* @param[in] sock: socket handler;
|
* @param[in] recv_buf: pointer of the buffer to recv the data;
|
* @param[in] len: length of the buffer;
|
*
|
* @return:
|
* >0: the number of bytes received;
|
* 0: connection is closed by peer
|
* -1: no data received this time
|
* -2: error occur;
|
*/
|
qxwz_int32_t qxwz_sock_recv(qxwz_int32_t sock, qxwz_uint8_t *recv_buf, qxwz_uint32_t len);
|
|
|
/*
|
* Close a socket handler.
|
* @param[in] sock: socket handler.
|
*
|
* @return:
|
* 0: succeeds;
|
* -1: fails;
|
*/
|
qxwz_int32_t qxwz_sock_close(qxwz_int32_t sock);
|
|
#ifdef __cplusplus
|
}
|
#endif
|
|
#endif
|
