cuberite/libevent
1
0
Fork 0
mirror of https://github.com/cuberite/libevent.git synced 2025-09-13 06:16:10 -04:00
Code Issues Packages Projects Releases Wiki Activity

Add some verbose notes to bufferevent unit tests

Browse Source
This commit is contained in:
Nick Mathewson 2013-04-09 18:15:08 -04:00
parent 8eedeabe50
commit 9d893c97fa
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
test/regress_bufferevent.c
View File

@ -420,6 +420,7 @@ sender_writecb(struct bufferevent *bev, void *ctx)
{ {
if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) {
bufferevent_disable(bev,EV_READ|EV_WRITE); bufferevent_disable(bev,EV_READ|EV_WRITE);
TT_BLATHER(("Flushed %d: freeing it.", (int)bufferevent_getfd(bev)));
bufferevent_free(bev); bufferevent_free(bev);
} }
} }
@ -462,6 +463,7 @@ reader_eventcb(struct bufferevent *bev, short what, void *ctx)
return; return;
} }
if (what & BEV_EVENT_CONNECTED) { if (what & BEV_EVENT_CONNECTED) {
TT_BLATHER(("connected on %d", (int)bufferevent_getfd(bev)));
bufferevent_enable(bev, EV_READ); bufferevent_enable(bev, EV_READ);
} }
if (what & BEV_EVENT_EOF) { if (what & BEV_EVENT_EOF) {
@ -472,6 +474,8 @@ reader_eventcb(struct bufferevent *bev, short what, void *ctx)
tt_str_op(buf, ==, TEST_STR); tt_str_op(buf, ==, TEST_STR);
if (++n_strings_read == 2) if (++n_strings_read == 2)
event_base_loopexit(base, NULL); event_base_loopexit(base, NULL);
TT_BLATHER(("EOF on %d: %d strings read.",
(int)bufferevent_getfd(bev), n_strings_read));
} }
end: end:
; ;
@ -480,6 +484,7 @@ end:
static void static void
reader_readcb(struct bufferevent *bev, void *ctx) reader_readcb(struct bufferevent *bev, void *ctx)
{ {
TT_BLATHER(("Read invoked on %d.", (int)bufferevent_getfd(bev)));
n_reads_invoked++; n_reads_invoked++;
} }