diff options
| author | Dan Goodliffe <dan@randomdan.homeip.net> | 2017-10-26 21:39:27 +0100 | 
|---|---|---|
| committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2017-12-16 20:51:55 +0000 | 
| commit | 4e6c262dbd00f83c2318054d5d50f89ad7aec0e7 (patch) | |
| tree | bea343d9efb059d8e210f9fbfee4da51536c24b1 | |
| parent | Add optimistic checking and pruning of background write results if it can be ... (diff) | |
| download | netfs-4e6c262dbd00f83c2318054d5d50f89ad7aec0e7.tar.bz2 netfs-4e6c262dbd00f83c2318054d5d50f89ad7aec0e7.tar.xz netfs-4e6c262dbd00f83c2318054d5d50f89ad7aec0e7.zip  | |
Use namespace NetFS { ... } in files and dirs
| -rw-r--r-- | netfs/fuse/fuseDirs.cpp | 24 | ||||
| -rw-r--r-- | netfs/fuse/fuseFiles.cpp | 58 | 
2 files changed, 43 insertions, 39 deletions
diff --git a/netfs/fuse/fuseDirs.cpp b/netfs/fuse/fuseDirs.cpp index becaa44..f872b79 100644 --- a/netfs/fuse/fuseDirs.cpp +++ b/netfs/fuse/fuseDirs.cpp @@ -2,7 +2,8 @@  #include <lockHelpers.h>  #include <entCache.h> -NetFS::FuseApp::OpenDir::OpenDir(DirectoryPrx r, const std::string & p) : +namespace NetFS { +FuseApp::OpenDir::OpenDir(DirectoryPrx r, const std::string & p) :  	remote(r),  	remoteV2(r->ice_getFacet() >= "v02" ? DirectoryV2Prx::uncheckedCast(r) : nullptr),  	path(p) @@ -36,20 +37,20 @@ NetFS::FuseApp::clearDirProxy(uint64_t localID)  }  int -NetFS::FuseApp::opendir(const char * p, struct fuse_file_info * fi) +FuseApp::opendir(const char * p, struct fuse_file_info * fi)  {  	try {  		auto remote = volume->opendir(reqEnv(), p);  		setProxy(new OpenDir(remote, p), fi->fh);  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::releasedir(const char *, struct fuse_file_info * fi) +FuseApp::releasedir(const char *, struct fuse_file_info * fi)  {  	try {  		auto remote = getDirProxy(fi->fh)->remote; @@ -57,13 +58,13 @@ NetFS::FuseApp::releasedir(const char *, struct fuse_file_info * fi)  		clearDirProxy(fi->fh);  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::readdir(const char * p, void * buf, fuse_fill_dir_t filler, off_t, struct fuse_file_info * fi) +FuseApp::readdir(const char * p, void * buf, fuse_fill_dir_t filler, off_t, struct fuse_file_info * fi)  {  	try {  		auto od = getDirProxy(fi->fh); @@ -89,32 +90,33 @@ NetFS::FuseApp::readdir(const char * p, void * buf, fuse_fill_dir_t filler, off_  		}  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::mkdir(const char * p, mode_t m) +FuseApp::mkdir(const char * p, mode_t m)  {  	try {  		volume->mkdir(reqEnv(), p, m);  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::rmdir(const char * p) +FuseApp::rmdir(const char * p)  {  	try {  		volume->rmdir(reqEnv(), p);  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  } +} diff --git a/netfs/fuse/fuseFiles.cpp b/netfs/fuse/fuseFiles.cpp index e81dd45..2fc6b26 100644 --- a/netfs/fuse/fuseFiles.cpp +++ b/netfs/fuse/fuseFiles.cpp @@ -3,7 +3,8 @@  #include "lockHelpers.h"  #include <entCache.h> -NetFS::FuseApp::OpenFile::OpenFile(FilePrx r, const std::string & p, int f) : +namespace NetFS { +FuseApp::OpenFile::OpenFile(FilePrx r, const std::string & p, int f) :  	remote(r),  	path(p),  	flags(f) @@ -30,14 +31,14 @@ NetFS::FuseApp::getFileProxy(uint64_t localID) const  }  void -NetFS::FuseApp::clearFileProxy(uint64_t localID) +FuseApp::clearFileProxy(uint64_t localID)  {  	Lock(_lock);  	openFiles.erase(localID);  }  void -NetFS::FuseApp::OpenFile::wait() const +FuseApp::OpenFile::wait() const  {  	SharedLock(_lock);  	for (const auto & w : bg) { @@ -46,7 +47,7 @@ NetFS::FuseApp::OpenFile::wait() const  }  void -NetFS::FuseApp::OpenFile::flush() +FuseApp::OpenFile::flush()  {  	Lock(_lock);  	while (!bg.empty()) { @@ -58,7 +59,7 @@ NetFS::FuseApp::OpenFile::flush()  }  void -NetFS::FuseApp::OpenFile::nonBlockingFlush() +FuseApp::OpenFile::nonBlockingFlush()  {  	boost::unique_lock<boost::shared_mutex> lock(_lock, boost::try_to_lock);  	if (lock.owns_lock()) { @@ -76,33 +77,33 @@ NetFS::FuseApp::OpenFile::nonBlockingFlush()  }  int -NetFS::FuseApp::open(const char * p, struct fuse_file_info * fi) +FuseApp::open(const char * p, struct fuse_file_info * fi)  {  	try {  		auto remote = volume->open(reqEnv(), p, fi->flags);  		setProxy(new OpenFile(remote, p, fi->flags), fi->fh);  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::create(const char * p, mode_t m, struct fuse_file_info * fi) +FuseApp::create(const char * p, mode_t m, struct fuse_file_info * fi)  {  	try {  		auto remote = volume->create(reqEnv(), p, fi->flags, m);  		setProxy(new OpenFile(remote, p, fi->flags), fi->fh);  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::release(const char *, struct fuse_file_info * fi) +FuseApp::release(const char *, struct fuse_file_info * fi)  {  	try {  		auto of = getFileProxy(fi->fh); @@ -110,53 +111,53 @@ NetFS::FuseApp::release(const char *, struct fuse_file_info * fi)  		try {  			of->flush();  		} -		catch (NetFS::SystemError & e) { +		catch (SystemError & e) {  		}  		remote->close();  		clearFileProxy(fi->fh);  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		clearFileProxy(fi->fh);  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::flush(const char *, struct fuse_file_info * fi) +FuseApp::flush(const char *, struct fuse_file_info * fi)  {  	try {  		getFileProxy(fi->fh)->flush();  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::read(const char *, char * buf, size_t s, off_t o, struct fuse_file_info * fi) +FuseApp::read(const char *, char * buf, size_t s, off_t o, struct fuse_file_info * fi)  {  	try {  		auto of = getFileProxy(fi->fh);  		of->wait();  		auto remote = of->remote; -		NetFS::Buffer data = remote->read(o, s); +		Buffer data = remote->read(o, s);  		memcpy(buf, &data.front(), data.size());  		return data.size();  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::write(const char *, const char * buf, size_t s, off_t o, struct fuse_file_info * fi) +FuseApp::write(const char *, const char * buf, size_t s, off_t o, struct fuse_file_info * fi)  {  	try {  		auto of = getFileProxy(fi->fh);  		auto remote = of->remote; -		auto r = remote->begin_write(o, s, NetFS::Buffer(buf, buf + s)); +		auto r = remote->begin_write(o, s, Buffer(buf, buf + s));  		if (fcr->Async) {  			ScopeLock(of->_lock) {  				of->bg.push_back(r); @@ -168,25 +169,25 @@ NetFS::FuseApp::write(const char *, const char * buf, size_t s, off_t o, struct  		}  		return s;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::truncate(const char * p, off_t o) +FuseApp::truncate(const char * p, off_t o)  {  	try {  		volume->truncate(reqEnv(), p, o);  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::ftruncate(const char *, off_t o, fuse_file_info * fi) +FuseApp::ftruncate(const char *, off_t o, fuse_file_info * fi)  {  	try {  		auto of = getFileProxy(fi->fh); @@ -195,13 +196,13 @@ NetFS::FuseApp::ftruncate(const char *, off_t o, fuse_file_info * fi)  		remote->ftruncate(reqEnv(), o);  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::fgetattr(const char *, struct stat * s, fuse_file_info * fi) +FuseApp::fgetattr(const char *, struct stat * s, fuse_file_info * fi)  {  	try {  		auto of = getFileProxy(fi->fh); @@ -210,20 +211,21 @@ NetFS::FuseApp::fgetattr(const char *, struct stat * s, fuse_file_info * fi)  		*s = converter.convert(remote->fgetattr(reqEnv()));  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  }  int -NetFS::FuseApp::unlink(const char * p) +FuseApp::unlink(const char * p)  {  	try {  		volume->unlink(reqEnv(), p);  		return 0;  	} -	catch (NetFS::SystemError & e) { +	catch (SystemError & e) {  		return -e.syserrno;  	}  } +}  | 
