this call will block until queue item available
| 745 | |
| 746 | // this call will block until queue item available |
| 747 | static int dbconsumer_get_int(Lua L, dbconsumer_t *q) |
| 748 | { |
| 749 | int rc; |
| 750 | while ((rc = dbq_poll(L, q, dbq_delay_ms)) == 0) |
| 751 | ; |
| 752 | return rc; |
| 753 | } |
| 754 | |
| 755 | static void dbconsumer_getargs(Lua L, dbconsumer_t *consumer) |
| 756 | { |
no test coverage detected