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

test: ensure that `find_last_transaction_timestamp` indeed returns the last timestamp

pull/24376/head
Marco Neumann 2021-06-02 09:55:58 +02:00
parent 98e413d5a9
commit e5b65e10ac
1 changed files with 61 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
parquet_file/src/catalog.rs
View File

@ -1828,6 +1828,7 @@ mod tests {
struct TestTrace {
tkeys: Vec<TransactionKey>,
states: Vec<TestCatalogState>,
post_timestamps: Vec<DateTime<Utc>>,
}
impl TestTrace {
@ -1835,6 +1836,7 @@ mod tests {
Self {
tkeys: vec![],
states: vec![],
post_timestamps: vec![],
}
}
@ -1842,6 +1844,7 @@ mod tests {
self.tkeys
.push(catalog.inner.read().previous_tkey.clone().unwrap());
self.states.push(catalog.state().deref().clone());
self.post_timestamps.push(Utc::now());
}
}
@ -2153,13 +2156,28 @@ mod tests {
let object_store = make_object_store();
let server_id = make_server_id();
let db_name = "db1";
assert_single_catalog_inmem_works(&object_store, server_id, db_name).await;
let trace = assert_single_catalog_inmem_works(&object_store, server_id, db_name).await;
let ts = find_last_transaction_timestamp(&object_store, server_id, db_name)
.await
.unwrap()
.unwrap();
// last trace entry is an aborted transaction, so the valid transaction timestamp is the third last
let second_last_committed_end_ts = trace.post_timestamps[trace.post_timestamps.len() - 3];
assert!(
find_last_transaction_timestamp(&object_store, server_id, db_name)
.await
.unwrap()
.is_some()
ts > second_last_committed_end_ts,
"failed: last start ts ({}) > second last committed end ts ({})",
ts,
second_last_committed_end_ts
);
let last_committed_end_ts = trace.post_timestamps[trace.post_timestamps.len() - 2];
assert!(
ts < last_committed_end_ts,
"failed: last start ts ({}) < last committed end ts ({})",
ts,
last_committed_end_ts
);
}
@ -2194,11 +2212,26 @@ mod tests {
.await
.unwrap();
let ts = find_last_transaction_timestamp(&object_store, server_id, db_name)
.await
.unwrap()
.unwrap();
// last trace entry is an aborted transaction, so the valid transaction timestamp is the third last
let second_last_committed_end_ts = trace.post_timestamps[trace.post_timestamps.len() - 3];
assert!(
find_last_transaction_timestamp(&object_store, server_id, db_name)
.await
.unwrap()
.is_some()
ts > second_last_committed_end_ts,
"failed: last start ts ({}) > second last committed end ts ({})",
ts,
second_last_committed_end_ts
);
let last_committed_end_ts = trace.post_timestamps[trace.post_timestamps.len() - 2];
assert!(
ts < last_committed_end_ts,
"failed: last start ts ({}) < last committed end ts ({})",
ts,
last_committed_end_ts
);
}
@ -2224,11 +2257,26 @@ mod tests {
.await
.unwrap();
let ts = find_last_transaction_timestamp(&object_store, server_id, db_name)
.await
.unwrap()
.unwrap();
// last trace entry is an aborted transaction, so the valid transaction timestamp is the third last
let second_last_committed_end_ts = trace.post_timestamps[trace.post_timestamps.len() - 3];
assert!(
find_last_transaction_timestamp(&object_store, server_id, db_name)
.await
.unwrap()
.is_some()
ts > second_last_committed_end_ts,
"failed: last start ts ({}) > second last committed end ts ({})",
ts,
second_last_committed_end_ts
);
let last_committed_end_ts = trace.post_timestamps[trace.post_timestamps.len() - 2];
assert!(
ts < last_committed_end_ts,
"failed: last start ts ({}) < last committed end ts ({})",
ts,
last_committed_end_ts
);
}