diff options
Diffstat (limited to 'apps/buffering.c')
-rw-r--r-- | apps/buffering.c | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/apps/buffering.c b/apps/buffering.c index 64f522c52f..0cb428c947 100644 --- a/apps/buffering.c +++ b/apps/buffering.c | |||
@@ -1446,16 +1446,21 @@ void buffering_thread(void) | |||
1446 | 1446 | ||
1447 | void buffering_init(void) { | 1447 | void buffering_init(void) { |
1448 | mutex_init(&llist_mutex); | 1448 | mutex_init(&llist_mutex); |
1449 | #ifdef HAVE_PRIORITY_SCHEDULING | ||
1450 | /* This behavior not safe atm */ | ||
1451 | mutex_set_preempt(&llist_mutex, false); | ||
1452 | #endif | ||
1449 | 1453 | ||
1450 | conf_watermark = BUFFERING_DEFAULT_WATERMARK; | 1454 | conf_watermark = BUFFERING_DEFAULT_WATERMARK; |
1451 | 1455 | ||
1452 | queue_init(&buffering_queue, true); | 1456 | queue_init(&buffering_queue, true); |
1453 | queue_enable_queue_send(&buffering_queue, &buffering_queue_sender_list); | ||
1454 | |||
1455 | buffering_thread_p = create_thread( buffering_thread, buffering_stack, | 1457 | buffering_thread_p = create_thread( buffering_thread, buffering_stack, |
1456 | sizeof(buffering_stack), CREATE_THREAD_FROZEN, | 1458 | sizeof(buffering_stack), CREATE_THREAD_FROZEN, |
1457 | buffering_thread_name IF_PRIO(, PRIORITY_BUFFERING) | 1459 | buffering_thread_name IF_PRIO(, PRIORITY_BUFFERING) |
1458 | IF_COP(, CPU)); | 1460 | IF_COP(, CPU)); |
1461 | |||
1462 | queue_enable_queue_send(&buffering_queue, &buffering_queue_sender_list, | ||
1463 | buffering_thread_p); | ||
1459 | } | 1464 | } |
1460 | 1465 | ||
1461 | /* Initialise the buffering subsystem */ | 1466 | /* Initialise the buffering subsystem */ |