fuse.py is a pain in the ass.
Signed-off-by: R. Tyler Ballance <tyler@slide.com>
This commit is contained in:
R. Tyler Ballance
parent
5ead39acfa
commit
a725106374
195
imuse.py
195
imuse.py
|
|
@ -20,6 +20,9 @@
|
|||
LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
'''
|
||||
|
||||
import logging
|
||||
import sys
|
||||
|
||||
from collections import defaultdict
|
||||
from errno import ENOENT
|
||||
from stat import S_IFDIR, S_IFLNK, S_IFREG
|
||||
|
|
@ -27,103 +30,107 @@ from time import time
|
|||
|
||||
from fuse import FUSE, FuseError, FuseOperations
|
||||
|
||||
import logging
|
||||
|
||||
|
||||
class ImuseOperations(FuseOperations):
|
||||
def __init__(self):
|
||||
self.files = {}
|
||||
self.data = defaultdict(str)
|
||||
self.fd = 0
|
||||
|
||||
def chmod(self, path, mode):
|
||||
self.files[path]['st_mode'] &= 0770000
|
||||
self.files[path]['st_mode'] |= mode
|
||||
return 0
|
||||
def __init__(self):
|
||||
self.files = {}
|
||||
self.data = defaultdict(str)
|
||||
self.fd = 0
|
||||
|
||||
def chmod(self, path, mode):
|
||||
self.files[path]['st_mode'] &= 0770000
|
||||
self.files[path]['st_mode'] |= mode
|
||||
return 0
|
||||
|
||||
def chown(self, path, uid, gid):
|
||||
self.files[path]['st_uid'] = uid
|
||||
self.files[path]['st_gid'] = gid
|
||||
return 0
|
||||
|
||||
def create(self, path, mode):
|
||||
self.files[path] = dict(st_mode=(S_IFREG | mode), st_nlink=1,
|
||||
st_size=0, st_ctime=time(), st_mtime=time(), st_atime=time())
|
||||
self.fd += 1
|
||||
return self.fd
|
||||
|
||||
def getattr(self, path, fh=None):
|
||||
if path not in self.files:
|
||||
raise FuseError(ENOENT)
|
||||
st = self.files[path]
|
||||
if path == '/':
|
||||
# Add 2 for `.` and `..` , subtruct 1 for `/`
|
||||
st['st_nlink'] = len(self.files) + 1
|
||||
return st
|
||||
|
||||
def init(self):
|
||||
mode = S_IFDIR | 0755
|
||||
now = time()
|
||||
self.files['/'] = dict(st_mode=mode, st_ctime=now, st_mtime=now,
|
||||
st_atime=now)
|
||||
|
||||
def mkdir(self, path, mode):
|
||||
self.files[path] = dict(st_mode=(S_IFDIR | mode), st_nlink=2,
|
||||
st_size=0, st_ctime=time(), st_mtime=time(), st_atime=time())
|
||||
return 0
|
||||
|
||||
def open(self, path, flags):
|
||||
self.fd += 1
|
||||
return self.fd
|
||||
|
||||
def read(self, path, size, offset, fh):
|
||||
return self.data[path][offset:offset + size]
|
||||
|
||||
def readdir(self, path, fh):
|
||||
return ['.', '..'] + [x[1:] for x in self.files if x != '/']
|
||||
|
||||
def readlink(self, path):
|
||||
return self.data[path]
|
||||
|
||||
def rename(self, old, new):
|
||||
self.files[new] = self.files.pop(old)
|
||||
return 0
|
||||
|
||||
def rmdir(self, path):
|
||||
self.files.pop(path)
|
||||
return 0
|
||||
|
||||
def statvfs(self, path):
|
||||
return dict(f_bsize=512, f_blocks=4096, f_bavail=2048)
|
||||
|
||||
def symlink(self, source, target):
|
||||
self.files[target] = dict(st_mode=(S_IFLNK | 0777), st_nlink=1,
|
||||
st_size=len(source))
|
||||
self.data[target] = source
|
||||
return 0
|
||||
|
||||
def truncate(self, path, length, fh=None):
|
||||
self.data[path] = self.data[path][:length]
|
||||
self.files[path]['st_size'] = length
|
||||
return 0
|
||||
|
||||
def unlink(self, path):
|
||||
self.files.pop(path)
|
||||
return 0
|
||||
|
||||
def utimens(self, path, atime, mtime):
|
||||
now = time()
|
||||
self.files[path]['st_atime'] = atime or now
|
||||
self.files[path]['st_mtime'] = mtime or now
|
||||
return 0
|
||||
|
||||
def write(self, path, data, offset, fh):
|
||||
self.data[path] = self.data[path][:offset] + data
|
||||
self.files[path]['st_size'] = len(self.data[path])
|
||||
return len(data)
|
||||
def chown(self, path, uid, gid):
|
||||
self.files[path]['st_uid'] = uid
|
||||
self.files[path]['st_gid'] = gid
|
||||
return 0
|
||||
|
||||
def create(self, path, mode):
|
||||
self.files[path] = dict(st_mode=(S_IFREG | mode), st_nlink=1,
|
||||
st_size=0, st_ctime=time(), st_mtime=time(), st_atime=time())
|
||||
self.fd += 1
|
||||
return self.fd
|
||||
|
||||
def getattr(self, path, fh=None):
|
||||
logging.debug((path, fh))
|
||||
st = {'st_size' : 0, 'st_ctime' : time(), 'st_mtime' : time(), 'st_atime' : time()}
|
||||
if path == '/':
|
||||
st['st_nlink'] = 3
|
||||
st['st_mode'] = S_IFDIR | 0755
|
||||
return st
|
||||
else:
|
||||
st['st_nlink'] = 1
|
||||
st['st_size'] = 100
|
||||
st['st_mode'] = S_IFREG | 0444
|
||||
return st
|
||||
|
||||
def init(self):
|
||||
mode = S_IFDIR | 0755
|
||||
now = time()
|
||||
self.files['/'] = dict(st_mode=mode, st_ctime=now, st_mtime=now,
|
||||
st_atime=now)
|
||||
|
||||
def mkdir(self, path, mode):
|
||||
self.files[path] = dict(st_mode=(S_IFDIR | mode), st_nlink=2,
|
||||
st_size=0, st_ctime=time(), st_mtime=time(), st_atime=time())
|
||||
return 0
|
||||
|
||||
def open(self, path, flags):
|
||||
self.fd += 1
|
||||
return self.fd
|
||||
|
||||
def read(self, path, size, offset, fh):
|
||||
return self.data[path][offset:offset + size]
|
||||
|
||||
def readdir(self, path, fh):
|
||||
rc = ['.', '..']
|
||||
return rc + ['Accounts']
|
||||
|
||||
def readlink(self, path):
|
||||
return self.data[path]
|
||||
|
||||
def rename(self, old, new):
|
||||
self.files[new] = self.files.pop(old)
|
||||
return 0
|
||||
|
||||
def rmdir(self, path):
|
||||
self.files.pop(path)
|
||||
return 0
|
||||
|
||||
def statvfs(self, path):
|
||||
return dict(f_bsize=512, f_blocks=4096, f_bavail=2048)
|
||||
|
||||
def symlink(self, source, target):
|
||||
self.files[target] = dict(st_mode=(S_IFLNK | 0777), st_nlink=1,
|
||||
st_size=len(source))
|
||||
self.data[target] = source
|
||||
return 0
|
||||
|
||||
def truncate(self, path, length, fh=None):
|
||||
self.data[path] = self.data[path][:length]
|
||||
self.files[path]['st_size'] = length
|
||||
return 0
|
||||
|
||||
def unlink(self, path):
|
||||
self.files.pop(path)
|
||||
return 0
|
||||
|
||||
def utimens(self, path, atime, mtime):
|
||||
now = time()
|
||||
self.files[path]['st_atime'] = atime or now
|
||||
self.files[path]['st_mtime'] = mtime or now
|
||||
return 0
|
||||
|
||||
def write(self, path, data, offset, fh):
|
||||
self.data[path] = self.data[path][:offset] + data
|
||||
self.files[path]['st_size'] = len(self.data[path])
|
||||
return len(data)
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
logging.basicConfig(level=logging.DEBUG)
|
||||
fuse = FUSE(ImuseOperations(), foreground=True, fsname='Imuse')
|
||||
if __name__ == "__main__":
|
||||
logging.basicConfig(level=logging.DEBUG)
|
||||
assert len(sys.argv) > 1, (sys.argv, 'You must specify the mountpoint as the first argument!')
|
||||
fuse = FUSE(ImuseOperations(), foreground=True, fsname='Imuse', mountpoint=sys.argv[1])
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue