| | |
|---|
| | | #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_exclude(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); |
|---|
