kfs.py

import os, sys, stat, errno, time
import fuse
import logging
from metafs import MetaFS
from helper import *


fuse.fuse_python_api = (0, 2)

class KFS(fuse.Fuse):
    def __init__(self, metafs, *args, **kwargs):
	fuse.Fuse.__init__(self, *args, **kwargs)
	self.metafs=metafs

    # --- Metadata -----------------------------------------------------------
    def getattr(self, path):
	logging.info("getattr")
	return self.metafs.getattr(path)

    def chmod(self, path, mode):
	return self.metafs.chmod(path, mode)

    def chown(self, path, uid, gid):
	return self.metafs.chown(path, uid, gid)

    def utime(self, path, times):
	return self.metafs.utime(path, times)

    # --- Namespace ----------------------------------------------------------
    def unlink(self, path):
	return self.metafs.unlink(path)

    def rename(self, oldpath, newpath):
	return self.metafs.rename(self, oldpath, newpath)

    # --- Links --------------------------------------------------------------
    def symlink(self, path, newpath):
	return self.metafs.symlink(path, newpath)

    def readlink(self, path):
	return self.metafs.readlink(path)


    # --- Files --------------------------------------------------------------
    def mknod(self, path, mode, dev):
	return self.metafs.mknod(path, mode, dev)

    def create(self, path, flags, mode):
	return self.metafs.create(path, flags, mode)

    def truncate(self, path, len):
	return self.metafs.truncate(path, len)

    def read(self, path, size, offset):
	return self.metafs.read(path, size, offset)

    def write(self, path, buf, offset):
	return self.metafs.write(path, buf, offset)

    # --- Directories --------------------------------------------------------
    def mkdir(self, path, mode):
	logging.info("Inside mkdir")
	return self.metafs.mkdir(path, mode)

    def rmdir(self, path):
	return self.metafs.rmdir(path)

    def readdir(self, path, offset):
	return self.metafs.readdir(path, offset)

    #--- Extra Attributes -----------------------------------------------------
    def setxattr(self, path, name, value, flags):
	return self.metafs.setxattr(path, name, value, flags)

    def getxattr(self, path, name, size):
	value = self.metafs.getxattr(path, name, size)
	return value

    def listxattr(self, path, size):
	return self.metafs.listxattr(path, size)

    def removexattr(self, path, name):
	return self.metafs.removexattr(path, name)

def main():
    usage="""
HTFS - HashTable File-System

""" + fuse.Fuse.fusage
    os.environ["KFS_PATH"] = os.getcwd()
    print os.getenv("KFS_PATH")
    print os.getcwd()
    initialValSet = initialize()
    module = sys.modules[__name__]	
     
    for key,value in initialValSet.items():
    	globals()[key] = value 
    
    #for key, value in globals():
	#	print "%s = %s\n" % (key, value)

	

    logging.basicConfig(filename=log,level=logging.DEBUG)


    metafs = MetaFS(db_loc=db_loc, host=mongo_host, port=int(mongo_port), log=log, mode=mode, 
			attributes=Attributes, extensions=Extensions)

    server = KFS(metafs,version="%prog " + fuse.__version__,usage=usage,dash_s_do='setsingle')

    server.parse(errex=1)
    server.main()


if __name__ == '__main__':
    main()