Lines Matching refs:reply_list

280 	if(m && m->reply_list && m->list_select == mesh_jostle_list) {  in mesh_make_new_space()
284 &m->reply_list->start_time); in mesh_make_new_space()
498 if(!s->reply_list && !s->cb_list) { in mesh_new_client()
623 if(!s->reply_list && !s->cb_list) { in mesh_new_callback()
880 mstate->reply_list = NULL; in mesh_state_create()
960 struct mesh_reply* rep = mstate->reply_list; in mesh_state_cleanup()
965 mstate->reply_list = NULL; in mesh_state_cleanup()
1012 if(!mstate->reply_list && !mstate->cb_list in mesh_state_delete()
1017 if(mstate->reply_list || mstate->cb_list) { in mesh_state_delete()
1078 if(!ref->s->reply_list && !ref->s->cb_list in mesh_detach_subs()
1146 if(!sub->reply_list && !sub->cb_list && was_detached && in mesh_attach_sub()
1333 struct mesh_reply* rlist = m->reply_list; in mesh_send_reply()
1386 m->reply_list = NULL; in mesh_send_reply()
1388 m->reply_list = rlist; in mesh_send_reply()
1410 m->reply_list = NULL; in mesh_send_reply()
1412 m->reply_list = rlist; in mesh_send_reply()
1448 m->reply_list = NULL; in mesh_send_reply()
1450 m->reply_list = rlist; in mesh_send_reply()
1501 if((mstate->reply_list || mstate->cb_list) in mesh_query_done()
1508 for(r = mstate->reply_list; r; r = r->next) { in mesh_query_done()
1520 struct mesh_reply* reply_list = mstate->reply_list; in mesh_query_done() local
1524 mstate->reply_list = NULL; in mesh_query_done()
1526 mstate->reply_list = reply_list; in mesh_query_done()
1553 struct mesh_reply* reply_list = mstate->reply_list; in mesh_query_done() local
1556 mstate->reply_list = NULL; in mesh_query_done()
1558 mstate->reply_list = reply_list; in mesh_query_done()
1596 if(mstate->reply_list) { in mesh_query_done()
1597 mstate->reply_list = NULL; in mesh_query_done()
1598 if(!mstate->reply_list && !mstate->cb_list) { in mesh_query_done()
1603 if(!mstate->reply_list && !mstate->cb_list && in mesh_query_done()
1612 if(!mstate->reply_list && mstate->cb_list && !c->next) { in mesh_query_done()
1618 if(!mstate->reply_list && !mstate->cb_list && in mesh_query_done()
1716 r->next = s->reply_list; in mesh_state_add_reply()
1769 s->reply_list = r; in mesh_state_add_reply()
1873 if(mstate->s.need_refetch && mstate->reply_list && in mesh_continue()
1876 addr = mstate->reply_list->query_reply.client_addr; in mesh_continue()
1973 m->s.curmod, (m->reply_list)?"rep":"", /*hasreply*/ in mesh_log_list()
2076 n = m->reply_list; in mesh_state_remove_reply()
2084 else m->reply_list = n->next; in mesh_state_remove_reply()
2099 if(!m->reply_list && !m->cb_list in mesh_state_remove_reply()
2104 if(!m->reply_list && !m->cb_list) { in mesh_state_remove_reply()
2229 for(r = mstate->reply_list; r; r = r->next) { in mesh_serve_expired_callback()
2241 struct mesh_reply* reply_list = mstate->reply_list; in mesh_serve_expired_callback() local
2245 mstate->reply_list = NULL; in mesh_serve_expired_callback()
2247 mstate->reply_list = reply_list; in mesh_serve_expired_callback()
2300 if(mstate->reply_list) { in mesh_serve_expired_callback()
2301 mstate->reply_list = NULL; in mesh_serve_expired_callback()
2302 if(!mstate->reply_list && !mstate->cb_list) { in mesh_serve_expired_callback()
2314 if(!mstate->reply_list && mstate->cb_list && !c->next) { in mesh_serve_expired_callback()
2320 if(!mstate->reply_list && !mstate->cb_list && in mesh_serve_expired_callback()