aboutsummaryrefslogtreecommitdiff
path: root/tests/test_bytes.rs
diff options
context:
space:
mode:
authorHaibo Huang <hhb@google.com>2021-01-11 19:30:56 -0800
committerHaibo Huang <hhb@google.com>2021-01-11 19:30:56 -0800
commit49f37ac424d7df1f8ee1989d8f3b5ceb6b6a9ea0 (patch)
tree9fee875946571b5e3156284b964bf3617ced0ca1 /tests/test_bytes.rs
parent2b95745e709cfb52a81074e4882d0a2cbaaea2ed (diff)
downloadbytes-49f37ac424d7df1f8ee1989d8f3b5ceb6b6a9ea0.tar.gz
Upgrade rust/crates/bytes to 1.0.1
Test: make Change-Id: Ie9751d0251a3844858395badc8546303dcddeb24
Diffstat (limited to 'tests/test_bytes.rs')
-rw-r--r--tests/test_bytes.rs17
1 files changed, 9 insertions, 8 deletions
diff --git a/tests/test_bytes.rs b/tests/test_bytes.rs
index 6b106a6..b9e6ce4 100644
--- a/tests/test_bytes.rs
+++ b/tests/test_bytes.rs
@@ -461,6 +461,7 @@ fn reserve_allocates_at_least_original_capacity() {
}
#[test]
+#[cfg_attr(miri, ignore)] // Miri is too slow
fn reserve_max_original_capacity_value() {
const SIZE: usize = 128 * 1024;
@@ -608,15 +609,15 @@ fn advance_past_len() {
#[test]
// Only run these tests on little endian systems. CI uses qemu for testing
-// little endian... and qemu doesn't really support threading all that well.
-#[cfg(target_endian = "little")]
+// big endian... and qemu doesn't really support threading all that well.
+#[cfg(any(miri, target_endian = "little"))]
fn stress() {
// Tests promoting a buffer from a vec -> shared in a concurrent situation
use std::sync::{Arc, Barrier};
use std::thread;
const THREADS: usize = 8;
- const ITERS: usize = 1_000;
+ const ITERS: usize = if cfg!(miri) { 100 } else { 1_000 };
for i in 0..ITERS {
let data = [i as u8; 256];
@@ -912,20 +913,20 @@ fn bytes_buf_mut_advance() {
let mut bytes = BytesMut::with_capacity(1024);
unsafe {
- let ptr = bytes.bytes_mut().as_ptr();
- assert_eq!(1024, bytes.bytes_mut().len());
+ let ptr = bytes.chunk_mut().as_mut_ptr();
+ assert_eq!(1024, bytes.chunk_mut().len());
bytes.advance_mut(10);
- let next = bytes.bytes_mut().as_ptr();
- assert_eq!(1024 - 10, bytes.bytes_mut().len());
+ let next = bytes.chunk_mut().as_mut_ptr();
+ assert_eq!(1024 - 10, bytes.chunk_mut().len());
assert_eq!(ptr.offset(10), next);
// advance to the end
bytes.advance_mut(1024 - 10);
// The buffer size is doubled
- assert_eq!(1024, bytes.bytes_mut().len());
+ assert_eq!(1024, bytes.chunk_mut().len());
}
}