Lines Matching refs:queue
40 static void fixed_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { in fixed_queue_ready() argument
41 void* msg = fixed_queue_try_dequeue(queue); in fixed_queue_ready()
55 fixed_queue_t* queue; in TEST_F() local
58 queue = fixed_queue_new(0); in TEST_F()
59 EXPECT_TRUE(queue != NULL); in TEST_F()
60 fixed_queue_free(queue, NULL); in TEST_F()
63 queue = fixed_queue_new(1); in TEST_F()
64 EXPECT_TRUE(queue != NULL); in TEST_F()
65 fixed_queue_free(queue, NULL); in TEST_F()
68 queue = fixed_queue_new((size_t)-1); in TEST_F()
69 EXPECT_TRUE(queue != NULL); in TEST_F()
70 fixed_queue_free(queue, NULL); in TEST_F()
73 queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
74 EXPECT_TRUE(queue != NULL); in TEST_F()
75 fixed_queue_free(queue, NULL); in TEST_F()
83 fixed_queue_t* queue; in TEST_F() local
86 queue = fixed_queue_new(0); in TEST_F()
87 EXPECT_TRUE(queue != NULL); in TEST_F()
88 fixed_queue_flush(queue, NULL); in TEST_F()
89 EXPECT_TRUE(fixed_queue_is_empty(queue)); in TEST_F()
90 fixed_queue_free(queue, osi_free); in TEST_F()
93 queue = fixed_queue_new(0); in TEST_F()
94 EXPECT_TRUE(queue != NULL); in TEST_F()
95 fixed_queue_flush(queue, osi_free); in TEST_F()
96 EXPECT_TRUE(fixed_queue_is_empty(queue)); in TEST_F()
97 fixed_queue_free(queue, osi_free); in TEST_F()
100 queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
101 EXPECT_TRUE(queue != NULL); in TEST_F()
102 fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING1); in TEST_F()
103 fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING2); in TEST_F()
104 fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING3); in TEST_F()
105 EXPECT_FALSE(fixed_queue_is_empty(queue)); in TEST_F()
106 fixed_queue_flush(queue, NULL); in TEST_F()
107 EXPECT_TRUE(fixed_queue_is_empty(queue)); in TEST_F()
108 fixed_queue_free(queue, osi_free); in TEST_F()
112 queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
113 EXPECT_TRUE(queue != NULL); in TEST_F()
114 fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING1); in TEST_F()
115 fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING2); in TEST_F()
116 fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING3); in TEST_F()
117 EXPECT_FALSE(fixed_queue_is_empty(queue)); in TEST_F()
118 fixed_queue_flush(queue, test_queue_entry_free_cb); in TEST_F()
120 EXPECT_TRUE(fixed_queue_is_empty(queue)); in TEST_F()
121 fixed_queue_free(queue, osi_free); in TEST_F()
125 fixed_queue_t* queue; in TEST_F() local
131 queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
132 ASSERT_TRUE(queue != NULL); in TEST_F()
133 EXPECT_TRUE(fixed_queue_is_empty(queue)); in TEST_F()
136 fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING); in TEST_F()
137 EXPECT_FALSE(fixed_queue_is_empty(queue)); in TEST_F()
140 ASSERT_EQ(DUMMY_DATA_STRING, fixed_queue_try_dequeue(queue)); in TEST_F()
141 EXPECT_TRUE(fixed_queue_is_empty(queue)); in TEST_F()
143 fixed_queue_free(queue, NULL); in TEST_F()
147 fixed_queue_t* queue; in TEST_F() local
153 queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
154 ASSERT_TRUE(queue != NULL); in TEST_F()
155 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
158 fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING); in TEST_F()
159 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
162 ASSERT_EQ(DUMMY_DATA_STRING, fixed_queue_try_dequeue(queue)); in TEST_F()
163 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
165 fixed_queue_free(queue, NULL); in TEST_F()
169 fixed_queue_t* queue; in TEST_F() local
172 queue = fixed_queue_new(0); in TEST_F()
173 ASSERT_TRUE(queue != NULL); in TEST_F()
174 EXPECT_EQ((size_t)0, fixed_queue_capacity(queue)); in TEST_F()
175 fixed_queue_free(queue, NULL); in TEST_F()
178 queue = fixed_queue_new(1); in TEST_F()
179 ASSERT_TRUE(queue != NULL); in TEST_F()
180 EXPECT_EQ((size_t)1, fixed_queue_capacity(queue)); in TEST_F()
181 fixed_queue_free(queue, NULL); in TEST_F()
184 queue = fixed_queue_new((size_t)-1); in TEST_F()
185 ASSERT_TRUE(queue != NULL); in TEST_F()
186 EXPECT_EQ((size_t)-1, fixed_queue_capacity(queue)); in TEST_F()
187 fixed_queue_free(queue, NULL); in TEST_F()
190 queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
191 ASSERT_TRUE(queue != NULL); in TEST_F()
192 EXPECT_EQ(TEST_QUEUE_SIZE, fixed_queue_capacity(queue)); in TEST_F()
193 fixed_queue_free(queue, NULL); in TEST_F()
197 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
198 ASSERT_TRUE(queue != NULL); in TEST_F()
201 fixed_queue_enqueue(queue, (void*)DUMMY_DATA_STRING); in TEST_F()
202 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
203 EXPECT_EQ(DUMMY_DATA_STRING, fixed_queue_dequeue(queue)); in TEST_F()
204 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
207 EXPECT_TRUE(fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING)); in TEST_F()
208 EXPECT_EQ((size_t)1, fixed_queue_length(queue)); in TEST_F()
209 EXPECT_EQ(DUMMY_DATA_STRING, fixed_queue_try_dequeue(queue)); in TEST_F()
210 EXPECT_EQ((size_t)0, fixed_queue_length(queue)); in TEST_F()
214 EXPECT_TRUE(fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING)); in TEST_F()
217 EXPECT_FALSE(fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING)); in TEST_F()
221 EXPECT_EQ(DUMMY_DATA_STRING, fixed_queue_try_dequeue(queue)); in TEST_F()
225 EXPECT_EQ(NULL, fixed_queue_try_dequeue(queue)); in TEST_F()
230 fixed_queue_free(queue, NULL); in TEST_F()
234 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
235 ASSERT_TRUE(queue != NULL); in TEST_F()
242 EXPECT_EQ(NULL, fixed_queue_try_peek_first(queue)); in TEST_F()
243 EXPECT_EQ(NULL, fixed_queue_try_peek_last(queue)); in TEST_F()
246 fixed_queue_enqueue(queue, (void*)DUMMY_DATA_STRING1); in TEST_F()
247 EXPECT_EQ(DUMMY_DATA_STRING1, fixed_queue_try_peek_first(queue)); in TEST_F()
248 EXPECT_EQ(DUMMY_DATA_STRING1, fixed_queue_try_peek_last(queue)); in TEST_F()
251 fixed_queue_enqueue(queue, (void*)DUMMY_DATA_STRING2); in TEST_F()
252 EXPECT_EQ(DUMMY_DATA_STRING1, fixed_queue_try_peek_first(queue)); in TEST_F()
253 EXPECT_EQ(DUMMY_DATA_STRING2, fixed_queue_try_peek_last(queue)); in TEST_F()
256 fixed_queue_enqueue(queue, (void*)DUMMY_DATA_STRING3); in TEST_F()
257 EXPECT_EQ(DUMMY_DATA_STRING1, fixed_queue_try_peek_first(queue)); in TEST_F()
258 EXPECT_EQ(DUMMY_DATA_STRING3, fixed_queue_try_peek_last(queue)); in TEST_F()
260 fixed_queue_free(queue, NULL); in TEST_F()
264 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
265 ASSERT_TRUE(queue != NULL); in TEST_F()
273 fixed_queue_try_remove_from_queue(queue, (void*)DUMMY_DATA_STRING)); in TEST_F()
276 fixed_queue_enqueue(queue, (void*)DUMMY_DATA_STRING1); in TEST_F()
277 fixed_queue_enqueue(queue, (void*)DUMMY_DATA_STRING2); in TEST_F()
278 fixed_queue_enqueue(queue, (void*)DUMMY_DATA_STRING3); in TEST_F()
279 EXPECT_EQ((size_t)3, fixed_queue_length(queue)); in TEST_F()
281 queue, (void*)DUMMY_DATA_STRING2)); in TEST_F()
282 EXPECT_EQ((size_t)2, fixed_queue_length(queue)); in TEST_F()
284 EXPECT_EQ(NULL, fixed_queue_try_remove_from_queue(queue, in TEST_F()
289 fixed_queue_try_remove_from_queue(queue, (void*)DUMMY_DATA_STRING)); in TEST_F()
291 fixed_queue_free(queue, NULL); in TEST_F()
295 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
296 ASSERT_TRUE(queue != NULL); in TEST_F()
299 int enqueue_fd = fixed_queue_get_enqueue_fd(queue); in TEST_F()
300 int dequeue_fd = fixed_queue_get_dequeue_fd(queue); in TEST_F()
313 fixed_queue_enqueue(queue, (void*)DUMMY_DATA_STRING); in TEST_F()
316 fixed_queue_dequeue(queue); in TEST_F()
321 EXPECT_TRUE(fixed_queue_try_enqueue(queue, (void*)DUMMY_DATA_STRING)); in TEST_F()
326 fixed_queue_free(queue, NULL); in TEST_F()
330 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
331 ASSERT_TRUE(queue != NULL); in TEST_F()
339 fixed_queue_register_dequeue(queue, thread_get_reactor(worker_thread), in TEST_F()
343 fixed_queue_enqueue(queue, (void*)DUMMY_DATA_STRING); in TEST_F()
347 fixed_queue_unregister_dequeue(queue); in TEST_F()
349 fixed_queue_free(queue, NULL); in TEST_F()