Lines Matching refs:sendqueue

16 static coap_queue_t *sendqueue;  variable
42 int result = coap_insert_node(&sendqueue, node[1]); in t_sendqueue1()
45 CU_ASSERT_PTR_NOT_NULL(sendqueue); in t_sendqueue1()
46 CU_ASSERT_PTR_EQUAL(sendqueue, node[1]); in t_sendqueue1()
54 result = coap_insert_node(&sendqueue, node[2]); in t_sendqueue2()
57 CU_ASSERT_PTR_EQUAL(sendqueue, node[1]); in t_sendqueue2()
58 CU_ASSERT_PTR_EQUAL(sendqueue->next, node[2]); in t_sendqueue2()
60 CU_ASSERT(sendqueue->t == timestamp[1]); in t_sendqueue2()
68 result = coap_insert_node(&sendqueue, node[3]); in t_sendqueue3()
72 CU_ASSERT_PTR_EQUAL(sendqueue, node[3]); in t_sendqueue3()
75 CU_ASSERT_PTR_NOT_NULL(sendqueue->next); in t_sendqueue3()
76 CU_ASSERT_PTR_NOT_NULL(sendqueue->next->next); in t_sendqueue3()
78 CU_ASSERT(sendqueue->next->t == timestamp[1] - timestamp[3]); in t_sendqueue3()
79 CU_ASSERT(sendqueue->next->next->t == timestamp[2] - timestamp[1]); in t_sendqueue3()
87 result = coap_insert_node(&sendqueue, node[4]); in t_sendqueue4()
91 CU_ASSERT_PTR_EQUAL(sendqueue, node[3]); in t_sendqueue4()
93 CU_ASSERT_PTR_NOT_NULL(sendqueue->next); in t_sendqueue4()
94 CU_ASSERT_PTR_EQUAL(sendqueue->next, node[1]); in t_sendqueue4()
96 CU_ASSERT_PTR_NOT_NULL(sendqueue->next->next); in t_sendqueue4()
97 CU_ASSERT_PTR_EQUAL(sendqueue->next->next, node[4]); in t_sendqueue4()
99 CU_ASSERT_PTR_NOT_NULL(sendqueue->next->next->next); in t_sendqueue4()
100 CU_ASSERT_PTR_EQUAL(sendqueue->next->next->next, node[2]); in t_sendqueue4()
102 CU_ASSERT(sendqueue->next->t == timestamp[1] - timestamp[3]); in t_sendqueue4()
103 CU_ASSERT(add_timestamps(sendqueue, 1) == timestamp[3]); in t_sendqueue4()
104 CU_ASSERT(add_timestamps(sendqueue, 2) == timestamp[1]); in t_sendqueue4()
105 CU_ASSERT(add_timestamps(sendqueue, 3) == timestamp[4]); in t_sendqueue4()
106 CU_ASSERT(add_timestamps(sendqueue, 4) == timestamp[2]); in t_sendqueue4()
123 for (p = sendqueue, i = 0; p; p = p->next, i++) { in t_sendqueue5()
128 ctx.sendqueue = sendqueue; in t_sendqueue5()
135 CU_ASSERT_PTR_NOT_NULL(ctx.sendqueue); in t_sendqueue5()
137 CU_ASSERT(ctx.sendqueue->t == timestamp[3] + delta1); in t_sendqueue5()
143 CU_ASSERT_PTR_NOT_NULL(ctx.sendqueue); in t_sendqueue5()
144 CU_ASSERT(ctx.sendqueue->t == 0); in t_sendqueue5()
146 CU_ASSERT_PTR_NOT_NULL(ctx.sendqueue->next); in t_sendqueue5()
147 CU_ASSERT(ctx.sendqueue->next->t == 0); in t_sendqueue5()
149 CU_ASSERT_PTR_NOT_NULL(ctx.sendqueue->next->next); in t_sendqueue5()
150 CU_ASSERT(ctx.sendqueue->next->next->t == delta2 - delta1 - timestamp[1]); in t_sendqueue5()
153 for (p = sendqueue, i = 0; p; p = p->next, i++) { in t_sendqueue5()
172 for (p = sendqueue, i = 0; p; p = p->next, i++) { in t_sendqueue6()
177 ctx.sendqueue = NULL; in t_sendqueue6()
186 for (p = sendqueue, i = 0; p; p = p->next, i++) { in t_sendqueue6()
196 CU_ASSERT_PTR_NOT_NULL(sendqueue); in t_sendqueue7()
197 CU_ASSERT_PTR_EQUAL(sendqueue, node[3]); in t_sendqueue7()
199 CU_ASSERT_PTR_NOT_NULL(sendqueue->next); in t_sendqueue7()
200 CU_ASSERT_PTR_EQUAL(sendqueue->next, node[1]); in t_sendqueue7()
202 result = coap_remove_from_queue(&sendqueue, 3, &tmp_node); in t_sendqueue7()
208 CU_ASSERT_PTR_NOT_NULL(sendqueue); in t_sendqueue7()
209 CU_ASSERT_PTR_EQUAL(sendqueue, node[1]); in t_sendqueue7()
211 CU_ASSERT(sendqueue->t == timestamp[1]); in t_sendqueue7()
219 result = coap_remove_from_queue(&sendqueue, 4, &tmp_node); in t_sendqueue8()
225 CU_ASSERT_PTR_NOT_NULL(sendqueue); in t_sendqueue8()
226 CU_ASSERT_PTR_EQUAL(sendqueue, node[1]); in t_sendqueue8()
227 CU_ASSERT(sendqueue->t == timestamp[1]); in t_sendqueue8()
229 CU_ASSERT_PTR_NOT_NULL(sendqueue->next); in t_sendqueue8()
230 CU_ASSERT_PTR_EQUAL(sendqueue->next, node[2]); in t_sendqueue8()
231 CU_ASSERT(sendqueue->next->t == timestamp[2] - timestamp[1]); in t_sendqueue8()
233 CU_ASSERT_PTR_NULL(sendqueue->next->next); in t_sendqueue8()
243 ctx.sendqueue = sendqueue; in t_sendqueue9()
245 sendqueue = ctx.sendqueue; /* must update global sendqueue for correct result */ in t_sendqueue9()
249 CU_ASSERT_PTR_EQUAL(tmp_node, ctx.sendqueue); in t_sendqueue9()
252 sendqueue = ctx.sendqueue; /* must update global sendqueue for correct result */ in t_sendqueue9()
257 CU_ASSERT_PTR_NOT_NULL(sendqueue); in t_sendqueue9()
258 CU_ASSERT_PTR_EQUAL(sendqueue, node[2]); in t_sendqueue9()
261 CU_ASSERT(sendqueue->t == timestamp[2]); in t_sendqueue9()
263 CU_ASSERT_PTR_NULL(sendqueue->next); in t_sendqueue9()
273 ctx.sendqueue = sendqueue; in t_sendqueue10()
276 sendqueue = ctx.sendqueue; /* must update global sendqueue for correct result */ in t_sendqueue10()
281 CU_ASSERT_PTR_NULL(sendqueue); in t_sendqueue10()
293 sendqueue = NULL; in t_sendqueue_tests_create()