X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/0d4bee15a0e69b08799bff869eb3f1ca122f107f..c980683a243903babe9cc09cabc71e1c6229fef1:/services/keepstore/azure_blob_volume.go diff --git a/services/keepstore/azure_blob_volume.go b/services/keepstore/azure_blob_volume.go index 36812304b0..f08cebff63 100644 --- a/services/keepstore/azure_blob_volume.go +++ b/services/keepstore/azure_blob_volume.go @@ -257,7 +257,7 @@ func (v *AzureBlobVolume) Put(loc string, block []byte) error { if v.readonly { return MethodDisabledError } - return v.bsClient.CreateBlockBlobFromReader(v.containerName, loc, uint64(len(block)), bytes.NewReader(block)) + return v.bsClient.CreateBlockBlobFromReader(v.containerName, loc, uint64(len(block)), bytes.NewReader(block), nil) } // Touch updates the last-modified property of a block blob. @@ -320,6 +320,11 @@ func (v *AzureBlobVolume) Trash(loc string) error { if v.readonly { return MethodDisabledError } + + if trashLifetime != 0 { + return ErrNotImplemented + } + // Ideally we would use If-Unmodified-Since, but that // particular condition seems to be ignored by Azure. Instead, // we get the Etag before checking Mtime, and use If-Match to @@ -390,3 +395,9 @@ var keepBlockRegexp = regexp.MustCompile(`^[0-9a-f]{32}$`) func (v *AzureBlobVolume) isKeepBlock(s string) bool { return keepBlockRegexp.MatchString(s) } + +// EmptyTrash looks for trashed blocks that exceeded trashLifetime +// and deletes them from the volume. +// TBD +func (v *AzureBlobVolume) EmptyTrash() { +}