oxen-io/lokinet
1
1
Fork 0
mirror of https://github.com/oxen-io/lokinet synced 2023-12-14 06:53:00 +01:00
Code Issues Projects Releases Wiki Activity

TELL ME WHEN IT WORKS

Browse source
This commit is contained in:
dr7ana 2023-12-07 16:33:06 -08:00
parent d00257b9f0
commit 8af38d3d44
3 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
llarp/link/link_manager.cpp
View file

@ -356,10 +356,10 @@ namespace llarp
std::move(on_close)); std::move(on_close));
rv) rv)
{ {
log::info(quic_cat, "Connection to {} successfully established!", remote_addr); log::info(quic_cat, "Begun establishing connection to {}", remote_addr);
return; return;
} }
log::warning(quic_cat, "Connection to {} successfully established!", remote_addr); log::warning(quic_cat, "Failed to begin establishing connection to {}", remote_addr);
} }
// TODO: should we add routes here now that Router::SessionOpen is gone? // TODO: should we add routes here now that Router::SessionOpen is gone?
@ -370,6 +370,12 @@ namespace llarp
const auto& scid = conn_interface.scid(); const auto& scid = conn_interface.scid();
const auto& rid = ep.connid_map[scid]; const auto& rid = ep.connid_map[scid];
log::critical(
logcat,
"SERVICE NODE (RID:{}) ESTABLISHED CONNECTION TO RID:{}",
_router.local_rid(),
rid);
// check to see if this connection was established while we were attempting to queue // check to see if this connection was established while we were attempting to queue
// messages to the remote // messages to the remote
if (auto itr = pending_conn_msg_queue.find(rid); itr != pending_conn_msg_queue.end()) if (auto itr = pending_conn_msg_queue.find(rid); itr != pending_conn_msg_queue.end())

1
llarp/nodedb.cpp
View file

@ -368,7 +368,6 @@ namespace llarp
} }
std::vector<RouterID> needed; std::vector<RouterID> needed;
const auto now = time_point_now(); const auto now = time_point_now();
for (const auto& [rid, rc] : rc_lookup) for (const auto& [rid, rc] : rc_lookup)

2
llarp/router/router.cpp
View file

@ -526,7 +526,7 @@ namespace llarp
void void
Router::save_rc() Router::save_rc()
{ {
_node_db->put_rc(router_contact.view()); // _node_db->put_rc(router_contact.view());
log::info(logcat, "Saving RC file to {}", our_rc_file); log::info(logcat, "Saving RC file to {}", our_rc_file);
queue_disk_io([&]() { router_contact.write(our_rc_file); }); queue_disk_io([&]() { router_contact.write(our_rc_file); });
} }