Skip to content

Commit 725d31a

Browse files
authored
Refactor WithBuffers to be more in line with the ReadWrite abstraction (#947)
* Refactor `WithBuffers` to be more in line with the `ReadWrite` abstraction * Fix logs showing wrong bytes count * Docfix
1 parent c2e2ff3 commit 725d31a

3 files changed

Lines changed: 346 additions & 468 deletions

File tree

full-node/src/network_service.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1256,6 +1256,7 @@ async fn background_task(mut inner: Inner) {
12561256

12571257
(inner.tasks_executor)(Box::pin(tasks::established_connection_task(
12581258
inner.log_callback.clone(),
1259+
info.multiaddr.to_string(),
12591260
socket,
12601261
connection_id,
12611262
connection_task,
@@ -1275,14 +1276,15 @@ async fn background_task(mut inner: Inner) {
12751276
inner.network.add_single_stream_incoming_connection(
12761277
when_connected,
12771278
service::SingleStreamHandshakeKind::MultistreamSelectNoiseYamux,
1278-
multiaddr,
1279+
multiaddr.clone(),
12791280
);
12801281

12811282
let (tx, rx) = channel::bounded(16); // TODO: ?!
12821283
inner.active_connections.insert(connection_id, tx);
12831284

12841285
(inner.tasks_executor)(Box::pin(tasks::established_connection_task(
12851286
inner.log_callback.clone(),
1287+
multiaddr.to_string(),
12861288
socket,
12871289
connection_id,
12881290
connection_task,

0 commit comments

Comments
 (0)