Lines Matching refs:waiting_tcp

182 	struct waiting_tcp* w1 = (struct waiting_tcp*)key1;
183 struct waiting_tcp* w2 = (struct waiting_tcp*)key2;
191 /** delete waiting_tcp entry. Does not unlink from waiting list.
195 waiting_tcp_delete(struct waiting_tcp* w)
213 pick_outgoing_tcp(struct pending_tcp* pend, struct waiting_tcp* w, int s)
385 struct waiting_tcp*
388 struct waiting_tcp* w = reuse->write_wait_first;
405 reuse_write_wait_remove(struct reuse_tcp* reuse, struct waiting_tcp* w)
430 reuse_write_wait_push_back(struct reuse_tcp* reuse, struct waiting_tcp* w)
450 reuse_tree_by_id_insert(struct reuse_tcp* reuse, struct waiting_tcp* w)
467 struct waiting_tcp*
470 struct waiting_tcp key_w;
477 return (struct waiting_tcp*)n->key;
484 struct waiting_tcp* w = (struct waiting_tcp*)node->key;
536 struct waiting_tcp key_w;
619 struct waiting_tcp* w)
631 /* set timer on the waiting_tcp entry, this is the write timeout
638 /* if the waiting_tcp was previously waiting for a buffer in the
646 outnet_tcp_take_into_use(struct waiting_tcp* w)
857 outnet_waiting_tcp_list_remove(struct outside_network* outnet, struct waiting_tcp* w)
859 struct waiting_tcp* p = outnet->tcp_wait_first, *prev = NULL;
881 struct waiting_tcp*
884 struct waiting_tcp* w = outnet->tcp_wait_first;
895 /** add waiting_tcp element to the outnet tcp waiting list */
898 struct waiting_tcp* w, int set_timer)
919 /** add waiting_tcp element as first to the outnet tcp waiting list */
922 struct waiting_tcp* w, int reset_timer)
946 /** call callback on waiting_tcp, if not NULL */
948 waiting_tcp_callback(struct waiting_tcp* w, struct comm_point* c, int error,
961 struct waiting_tcp* w;
1036 reuse_tree_by_id_delete(struct reuse_tcp* reuse, struct waiting_tcp* w)
1063 struct waiting_tcp* w;
1171 struct waiting_tcp* w = (struct waiting_tcp*)node->key;
1175 /** delete readwait waiting_tcp elements, deletes the elements in the list */
1185 /** decommission a tcp buffer, closes commpoint and frees waiting_tcp entry */
1230 struct waiting_tcp* w = (struct waiting_tcp*)node->key;
1240 struct waiting_tcp* w = (struct waiting_tcp*)node->key;
1241 /* Mark the waiting_tcp to signal later code (serviced_delete) that
1253 * the callbacks remove references in sq->pending to the waiting_tcp
1300 struct waiting_tcp* w = NULL;
1368 * sent query with the same ID; the waiting_tcp that
1921 /* delete waiting_tcp elements that
1933 struct waiting_tcp* p = outnet->tcp_wait_first, *np;
2326 struct waiting_tcp* w = (struct waiting_tcp*)arg;
2433 struct waiting_tcp*
2439 struct waiting_tcp* w;
2470 w = (struct waiting_tcp*)malloc(sizeof(struct waiting_tcp)
2479 w->pkt = (uint8_t*)w + sizeof(struct waiting_tcp);
2709 reuse_tcp_remove_serviced_keep(struct waiting_tcp* w,
2768 struct waiting_tcp* w = (struct waiting_tcp*)
3094 struct waiting_tcp* w = (struct waiting_tcp*)sq->pending;
3855 waiting_tcp_get_mem(struct waiting_tcp* w)
3895 struct waiting_tcp* w;
3956 s += sizeof(struct waiting_tcp);