X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/0041395d00cda5ddeb488dae2d9fae7b6b437c9d..2bbb912c6a41bf8046cf36a77b40541f224b703d:/services/keepstore/trash_worker.go diff --git a/services/keepstore/trash_worker.go b/services/keepstore/trash_worker.go index 7e19ba41c5..65e3fbd284 100644 --- a/services/keepstore/trash_worker.go +++ b/services/keepstore/trash_worker.go @@ -23,13 +23,13 @@ func RunTrashWorker(trashq *WorkQueue) { // TrashItem deletes the indicated block from every writable volume. func TrashItem(trashRequest TrashRequest) { reqMtime := time.Unix(trashRequest.BlockMtime, 0) - if time.Since(reqMtime) < blob_signature_ttl { - log.Printf("WARNING: data manager asked to delete a %v old block %v (BlockMtime %d = %v), but my blob_signature_ttl is %v! Skipping.", + if time.Since(reqMtime) < blobSignatureTTL { + log.Printf("WARNING: data manager asked to delete a %v old block %v (BlockMtime %d = %v), but my blobSignatureTTL is %v! Skipping.", time.Since(reqMtime), trashRequest.Locator, trashRequest.BlockMtime, reqMtime, - blob_signature_ttl) + blobSignatureTTL) return } @@ -44,8 +44,8 @@ func TrashItem(trashRequest TrashRequest) { continue } - if never_delete { - err = errors.New("did not delete block because never_delete is true") + if neverDelete { + err = errors.New("did not delete block because neverDelete is true") } else { err = volume.Delete(trashRequest.Locator) }