Expose API for modifying fuse_conn_info.max_read

src/_pyfuse3.py

@@ -65,7 +65,7 @@ class Operations:
     enable_writeback_cache: bool = False
     enable_acl: bool = False
 
-    def init(self) -> None:
+    def init(self, conn_info) -> None:
         '''Initialize operations.
 
         This method will be called just before the file system starts handling

src/handlers.pxi

@@ -45,9 +45,13 @@ cdef void fuse_init (void *userdata, fuse_conn_info *conn):
         conn.capable & FUSE_CAP_POSIX_ACL):
         conn.want |= FUSE_CAP_POSIX_ACL
 
-    # Blocking rather than async, in case we decide to let the
-    # init hander modify `conn` in the future.
-    operations.init()
+    cdef ConnInfo conn_obj
+    conn_obj = ConnInfo.__new__(ConnInfo)
+    string.memcpy(&conn_obj.conn, conn, sizeof(fuse_conn_info))
+    # Blocking rather than async, to let the init hander modify `conn`.
+    operations.init(conn_obj)
+    string.memcpy(conn, &conn_obj.conn, sizeof(fuse_conn_info))
+
 
 cdef void fuse_lookup (fuse_req_t req, fuse_ino_t parent,
                        const_char *name):

src/pyfuse3.pyi

@@ -72,6 +72,15 @@ class FileInfo:
     def __cinit__(self, fh: FileHandleT, direct_io: bool, keep_cache: bool, nonseekable: bool) -> None: ...
 #    def _copy_to_fuse(self, fuse_file_info *out) -> None: ...
 
+
+class ConnInfo:
+    max_read: int
+
+    def __cinit__(self) -> None: ...
+    def __getstate__(self) -> StatDict: ...
+    def __setstate__(self, state: StatDict) -> None: ...
+
+
 class StatvfsData:
     f_bsize: int
     f_frsize: int

src/pyfuse3.pyx

@@ -393,6 +393,37 @@ cdef class FileInfo:
             out.nonseekable = 0
 
 
+@cython.freelist(1)
+cdef class ConnInfo:
+    '''
+    Instances of this class store information about the fuse connection.
+    The attributes correspond to the elements of the ``fuse_conn_info`` struct.
+    '''
+
+    cdef fuse_conn_info conn
+
+    def __cinit__(self):
+        string.memset(&self.conn, 0, sizeof(fuse_conn_info))
+
+    @property
+    def max_read(self):
+        return self.conn.max_read
+    @max_read.setter
+    def max_read(self, val):
+        self.conn.max_read = val
+
+    # Pickling and copy support
+    def __getstate__(self):
+        state = dict()
+        for k in ('max_read',):
+            state[k] = getattr(self, k)
+        return state
+
+    def __setstate__(self, state):
+        for (k,v) in state.items():
+            setattr(self, k, v)
+
+
 @cython.freelist(1)
 cdef class StatvfsData:
     '''

test/test_fs.py

@@ -166,6 +166,9 @@ def __init__(self, cross_process):
         self.status.entry_timeout = 99999
         self.status.attr_timeout = 99999
 
+    def init(self, conn_info):
+        conn_info.max_read = 4096
+
     async def getattr(self, inode, ctx=None):
         entry = pyfuse3.EntryAttributes()
         if inode == pyfuse3.ROOT_INODE:
@@ -268,6 +271,7 @@ def run_fs(mountpoint, cross_process):
     testfs = Fs(cross_process)
     fuse_options = set(pyfuse3.default_options)
     fuse_options.add('fsname=pyfuse3_testfs')
+    fuse_options.add('max_read=4096')
     pyfuse3.init(testfs, mountpoint, fuse_options)
     try:
         trio.run(pyfuse3.main)