sark-h2 0.27.0

Fiber-free HTTP/2 protocol primitives and manifold server for sark
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

use sark_core::{
    body::{self, buffered, credit},
    decode::request,
};

use crate::frame::numbers;

mod buffer;
mod error;
pub(crate) mod raw;

pub(crate) use buffer::{Buffer, Push};
pub(crate) use error::Error;

pub(crate) fn discard<O: credit::Origin, E: credit::Evidence>(
    release: credit::Release<O>,
    ledger: &mut credit::raw::Ledger<'_, O>,
    mut evidence: E,
) -> Result<(), Error> {
    release
        .try_discard(ledger, &mut evidence)
        .abandon(evidence)
        .map_err(|error| Error::Body(body::Error::Credit(error)))
}

/// Releases the credit of rejected input and classifies its exact wire code.
pub(crate) fn release_rejected<K, P, S, T, E, O>(
    failure: request::Failure<K, P, buffered::Rejected<S, T, O>>,
    ledger: &mut credit::raw::Ledger<'_, O>,
    evidence: &mut E,
) -> numbers::ErrorCode
where
    E: credit::Evidence,
    O: credit::Origin,
{
    match failure.discard().try_release(ledger, evidence) {
        Ok(rejected) => Error::Body(*rejected.error()).code(),
        Err(_) => numbers::ErrorCode::InternalError,
    }
}