X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/29c5c69ef3c9ceadbea3085f2268bb5ed8496c04..c72b6bb73def5f60f0a10f5bbb75f9228980dd8c:/services/keepstore/work_queue.go?ds=sidebyside diff --git a/services/keepstore/work_queue.go b/services/keepstore/work_queue.go index f1878ffbbc..56c6376ad3 100644 --- a/services/keepstore/work_queue.go +++ b/services/keepstore/work_queue.go @@ -1,3 +1,7 @@ +// Copyright (C) The Arvados Authors. All rights reserved. +// +// SPDX-License-Identifier: AGPL-3.0 + package main /* A WorkQueue is an asynchronous thread-safe queue manager. It @@ -84,6 +88,7 @@ package main import "container/list" +// WorkQueue definition type WorkQueue struct { getStatus chan WorkQueueStatus newlist chan *list.List @@ -96,6 +101,7 @@ type WorkQueue struct { DoneItem chan<- struct{} } +// WorkQueueStatus reflects the queue status. type WorkQueueStatus struct { InProgress int Queued int