+ go RunTrashWorker(s.handler.volmgr, ctxlog.TestLogger(c), s.cluster, trashq)
+
+ // Install gate so all local operations block until we say go
+ gate := make(chan struct{})
+ for _, mnt := range mounts {
+ mnt.Volume.(*MockVolume).Gate = gate
+ }
+
+ assertStatusItem := func(k string, expect float64) {
+ if v := getStatusItem(s.handler, "TrashQueue", k); v != expect {
+ c.Errorf("Got %s %v, expected %v", k, v, expect)
+ }
+ }