From d94bfb19c54d4b980c1b4d63b42f3dfa0bc202a6 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期一, 27 七月 2020 11:42:34 +0800
Subject: [PATCH] update
---
src/socket/dgram_mod_socket.c | 9 ++++-----
1 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/src/socket/dgram_mod_socket.c b/src/socket/dgram_mod_socket.c
index 4856204..62ae7ac 100644
--- a/src/socket/dgram_mod_socket.c
+++ b/src/socket/dgram_mod_socket.c
@@ -17,7 +17,6 @@
static Logger logger = LoggerFactory::getLogger();
typedef struct dgram_mod_socket_t {
- socket_mod_t mod;
shm_socket_t *shm_socket;
// pthread_t recv_thread;
// <涓婚锛� 璁㈤槄鑰�>
@@ -85,7 +84,7 @@
-int dgram_mod_get_socket_port(void * _socket) {
+int dgram_mod_get_port(void * _socket) {
dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
return socket->shm_socket->port;
}
@@ -95,7 +94,7 @@
free(buf);
}
-int start_bus(void * _socket) {
+int dgram_mod_start_bus(void * _socket) {
dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
socket->topic_sub_map = new std::map<std::string, std::set<int> *>;
run_pubsub_proxy(socket);
@@ -108,7 +107,7 @@
/**
* @port 鎬荤嚎绔彛
*/
-int sub(void * _socket, void *topic, int size, int port) {
+int dgram_mod_sub(void * _socket, void *topic, int size, int port) {
dgram_mod_socket_t * socket = (dgram_mod_socket_t *) _socket;
char buf[8192];
snprintf(buf, 8192, "%ssub%s%s%s%s", ACTION_LIDENTIFIER, ACTION_RIDENTIFIER, TOPIC_LIDENTIFIER, (char *)topic, TOPIC_RIDENTIFIER);
@@ -118,7 +117,7 @@
/**
* @port 鎬荤嚎绔彛
*/
-int pub(void * _socket, void *topic, int topic_size, void *content, int content_size, int 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;
int head_len;
--
Gitblit v1.8.0