int dlq_add(dlq_node **queue,dlq_node *node);
dlq_node *dlq_get(dlq_node **queue);
void dlq_timeout_check(dlq_node **queue);
//删除节点,返回-1:错,0:没找到,1:删除
int dlq_del(dlq_node **queue,dlq_node *node);
int c_thread_init(int num);
int to_epoll(dlq_node *dlp,int op,int flg);
int to_ctpool(dlq_node *dlp);
int rqueue(dlq_node *dlq,int Dnode);
//in rq_util.c
int Qpoll_init(int num);
dlq_node *Q_get(void);
int Q_release(dlq_node *dlp);
int finish(dlq_node *dlp,int flg);
int setTx(dlq_node *dlp);
int server_recv(dlq_node *dlp);
int timeout_deal(dlq_node *dlp);
int rs_timeout(resource *rs);
void Qp_timeout_check(void);