pub(crate) async fn flush_buffer(&self, ino: u64, buffer: WriteBuffer) -> FSResult<()> {
        let blob_id = self
            .inode_to_blobid
            .get(&ino)
            .await
            .ok_or(Error::NotFound)?;

        self.client
            .write(&blob_id, buffer.offset, buffer.data.freeze())
            .await
            .map_err(|e| {
                log::error!("write error: {}", e);
                Error::IOError
            })?;

        Ok(())
    }
/// Flushes the write buffer for an inode to the menmos cluster.
///
/// Returns an IO error if the write fails.
Flushes the write buffer for an inode to the menmos cluster.
Returns an IO error if the write fails.
Flushes the write buffer for an inode to the menmos cluster . Returns an IO error if the write fails .
pub(crate) async fn flush_buffer(&self, ino: u64, buffer: WriteBuffer) -> FSResult<()> {
        let blob_id = self
            .inode_to_blobid
            .get(&ino)
            .await
            .ok_or(Error::NotFound)?;
        self.client
            .write(&blob_id, buffer.offset, buffer.data.freeze())
            .await
            .map_err(|e| {
                log::error!("write error: {}", e);
                Error::IOError
            })?;
        Ok(())
    }
pub ( crate ) async fn flush_buffer ( & self , ino : u64 , buffer : WriteBuffer ) -> FSResult < ( ) > { let blob_id = self . inode_to_blobid . get ( & ino ) . await . ok_or ( Error :: NotFound ) ? ; self . client . write ( & blob_id , buffer . offset , buffer . data . freeze ( ) ) . await . map_err ( | e | { log :: error ! ( " " e ) ; Error :: IOError } ) ? ; Ok ( ( ) ) }
Flushes the write buffer for an inode to the menmos cluster.
Flushes the write buffer for an inode to the menmos cluster .
&self
ino
u64
buffer
WriteBuffer
&self
ino
u64
buffer
WriteBuffer