| | |
|---|
| | | #include "shm_mod_socket.h" |
|---|
| | | #include "socket_io.h" |
|---|
| | | #include <poll.h> |
|---|
| | | #include "socket_def.h" |
|---|
| | | |
|---|
| | | |
|---|
| | | #define GET(p) (*(uint32_t *)(p)) |
|---|
| | | #define PUT(p, val) (*(uint32_t *)(p) = (val)) |
|---|
| | | |
|---|
| | | #define GET_INT32(p) (*(int32_t *)(p)) |
|---|
| | | #define PUT_INT32(p, val) (*(int32_t *)(p) = (val)) |
|---|
| | | |
|---|
| | | |
|---|
| | | class NetModServerSocket; |
|---|
| | |
|---|
| | | /** |
|---|
| | | * 如果建立连接的节点没有接受到消息会一直等待 |
|---|
| | | * 向node_arr 中的所有网络节点发送请求消息，节点的返回信息汇总并存储在recv_arr中 |
|---|
| | | * @node_arr 网络节点组, @node_arr_len该数组长度 |
|---|
| | | * @node_arr 网络节点组, @node_arr_len该数组长度.如果IP为空则为本地发送。 |
|---|
| | | * @send_buf 发送的消息，@send_size 该消息体的长度 |
|---|
| | | * @recv_arr 返回的应答消息组，@recv_arr_size 该数组长度 |
|---|
| | | * @return 成功发送的节点的个数 |
|---|
| | |
|---|
| | | int sendandrecv_timeout( const void *send_buf, const int send_size, const int send_key, void **recv_buf, int *recv_size, int sec, int nsec) ; |
|---|
| | | int sendandrecv_nowait( const void *send_buf, const int send_size, const int send_key, void **recv_buf, int *recv_size) ; |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 启动bus |
|---|
| | | * |
|---|
| | | * @return 0 成功， 其他值 失败的错误码 |
|---|
| | | */ |
|---|
| | | int start_bus(); |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 向node_arr 中的所有网络节点发布消息 |
|---|
| | | * @node_arr 网络节点组, @node_arr_len该数组长度 |
|---|
