projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
20497: Direct the reader to the tutorial project via Public Favorites
[arvados.git]
/
lib
/
lsf
/
lsfqueue.go
diff --git
a/lib/lsf/lsfqueue.go
b/lib/lsf/lsfqueue.go
index 3ed4d0c1820cfaad1340c1304902a7deabd0fcb7..60f01640a0fcab807f3f1a487558179f090de7e2 100644
(file)
--- a/
lib/lsf/lsfqueue.go
+++ b/
lib/lsf/lsfqueue.go
@@
-58,7
+58,7
@@
func (q *lsfqueue) getNext() map[string]bjobsEntry {
func (q *lsfqueue) init() {
q.updated = sync.NewCond(&q.mutex)
q.nextReady = make(chan (<-chan struct{}))
func (q *lsfqueue) init() {
q.updated = sync.NewCond(&q.mutex)
q.nextReady = make(chan (<-chan struct{}))
- ticker := time.NewTicker(
time.Secon
d)
+ ticker := time.NewTicker(
q.perio
d)
go func() {
for range ticker.C {
// Send a new "next update ready" channel to
go func() {
for range ticker.C {
// Send a new "next update ready" channel to