diff options
| -rw-r--r-- | channels/chan_console.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/channels/chan_console.c b/channels/chan_console.c index 7c57ec4ff..7692b26cc 100644 --- a/channels/chan_console.c +++ b/channels/chan_console.c @@ -278,7 +278,9 @@ static void *stream_monitor(void *data) for (;;) { pthread_testcancel(); + console_pvt_lock(pvt); res = Pa_ReadStream(pvt->stream, buf, sizeof(buf) / sizeof(int16_t)); + console_pvt_unlock(pvt); pthread_testcancel(); if (!pvt->owner) { @@ -611,7 +613,9 @@ static int console_write(struct ast_channel *chan, struct ast_frame *f) { struct console_pvt *pvt = ast_channel_tech_pvt(chan); + console_pvt_lock(pvt); Pa_WriteStream(pvt->stream, f->data.ptr, f->samples); + console_pvt_unlock(pvt); return 0; } |