|
|
|
@ -26,11 +26,10 @@
|
|
|
|
|
|
|
|
|
|
//! This module contains automated tests for queries
|
|
|
|
|
|
|
|
|
|
use crate::config::SnapshotConfig;
|
|
|
|
|
use crate::coredb::CoreDB;
|
|
|
|
|
use crate::dbnet;
|
|
|
|
|
use crate::BGSave;
|
|
|
|
|
use std::net::SocketAddr;
|
|
|
|
|
use std::sync::Arc;
|
|
|
|
|
use tokio::net::TcpListener;
|
|
|
|
|
mod kvengine;
|
|
|
|
|
|
|
|
|
@ -50,7 +49,7 @@ macro_rules! __func__ {
|
|
|
|
|
async fn start_test_server(port: u16, db: Option<CoreDB>) -> SocketAddr {
|
|
|
|
|
let mut socket = String::from("127.0.0.1:");
|
|
|
|
|
socket.push_str(&port.to_string());
|
|
|
|
|
let db = db.unwrap_or(CoreDB::new(BGSave::Disabled, SnapshotConfig::default(), None).unwrap());
|
|
|
|
|
let db = db.unwrap_or(CoreDB::new_empty(0, Arc::new(None)));
|
|
|
|
|
let listener = TcpListener::bind(socket)
|
|
|
|
|
.await
|
|
|
|
|
.expect(&format!("Failed to bind to port {}", port));
|
|
|
|
|