fast-cache 0.1.0

Embedded-first thread-per-core in-memory cache with optional Redis-compatible server
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

use super::*;
use crate::server::commands::BorrowedCommandContext;

impl DirectProtocol {
    #[cfg(feature = "embedded")]
    #[allow(dead_code)]
    pub(in crate::server) fn shared_execute_borrowed(
        store: &EmbeddedStore,
        command: BorrowedCommand<'_>,
        now_ms: u64,
    ) -> Frame {
        command.execute_borrowed_frame(store, now_ms)
    }
}

impl DirectProtocol {
    #[cfg(feature = "embedded")]
    #[inline(always)]
    pub(in crate::server) fn borrowed_command_mutates_value(command: &BorrowedCommand<'_>) -> bool {
        command.mutates_value()
    }
}

/// SAFETY: caller must guarantee this is the only thread accessing the store.
impl DirectProtocol {
    #[cfg(feature = "embedded")]
    #[inline]
    pub(in crate::server) unsafe fn shared_execute_borrowed_into_single_threaded(
        store: &EmbeddedStore,
        command: BorrowedCommand<'_>,
        out: &mut BytesMut,
        fast_write_queue: Option<&mut FastWriteQueue>,
        _started_at: Instant,
    ) {
        command.execute_borrowed(BorrowedCommandContext {
            store,
            out,
            fast_write_queue,
            single_threaded: true,
        });
    }
}

impl DirectProtocol {
    #[cfg(feature = "embedded")]
    #[inline]
    pub(in crate::server) fn shared_execute_borrowed_into(
        store: &EmbeddedStore,
        command: BorrowedCommand<'_>,
        out: &mut BytesMut,
        fast_write_queue: Option<&mut FastWriteQueue>,
        _started_at: Instant,
    ) {
        command.execute_borrowed(BorrowedCommandContext {
            store,
            out,
            fast_write_queue,
            single_threaded: false,
        });
    }
}