RepoMirrors/mars
1
0
Fork 0
mirror of https://github.com/schoebel/mars synced 2024-12-21 22:30:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

aio: adapt to semi-new pre-patch generations

Browse Source
This commit is contained in:
Thomas Schoebel-Theuer 2022-10-19 11:52:20 +02:00 committed by Thomas Schoebel-Theuer
parent f11993a1ee
commit b176b72843
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
kernel/mars_aio.c
View File

@ -44,7 +44,7 @@
#include "mars_aio.h"
#if !defined(MARS_HAS_PREPATCH_V2) && !defined(MARS_HAS_PREPATCH)
#if !defined(MARS_HAS_PREPATCH_V3) && !defined(MARS_HAS_PREPATCH_V2) && !defined(MARS_HAS_PREPATCH)
#warning You are compiling without pre-patch, resulting in BAD IO PERFORMANCE
#endif
@ -425,7 +425,7 @@ static int aio_submit(struct aio_output *output, struct aio_mref_aspect *mref_a,
set_fs(KERNEL_DS);
latency = TIME_STATS(
this_timing,
#ifdef MARS_HAS_PREPATCH_V2
#if defined(MARS_HAS_PREPATCH_V2) || defined(MARS_HAS_PREPATCH_V3)
res = ksys_io_submit(output->ctxp, 1, &iocbp)
#else
res = sys_io_submit(output->ctxp, 1, &iocbp)
@ -466,7 +466,7 @@ static int aio_submit_dummy(struct aio_output *output)
oldfs = get_fs();
set_fs(KERNEL_DS);
#ifdef MARS_HAS_PREPATCH_V2
#if defined(MARS_HAS_PREPATCH_V2) || defined(MARS_HAS_PREPATCH_V3)
res = ksys_io_submit(output->ctxp, 1, &iocbp);
#else
res = sys_io_submit(output->ctxp, 1, &iocbp);
@ -702,7 +702,7 @@ static int aio_event_thread(void *data)
/* TODO: don't timeout upon termination.
* Probably we should submit a dummy request.
*/
#ifdef MARS_HAS_PREPATCH_V2
#if defined(MARS_HAS_PREPATCH_V2) || defined(MARS_HAS_PREPATCH_V3)
count = ksys_io_getevents(output->ctxp, 1, MARS_MAX_AIO_READ, events, &timeout);
#else
count = sys_io_getevents(output->ctxp, 1, MARS_MAX_AIO_READ, events, &timeout);
@ -818,7 +818,7 @@ void _destroy_ioctx(struct aio_output *output)
MARS_DBG("ioctx count = %d destroying %p\n", atomic_read(&ioctx_count), (void*)output->ctxp);
oldfs = get_fs();
set_fs(KERNEL_DS);
#ifdef MARS_HAS_PREPATCH_V2
#if defined(MARS_HAS_PREPATCH_V2) || defined(MARS_HAS_PREPATCH_V3)
err = ksys_io_destroy(output->ctxp);
#else
err = sys_io_destroy(output->ctxp);
@ -960,7 +960,7 @@ int _create_ioctx(struct aio_output *output)
oldfs = get_fs();
set_fs(KERNEL_DS);
#ifdef MARS_HAS_PREPATCH_V2
#if defined(MARS_HAS_PREPATCH_V2) || defined(MARS_HAS_PREPATCH_V3)
err = ksys_io_setup(MARS_MAX_AIO, &output->ctxp);
#else
err = sys_io_setup(MARS_MAX_AIO, &output->ctxp);