remove dead code in concurrent sim regression tests

Author: PThorpe92

testing/concurrent-simulator/regression_tests.rs

@@ -418,110 +418,6 @@ fn count_rows_in_table(conn: &Arc<Connection>, table_name: &str) -> i64 {
     count
 }
 
-#[cfg(all(any(unix, target_os = "windows"), target_pointer_width = "64"))]
-fn read_simple_kv_length(db_path: &Path, table_name: &str, key: &str) -> Option<i64> {
-    let io: Arc<dyn IO> = multiprocess_test_io();
-    let reopened = Database::open_file_with_flags(
-        io,
-        db_path.to_str().expect("db path utf8"),
-        OpenFlags::ReadOnly,
-        multiprocess_wal_db_opts(),
-        None,
-    )
-    .expect("open observer database");
-    let conn = reopened.connect().expect("connect observer db");
-    let sql = format!("select length(value) from {table_name} where key='{key}'");
-    for _ in 0..32 {
-        let mut stmt = match conn.prepare(sql.clone()) {
-            Ok(stmt) => stmt,
-            Err(LimboError::SchemaUpdated | LimboError::SchemaConflict) => {
-                conn.maybe_reparse_schema()
-                    .expect("observer reparse after schema change");
-                continue;
-            }
-            Err(LimboError::Busy | LimboError::BusySnapshot | LimboError::TableLocked) => {
-                continue;
-            }
-            Err(err) => panic!("observer prepare should succeed: {err}"),
-        };
-        let mut result = None;
-        match stmt.run_with_row_callback(|row| {
-            result = Some(row.get::<i64>(0).expect("length column"));
-            Ok(())
-        }) {
-            Ok(()) => return result,
-            Err(LimboError::SchemaUpdated | LimboError::SchemaConflict) => {
-                drop(stmt);
-                conn.maybe_reparse_schema()
-                    .expect("observer reparse after schema change");
-                continue;
-            }
-            Err(LimboError::Busy | LimboError::BusySnapshot | LimboError::TableLocked) => {
-                continue;
-            }
-            Err(err) => panic!("observer query should succeed: {err}"),
-        }
-    }
-    panic!("observer query did not stabilize after transient multiprocess errors");
-}
-
-#[cfg(all(any(unix, target_os = "windows"), target_pointer_width = "64"))]
-fn probe_optional_int_via_fresh_worker(whopper: &MultiprocessWhopper, sql: String) -> Option<i64> {
-    for _ in 0..8 {
-        let (_startup, result) = whopper
-            .execute_sql_via_fresh_worker(sql.clone())
-            .expect("probe via fresh worker should succeed");
-        match result {
-            Ok(rows) => {
-                return match rows.as_slice() {
-                    [] => None,
-                    [row] => Some(row[0].as_int().expect("probe column should be integer")),
-                    _ => panic!("probe query should return at most one row, got {rows:?}"),
-                };
-            }
-            Err(
-                LimboError::SchemaUpdated
-                | LimboError::SchemaConflict
-                | LimboError::Busy
-                | LimboError::BusySnapshot
-                | LimboError::TableLocked,
-            ) => continue,
-            Err(err) => panic!("probe SQL should succeed: {err}"),
-        }
-    }
-    panic!("fresh-worker probe did not stabilize after transient multiprocess errors");
-}
-
-#[cfg(all(any(unix, target_os = "windows"), target_pointer_width = "64"))]
-fn probe_table_rootpage_via_fresh_worker(
-    whopper: &MultiprocessWhopper,
-    table_name: &str,
-) -> Option<i64> {
-    probe_optional_int_via_fresh_worker(
-        whopper,
-        format!("select rootpage from sqlite_schema where type='table' and name='{table_name}'"),
-    )
-}
-
-#[cfg(all(any(unix, target_os = "windows"), target_pointer_width = "64"))]
-fn probe_simple_kv_length_via_fresh_worker(
-    whopper: &MultiprocessWhopper,
-    table_name: &str,
-    key: &str,
-) -> Option<i64> {
-    probe_optional_int_via_fresh_worker(
-        whopper,
-        format!("select length(value) from {table_name} where key='{key}'"),
-    )
-}
-
-#[cfg(all(any(unix, target_os = "windows"), target_pointer_width = "64"))]
-fn advance_seeded_whopper_to_step(whopper: &mut MultiprocessWhopper, step_after_execution: usize) {
-    while whopper.current_step < step_after_execution {
-        whopper.step().expect("seeded whopper step");
-    }
-}
-
 #[cfg(all(any(unix, target_os = "windows"), target_pointer_width = "64"))]
 #[test]
 fn multiprocess_restart_reuses_persisted_tshm_without_disk_scan() {