trunk/python/fuse.py

#@+leo-ver=4
#@+node:@file fuse.py
#
#    Copyright (C) 2001  Jeff Epler  <jepler@unpythonic.dhs.org>
#
#    This program can be distributed under the terms of the GNU GPL.
#    See the file COPYING.
#


#@@language python
#@+others
#@+node:imports
# suppress version mismatch warnings
try:
    import warnings
    warnings.filterwarnings('ignore',
                            'Python C API version mismatch',
                            RuntimeWarning,
                            )
except:
    pass
 
from _fuse import main, DEBUG
import os, sys
from errno import *

#@-node:imports
#@+node:class ErrnoWrapper
class ErrnoWrapper:
    #@  @+others
    #@+node:__init__
    def __init__(self, func):
        self.func = func
    #@-node:__init__
    #@+node:__call__
    def __call__(self, *args, **kw):
        try:
                return apply(self.func, args, kw)
        except (IOError, OSError), detail:
                # Sometimes this is an int, sometimes an instance...
                if hasattr(detail, "errno"): detail = detail.errno
                return -detail
    #@-node:__call__
    #@-others
#@-node:class ErrnoWrapper
#@+node:class Fuse
class Fuse:

    #@  @+others
    #@+node:attribs
    _attrs = ['getattr', 'readlink', 'getdir', 'mknod', 'mkdir',
          'unlink', 'rmdir', 'symlink', 'rename', 'link', 'chmod',
          'chown', 'truncate', 'utime', 'open', 'read', 'write', 'release',
          'statfs', 'fsync']
    
    flags = 0
    multithreaded = 0
    
    #@-node:attribs
    #@+node:__init__
    def __init__(self, *args, **kw):
    
        # default attributes
        self.optlist = []
        self.optdict = {}
        self.mountpoint = None
    
        # grab arguments, if any
        argv = sys.argv
        argc = len(argv)
        if argc > 1:
            # we've been given the mountpoint
            self.mountpoint = argv[1]
        if argc > 2:
            # we've received mount args
            optstr = argv[2]
            opts = optstr.split(",")
            for o in opts:
                try:
                    k, v = o.split("=", 1)
                    self.optdict[k] = v
                except:
                    self.optlist.append(o)
    #@-node:__init__
    #@+node:main
    def main(self):
        d = {'flags': self.flags}
        d['multithreaded'] = self.multithreaded
        for a in self._attrs:
                if hasattr(self,a):
                        d[a] = ErrnoWrapper(getattr(self, a))
        apply(main, (), d)
    #@-node:main
    #@-others
#@-node:class Fuse
#@-others
#@-node:@file fuse.py
#@-leo
1	dpavlin	4	#@+leo-ver=4
2			#@+node:@file fuse.py
3			#
4			# Copyright (C) 2001 Jeff Epler <jepler@unpythonic.dhs.org>
5			#
6			# This program can be distributed under the terms of the GNU GPL.
7			# See the file COPYING.
8			#
9
10
11			#@@language python
12			#@+others
13			#@+node:imports
14			# suppress version mismatch warnings
15			try:
16			import warnings
17			warnings.filterwarnings('ignore',
18			'Python C API version mismatch',
19			RuntimeWarning,
20			)
21			except:
22			pass
23
24			from _fuse import main, DEBUG
25			import os, sys
26			from errno import *
27
28			#@-node:imports
29			#@+node:class ErrnoWrapper
30			class ErrnoWrapper:
31			#@ @+others
32			#@+node:__init__
33			def __init__(self, func):
34			self.func = func
35			#@-node:__init__
36			#@+node:__call__
37			def __call__(self, args, *kw):
38			try:
39			return apply(self.func, args, kw)
40			except (IOError, OSError), detail:
41			# Sometimes this is an int, sometimes an instance...
42			if hasattr(detail, "errno"): detail = detail.errno
43			return -detail
44			#@-node:__call__
45			#@-others
46			#@-node:class ErrnoWrapper
47			#@+node:class Fuse
48			class Fuse:
49
50			#@ @+others
51			#@+node:attribs
52			_attrs = ['getattr', 'readlink', 'getdir', 'mknod', 'mkdir',
53			'unlink', 'rmdir', 'symlink', 'rename', 'link', 'chmod',
54			'chown', 'truncate', 'utime', 'open', 'read', 'write', 'release',
55			'statfs', 'fsync']
56
57			flags = 0
58			multithreaded = 0
59
60			#@-node:attribs
61			#@+node:__init__
62			def __init__(self, args, *kw):
63
64			# default attributes
65			self.optlist = []
66			self.optdict = {}
67			self.mountpoint = None
68
69			# grab arguments, if any
70			argv = sys.argv
71			argc = len(argv)
72			if argc > 1:
73			# we've been given the mountpoint
74			self.mountpoint = argv[1]
75			if argc > 2:
76			# we've received mount args
77			optstr = argv[2]
78			opts = optstr.split(",")
79			for o in opts:
80			try:
81			k, v = o.split("=", 1)
82			self.optdict[k] = v
83			except:
84			self.optlist.append(o)
85			#@-node:__init__
86			#@+node:main
87			def main(self):
88			d = {'flags': self.flags}
89			d['multithreaded'] = self.multithreaded
90			for a in self._attrs:
91			if hasattr(self,a):
92			d[a] = ErrnoWrapper(getattr(self, a))
93			apply(main, (), d)
94			#@-node:main
95			#@-others
96			#@-node:class Fuse
97			#@-others
98			#@-node:@file fuse.py
99			#@-leo