Home | History | Annotate | Download | only in testcode

Lines Matching refs:reuse

49 /** add number of new IDs to the reuse tree, randomly chosen */
50 static void tcpid_addmore(struct reuse_tcp* reuse,
56 		uint16_t id = reuse_tcp_select_id(reuse, outnet);
57 		unit_assert(!reuse_tcp_by_id_find(reuse, id));
62 		w->next_waiting = (void*)reuse->pending;
63 		reuse_tree_by_id_insert(reuse, w);
67 /** fill up the reuse ID tree and test assertions */
68 static void tcpid_fillup(struct reuse_tcp* reuse,
73 		rbtree_init(&reuse->tree_by_id, reuse_id_cmp);
74 		tcpid_addmore(reuse, outnet, 65535);
75 		reuse_del_readwait(&reuse->tree_by_id);
86 	pend.reuse.pending = &pend;
89 	rbtree_init(&pend.reuse.tree_by_id, reuse_id_cmp);
90 	tcpid_fillup(&pend.reuse, &outnet);
99 	struct reuse_tcp *reuse, *next_reuse;
108 	reuse = outnet->tcp_reuse_first;
110 		unit_assert(reuse->item_on_lru_list);
111 		unit_assert(reuse->lru_next);
112 		unit_assert(reuse->lru_next != reuse);
113 		next_reuse = reuse->lru_next;
114 		unit_assert(next_reuse->lru_prev == reuse);
115 		reuse = next_reuse;
117 	unit_assert(!reuse->lru_next);
119 	unit_assert(outnet->tcp_reuse_last == reuse);
146 	struct reuse_tcp* reuse;
147 	reuse = outnet->tcp_reuse_first;
149 	while(reuse) {
150 		reuse_tcp_remove_tree_list(outnet, reuse);
152 		reuse = outnet->tcp_reuse_first;
160 	struct reuse_tcp* reuse;
166 	reuse = outnet->tcp_reuse_first;
167 	for(i=0; i<position; i++) reuse = reuse->lru_next;
168 	reuse_tcp_remove_tree_list(outnet, reuse);
176 	struct reuse_tcp* reuse;
182 	reuse = reuse_tcp_lru_snip(outnet);
183 	while(reuse) {
184 		reuse_tcp_remove_tree_list(outnet, reuse);
186 		reuse = reuse_tcp_lru_snip(outnet);
198 	struct reuse_tcp* reuse;
213 		for(reuse = outnet.tcp_reuse_first; reuse->lru_next; reuse = reuse->lru_next);
214 		reuse_tcp_lru_touch(&outnet, reuse);
359 static void check_reuse_write_wait(struct reuse_tcp* reuse,
363 	struct waiting_tcp* w = reuse->write_wait_first;
365 	if(first) unit_assert(reuse->write_wait_first == first && !first->write_wait_prev);
366 	if(last) unit_assert(reuse->write_wait_last == last && !last->write_wait_next);
380 	w = reuse->write_wait_last;
395 static void reuse_write_wait_clear(struct reuse_tcp* reuse)
397 	struct waiting_tcp* w = reuse->write_wait_first, *n = NULL;
399 	unit_assert(reuse->write_wait_first);
400 	unit_assert(reuse->write_wait_last);
408 	reuse->write_wait_first = NULL;
409 	reuse->write_wait_last = NULL;
415 	struct reuse_tcp* reuse, struct waiting_tcp* store,
420 	reuse_write_wait_clear(reuse);
422 		reuse_write_wait_push_back(reuse, &store[i]);
424 	check_reuse_write_wait(reuse, &store[0], &store[total-1], total);
427 		w = reuse_write_wait_pop(reuse);
429 		w = reuse->write_wait_first;
431 		reuse_write_wait_remove(reuse, w);
437 		check_reuse_write_wait(reuse, NULL, NULL, total-1);
440 		check_reuse_write_wait(reuse, &store[1], &store[total-1], total-1);
443 		check_reuse_write_wait(reuse, &store[0], &store[total-2], total-1);
446 		check_reuse_write_wait(reuse, &store[0], &store[total-1], total-1);
453 	struct reuse_tcp reuse;
456 	memset(&reuse, 0, sizeof(reuse));
463 		reuse_write_wait_push_back(&reuse, w);
465 	check_reuse_write_wait(&reuse, &store[0], w, MAX_TCP_WAITING_NODES);
469 	check_reuse_write_wait_removal(0, &reuse, store, 2, 5);
470 	check_reuse_write_wait_removal(0, &reuse, store, 1, 3);
471 	check_reuse_write_wait_removal(0, &reuse, store, 0, 2);
472 	check_reuse_write_wait_removal(0, &reuse, store, 1, 2);
473 	check_reuse_write_wait_removal(0, &reuse, store, 0, 1);
477 	check_reuse_write_wait_removal(1, &reuse, store, 0, 3);
478 	check_reuse_write_wait_removal(1, &reuse, store, 0, 2);
479 	check_reuse_write_wait_removal(1, &reuse, store, 0, 1);