author | Tero Marttila <terom@fixme.fi> |
Thu, 21 May 2009 16:57:56 +0300 | |
changeset 213 | f0e52e026197 |
parent 171 | b54f393c3df0 |
permissions | -rw-r--r-- |
168 | 1 |
/** |
2 |
* @file |
|
3 |
* |
|
4 |
* Test functions for the irc_queue module |
|
5 |
*/ |
|
6 |
#include "test.h" |
|
7 |
#include "transport.h" |
|
8 |
||
9 |
#include "../irc_queue.h" |
|
10 |
||
11 |
static struct line_proto_callbacks _lp_callbacks = { |
|
12 |
.on_line = NULL, |
|
13 |
.on_error = NULL |
|
14 |
}; |
|
15 |
||
16 |
void test_irc_queue (void) |
|
17 |
{ |
|
18 |
struct transport_test *tp = transport_test_create(NULL); |
|
19 |
transport_t *transport = transport_test_cast(tp); |
|
20 |
struct line_proto *lp; |
|
21 |
struct irc_queue *queue; |
|
22 |
struct irc_queue_entry *queue_entry; |
|
23 |
struct error_info err; |
|
24 |
||
25 |
// create the lp |
|
26 |
assert_success(line_proto_create(&lp, transport, 128, &_lp_callbacks, NULL, &err)); |
|
27 |
||
28 |
// create the queue |
|
29 |
assert_success(irc_queue_create(&queue, _test_ctx.ev_base, lp, &err)); |
|
30 |
||
31 |
struct irc_line line = { |
|
32 |
NULL, "TEST", { "fooX" } |
|
33 |
}; |
|
34 |
||
35 |
// then test simple writes, we should be able to push five lines directly |
|
36 |
log_info("test irc_queue_process (irc_queue_send_direct)"); |
|
37 |
line.args[0] = "foo0"; assert_success(irc_queue_process(queue, &line)); |
|
38 |
line.args[0] = "foo1"; assert_success(irc_queue_process(queue, &line)); |
|
39 |
line.args[0] = "foo2"; assert_success(irc_queue_process(queue, &line)); |
|
40 |
line.args[0] = "foo3"; assert_success(irc_queue_process(queue, &line)); |
|
41 |
line.args[0] = "foo4"; assert_success(irc_queue_process(queue, &line)); |
|
42 |
||
43 |
// they should all be output |
|
44 |
assert_transport_data(tp, |
|
45 |
"TEST foo0\r\n" |
|
46 |
"TEST foo1\r\n" |
|
47 |
"TEST foo2\r\n" |
|
48 |
"TEST foo3\r\n" |
|
49 |
"TEST foo4\r\n" |
|
50 |
); |
|
51 |
||
52 |
// then enqueue |
|
53 |
log_info("test irc_queue_process (irc_queue_put)"); |
|
54 |
line.args[0] = "foo5"; assert_success(irc_queue_process(queue, &line)); |
|
55 |
||
56 |
// ensure it was enqueued |
|
57 |
assert((queue_entry = TAILQ_FIRST(&queue->list)) != NULL); |
|
58 |
assert_strcmp(queue_entry->line_buf, "TEST foo5\r\n"); |
|
59 |
||
60 |
// ensure timer is set |
|
61 |
assert(event_pending(queue->ev, EV_TIMEOUT, NULL)); |
|
62 |
||
63 |
// run the event loop to let the timer run |
|
64 |
log_info("running the event loop once..."); |
|
65 |
assert(event_base_loop(_test_ctx.ev_base, EVLOOP_ONCE) == 0); |
|
66 |
||
67 |
// test to check that the line was now sent |
|
68 |
log_info("checking that the delayed line was sent..."); |
|
69 |
assert_transport_data(tp, "TEST foo5\r\n"); |
|
70 |
assert(TAILQ_EMPTY(&queue->list)); |
|
71 |
assert(!event_pending(queue->ev, EV_TIMEOUT, NULL)); |
|
72 |
||
73 |
// cleanup |
|
74 |
irc_queue_destroy(queue); |
|
171
b54f393c3df0
evil chain.h macro magic, fix irc_conn_set_nickname bug, misc. test bugs (mem leaks, missing #includes)
Tero Marttila <terom@fixme.fi>
parents:
168
diff
changeset
|
75 |
line_proto_destroy(lp); |
168 | 76 |
} |
77 |