Struct FileManager 

pub struct FileManager {
    embedder_proxy: EmbedderProxy,
    store: Arc<FileManagerStore>,
    thread_pool: Weak<ThreadPool>,
}

Fields

embedder_proxy: EmbedderProxy

store: Arc<FileManagerStore>

thread_pool: Weak<ThreadPool>

Implementations

impl FileManager

pub fn new( embedder_proxy: EmbedderProxy, pool_handle: Weak<ThreadPool>, ) -> FileManager

pub fn read_file( &self, sender: IpcSender<FileManagerResult<ReadFileProgress>>, id: Uuid, origin: FileOrigin, )

pub fn get_token_for_file(&self, file_id: &Uuid) -> FileTokenCheck

pub fn invalidate_token(&self, token: &FileTokenCheck, file_id: &Uuid)

pub fn fetch_file( &self, done_sender: &mut TokioSender<Data>, cancellation_listener: Arc<CancellationListener>, id: Uuid, file_token: &FileTokenCheck, origin: FileOrigin, response: &mut Response, range: Option<Range>, ) -> Result<(), BlobURLStoreError>

Read a file for the Fetch implementation. It gets the required headers synchronously and reads the actual content in a separate thread.

pub fn promote_memory( &self, id: Uuid, blob_buf: BlobBuf, set_valid: bool, origin: FileOrigin, )

pub fn handle(&self, msg: FileManagerThreadMsg)

Message handler

pub fn fetch_file_in_chunks( &self, done_sender: &mut TokioSender<Data>, reader: BufReader<File>, res_body: ServoArc<Mutex<ResponseBody>>, cancellation_listener: Arc<CancellationListener>, range: RelativePos, )

fn fetch_blob_buf( &self, done_sender: &mut TokioSender<Data>, cancellation_listener: Arc<CancellationListener>, id: &Uuid, file_token: &FileTokenCheck, origin_in: &FileOrigin, bounds: BlobBounds, response: &mut Response, ) -> Result<(), BlobURLStoreError>

Trait Implementations

impl Clone for FileManager

fn clone(&self) -> FileManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.