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

fix: Use a method instead of holding a lock across an await point

pull/24376/head
Carol (Nichols || Goulding) 2022-05-19 16:09:47 -04:00
parent 15ee3f326f
commit 4bad553dc6
No known key found for this signature in database
GPG Key ID: E907EE5A736F87D4
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ingester/src/data.rs
View File

@ -2206,8 +2206,8 @@ mod tests {
.await
.unwrap();
{
let tables = data.tables.read();
let table = tables.get("mem").unwrap().read().await;
let table_data = data.table_data("mem").unwrap();
let table = table_data.read().await;
let p = table.partition_data.get("1970-01-01").unwrap();
assert_eq!(
p.data.max_persisted_sequence_number,
@ -2229,8 +2229,8 @@ mod tests {
.await
.unwrap();
let tables = data.tables.read();
let table = tables.get("mem").unwrap().read().await;
let table_data = data.table_data("mem").unwrap();
let table = table_data.read().await;
let partition = table.partition_data.get("1970-01-01").unwrap();
assert_eq!(
partition.data.buffer.as_ref().unwrap().min_sequence_number,