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

fixed hio_loop() to check if there are scheduled timer jobs before breaking out of the loop

Browse Source
This commit is contained in:
hyung-hwan 2021-07-26 17:49:28 +00:00
parent d7e5ebdf4f
commit 56decb7174
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hio/bin/t04.c
View File

@ -173,6 +173,7 @@ static void send_test_query (hio_t* hio, const hio_ntime_t* now, hio_tmrjob_t* j
hio_bch_t tmp[256]; hio_bch_t tmp[256];
int len; int len;
HIO_INFO0 (hio, "ATTEMPTING TO SEND QUERY\n");
if (hio_svc_marc_querywithbchars(marc, 0, HIO_SVC_MARC_QTYPE_SELECT, "SHOW STATUS", 11, on_result, HIO_NULL) <= -1) if (hio_svc_marc_querywithbchars(marc, 0, HIO_SVC_MARC_QTYPE_SELECT, "SHOW STATUS", 11, on_result, HIO_NULL) <= -1)
{ {
HIO_INFO1 (hio, "FAILED TO SEND QUERY - %js\n", hio_geterrmsg(hio)); HIO_INFO1 (hio, "FAILED TO SEND QUERY - %js\n", hio_geterrmsg(hio));
@ -278,7 +279,7 @@ int main (int argc, char* argv[])
/* ---------------------------------------- */ /* ---------------------------------------- */
{ {
hio_ntime_t x; hio_ntime_t x;
HIO_INIT_NTIME (&x, 32, 0); HIO_INIT_NTIME (&x, 20, 0);
schedule_timer_job_after (hio, &x, send_test_query, marc); schedule_timer_job_after (hio, &x, send_test_query, marc);
hio_loop (hio); hio_loop (hio);
} }

5
hio/lib/hio.c
View File

@ -942,7 +942,7 @@ void hio_stop (hio_t* hio, hio_stopreq_t stopreq)
hio_sys_intrmux (hio); hio_sys_intrmux (hio);
} }
int hio_loop (hio_t* hio) int hio_loop (hio_t* hio/*, int check_svc*/)
{ {
HIO_ASSERT (hio, (HIO_FEATURE_ALL & HIO_FEATURE_MUX)); /* never call this if you disableed this feature */ HIO_ASSERT (hio, (HIO_FEATURE_ALL & HIO_FEATURE_MUX)); /* never call this if you disableed this feature */
@ -952,7 +952,8 @@ int hio_loop (hio_t* hio)
if (hio_prologue(hio) <= -1) return -1; if (hio_prologue(hio) <= -1) return -1;
while (hio->stopreq == HIO_STOPREQ_NONE && !HIO_DEVL_IS_EMPTY(&hio->actdev)) while (hio->stopreq == HIO_STOPREQ_NONE &&
(!HIO_DEVL_IS_EMPTY(&hio->actdev) || hio->tmr.size > 0))
{ {
if (__exec(hio) <= -1) break; if (__exec(hio) <= -1) break;
/* you can do other things here */ /* you can do other things here */