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
item_init(item_t * item,int value)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);
ATF_TC_HEAD(queue_valid,tc)54 ATF_TC_HEAD(queue_valid, tc) {
55 atf_tc_set_md_var(tc, "descr", "Check queue validity");
56 }
ATF_TC_BODY(queue_valid,tc)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 */
ATF_TP_ADD_TCS(tp)141 ATF_TP_ADD_TCS(tp) {
142 ATF_TP_ADD_TC(tp, queue_valid);
143
144 return (atf_no_error());
145 }
146
147