Searched refs:sync_queue (Results 1 – 1 of 1) sorted by relevance
245 static list_t* sync_queue; variable868 if (!sync_queue) { in sync_queue_add()870 sync_queue = list_new(osi_free); in sync_queue_add()871 log::assert_that(sync_queue != NULL, "assert failed: sync_queue != NULL"); in sync_queue_add()876 list_length(sync_queue) < MAX_SYNC_TRANSACTION, in sync_queue_add()880 list_append(sync_queue, p_node); in sync_queue_add()887 if (sync_queue && !list_is_empty(sync_queue)) { in sync_queue_advance()888 sync_node_t* p_head = (sync_node_t*)list_front(sync_queue); in sync_queue_advance()890 list_remove(sync_queue, p_head); in sync_queue_advance()896 if (!sync_queue) { in sync_queue_cleanup()[all …]