- pthread_mutex_lock(&handle->cmd_queue.lock);
- /* Purge queue of in-flight commands and mark them as cancelled. */
- cds_list_for_each_entry_safe(cmd, tmp, &handle->cmd_queue.list,
- cmd_list_node) {
- cds_list_del(&cmd->cmd_list_node);
- cmd->reply_code = LTTNG_ERR_COMMAND_CANCELLED;
- futex_nto1_wake(&cmd->reply_futex);
- }
- pthread_mutex_unlock(&handle->cmd_queue.lock);