projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch '6953-docker-image-cleaner' closes #6953
[arvados.git]
/
services
/
keepstore
/
work_queue.go
diff --git
a/services/keepstore/work_queue.go
b/services/keepstore/work_queue.go
index 58e49665950dd929b54668ec4ce7bf5c87174d57..f1878ffbbc550250ab88c5ea9a4a694d12d63132 100644
(file)
--- a/
services/keepstore/work_queue.go
+++ b/
services/keepstore/work_queue.go
@@
-89,11
+89,11
@@
type WorkQueue struct {
newlist chan *list.List
// Workers get work items by reading from this channel.
NextItem <-chan interface{}
newlist chan *list.List
// Workers get work items by reading from this channel.
NextItem <-chan interface{}
- // Each worker must send struct{}{} to
ReportDone
exactly once
+ // Each worker must send struct{}{} to
DoneItem
exactly once
// for each work item received from NextItem, when it stops
// working on that item (regardless of whether the work was
// successful).
// for each work item received from NextItem, when it stops
// working on that item (regardless of whether the work was
// successful).
-
ReportDone
chan<- struct{}
+
DoneItem
chan<- struct{}
}
type WorkQueueStatus struct {
}
type WorkQueueStatus struct {
@@
-108,10
+108,10
@@
func NewWorkQueue() *WorkQueue {
reportDone := make(chan struct{})
newList := make(chan *list.List)
b := WorkQueue{
reportDone := make(chan struct{})
newList := make(chan *list.List)
b := WorkQueue{
- getStatus:
make(chan WorkQueueStatus),
- newlist:
newList,
- NextItem:
nextItem,
-
ReportDone:
reportDone,
+ getStatus: make(chan WorkQueueStatus),
+ newlist: newList,
+ NextItem: nextItem,
+
DoneItem:
reportDone,
}
go func() {
// Read new work lists from the newlist channel.
}
go func() {
// Read new work lists from the newlist channel.