#include "dgram_mod_socket.h" #include "shm_mod_socket.h" typedef struct dgram_mod_socket_t { ShmModSocket *m_socket; } dgram_mod_socket_t; int dgram_mod_remove_keys(int keys[], int length){ return ShmModSocket::remove_keys(keys, length); } int dgram_mod_remove_key(int key){ int keys[] = {key}; return ShmModSocket::remove_keys(keys, 1); } /** * 创建socket * @return socket地址 */ void *dgram_mod_open_socket() { dgram_mod_socket_t * socket = (dgram_mod_socket_t *)calloc(1, sizeof(dgram_mod_socket_t)); // socket->mod = (socket_mod_t)mod; socket->m_socket = new ShmModSocket; return (void *)socket; } /** * 关闭socket * @return 0 成功, 其他值 失败的错误码 */ int dgram_mod_close_socket(void * _socket) { dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; delete socket->m_socket; free(_socket); return 0; } /** * 绑定端口到socket, 如果不绑定则系统自动分配一个 * @return 0 成功, 其他值 失败的错误码 */ int dgram_mod_bind(void * _socket, int port) { dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->bind(port); } /** * 强制绑定端口到socket, 适用于程序非正常关闭的情况下,重启程序绑定原来还没释放的key * @return 0 成功, 其他值 失败的错误码 */ int dgram_mod_force_bind(void * _socket, int port) { dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->force_bind(port); } /** * 发送信息 * @port 发送给谁 * @return 0 成功, 其他值 失败的错误码 */ int dgram_mod_sendto(void *_socket, const void *buf, const int size, const int port){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->sendto(buf, size,port); } // 发送信息超时返回。 @sec 秒 , @nsec 纳秒 int dgram_mod_sendto_timeout(void *_socket, const void *buf, const int size, const int port, int sec, int nsec){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; struct timespec timeout = {sec, nsec}; return socket->m_socket->sendto_timeout(buf, size, port, &timeout); } // 发送信息立刻返回。 int dgram_mod_sendto_nowait(void *_socket, const void *buf, const int size, const int port){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->sendto_nowait(buf, size,port); } /** * 接收信息 * @port 从谁哪里收到的信息 * @return 0 成功, 其他值 失败的错误码 */ int dgram_mod_recvfrom(void *_socket, void **buf, int *size, int *port) { dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->recvfrom(buf, size, port); } // 接受信息超时返回。 @sec 秒 , @nsec 纳秒 int dgram_mod_recvfrom_timeout(void *_socket, void **buf, int *size, int *port, int sec, int nsec){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; struct timespec timeout = {sec, nsec}; return socket->m_socket->recvfrom_timeout(buf, size, port, &timeout); } int dgram_mod_recvfrom_nowait(void *_socket, void **buf, int *size, int *port){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->recvfrom_nowait(buf, size, port); } /** * 发送请求信息并等待接收应答 * @port 发送给谁 * @return 0 成功, 其他值 失败的错误码 */ int dgram_mod_sendandrecv(void * _socket, const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->sendandrecv(send_buf, send_size, port, recv_buf, recv_size); } // 超时返回。 @sec 秒 , @nsec 纳秒 int dgram_mod_sendandrecv_timeout(void * _socket, const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size, int sec, int nsec){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; struct timespec timeout = {sec, nsec}; return socket->m_socket->sendandrecv_timeout(send_buf, send_size, port, recv_buf, recv_size, &timeout); } int dgram_mod_sendandrecv_nowait(void * _socket, const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size) { dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->sendandrecv_nowait(send_buf, send_size, port, recv_buf, recv_size); } /** * 启动bus * * @return 0 成功, 其他值 失败的错误码 */ int dgram_mod_start_bus(void * _socket) { dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->start_bus(); } /** * 订阅指定主题 * @topic 主题 * @size 主题长度 * @port 总线端口 */ int dgram_mod_sub(void * _socket, void *topic, int size, int port){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->sub((char *)topic, size, port); } // 超时返回。 @sec 秒 , @nsec 纳秒 int dgram_mod_sub_timeout(void * _socket, void *topic, int size, int port, int sec, int nsec){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; struct timespec timeout = {sec, nsec}; return socket->m_socket->sub_timeout((char *)topic, size, port, &timeout); } int dgram_mod_sub_nowait(void * _socket, void *topic, int size, int port){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->sub_nowait((char *)topic, size, port); } /** * 取消订阅指定主题 * @topic 主题 * @size 主题长度 * @port 总线端口 */ int dgram_mod_desub(void * _socket, void *topic, int size, int port){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->desub((char *)topic, size, port); } // 超时返回。 @sec 秒 , @nsec 纳秒 int dgram_mod_desub_timeout(void * _socket, void *topic, int size, int port, int sec, int nsec){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; struct timespec timeout = {sec, nsec}; return socket->m_socket->desub_timeout((char *)topic, size, port, &timeout); } int dgram_mod_desub_nowait(void * _socket, void *topic, int size, int port){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->desub_nowait((char *)topic, size, port); } /** * 发布主题 * @topic 主题 * @content 主题内容 * @port 总线端口 */ int dgram_mod_pub(void * _socket, void *topic, int topic_size, void *content, int content_size, int port){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->pub((char *)topic, topic_size, content, content_size, port); } // 超时返回。 @sec 秒 , @nsec 纳秒 int dgram_mod_pub_timeout(void * _socket, void *topic, int topic_size, void *content, int content_size, int port, int sec, int nsec){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; struct timespec timeout = {sec, nsec}; return socket->m_socket->pub_timeout((char *)topic, topic_size, content, content_size, port, &timeout); } int dgram_mod_pub_nowait(void * _socket, void *topic, int topic_size, void *content, int content_size, int port){ dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->pub_nowait((char *)topic, topic_size, content, content_size, port); } /** * 获取soket端口号 */ int dgram_mod_get_port(void * _socket) { dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket; return socket->m_socket->get_port(); } /** * 释放存储接收信息的buf */ void dgram_mod_free(void *buf) { free(buf); }