forked/ustreamer
1
0
Fork 0
mirror of https://github.com/pikvm/ustreamer.git synced 2026-03-14 11:33:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

python: handle signals

Browse Source
This commit is contained in:
Devaev Maxim
2021-01-21 09:18:09 +03:00
parent 94383a2d54
commit b7b3e8e87d
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
python/ustreamer.c
View File

@@ -149,8 +149,9 @@ static int wait_frame(MemsinkObject *self) {
return -1; \ return -1; \
} }
Py_BEGIN_ALLOW_THREADS
do { do {
Py_BEGIN_ALLOW_THREADS
int retval = flock_timedwait_monotonic(self->fd, self->lock_timeout); int retval = flock_timedwait_monotonic(self->fd, self->lock_timeout);
if (retval < 0 && errno != EWOULDBLOCK) { if (retval < 0 && errno != EWOULDBLOCK) {
RETURN_OS_ERROR; RETURN_OS_ERROR;
@@ -166,8 +167,13 @@ static int wait_frame(MemsinkObject *self) {
if (usleep(1000) < 0) { if (usleep(1000) < 0) {
RETURN_OS_ERROR; RETURN_OS_ERROR;
} }
Py_END_ALLOW_THREADS
if (PyErr_CheckSignals() < 0) {
return -1;
}
} while (get_now_monotonic() < deadline_ts); } while (get_now_monotonic() < deadline_ts);
Py_END_ALLOW_THREADS
# undef RETURN_OS_ERROR # undef RETURN_OS_ERROR