GitHub/libevent
1
0
Fork 0
mirror of https://github.com/libevent/libevent.git synced 2025-01-09 00:56:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

Addition to bufferevent_async unit test

Browse Source 
svn:r1279
This commit is contained in:
Nick Mathewson 2009-05-06 02:34:10 +00:00
parent a8bcbfd416
commit 8910901020
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
test/regress_iocp.c
View File

@ -190,6 +190,7 @@ test_iocp_evbuffer(void *ptr)
/* FIXME Actually test some stuff here. */ /* FIXME Actually test some stuff here. */
tt_want(!event_iocp_shutdown(port, 2000));
end: end:
evbuffer_free(rbuf); evbuffer_free(rbuf);
evbuffer_free(wbuf); evbuffer_free(wbuf);
@ -208,6 +209,7 @@ test_iocp_bufferevent_async(void *ptr)
struct bufferevent *bea1=NULL, *bea2=NULL; struct bufferevent *bea1=NULL, *bea2=NULL;
char buf[128]; char buf[128];
size_t n; size_t n;
struct timeval one_sec = {1,0};
#ifdef WIN32 #ifdef WIN32
@ -224,27 +226,26 @@ test_iocp_bufferevent_async(void *ptr)
#endif #endif
bea1 = bufferevent_async_new(data->base, data->pair[0], bea1 = bufferevent_async_new(data->base, data->pair[0],
0); /* We'd defer callbacks, but that would need a base. */ BEV_OPT_DEFER_CALLBACKS);
bea2 = bufferevent_async_new(data->base, data->pair[1], bea2 = bufferevent_async_new(data->base, data->pair[1],
0); BEV_OPT_DEFER_CALLBACKS);
tt_assert(bea1); tt_assert(bea1);
tt_assert(bea2); tt_assert(bea2);
/*FIXME set some callbacks */ /*FIXME set some callbacks */
bufferevent_enable(bea1, EV_WRITE); bufferevent_enable(bea1, EV_WRITE);
bufferevent_enable(bea2, EV_READ); bufferevent_enable(bea2, EV_READ);
bufferevent_write(bea1, "Hello world", strlen("Hello world")+1); bufferevent_write(bea1, "Hello world", strlen("Hello world")+1);
#ifdef WIN32 event_base_loopexit(data->base, &one_sec);
/* FIXME: again, stupid. */ event_base_dispatch(data->base);
Sleep(1000);
#endif
n = bufferevent_read(bea2, buf, sizeof(buf)-1); n = bufferevent_read(bea2, buf, sizeof(buf)-1);
buf[n]='\0'; buf[n]='\0';
tt_str_op(buf, ==, "Hello world"); tt_str_op(buf, ==, "Hello world");
tt_want(!event_iocp_shutdown(port, 2000));
end: end:
/* FIXME: free stuff. */; /* FIXME: free stuff. */;
} }