From 2e1afff475181677a3dd38ab6e6d5632f8a70590 Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期一, 27 七月 2020 10:55:10 +0800
Subject: [PATCH] udpate
---
src/socket/dgram_mod_socket.c | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/socket/dgram_mod_socket.c b/src/socket/dgram_mod_socket.c
index 84976b6..62ae7ac 100644
--- a/src/socket/dgram_mod_socket.c
+++ b/src/socket/dgram_mod_socket.c
@@ -94,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);
@@ -107,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);
@@ -117,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