Struct Queue

pub struct Queue(pub(super) Arc<QueueI>);

Tuple Fields

0: Arc<QueueI>

Implementations

impl Queue

pub(crate) fn new(id: QueueId, name: QueueName, backend: AnyBackend) -> Self

pub fn backend(&self) -> &AnyBackend

pub fn listener(&self) -> ChangeListener<QueueMessage>

pub fn state_message(&self) -> QueueMessage

pub fn name(&self) -> &QueueName

pub fn start(&self, sem: Semaphore)

fn run_sync(&self)

async fn run_async(self, sem: Arc<Semaphore>)

Available on crate feature tokio only.

fn finish(&self)

pub fn requeue_failed(&self)

fn run_task_async( &self, task: &BuildTask, target: BuildTargetId, permit: OwnedSemaphorePermit, )

Available on crate feature tokio only.

fn run_task(&self, task: &BuildTask, target: BuildTargetId)

fn maybe_restart(&self)

pub fn enqueue_all( &self, target: FormatOrTargets<'_>, stale_only: bool, clean: bool, ) -> usize

pub fn enqueue_group( &self, id: &ArchiveId, target: FormatOrTargets<'_>, stale_only: bool, clean: bool, ) -> usize

pub fn enqueue_archive( &self, id: &ArchiveId, target: FormatOrTargets<'_>, stale_only: bool, rel_path: Option<&str>, clean: bool, ) -> usize

impl Queue

pub(super) fn sort(map: &TaskMap, state: &mut RunningQueue)

pub(super) fn get_next(&self) -> Option<(BuildTask, BuildTargetId)>

fn can_be_next(e: &BuildTask) -> Option<BuildTargetId>

pub(super) fn enqueue<'a, I: Iterator<Item = &'a SourceFile>>( map: &mut TaskMap, backend: &AnyBackend, archive: &Archive, target: FormatOrTargets<'_>, stale_only: bool, files: I, ) -> usize

fn process_dependencies(task: &BuildTask, map: &mut TaskMap)

Trait Implementations

impl Clone for Queue

fn clone(&self) -> Queue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Queue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.