Skip to main content

KvBlockPool

Struct KvBlockPool 

Source
pub struct KvBlockPool { /* private fields */ }
Expand description

A bounded pool of fixed-size KV-cache blocks (in positions) shared across many KvCache instances, typically one pool per server process. Each KvCache::with_pool acquires one block up front and one more each time it grows past its currently held capacity; free_blocks is therefore a live, accurate admission-control signal – a caller can check it before accepting a new request rather than discovering exhaustion only after committing memory.

Implementations§

Source§

impl KvBlockPool

Source

pub fn new(block_size: usize, total_blocks: usize) -> Self

block_size positions per block, total_blocks blocks in the whole shared budget (so block_size * total_blocks positions total, across however many caches draw from this pool at once).

Source

pub fn block_size(&self) -> usize

Source

pub fn total_blocks(&self) -> usize

Source

pub fn free_blocks(&self) -> usize

Source

pub fn resize(&mut self, total_blocks: usize) -> Result<(), usize>

Re-budget the pool.

The pool is an accounting budget, not an allocator: each KvCache owns its own buffer and this counts how many blocks the deployment has promised. So a resize is arithmetic, with one rule that is not.

Shrinking below what is currently held is REFUSED and the pool is left exactly as it was. free_blocks would have to go negative to represent it, and the alternative – clamping it to zero – silently over-promises: the caches already holding those blocks do not give them back, so every later try_acquire would be deciding against a budget that does not describe the memory in use.

Returns the number of blocks currently held when it refuses, so the caller can say what the floor actually is rather than making the operator find it by being rejected.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.