Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: Remove some unneeded type annotations

pull/24376/head
Carol (Nichols || Goulding) 2020-06-18 09:12:17 -04:00
parent 8bc25e92bf
commit df75db6870
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
delorean_tsm/src/reader.rs
View File

@ -65,7 +65,7 @@ where
pub fn try_new(mut r: R, len: usize) -> Result<Self, TSMError> {
// determine offset to index, which is held in last 8 bytes of file.
r.seek(SeekFrom::End(-8))?;
let mut buf: [u8; 8] = [0; 8];
let mut buf = [0u8; 8];
r.read_exact(&mut buf)?;
let index_offset = u64::from_be_bytes(buf);
@ -86,7 +86,7 @@ where
/// when the index has been exhausted.
fn next_index_entry(&mut self) -> Result<IndexEntry, TSMError> {
// read length of series key
let mut buf: [u8; 2] = [0; 2];
let mut buf = [0u8; 2];
self.r.read_exact(&mut buf)?;
self.curr_offset += 2;
let key_len = u16::from_be_bytes(buf);
@ -120,7 +120,7 @@ where
/// they have all been read for an index entry.
fn next_block_entry(&mut self) -> Result<Block, TSMError> {
// read min time on block entry
let mut buf: [u8; 8] = [0; 8];
let mut buf = [0u8; 8];
self.r.read_exact(&mut buf[..])?;
self.curr_offset += 8;
let min_time = i64::from_be_bytes(buf);
@ -212,7 +212,7 @@ impl IndexEntry {
}
fn extract_id_from_slice(data: &[u8]) -> InfluxID {
let mut buf: [u8; 8] = [0; 8];
let mut buf = [0u8; 8];
buf.copy_from_slice(&data[..8]);
InfluxID::from_be_bytes(buf)
}
@ -260,7 +260,7 @@ where
idx += 1;
// first decode the timestamp block.
let mut ts: Vec<i64> = Vec::with_capacity(MAX_BLOCK_VALUES); // 1000 is the max block size
let mut ts = Vec::with_capacity(MAX_BLOCK_VALUES); // 1000 is the max block size
let (len, n) = u64::decode_var(&data[idx..]); // size of timestamp block
idx += n;
encoders::timestamp::decode(&data[idx..idx + (len as usize)], &mut ts).map_err(|e| {
@ -273,7 +273,7 @@ where
match block_type {
BlockType::Float => {
// values will be same length as time-stamps.
let mut values: Vec<f64> = Vec::with_capacity(ts.len());
let mut values = Vec::with_capacity(ts.len());
encoders::float::decode_influxdb(&data[idx..], &mut values).map_err(|e| {
TSMError {
description: e.to_string(),
@ -284,7 +284,7 @@ where
}
BlockType::Integer => {
// values will be same length as time-stamps.
let mut values: Vec<i64> = Vec::with_capacity(ts.len());
let mut values = Vec::with_capacity(ts.len());
encoders::integer::decode(&data[idx..], &mut values).map_err(|e| TSMError {
description: e.to_string(),
})?;
@ -341,7 +341,7 @@ mod tests {
let reader = TSMIndexReader::try_new(BufReader::new(Cursor::new(buf)), 4_222_248).unwrap();
let mut got_blocks: u64 = 0;
let mut got_blocks = 0;
let mut got_min_time = i64::MAX;
let mut got_max_time = i64::MIN;