Searched refs:sync_queue (Results 1 – 1 of 1) sorted by relevance
242 static list_t* sync_queue; variable815 if (!sync_queue) { in sync_queue_add()817 sync_queue = list_new(osi_free); in sync_queue_add()818 log::assert_that(sync_queue != NULL, "assert failed: sync_queue != NULL"); in sync_queue_add()822 log::assert_that(list_length(sync_queue) < MAX_SYNC_TRANSACTION, in sync_queue_add()826 list_append(sync_queue, p_node); in sync_queue_add()833 if (sync_queue && !list_is_empty(sync_queue)) { in sync_queue_advance()834 sync_node_t* p_head = (sync_node_t*)list_front(sync_queue); in sync_queue_advance()836 list_remove(sync_queue, p_head); in sync_queue_advance()842 if (!sync_queue) { in sync_queue_cleanup()[all …]