services/keepstore/trash_worker.go

   1 package main
   2
   3 import (
   4         "errors"
   5         "log"
   6         "time"
   7 )
   8
   9 /*
  10         Keepstore initiates trash worker channel goroutine.
  11         The channel will process trash list.
  12                 For each (next) trash request:
  13       Delete the block indicated by the trash request Locator
  14                 Repeat
  15 */
  16
  17 func RunTrashWorker(trashq *WorkQueue) {
  18         for item := range trashq.NextItem {
  19                 trashRequest := item.(TrashRequest)
  20                 TrashItem(trashRequest)
  21         }
  22 }
  23
  24 // TrashItem deletes the indicated block from every writable volume.
  25 func TrashItem(trashRequest TrashRequest) {
  26         reqMtime := time.Unix(trashRequest.BlockMtime, 0)
  27         if time.Since(reqMtime) < blob_signature_ttl {
  28                 log.Printf("WARNING: data manager asked to delete a %v old block %v (BlockMtime %d = %v), but my blob_signature_ttl is %v! Skipping.",
  29                         time.Since(reqMtime),
  30                         trashRequest.Locator,
  31                         trashRequest.BlockMtime,
  32                         reqMtime,
  33                         blob_signature_ttl)
  34                 return
  35         }
  36         for _, volume := range KeepVM.AllWritable() {
  37                 mtime, err := volume.Mtime(trashRequest.Locator)
  38                 if err != nil || trashRequest.BlockMtime != mtime.Unix() {
  39                         continue
  40                 }
  41
  42                 if never_delete {
  43                         err = errors.New("did not delete block because never_delete is true")
  44                 } else {
  45                         err = volume.Delete(trashRequest.Locator)
  46                 }
  47
  48                 if err != nil {
  49                         log.Printf("%v Delete(%v): %v", volume, trashRequest.Locator, err)
  50                 } else {
  51                         log.Printf("%v Delete(%v) OK", volume, trashRequest.Locator)
  52                 }
  53         }
  54 }