1 /*	$NetBSD: queue_test.c,v 1.1.1.4 2014/12/10 03:34:44 christos Exp $	*/
2 
3 /*
4  * Copyright (C) 2011, 2012  Internet Systems Consortium, Inc. ("ISC")
5  *
6  * Permission to use, copy, modify, and/or distribute this software for any
7  * purpose with or without fee is hereby granted, provided that the above
8  * copyright notice and this permission notice appear in all copies.
9  *
10  * THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH
11  * REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
12  * AND FITNESS.  IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT,
13  * INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
14  * LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
15  * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
16  * PERFORMANCE OF THIS SOFTWARE.
17  */
18 
19 /* Id */
20 
21 /*! \file */
22 
23 #include <config.h>
24 
25 #include <atf-c.h>
26 
27 #include <unistd.h>
28 #include <time.h>
29 
30 #include <isc/queue.h>
31 
32 #include "isctest.h"
33 
34 typedef struct item item_t;
35 struct item {
36 	int 			value;
37 	ISC_QLINK(item_t)	qlink;
38 };
39 
40 typedef ISC_QUEUE(item_t) item_queue_t;
41 
42 static void
43 item_init(item_t *item, int value) {
44 	item->value = value;
45 	ISC_QLINK_INIT(item, qlink);
46 }
47 
48 /*
49  * Individual unit tests
50  */
51 
52 /* Test UDP sendto/recv (IPv4) */
53 ATF_TC(queue_valid);
54 ATF_TC_HEAD(queue_valid, tc) {
55 	atf_tc_set_md_var(tc, "descr", "Check queue validity");
56 }
57 ATF_TC_BODY(queue_valid, tc) {
58 	isc_result_t result;
59 	item_queue_t queue;
60 	item_t one, two, three, four, five;
61 	item_t *p;
62 
63 	UNUSED(tc);
64 
65 	ISC_QUEUE_INIT(queue, qlink);
66 
67 	item_init(&one, 1);
68 	item_init(&two, 2);
69 	item_init(&three, 3);
70 	item_init(&four, 4);
71 	item_init(&five, 5);
72 
73 	result = isc_test_begin(NULL, ISC_TRUE);
74 	ATF_REQUIRE_EQ(result, ISC_R_SUCCESS);
75 
76 	ATF_CHECK(ISC_QUEUE_EMPTY(queue));
77 
78 	ISC_QUEUE_POP(queue, qlink, p);
79 	ATF_CHECK(p == NULL);
80 
81 	ATF_CHECK(! ISC_QLINK_LINKED(&one, qlink));
82 	ISC_QUEUE_PUSH(queue, &one, qlink);
83 	ATF_CHECK(ISC_QLINK_LINKED(&one, qlink));
84 
85 	ATF_CHECK(! ISC_QUEUE_EMPTY(queue));
86 
87 	ISC_QUEUE_POP(queue, qlink, p);
88 	ATF_REQUIRE(p != NULL);
89 	ATF_CHECK_EQ(p->value, 1);
90 	ATF_CHECK(ISC_QUEUE_EMPTY(queue));
91 	ATF_CHECK(! ISC_QLINK_LINKED(p, qlink));
92 
93 	ISC_QUEUE_PUSH(queue, p, qlink);
94 	ATF_CHECK(! ISC_QUEUE_EMPTY(queue));
95 	ATF_CHECK(ISC_QLINK_LINKED(p, qlink));
96 
97 	ATF_CHECK(! ISC_QLINK_LINKED(&two, qlink));
98 	ISC_QUEUE_PUSH(queue, &two, qlink);
99 	ATF_CHECK(ISC_QLINK_LINKED(&two, qlink));
100 
101 	ATF_CHECK(! ISC_QLINK_LINKED(&three, qlink));
102 	ISC_QUEUE_PUSH(queue, &three, qlink);
103 	ATF_CHECK(ISC_QLINK_LINKED(&three, qlink));
104 
105 	ATF_CHECK(! ISC_QLINK_LINKED(&four, qlink));
106 	ISC_QUEUE_PUSH(queue, &four, qlink);
107 	ATF_CHECK(ISC_QLINK_LINKED(&four, qlink));
108 
109 	ATF_CHECK(! ISC_QLINK_LINKED(&five, qlink));
110 	ISC_QUEUE_PUSH(queue, &five, qlink);
111 	ATF_CHECK(ISC_QLINK_LINKED(&five, qlink));
112 
113 	/* Test unlink by removing one item from the middle */
114 	ISC_QUEUE_UNLINK(queue, &three, qlink);
115 
116 	ISC_QUEUE_POP(queue, qlink, p);
117 	ATF_REQUIRE(p != NULL);
118 	ATF_CHECK_EQ(p->value, 1);
119 
120 	ISC_QUEUE_POP(queue, qlink, p);
121 	ATF_REQUIRE(p != NULL);
122 	ATF_CHECK_EQ(p->value, 2);
123 
124 	ISC_QUEUE_POP(queue, qlink, p);
125 	ATF_REQUIRE(p != NULL);
126 	ATF_CHECK_EQ(p->value, 4);
127 
128 	ISC_QUEUE_POP(queue, qlink, p);
129 	ATF_REQUIRE(p != NULL);
130 	ATF_CHECK_EQ(p->value, 5);
131 
132 	ATF_CHECK(ISC_QUEUE_EMPTY(queue));
133 
134 	ISC_QUEUE_DESTROY(queue);
135 	isc_test_end();
136 }
137 
138 /*
139  * Main
140  */
141 ATF_TP_ADD_TCS(tp) {
142 	ATF_TP_ADD_TC(tp, queue_valid);
143 
144 	return (atf_no_error());
145 }
146 
147