diff options
Diffstat (limited to 'third_party/rust/neqo-common/src/lib.rs')
-rw-r--r-- | third_party/rust/neqo-common/src/lib.rs | 108 |
1 files changed, 108 insertions, 0 deletions
diff --git a/third_party/rust/neqo-common/src/lib.rs b/third_party/rust/neqo-common/src/lib.rs new file mode 100644 index 0000000000..735e5a8bb8 --- /dev/null +++ b/third_party/rust/neqo-common/src/lib.rs @@ -0,0 +1,108 @@ +// 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. + +#![cfg_attr(feature = "deny-warnings", deny(warnings))] +#![warn(clippy::pedantic)] + +mod codec; +mod datagram; +pub mod event; +pub mod header; +pub mod hrtime; +mod incrdecoder; +pub mod log; +pub mod qlog; +pub mod timer; + +pub use self::codec::{Decoder, Encoder}; +pub use self::datagram::Datagram; +pub use self::header::Header; +pub use self::incrdecoder::{ + IncrementalDecoderBuffer, IncrementalDecoderIgnore, IncrementalDecoderUint, +}; + +#[macro_use] +extern crate lazy_static; + +use std::fmt::Write; + +#[must_use] +pub fn hex(buf: impl AsRef<[u8]>) -> String { + let mut ret = String::with_capacity(buf.as_ref().len() * 2); + for b in buf.as_ref() { + write!(&mut ret, "{:02x}", b).unwrap(); + } + ret +} + +#[must_use] +pub fn hex_snip_middle(buf: impl AsRef<[u8]>) -> String { + const SHOW_LEN: usize = 8; + let buf = buf.as_ref(); + if buf.len() <= SHOW_LEN * 2 { + hex_with_len(buf) + } else { + let mut ret = String::with_capacity(SHOW_LEN * 2 + 16); + write!(&mut ret, "[{}]: ", buf.len()).unwrap(); + for b in &buf[..SHOW_LEN] { + write!(&mut ret, "{:02x}", b).unwrap(); + } + ret.push_str(".."); + for b in &buf[buf.len() - SHOW_LEN..] { + write!(&mut ret, "{:02x}", b).unwrap(); + } + ret + } +} + +#[must_use] +pub fn hex_with_len(buf: impl AsRef<[u8]>) -> String { + let buf = buf.as_ref(); + let mut ret = String::with_capacity(10 + buf.len() * 2); + write!(&mut ret, "[{}]: ", buf.len()).unwrap(); + for b in buf { + write!(&mut ret, "{:02x}", b).unwrap(); + } + ret +} + +#[must_use] +pub const fn const_max(a: usize, b: usize) -> usize { + [a, b][(a < b) as usize] +} +#[must_use] +pub const fn const_min(a: usize, b: usize) -> usize { + [a, b][(a >= b) as usize] +} + +#[derive(Debug, PartialEq, Eq, Copy, Clone)] +/// Client or Server. +pub enum Role { + Client, + Server, +} + +impl Role { + #[must_use] + pub fn remote(self) -> Self { + match self { + Self::Client => Self::Server, + Self::Server => Self::Client, + } + } +} + +impl ::std::fmt::Display for Role { + fn fmt(&self, f: &mut ::std::fmt::Formatter) -> ::std::fmt::Result { + write!(f, "{:?}", self) + } +} + +#[derive(Debug, Clone, Copy, PartialEq, Eq)] +pub enum MessageType { + Request, + Response, +} |