Apache
/
jclouds
mirror of https://github.com/apache/jclouds.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

JCLOUDS-1337: filesystem putBlob portable storage tiers

This commit is contained in:
Andrew Gaul 2017-10-11 01:10:01 -07:00
parent 152ca564b5
commit 61d4be8746
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apis/filesystem/src/main/java/org/jclouds/filesystem/strategy/internal/FilesystemStorageStrategyImpl.java
View File

@ -62,6 +62,7 @@ import org.jclouds.blobstore.domain.ContainerAccess;
import org.jclouds.blobstore.domain.MutableStorageMetadata; import org.jclouds.blobstore.domain.MutableStorageMetadata;
import org.jclouds.blobstore.domain.StorageMetadata; import org.jclouds.blobstore.domain.StorageMetadata;
import org.jclouds.blobstore.domain.StorageType; import org.jclouds.blobstore.domain.StorageType;
import org.jclouds.blobstore.domain.Tier;
import org.jclouds.blobstore.domain.internal.MutableStorageMetadataImpl; import org.jclouds.blobstore.domain.internal.MutableStorageMetadataImpl;
import org.jclouds.blobstore.options.CreateContainerOptions; import org.jclouds.blobstore.options.CreateContainerOptions;
import org.jclouds.blobstore.options.ListContainerOptions; import org.jclouds.blobstore.options.ListContainerOptions;
@ -107,6 +108,7 @@ public class FilesystemStorageStrategyImpl implements LocalStorageStrategy {
private static final String XATTR_CONTENT_MD5 = "user.content-md5"; private static final String XATTR_CONTENT_MD5 = "user.content-md5";
private static final String XATTR_CONTENT_TYPE = "user.content-type"; private static final String XATTR_CONTENT_TYPE = "user.content-type";
private static final String XATTR_EXPIRES = "user.expires"; private static final String XATTR_EXPIRES = "user.expires";
private static final String XATTR_STORAGE_TIER = "user.storage-tier";
private static final String XATTR_USER_METADATA_PREFIX = "user.user-metadata."; private static final String XATTR_USER_METADATA_PREFIX = "user.user-metadata.";
private static final byte[] DIRECTORY_MD5 = private static final byte[] DIRECTORY_MD5 =
Hashing.md5().hashBytes(new byte[0]).asBytes(); Hashing.md5().hashBytes(new byte[0]).asBytes();
@ -342,6 +344,7 @@ public class FilesystemStorageStrategyImpl implements LocalStorageStrategy {
String contentType = null; String contentType = null;
HashCode hashCode = null; HashCode hashCode = null;
Date expires = null; Date expires = null;
Tier tier = Tier.STANDARD;
ImmutableMap.Builder<String, String> userMetadata = ImmutableMap.builder(); ImmutableMap.Builder<String, String> userMetadata = ImmutableMap.builder();
UserDefinedFileAttributeView view = getUserDefinedFileAttributeView(file.toPath()); UserDefinedFileAttributeView view = getUserDefinedFileAttributeView(file.toPath());
@ -368,6 +371,7 @@ public class FilesystemStorageStrategyImpl implements LocalStorageStrategy {
buf.flip(); buf.flip();
expires = new Date(buf.asLongBuffer().get()); expires = new Date(buf.asLongBuffer().get());
} }
tier = Tier.valueOf(readStringAttributeIfPresent(view, attributes, XATTR_STORAGE_TIER));
for (String attribute : attributes) { for (String attribute : attributes) {
if (!attribute.startsWith(XATTR_USER_METADATA_PREFIX)) { if (!attribute.startsWith(XATTR_USER_METADATA_PREFIX)) {
continue; continue;
@ -388,6 +392,7 @@ public class FilesystemStorageStrategyImpl implements LocalStorageStrategy {
.contentMD5(hashCode) .contentMD5(hashCode)
.contentType(contentType) .contentType(contentType)
.expires(expires) .expires(expires)
.tier(tier)
.userMetadata(userMetadata.build()); .userMetadata(userMetadata.build());
} else { } else {
builder.payload(byteSource) builder.payload(byteSource)
@ -421,6 +426,7 @@ public class FilesystemStorageStrategyImpl implements LocalStorageStrategy {
buf.flip(); buf.flip();
view.write(XATTR_EXPIRES, buf); view.write(XATTR_EXPIRES, buf);
} }
writeStringAttributeIfPresent(view, XATTR_STORAGE_TIER, blob.getMetadata().getTier().toString());
for (Map.Entry<String, String> entry : blob.getMetadata().getUserMetadata().entrySet()) { for (Map.Entry<String, String> entry : blob.getMetadata().getUserMetadata().entrySet()) {
writeStringAttributeIfPresent(view, XATTR_USER_METADATA_PREFIX + entry.getKey(), entry.getValue()); writeStringAttributeIfPresent(view, XATTR_USER_METADATA_PREFIX + entry.getKey(), entry.getValue());
} }