X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/45f10d80d1b584808a6e375214b5be6bc7d2a730..013a5d60ce55b627f314ed05000e4a7fa6b1cae8:/services/datamanager/summary/trash_list.go?ds=inline diff --git a/services/datamanager/summary/trash_list.go b/services/datamanager/summary/trash_list.go index 0bedc9cc3a..b6ceacecde 100644 --- a/services/datamanager/summary/trash_list.go +++ b/services/datamanager/summary/trash_list.go @@ -1,4 +1,5 @@ // Code for generating trash lists + package summary import ( @@ -9,6 +10,7 @@ import ( "time" ) +// BuildTrashLists builds list of blocks to be sent to trash queue func BuildTrashLists(kc *keepclient.KeepClient, keepServerInfo *keep.ReadServers, keepBlocksNotInCollections BlockSet) (m map[string]keep.TrashList, err error) { @@ -40,19 +42,19 @@ func buildTrashListsInternal(writableServers map[string]struct{}, m = make(map[string]keep.TrashList) for block := range keepBlocksNotInCollections { - for _, block_on_server := range keepServerInfo.BlockToServers[block] { - if block_on_server.Mtime >= expiry { + for _, blockOnServer := range keepServerInfo.BlockToServers[block] { + if blockOnServer.Mtime >= expiry { continue } // block is older than expire cutoff - srv := keepServerInfo.KeepServerIndexToAddress[block_on_server.ServerIndex].String() + srv := keepServerInfo.KeepServerIndexToAddress[blockOnServer.ServerIndex].String() if _, writable := writableServers[srv]; !writable { continue } - m[srv] = append(m[srv], keep.TrashRequest{Locator: block.Digest.String(), BlockMtime: block_on_server.Mtime}) + m[srv] = append(m[srv], keep.TrashRequest{Locator: block.Digest.String(), BlockMtime: blockOnServer.Mtime}) } } return