Method write

crates/commitlog/src/repo/mem/segment.rs:102–129

(&mut self, buf: &[u8])

impl io::Write for Segment {
    fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
        let mut storage = self.storage.write().unwrap();

        let mut remaining = (storage.alloc - self.pos) as usize;
        // If we don't have enough space, allocate some.
        // If not enough space to write all of `buf` can be allocated,
        // just write as much as we can. The next `write` call will return
        // ENOSPC then.
        if remaining == 0 {
            let mut avail = self.space.lock().unwrap();
            if *avail == 0 {
                return Err(enospc());
            }

            let want = (buf.len() - remaining).next_multiple_of(PAGE_SIZE);
            let have = want.min(*avail as usize);

            storage.alloc += have as u64;
            *avail -= have as u64;
            remaining = (storage.alloc - self.pos) as usize;
        }

        let read = buf.len().min(remaining);
        storage.buf.extend(&buf[..read]);
        self.pos += read as u64;

        Ok(read)
    }

    fn flush(&mut self) -> io::Result<()> {
        Ok(())