Eine aufbereitete Darstellung der Quelle

 
     
 
 
Anforderungen  |   Konzepte  |   Entwurf  |   Entwicklung  |   Qualitätssicherung  |   Lebenszyklus  |   Steuerung
 
 
 
 

Benutzer

Quelle  qpack_send_buf.rs

  Sprache: Rust
 

// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
// option. This file may not be copied, modified, or distributed
// except according to those terms.

use crate::{huffman, prefix::Prefix};

/// Extension trait providing QPACK-specific encoding methods for `Encoder`.
///
/// This trait extends the standard [`neqo_common::Encoder`] with QPACK-specific
/// methods for encoding integers with prefixes and literal strings with
/// optional Huffman encoding.
pub trait Encoder {
    /// Encode an integer with a QPACK prefix according to RFC 7541 Section 5.1.
    fn encode_prefixed_encoded_int(&mut self, prefix: Prefix, val: u64) -> usize;

    /// Encode a literal string with optional Huffman encoding according to RFC 7541 Section 5.2.
    fn encode_literal(&mut self, use_huffman: bool, prefix: Prefix, value: &[u8]);
}

impl<B> Encoder for neqo_common::Encoder<B>
where
    B: neqo_common::Buffer,
{
    fn encode_prefixed_encoded_int(&mut self, prefix: Prefix, mut val: u64) -> usize {
        let first_byte_max: u8 = if prefix.len() == 0 {
            0xff
        } else {
            (1 << (8 - prefix.len())) - 1
        };

        if val < u64::from(first_byte_max) {
            let v = u8::try_from(val).expect("first_byte_max is a u8 and val is smaller");
            self.encode_byte((prefix.prefix() & !first_byte_max) | v);
            return 1;
        }

        self.encode_byte(prefix.prefix() | first_byte_max);
        val -= u64::from(first_byte_max);

        let mut written = 1;
        let mut done = false;
        while !done {
            let mut b = (val & 0x7f) as u8; // Safe because of the mask.
            val >>= 7;
            if val > 0 {
                b |= 0x80;
            } else {
                done = true;
            }

            self.encode_byte(b);
            written += 1;
        }
        written
    }

    fn encode_literal(&mut self, use_huffman: bool, prefix: Prefix, value: &[u8]) {
        let real_prefix = Prefix::new(
            if use_huffman {
                prefix.prefix() | (0x80 >> prefix.len())
            } else {
                prefix.prefix()
            },
            prefix.len() + 1,
        );

        if use_huffman {
            let encoded = huffman::encode(value);
            self.encode_prefixed_encoded_int(
                real_prefix,
                u64::try_from(encoded.len()).expect("usize fits in u64"),
            );
            self.encode(&encoded);
        } else {
            self.encode_prefixed_encoded_int(
                real_prefix,
                u64::try_from(value.len()).expect("usize fits in u64"),
            );
            self.encode(value);
        }
    }
}

#[cfg(test)]
#[cfg_attr(coverage_nightly, coverage(off))]
mod tests {
    use neqo_common::Encoder;

    use super::{Encoder as _, Prefix};

    #[test]
    fn encode_prefixed_encoded_int_1() {
        let mut d = Encoder::default();
        d.encode_prefixed_encoded_int(Prefix::new(0xC0, 2), 5);
        assert_eq!(d.as_ref(), [0xc5]);
    }

    #[test]
    fn encode_prefixed_encoded_int_2() {
        let mut d = Encoder::default();
        d.encode_prefixed_encoded_int(Prefix::new(0xC0, 2), 65);
        assert_eq!(d.as_ref(), [0xff, 0x02]);
    }

    #[test]
    fn encode_prefixed_encoded_int_3() {
        let mut d = Encoder::default();
        d.encode_prefixed_encoded_int(Prefix::new(0xC0, 2), 100_000);
        assert_eq!(d.as_ref(), [0xff, 0xe1, 0x8c, 0x06]);
    }

    #[test]
    fn max_int() {
        let mut d = Encoder::default();
        d.encode_prefixed_encoded_int(Prefix::new(0x80, 1), u64::MAX);
        assert_eq!(
            d.as_ref(),
            [
                0xff, 0x80, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0x01
            ]
        );
    }

    const VALUE: &[u8] = b"custom-key";

    const LITERAL: &[u8] = &[
        0xca, 0x63, 0x75, 0x73, 0x74, 0x6f, 0x6d, 0x2d, 0x6b, 0x65, 0x79,
    ];
    const LITERAL_HUFFMAN: &[u8] = &[0xe8, 0x25, 0xa8, 0x49, 0xe9, 0x5b, 0xa9, 0x7d, 0x7f];

    #[test]
    fn encode_literal() {
        let mut d = Encoder::default();
        d.encode_literal(false, Prefix::new(0xC0, 2), VALUE);
        assert_eq!(d.as_ref(), LITERAL);
    }

    #[test]
    fn encode_literal_huffman() {
        let mut d = Encoder::default();
        d.encode_literal(true, Prefix::new(0xC0, 2), VALUE);
        assert_eq!(d.as_ref(), LITERAL_HUFFMAN);
    }
}

Messung V0.5 in Prozent
C=74 H=95 G=84

¤ Dauer der Verarbeitung: 0.4 Sekunden  ¤

*© Formatika GbR, Deutschland






Wurzel

Suchen

PVS Prover

Isabelle Prover

NIST Cobol Testsuite

Cephes Mathematical Library

Vienna Development Method

Haftungshinweis

Die Informationen auf dieser Webseite wurden nach bestem Wissen sorgfältig zusammengestellt. Es wird jedoch weder Vollständigkeit, noch Richtigkeit, noch Qualität der bereit gestellten Informationen zugesichert.

Bemerkung:

Die farbliche Syntaxdarstellung und die Messung sind noch experimentell.






                                                                                                                                                                                                                                                                                                                                                                                                     


Neuigkeiten

     Aktuelles
     Motto des Tages

Open Source Software

     Quellcodebibliothek
     Eigene Quellcodes
     Fremde Quellcodes
     Suchen

Jenseits des Üblichen ....

Besucherstatistik

Besucherstatistik

Statistik
#Sources=434850
#Domains=661743