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

test/regress_be: basic coverage bufferevent_flush() for pair/sock layers

Browse Source 
Refs #266
This commit is contained in:
Azat Khuzhin 2015-10-30 18:38:21 +03:00
parent f8081afc5e
commit ad52602ffd
1 changed files with 28 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
test/regress_bufferevent.c
View File

@ -123,11 +123,12 @@ errorcb(struct bufferevent *bev, short what, void *arg)
} }
static void static void
test_bufferevent_impl(int use_pair) test_bufferevent_impl(int use_pair, int flush)
{ {
struct bufferevent *bev1 = NULL, *bev2 = NULL; struct bufferevent *bev1 = NULL, *bev2 = NULL;
char buffer[8333]; char buffer[8333];
int i; int i;
int expected = 2;
if (use_pair) { if (use_pair) {
struct bufferevent *pair[2]; struct bufferevent *pair[2];
@ -171,6 +172,9 @@ test_bufferevent_impl(int use_pair)
buffer[i] = i; buffer[i] = i;
bufferevent_write(bev1, buffer, sizeof(buffer)); bufferevent_write(bev1, buffer, sizeof(buffer));
if (flush >= 0) {
tt_int_op(bufferevent_flush(bev1, EV_WRITE, flush), >=, 0);
}
event_dispatch(); event_dispatch();
@ -178,23 +182,26 @@ test_bufferevent_impl(int use_pair)
tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, NULL); tt_ptr_op(bufferevent_pair_get_partner(bev1), ==, NULL);
bufferevent_free(bev1); bufferevent_free(bev1);
if (test_ok != 2) /** Only pair call errorcb for BEV_FINISHED */
if (use_pair && flush == BEV_FINISHED) {
expected = -1;
}
if (test_ok != expected)
test_ok = 0; test_ok = 0;
end: end:
; ;
} }
static void static void test_bufferevent(void) { test_bufferevent_impl(0, -1); }
test_bufferevent(void) static void test_bufferevent_pair(void) { test_bufferevent_impl(1, -1); }
{
test_bufferevent_impl(0);
}
static void static void test_bufferevent_flush_normal(void) { test_bufferevent_impl(0, BEV_NORMAL); }
test_bufferevent_pair(void) static void test_bufferevent_flush_flush(void) { test_bufferevent_impl(0, BEV_FLUSH); }
{ static void test_bufferevent_flush_finished(void) { test_bufferevent_impl(0, BEV_FINISHED); }
test_bufferevent_impl(1);
} static void test_bufferevent_pair_flush_normal(void) { test_bufferevent_impl(1, BEV_NORMAL); }
static void test_bufferevent_pair_flush_flush(void) { test_bufferevent_impl(1, BEV_FLUSH); }
static void test_bufferevent_pair_flush_finished(void) { test_bufferevent_impl(1, BEV_FINISHED); }
#if defined(EVTHREAD_USE_PTHREADS_IMPLEMENTED) #if defined(EVTHREAD_USE_PTHREADS_IMPLEMENTED)
/** /**
@ -1174,6 +1181,12 @@ struct testcase_t bufferevent_testcases[] = {
LEGACY(bufferevent, TT_ISOLATED), LEGACY(bufferevent, TT_ISOLATED),
LEGACY(bufferevent_pair, TT_ISOLATED), LEGACY(bufferevent_pair, TT_ISOLATED),
LEGACY(bufferevent_flush_normal, TT_ISOLATED),
LEGACY(bufferevent_flush_flush, TT_ISOLATED),
LEGACY(bufferevent_flush_finished, TT_ISOLATED),
LEGACY(bufferevent_pair_flush_normal, TT_ISOLATED),
LEGACY(bufferevent_pair_flush_flush, TT_ISOLATED),
LEGACY(bufferevent_pair_flush_finished, TT_ISOLATED),
#if defined(EVTHREAD_USE_PTHREADS_IMPLEMENTED) #if defined(EVTHREAD_USE_PTHREADS_IMPLEMENTED)
{ "bufferevent_pair_release_lock", test_bufferevent_pair_release_lock, { "bufferevent_pair_release_lock", test_bufferevent_pair_release_lock,
TT_FORK|TT_ISOLATED|TT_NEED_THREADS|TT_NEED_BASE|TT_LEGACY, TT_FORK|TT_ISOLATED|TT_NEED_THREADS|TT_NEED_BASE|TT_LEGACY,
@ -1238,6 +1251,9 @@ struct testcase_t bufferevent_testcases[] = {
struct testcase_t bufferevent_iocp_testcases[] = { struct testcase_t bufferevent_iocp_testcases[] = {
LEGACY(bufferevent, TT_ISOLATED|TT_ENABLE_IOCP), LEGACY(bufferevent, TT_ISOLATED|TT_ENABLE_IOCP),
LEGACY(bufferevent_flush_normal, TT_ISOLATED),
LEGACY(bufferevent_flush_flush, TT_ISOLATED),
LEGACY(bufferevent_flush_finished, TT_ISOLATED),
LEGACY(bufferevent_watermarks, TT_ISOLATED|TT_ENABLE_IOCP), LEGACY(bufferevent_watermarks, TT_ISOLATED|TT_ENABLE_IOCP),
LEGACY(bufferevent_filters, TT_ISOLATED|TT_ENABLE_IOCP), LEGACY(bufferevent_filters, TT_ISOLATED|TT_ENABLE_IOCP),
{ "bufferevent_connect", test_bufferevent_connect, { "bufferevent_connect", test_bufferevent_connect,