Skip to content

Commit 986f17f

Browse files
committed
chore: clean up as usage, MAX
* `as` operator could cause all sorts of surprises, plus constants do not needed it because they can be written as `1_u8` or even `1u8`
1 parent 5ef95f8 commit 986f17f

File tree

4 files changed

+48
-54
lines changed

4 files changed

+48
-54
lines changed

src/fixed_tests.rs

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -12,63 +12,63 @@ mod tests {
1212

1313
#[test]
1414
fn test_u32_enc() {
15-
let result = (32 as u32).encode_fixed_vec();
15+
let result = 32_u32.encode_fixed_vec();
1616
assert_eq!(result, vec![32, 0, 0, 0]);
1717
}
1818
#[test]
1919
fn test_u16_enc() {
20-
let result = (256 as u16).encode_fixed_vec();
20+
let result = 256_u16.encode_fixed_vec();
2121
assert_eq!(result, vec![0, 1]);
2222
}
2323
#[test]
2424
fn test_u16_endian() {
25-
let le = 1 as u16;
25+
let le = 1_u16;
2626
let be = le.switch_endianness();
2727
assert_eq!(be, 256);
2828
}
2929
#[test]
3030
fn test_u32_endian() {
31-
let le = 1 as u32;
31+
let le = 1_u32;
3232
let be = le.switch_endianness();
3333
assert_eq!(be, 1 << 24);
3434
assert_eq!(be.switch_endianness(), 1);
3535
}
3636
#[test]
37-
fn test_allones_endian() {
37+
fn test_all_ones_endian() {
3838
assert_eq!(u64::MAX.switch_endianness(), u64::MAX);
3939
}
4040
#[test]
4141
fn test_signed_endian() {
4242
// x86: two's complement, LE.
43-
let le = -2 as i16;
43+
let le = -2_i16;
4444
let be = le.switch_endianness();
4545
assert_eq!(be, -257);
4646
}
4747
#[test]
4848
fn test_u8_enc() {
49-
let result = (255 as u8).encode_fixed_vec();
49+
let result = 255_u8.encode_fixed_vec();
5050
assert_eq!(result, vec![255]);
5151
}
5252
#[test]
5353
fn test_i8_enc() {
54-
let result = (-1 as i8).encode_fixed_vec();
54+
let result = (-1_i8).encode_fixed_vec();
5555
assert_eq!(result, vec![255]);
5656
}
5757
#[test]
5858
fn test_i16_enc() {
59-
let result = (-32768 as i16).encode_fixed_vec();
59+
let result = (-32768_i16).encode_fixed_vec();
6060
assert_eq!(result, vec![0, 128]);
6161
}
6262
#[test]
6363
fn test_i32_enc() {
64-
let result = (-32767 as i32).encode_fixed_vec();
64+
let result = (-32767_i32).encode_fixed_vec();
6565
assert_eq!(result, vec![1, 128, 255, 255]);
6666
}
6767

6868
// This must fail to compile:
6969
/*
7070
fn test() -> &'static [u8] {
71-
let int = -32767 as i32;
71+
let int = -32767_i32;
7272
let result = int.encode_fixed_light();
7373
assert_eq!(result, &[1, 128, 255, 255]);
7474
result
@@ -77,7 +77,7 @@ mod tests {
7777

7878
#[test]
7979
fn test_i32_enc_light() {
80-
let int = -32767 as i32;
80+
let int = -32767_i32;
8181
let result = int.encode_fixed_light();
8282
assert_eq!(result, [1, 128, 255, 255]);
8383
}
@@ -137,8 +137,8 @@ mod tests {
137137
#[should_panic]
138138
#[test]
139139
fn test_invalid_encode_size() {
140-
let mut buf = [0 as u8; 4];
141-
(11 as u64).encode_fixed(&mut buf).unwrap();
140+
let mut buf = [0_u8; 4];
141+
11_u64.encode_fixed(&mut buf).unwrap();
142142
}
143143

144144
#[cfg(any(feature = "tokio_async", feature = "futures_async"))]

src/varint.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ use std::mem::size_of;
22

33
/// Most-significant byte, == 0x80
44
pub const MSB: u8 = 0b1000_0000;
5-
/// All bits except for the most significant. Can be used as bitmask to drop the most-signficant
5+
/// All bits except for the most significant. Can be used as bitmask to drop the most-significant
66
/// bit using `&` (binary-and).
77
const DROP_MSB: u8 = 0b0111_1111;
88

@@ -134,9 +134,9 @@ impl VarInt for u64 {
134134
let mut shift = 0;
135135

136136
let mut success = false;
137-
for b in src.iter() {
137+
for b in src {
138138
let msb_dropped = b & DROP_MSB;
139-
result |= (msb_dropped as u64) << shift;
139+
result |= u64::from(msb_dropped) << shift;
140140
shift += 7;
141141

142142
if b & MSB == 0 || shift > (9 * 7) {
@@ -177,7 +177,7 @@ impl VarInt for i64 {
177177
#[inline]
178178
fn decode_var(src: &[u8]) -> Option<(Self, usize)> {
179179
if let Some((result, size)) = u64::decode_var(src) {
180-
Some((zigzag_decode(result) as Self, size))
180+
Some((zigzag_decode(result), size))
181181
} else {
182182
None
183183
}

src/varint_tests.rs

Lines changed: 24 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -11,29 +11,29 @@ mod tests {
1111

1212
#[test]
1313
fn test_required_space() {
14-
assert_eq!((0 as u32).required_space(), 1);
15-
assert_eq!((1 as u32).required_space(), 1);
16-
assert_eq!((128 as u32).required_space(), 2);
17-
assert_eq!((16384 as u32).required_space(), 3);
18-
assert_eq!((2097151 as u32).required_space(), 3);
19-
assert_eq!((2097152 as u32).required_space(), 4);
14+
assert_eq!(0_u32.required_space(), 1);
15+
assert_eq!(1_u32.required_space(), 1);
16+
assert_eq!(128_u32.required_space(), 2);
17+
assert_eq!(16384_u32.required_space(), 3);
18+
assert_eq!(2097151_u32.required_space(), 3);
19+
assert_eq!(2097152_u32.required_space(), 4);
2020
}
2121

2222
#[test]
2323
fn test_encode_u64() {
24-
assert_eq!((0 as u32).encode_var_vec(), vec![0b00000000]);
25-
assert_eq!((300 as u32).encode_var_vec(), vec![0b10101100, 0b00000010]);
24+
assert_eq!(0_u32.encode_var_vec(), vec![0b00000000]);
25+
assert_eq!(300_u32.encode_var_vec(), vec![0b10101100, 0b00000010]);
2626
}
2727

2828
#[test]
2929
fn test_identity_u64() {
30-
for i in 1 as u64..100 {
30+
for i in 1_u64..100 {
3131
assert_eq!(
3232
u64::decode_var(i.encode_var_vec().as_slice()).unwrap(),
3333
(i, 1)
3434
);
3535
}
36-
for i in 16400 as u64..16500 {
36+
for i in 16400_u64..16500 {
3737
assert_eq!(
3838
u64::decode_var(i.encode_var_vec().as_slice()).unwrap(),
3939
(i, 3)
@@ -46,28 +46,25 @@ mod tests {
4646
let max_vec_encoded = vec![0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0x01];
4747
assert_eq!(
4848
u64::decode_var(max_vec_encoded.as_slice()).unwrap().0,
49-
u64::max_value()
49+
u64::MAX
5050
);
5151
}
5252

5353
#[test]
5454
fn test_encode_i64() {
55-
assert_eq!((0 as i64).encode_var_vec(), (0 as u32).encode_var_vec());
56-
assert_eq!((150 as i64).encode_var_vec(), (300 as u32).encode_var_vec());
55+
assert_eq!(0_i64.encode_var_vec(), 0_u32.encode_var_vec());
56+
assert_eq!(150_i64.encode_var_vec(), 300_u32.encode_var_vec());
57+
assert_eq!((-150_i64).encode_var_vec(), 299_u32.encode_var_vec());
5758
assert_eq!(
58-
(-150 as i64).encode_var_vec(),
59-
(299 as u32).encode_var_vec()
59+
(-2147483648_i64).encode_var_vec(),
60+
4294967295_u64.encode_var_vec()
6061
);
6162
assert_eq!(
62-
(-2147483648 as i64).encode_var_vec(),
63-
(4294967295 as u64).encode_var_vec()
64-
);
65-
assert_eq!(
66-
(i64::max_value() as i64).encode_var_vec(),
63+
i64::MAX.encode_var_vec(),
6764
&[0xFE, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0x01]
6865
);
6966
assert_eq!(
70-
(i64::min_value() as i64).encode_var_vec(),
67+
i64::MIN.encode_var_vec(),
7168
&[0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0x01]
7269
);
7370
}
@@ -77,7 +74,7 @@ mod tests {
7774
let min_vec_encoded = vec![0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0x01];
7875
assert_eq!(
7976
i64::decode_var(min_vec_encoded.as_slice()).unwrap().0,
80-
i64::min_value()
77+
i64::MIN
8178
);
8279
}
8380

@@ -86,17 +83,14 @@ mod tests {
8683
let max_vec_encoded = vec![0xFE, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0x01];
8784
assert_eq!(
8885
i64::decode_var(max_vec_encoded.as_slice()).unwrap().0,
89-
i64::max_value()
86+
i64::MAX
9087
);
9188
}
9289

9390
#[test]
9491
fn test_encode_i16() {
95-
assert_eq!((150 as i16).encode_var_vec(), (300 as u32).encode_var_vec());
96-
assert_eq!(
97-
(-150 as i16).encode_var_vec(),
98-
(299 as u32).encode_var_vec()
99-
);
92+
assert_eq!(150_i16.encode_var_vec(), 300_u32.encode_var_vec());
93+
assert_eq!((-150_i16).encode_var_vec(), 299_u32.encode_var_vec());
10094
}
10195

10296
#[test]
@@ -155,7 +149,7 @@ mod tests {
155149

156150
#[test]
157151
fn test_unterminated_varint() {
158-
let buf = vec![0xff as u8; 12];
152+
let buf = vec![0xff_u8; 12];
159153
let mut read = buf.as_slice();
160154
assert!(read.read_varint::<u64>().is_err());
161155
}
@@ -203,7 +197,7 @@ mod tests {
203197

204198
#[test]
205199
fn test_regression_22() {
206-
let encoded: Vec<u8> = (0x112233 as u64).encode_var_vec();
200+
let encoded: Vec<u8> = 0x112233_u64.encode_var_vec();
207201
assert_eq!(
208202
encoded.as_slice().read_varint::<i8>().unwrap_err().kind(),
209203
std::io::ErrorKind::InvalidData

src/writer.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -60,18 +60,18 @@ pub trait FixedIntAsyncWriter {
6060
impl<AW: AsyncWrite + Unpin> FixedIntAsyncWriter for AW {
6161
async fn write_fixedint_async<FI: FixedInt>(&mut self, n: FI) -> Result<usize> {
6262
let mut buf = [0_u8; 8];
63-
n.encode_fixed(&mut buf[..std::mem::size_of::<FI>()]);
64-
self.write_all(&buf[..std::mem::size_of::<FI>()]).await?;
65-
Ok(std::mem::size_of::<FI>())
63+
n.encode_fixed(&mut buf[..size_of::<FI>()]);
64+
self.write_all(&buf[..size_of::<FI>()]).await?;
65+
Ok(size_of::<FI>())
6666
}
6767
}
6868

6969
impl<W: Write> FixedIntWriter for W {
7070
fn write_fixedint<FI: FixedInt>(&mut self, n: FI) -> Result<usize> {
7171
let mut buf = [0_u8; 8];
72-
n.encode_fixed(&mut buf[..std::mem::size_of::<FI>()]);
72+
n.encode_fixed(&mut buf[..size_of::<FI>()]);
7373

74-
self.write_all(&buf[..std::mem::size_of::<FI>()])?;
75-
Ok(std::mem::size_of::<FI>())
74+
self.write_all(&buf[..size_of::<FI>()])?;
75+
Ok(size_of::<FI>())
7676
}
7777
}

0 commit comments

Comments
 (0)