| | |
|---|
| | | private: |
|---|
| | | |
|---|
| | | ShmModSocket shmModSocket; |
|---|
| | | // pool req_resp_pool; |
|---|
| | | NetConnPool *gpool; |
|---|
| | | |
|---|
| | | pthread_mutex_t sendMutex; |
|---|
| | | // pthread_mutex_t sendMutex; |
|---|
| | | |
|---|
| | | // request header 编码为网络传输的字节 |
|---|
| | | static void * encode_request_head(net_mod_request_head_t & request); |
|---|
| | |
|---|
| | | NetModSocket(); |
|---|
| | | ~NetModSocket(); |
|---|
| | | |
|---|
| | | |
|---|
| | | int stop(); |
|---|
| | | /** |
|---|
| | | * 绑定端口到socket, 如果不绑定则系统自动分配一个 |
|---|
| | | * @return 0 成功， 其他值 失败的错误码 |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | int recvandsend(void **recvbuf, int *recvsize, int *key, recv_callback_fn callback, |
|---|
| | | /** |
|---|
| | | * recvandsend |
|---|
| | | */ |
|---|
| | | int recvandsend( recvandsend_callback_fn callback, |
|---|
| | | const struct timespec *timeout = NULL , int flag = 0, void * user_data = NULL ); |
|---|
| | | |
|---|
| | | /** |
|---|
