| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | http_body.rs | 59 pub(crate) fn text(len: u64, pre: &[u8], io: BoxStreamData) -> Self {
61 kind: Kind::Text(Text::new(len, pre, io)),
65 pub(crate) fn chunk(pre: &[u8], io: BoxStreamData, is_trailer: bool) -> Self {
67 kind: Kind::Chunk(Chunk::new(pre, io, is_trailer)),
81 pre: Option<Cursor<Vec<u8>>>,
86 pub(crate) fn new(len: u64, pre: &[u8], io: BoxStreamData) -> Self {
89 pre: (!pre.is_empty()).then_some(Cursor::new(pre.to_vec())),
128 if let Some(pre) in data()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | http_body.rs | 77 pre: &[u8],
81 if !pre.is_empty() {
82 // TODO: Consider the case where BodyLength is empty but pre is not empty.
88 BodyLength::Length(len) => Kind::Text(Text::new(len, pre, io, interceptors)),
89 BodyLength::UntilClose => Kind::UntilClose(UntilClose::new(pre, io, interceptors)),
92 BodyLength::Chunk => Kind::Chunk(Chunk::new(pre, io, interceptors)),
190 pre: Option<Cursor<Vec<u8>>>,
195 pub(crate) fn new(pre: &[u8], io: BoxStreamData, interceptors: Arc<Interceptors>) -> Self {
198 pre: (!pre
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| H A D | integer.rs | 23 pub(crate) fn index(pre: u8, index: usize, mask: u8) -> Self {
25 int: IntegerEncoder::new(pre, index, mask),
80 pre: u8,
95 pub(crate) fn new(pre: u8, i: usize, mask: u8) -> Self {
97 pre,
109 self.pre
119 return Some(self.pre | (self.i as u8));
123 Some(self.pre | self.mask)
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| H A D | integer.rs | 100 pre: u8,
113 pub(crate) fn new(i: usize, mask: u8, pre: u8) -> Self {
117 pre,
129 return Some(self.pre | (self.i as u8));
133 Some(self.pre | self.mask)
219 ($int: expr, $mask: expr, $pre: expr $(, $byte: expr)* $(,)? ) => { in ut_integer_encode()
220 let mut integer = IntegerEncoder::new($int, $mask, $pre); in ut_integer_encode()
|
| /commonlibrary/rust/ylong_json/src/reader/ |
| H A D | io_reader.rs | 42 pre: usize, // Last cached location.
50 pre: 0, in new()
93 cacher.cache.extend_from_slice(&self.buf[cacher.pre..]); in load()
94 cacher.pre = 0; in load()
107 if self.cur > cacher.pre { in update_cache()
110 .extend_from_slice(&self.buf[cacher.pre..self.cur]); in update_cache()
112 cacher.pre = self.cur; in update_cache()
191 cacher.pre = self.cur; in start_caching()
194 cache.pre = self.cur; in start_caching()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| H A D | encoder.rs | 428 fn set_index(mut self, index: usize, mask: u8, pre: u8) -> Self { in set_index()
429 self.index = Some(Integer::index(index, mask, pre)); in set_index()
468 fn set_index(mut self, mask: u8, pre: u8) -> Self { in set_index()
469 self.index = Some(Integer::index(0, mask, pre)); in set_index()
499 fn index(index: usize, mask: u8, pre: u8) -> Self { in index()
501 int: IntegerEncoder::new(index, mask, pre), in index()
|
| /commonlibrary/c_utils/base/test/benchmarktest/timer_benchmark_test/ |
| H A D | timer_benchmark_test.cpp | 238 int64_t pre = CurMs(); in BENCHMARK_F() local
241 AssertGreaterThanOrEqual(cur - pre, 10, in BENCHMARK_F()
242 "(cur - pre) was not greater than or equal to 10 as expected.", state); in BENCHMARK_F()
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_timer_test.cpp | 254 int64_t pre = CurMs(); in SleepLoopFunc() local
257 EXPECT_GE(cur - pre, desiredVal); in SleepLoopFunc()
|
| H A D | utils_event_test.cpp | 1044 int64_t pre = CurMs(); in SleepLoop() local
1047 EXPECT_GE(cur - pre, desiredVal); in SleepLoop()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http1.rs | 62 let (part, pre) = {
89 decode_response(message, part, conn, pre)
173 pre: &[u8], in decode_response()
217 let body = HttpBody::new(message.interceptor, length, Box::new(conn), pre)?; in decode_response()
|
| /commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/ |
| H A D | event_benchmark_test.cpp | 1262 int64_t pre = CurMs(); in BENCHMARK_F() local
1265 AssertGreaterThanOrEqual(cur - pre, expectedTimeDiff, in BENCHMARK_F()
1266 "cur - pre was not greater than or equal to expectedTimeDiff as expected.", state); in BENCHMARK_F()
|