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)
371 struct waiting_tcp*
374 struct waiting_tcp* w = reuse->write_wait_first;
391 reuse_write_wait_remove(struct reuse_tcp* reuse, struct waiting_tcp* w)
416 reuse_write_wait_push_back(struct reuse_tcp* reuse, struct waiting_tcp* w)
436 reuse_tree_by_id_insert(struct reuse_tcp* reuse, struct waiting_tcp* w)
453 struct waiting_tcp*
456 struct waiting_tcp key_w;
463 return (struct waiting_tcp*)n->key;
470 struct waiting_tcp* w = (struct waiting_tcp*)node->key;
522 struct waiting_tcp key_w;
605 struct waiting_tcp* w)
617 /* set timer on the waiting_tcp entry, this is the write timeout
624 /* if the waiting_tcp was previously waiting for a buffer in the
632 outnet_tcp_take_into_use(struct waiting_tcp* w)
842 outnet_waiting_tcp_list_remove(struct outside_network* outnet, struct waiting_tcp* w)
844 struct waiting_tcp* p = outnet->tcp_wait_first, *prev = NULL;
866 struct waiting_tcp*
869 struct waiting_tcp* w = outnet->tcp_wait_first;
880 /** add waiting_tcp element to the outnet tcp waiting list */
883 struct waiting_tcp* w, int set_timer)
904 /** add waiting_tcp element as first to the outnet tcp waiting list */
907 struct waiting_tcp* w, int reset_timer)
931 /** call callback on waiting_tcp, if not NULL */
933 waiting_tcp_callback(struct waiting_tcp* w, struct comm_point* c, int error,
946 struct waiting_tcp* w;
1021 reuse_tree_by_id_delete(struct reuse_tcp* reuse, struct waiting_tcp* w)
1048 struct waiting_tcp* w;
1156 struct waiting_tcp* w = (struct waiting_tcp*)node->key;
1160 /** delete readwait waiting_tcp elements, deletes the elements in the list */
1170 /** decommission a tcp buffer, closes commpoint and frees waiting_tcp entry */
1215 struct waiting_tcp* w = (struct waiting_tcp*)node->key;
1225 struct waiting_tcp* w = (struct waiting_tcp*)node->key;
1226 /* Mark the waiting_tcp to signal later code (serviced_delete) that
1238 * the callbacks remove references in sq->pending to the waiting_tcp
1285 struct waiting_tcp* w = NULL;
1353 * sent query with the same ID; the waiting_tcp that
1906 /* delete waiting_tcp elements that
1918 struct waiting_tcp* p = outnet->tcp_wait_first, *np;
2311 struct waiting_tcp* w = (struct waiting_tcp*)arg;
2418 struct waiting_tcp*
2424 struct waiting_tcp* w;
2455 w = (struct waiting_tcp*)malloc(sizeof(struct waiting_tcp)
2464 w->pkt = (uint8_t*)w + sizeof(struct waiting_tcp);
2694 reuse_tcp_remove_serviced_keep(struct waiting_tcp* w,
2753 struct waiting_tcp* w = (struct waiting_tcp*)
3079 struct waiting_tcp* w = (struct waiting_tcp*)sq->pending;
3838 waiting_tcp_get_mem(struct waiting_tcp* w)
3878 struct waiting_tcp* w;
3939 s += sizeof(struct waiting_tcp);