hyung-hwan/hio
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

improving hio_loop()

Browse Source
This commit is contained in:
hyung-hwan 2021-07-27 15:11:10 +00:00
parent f15918ef30
commit feddfb260e
1 changed files with 39 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
hio/lib/hio.c
View File

@ -931,36 +931,62 @@ static HIO_INLINE int __exec (hio_t* hio)
int hio_exec (hio_t* hio) int hio_exec (hio_t* hio)
{ {
HIO_ASSERT (hio, (HIO_FEATURE_ALL & HIO_FEATURE_MUX)); /* never call this if you disableed this feature */ /* never call this if you disabled this feature */
HIO_ASSERT (hio, (hio->_features & HIO_FEATURE_MUX));
return __exec(hio); return __exec(hio);
} }
void hio_stop (hio_t* hio, hio_stopreq_t stopreq) void hio_stop (hio_t* hio, hio_stopreq_t stopreq)
{ {
HIO_ASSERT (hio, (HIO_FEATURE_ALL & HIO_FEATURE_MUX)); /* never call this if you disableed this feature */ /* never call this if you disabled this feature */
HIO_ASSERT (hio, (hio->_features & HIO_FEATURE_MUX));
hio->stopreq = stopreq; hio->stopreq = stopreq;
hio_sys_intrmux (hio); hio_sys_intrmux (hio);
} }
int hio_loop (hio_t* hio/*, int check_svc*/) int hio_loop (hio_t* hio)
{ {
HIO_ASSERT (hio, (HIO_FEATURE_ALL & HIO_FEATURE_MUX)); /* never call this if you disableed this feature */ int ret = 0;
if (HIO_DEVL_IS_EMPTY(&hio->actdev)) return 0; /* never call this if you disabled this feature */
HIO_ASSERT (hio, (hio->_features & HIO_FEATURE_MUX));
if (HIO_UNLIKELY(HIO_DEVL_IS_EMPTY(&hio->actdev) && hio->tmr.size <= 0)) return 0;
hio->stopreq = HIO_STOPREQ_NONE; hio->stopreq = HIO_STOPREQ_NONE;
if (hio_prologue(hio) <= -1) return -1; if (hio_prologue(hio) <= -1)
while (hio->stopreq == HIO_STOPREQ_NONE &&
(!HIO_DEVL_IS_EMPTY(&hio->actdev) || hio->tmr.size > 0))
{ {
if (__exec(hio) <= -1) break; ret = -1;
/* you can do other things here */
} }
else
{
while (HIO_LIKELY(hio->stopreq == HIO_STOPREQ_NONE))
{
if (HIO_UNLIKELY(HIO_DEVL_IS_EMPTY(&hio->actdev) && hio->tmr.size <= 0)) break;
hio_epilogue(hio); ret = __exec(hio);
return 0; if (ret <= -1) break;
if (HIO_UNLIKELY(hio->stopreq == HIO_STOPREQ_WATCHER_ERROR))
{
const hio_ooch_t* prev_errmsg;
prev_errmsg = hio_backuperrmsg(hio);
/* this previous error message may be off the error context.
* try the best to capture the message */
hio_seterrbfmt (hio, HIO_ESYSERR, "watcher error detected - %js", prev_errmsg);
ret = -2;
break;
}
/* you can do other things here */
}
hio_epilogue(hio);
}
return ret;
} }
hio_dev_t* hio_dev_make (hio_t* hio, hio_oow_t dev_size, hio_dev_mth_t* dev_mth, hio_dev_evcb_t* dev_evcb, void* make_ctx) hio_dev_t* hio_dev_make (hio_t* hio, hio_oow_t dev_size, hio_dev_mth_t* dev_mth, hio_dev_evcb_t* dev_evcb, void* make_ctx)