octoleo/s3fs-fuse
1
0
Fork 0
mirror of https://github.com/s3fs-fuse/s3fs-fuse.git synced 2024-06-01 16:40:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

configurable path for use_cache

Browse Source 
git-svn-id: http://s3fs.googlecode.com/svn/trunk@72 df820570-a93a-0410-bd06-b72b767a4274
This commit is contained in:
rrizun 2008-02-19 04:36:27 +00:00
parent d8c2ee2d68
commit a7a99366c4
1 changed files with 38 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
s3fs/s3fs.cpp
View File

@ -366,39 +366,39 @@ mkdirp(const string& path, mode_t mode) {
return 0; return 0;
} }
#include <pwd.h> //#include <pwd.h>
//
string //string
expand_path(const string& path) { //expand_path(const string& path) {
if (path.length() == 0 || path[0] != '~') // if (path.length() == 0 || path[0] != '~')
return path; // return path;
const char *pfx= NULL; // const char *pfx= NULL;
string::size_type pos = path.find_first_of('/'); // string::size_type pos = path.find_first_of('/');
if (path.length() == 1 || pos == 1) { // if (path.length() == 1 || pos == 1) {
pfx = getenv("HOME"); // pfx = getenv("HOME");
if (!pfx) { // if (!pfx) {
// Punt. We're trying to expand ~/, but HOME isn't set // // Punt. We're trying to expand ~/, but HOME isn't set
struct passwd *pw = getpwuid(getuid()); // struct passwd *pw = getpwuid(getuid());
if (pw) // if (pw)
pfx = pw->pw_dir; // pfx = pw->pw_dir;
} // }
} else { // } else {
string user(path, 1, (pos==string::npos) ? string::npos : pos-1); // string user(path, 1, (pos==string::npos) ? string::npos : pos-1);
struct passwd *pw = getpwnam(user.c_str()); // struct passwd *pw = getpwnam(user.c_str());
if (pw) // if (pw)
pfx = pw->pw_dir; // pfx = pw->pw_dir;
} // }
// if we failed to find an expansion, return the path unchanged. // // if we failed to find an expansion, return the path unchanged.
if (!pfx) // if (!pfx)
return path; // return path;
string result(pfx); // string result(pfx);
if (pos == string::npos) // if (pos == string::npos)
return result; // return result;
if (result.length() == 0 || result[result.length()-1] != '/') // if (result.length() == 0 || result[result.length()-1] != '/')
result += '/'; // result += '/';
result += path.substr(pos+1); // result += path.substr(pos+1);
return result; // return result;
} //}
#include <openssl/md5.h> #include <openssl/md5.h>
@ -447,7 +447,7 @@ get_headers(const char* path, headers_t& meta) {
return 0; return 0;
} }
static int use_local_file_cache = 0; static string use_cache;
/** /**
* get_local_fd * get_local_fd
@ -458,7 +458,7 @@ get_local_fd(const char* path) {
string url(host + resource); string url(host + resource);
string baseName = mybasename(path); string baseName = mybasename(path);
string resolved_path(expand_path("~/.s3fs/"+bucket)); string resolved_path(use_cache + "/" + bucket);
int fd = -1; int fd = -1;
@ -466,7 +466,7 @@ get_local_fd(const char* path) {
headers_t responseHeaders; headers_t responseHeaders;
if (use_local_file_cache) { if (use_cache.size() > 0) {
if (get_headers(path, responseHeaders) != 0) if (get_headers(path, responseHeaders) != 0)
Yikes(-ENOENT); Yikes(-ENOENT);
@ -506,7 +506,7 @@ get_local_fd(const char* path) {
// need to download? // need to download?
if (fd == -1) { if (fd == -1) {
// yes! // yes!
if (use_local_file_cache) { if (use_cache.size() > 0) {
/*if (*/mkdirp(resolved_path + mydirname(path), 0777)/* == -1) /*if (*/mkdirp(resolved_path + mydirname(path), 0777)/* == -1)
return -errno*/; return -errno*/;
mode_t mode = atoi(responseHeaders["x-amz-meta-mode"].c_str()); mode_t mode = atoi(responseHeaders["x-amz-meta-mode"].c_str());
@ -1097,7 +1097,7 @@ my_fuse_opt_proc(void *data, const char *arg, int key, struct fuse_args *outargs
return 0; return 0;
} }
if (strstr(arg, "use_cache=") != 0) { if (strstr(arg, "use_cache=") != 0) {
use_local_file_cache = atoi(strchr(arg, '=') + 1); use_cache = strchr(arg, '=') + 1;
return 0; return 0;
} }
} }