| | |
|---|
| | | #include "usg_common.h" |
|---|
| | | #include "shm_socket.h" |
|---|
| | | #include "shm_allocator.h" |
|---|
| | | #include "mem_pool.h" |
|---|
| | | #include "shm_mm.h" |
|---|
| | | #include "hashtable.h" |
|---|
| | | #include "sem_util.h" |
|---|
| | | #include "logger_factory.h" |
|---|
| | |
|---|
| | | #include <set> |
|---|
| | | #include "socket_def.h" |
|---|
| | | |
|---|
| | | #define BUS_HEAD_SIZE (64 + 2 * sizeof(uint32_t)) |
|---|
| | | #define BUS_HEAD_SIZE sizeof(bus_head_t) |
|---|
| | | class BusServerSocket; |
|---|
| | | |
|---|
| | | struct bus_head_t |
|---|
| | |
|---|
| | | static int get_bus_sendbuf(bus_head_t &request_head, const void *topic_buf, int topic_size, const void *content_buf, int content_size, void **retbuf); |
|---|
| | | |
|---|
| | | public: |
|---|
| | | static size_t remove_keys(int keys[], size_t length); |
|---|
| | | // static size_t remove_keys(int keys[], size_t length); |
|---|
| | | // static size_t remove_keys_exclude(int keys[], size_t length); |
|---|
| | | |
|---|
| | | // bus header 编码为网络传输的字节 |
|---|
| | | static void * encode_bus_head(bus_head_t & bushead); |
|---|
| | |
|---|
| | | ShmModSocket(); |
|---|
| | | ~ShmModSocket(); |
|---|
| | | |
|---|
| | | int stop(); |
|---|
| | | /** |
|---|
| | | * 绑定端口到socket, 如果不绑定则系统自动分配一个 |
|---|
| | | * @return 0 成功， 其他值 失败的错误码 |
|---|
| | |
|---|
| | | const struct timespec *timeout = NULL, int flag = 0); |
|---|
| | | |
|---|
| | | |
|---|
| | | int recvandsend(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback, |
|---|
| | | const struct timespec *timeout = NULL , int flag = 0); |
|---|
| | | /** |
|---|
| | | * |
|---|
| | | */ |
|---|
| | | int recvandsend( recvandsend_callback_fn callback, const struct timespec *timeout = NULL , int flag = 0, void * user_data = NULL); |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 订阅指定主题 |
|---|
