(tokenCh chan struct{})
| 268 | } |
| 269 | |
| 270 | func (importer *SnapFileImporter) releaseToken(tokenCh chan struct{}) { |
| 271 | tokenCh <- struct{}{} |
| 272 | // finish the task, notify the main goroutine to continue |
| 273 | importer.cond.L.Lock() |
| 274 | importer.cond.Signal() |
| 275 | importer.cond.L.Unlock() |
| 276 | } |
| 277 | |
| 278 | func (importer *SnapFileImporter) Close() error { |
| 279 | if importer != nil && importer.importClient != nil { |
no test coverage detected