Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Replacing Tokio's TcpStream with async-std TcpStream #475

Merged
merged 13 commits into from
Jan 30, 2024
Merged

Replacing Tokio's TcpStream with async-std TcpStream #475

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
13d839e
adding trace logs to every function call.
b-yap Jan 11, 2024
68c9809
adding trace logs for ready status
b-yap Jan 15, 2024
fc3fb12
show peer_addr and local_addr
b-yap Jan 16, 2024
828da4b
adding std::net::TcpStream
b-yap Jan 16, 2024
4ec63a4
convert std::net::TcpStream to tokio
b-yap Jan 16, 2024
de9ac93
completely change tokio to std::net
b-yap Jan 17, 2024
2d390fb
code cleanup, ready for review
b-yap Jan 18, 2024
1a71b00
remove unnecessary features of tokio
b-yap Jan 18, 2024
3ab5d1c
from async to just normal funcs
b-yap Jan 19, 2024
d282826
testing fixes for test not stopping
gianfra-t Jan 19, 2024
d089c0f
set timeout for tests to 180
gianfra-t Jan 19, 2024
3e8c6a9
fixes warnings
gianfra-t Jan 19, 2024
c52db4f
Replace tokio's TcpStream with async-std (#481)
b-yap Jan 26, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
119 changes: 119 additions & 0 deletions Cargo.lock
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

3 changes: 1 addition & 2 deletions clients/stellar-relay-lib/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,11 +36,10 @@ err-derive = "0.3.1"
tokio = { version = "1.0", features = [
"macros", # allows main function to be async
"rt-multi-thread", # for multi-thread runtime
"net", # contains the TcpStream
"sync", # to make channels available
"io-util", # for async read/write operations
"time" # for timeouts and sleep, when reconnecting
] }
async-std = { version = "1.12.0", features = ["attributes"] }

[features]
std = [
Expand Down
2 changes: 1 addition & 1 deletion clients/stellar-relay-lib/examples/connect.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {

let mut overlay_connection = connect_to_stellar_overlay_network(cfg, &secret_key).await?;

while let Ok(Some(msg)) = overlay_connection.listen().await {
while let Ok(Some(msg)) = overlay_connection.listen() {
match msg {
StellarMessage::ScpMessage(msg) => {
let node_id = msg.statement.node_id.to_encoding();
Expand Down
Loading
Loading