diff options
| author | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2012-03-11 17:53:58 +0400 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2012-03-11 17:53:58 +0400 |
| commit | 7437cc1df6e16a884678f8725957cbcd9843fc33 (patch) | |
| tree | 8e0744ff3b08a62b18c232c9b1148a11c4861767 /test | |
| parent | 899c90dd4273245f3e26cb2d2cf311918dcc9068 (diff) | |
| download | rspamd-7437cc1df6e16a884678f8725957cbcd9843fc33.tar.gz rspamd-7437cc1df6e16a884678f8725957cbcd9843fc33.zip | |
Aio context must be long not int.
O_DIRECT on linux requires strict memory alignment.
Diffstat (limited to 'test')
| -rw-r--r-- | test/rspamd_async_test.c | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/test/rspamd_async_test.c b/test/rspamd_async_test.c index f2c6e6421..2308acc67 100644 --- a/test/rspamd_async_test.c +++ b/test/rspamd_async_test.c @@ -25,6 +25,7 @@ #include "tests.h" #include "main.h" #include "aio_event.h" +#include "mem_pool.h" extern struct event_base *base; @@ -35,7 +36,7 @@ aio_read_cb (gint fd, gint res, gsize len, gpointer data, gpointer ud) guchar *p = data; guint i; - g_assert (res != -1); + g_assert (res > 0); g_assert (len == BUFSIZ); for (i = 0; i < len; i ++) { @@ -49,11 +50,13 @@ static void aio_write_cb (gint fd, gint res, gsize len, gpointer data, gpointer ud) { struct aio_context *aio_ctx = ud; - static gchar testbuf[BUFSIZ]; + gchar *testbuf; + + g_assert (res > 0); - g_assert (res != -1); + g_assert (posix_memalign ((void **)&testbuf, 512, BUFSIZ) == 0); - g_assert (rspamd_aio_read (fd, testbuf, sizeof (testbuf), aio_ctx, aio_read_cb, aio_ctx) != -1); + g_assert (rspamd_aio_read (fd, testbuf, BUFSIZ, 0, aio_ctx, aio_read_cb, aio_ctx) != -1); } void @@ -76,7 +79,7 @@ rspamd_async_test_func () /* Write some data */ memset (testbuf, 0xef, sizeof (testbuf)); - ret = rspamd_aio_write (afd, testbuf, sizeof (testbuf), aio_ctx, aio_write_cb, aio_ctx); + ret = rspamd_aio_write (afd, testbuf, sizeof (testbuf), 0, aio_ctx, aio_write_cb, aio_ctx); g_assert (ret != -1); event_base_loop (base, 0); |