summaryrefslogtreecommitdiff
path: root/apps/buffering.c
diff options
context:
space:
mode:
Diffstat (limited to 'apps/buffering.c')
-rw-r--r--apps/buffering.c9
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
1447void buffering_init(void) { 1447void 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 */