Struct MSIProtocol 

pub struct MSIProtocol { /* private fields */ }

MSI coherency protocol implementation

Implementations

impl MSIProtocol

pub fn new(node_id: String) -> Self

Create new MSI protocol instance

pub async fn add_peer(&self, peer_id: String)

Add peer node

pub async fn remove_peer(&self, peer_id: &str)

Remove peer node

pub async fn get_state(&self, key: &CacheKey) -> MSIState

Get current state of a cache line

pub async fn handle_read(&self, key: &CacheKey) -> Result<Vec<CoherencyMessage>>

Handle read request

pub async fn handle_write( &self, key: &CacheKey, ) -> Result<Vec<CoherencyMessage>>

Handle write request

pub async fn handle_remote_invalidate( &self, key: &CacheKey, ) -> Result<CoherencyMessage>

Handle invalidation request from remote node

pub async fn handle_invalidate_ack(&self, key: &CacheKey, from_node: &str)

Handle invalidation acknowledgment

pub async fn invalidations_complete(&self, key: &CacheKey) -> bool

Check if invalidations are complete

pub async fn evict(&self, key: &CacheKey) -> Result<Option<CoherencyMessage>>

Evict cache line