adding more logs to test failing tests

This commit is contained in:
godmodegalactus 2024-10-07 21:08:49 +02:00
parent 724ab79adc
commit d30e74542b
No known key found for this signature in database
GPG Key ID: 22DA4A30887FDA3C
3 changed files with 10 additions and 2 deletions

2
Cargo.lock generated
View File

@ -2921,6 +2921,8 @@ dependencies = [
"bincode", "bincode",
"itertools", "itertools",
"log", "log",
"mio",
"mio_channel",
"pkcs8", "pkcs8",
"quic-geyser-common", "quic-geyser-common",
"quic-geyser-server", "quic-geyser-server",

View File

@ -23,4 +23,6 @@ tokio = { workspace = true }
rand = { workspace = true } rand = { workspace = true }
tracing-subscriber = { workspace = true } tracing-subscriber = { workspace = true }
itertools = { workspace = true } itertools = { workspace = true }
quic-geyser-server = { workspace = true } quic-geyser-server = { workspace = true }
mio = {workspace = true}
mio_channel = {workspace = true}

View File

@ -311,6 +311,7 @@ mod tests {
// wait for client to connect and subscribe // wait for client to connect and subscribe
sleep(Duration::from_secs(2)); sleep(Duration::from_secs(2));
for msg in msgs { for msg in msgs {
log::info!("sending message");
let Message::AccountMsg(account) = msg else { let Message::AccountMsg(account) = msg else {
panic!("should never happen"); panic!("should never happen");
}; };
@ -332,7 +333,7 @@ mod tests {
}) })
}; };
// wait for server to start // wait for server to start
sleep(Duration::from_millis(100)); sleep(Duration::from_millis(10));
// server started // server started
let (client, mut reciever, _tasks) = Client::new( let (client, mut reciever, _tasks) = Client::new(
@ -348,7 +349,10 @@ mod tests {
) )
.await .await
.unwrap(); .unwrap();
log::info!("subscribing");
client.subscribe(vec![Filter::AccountsAll]).await.unwrap(); client.subscribe(vec![Filter::AccountsAll]).await.unwrap();
log::info!("subscribed");
sleep(Duration::from_millis(100)); sleep(Duration::from_millis(100));
for (cnt, message_sent) in msgs.iter().enumerate() { for (cnt, message_sent) in msgs.iter().enumerate() {