mirror of
https://github.com/oxen-io/lokinet
synced 2023-12-14 06:53:00 +01:00
kick
This commit is contained in:
parent
22edd63284
commit
0bf3a3323a
2
external/oxen-libquic
vendored
2
external/oxen-libquic
vendored
|
@ -1 +1 @@
|
||||||
Subproject commit 69e577ffd788e85091eaf9ecde9b3ec2e00727ea
|
Subproject commit ad8904debc55f9495667e8571ee5bb963156d54e
|
|
@ -135,7 +135,7 @@ namespace llarp
|
||||||
[this, msg = std::move(m)]() mutable { handle_gossip_rc(std::move(msg)); });
|
[this, msg = std::move(m)]() mutable { handle_gossip_rc(std::move(msg)); });
|
||||||
});
|
});
|
||||||
|
|
||||||
s->register_command("bfetc_rcs"s, [this, rid](oxen::quic::message m) {
|
s->register_command("bfetch_rcs"s, [this, rid](oxen::quic::message m) {
|
||||||
_router.loop()->call(
|
_router.loop()->call(
|
||||||
[this, msg = std::move(m)]() mutable { handle_fetch_bootstrap_rcs(std::move(msg)); });
|
[this, msg = std::move(m)]() mutable { handle_fetch_bootstrap_rcs(std::move(msg)); });
|
||||||
});
|
});
|
||||||
|
@ -385,7 +385,7 @@ namespace llarp
|
||||||
ep.connid_map.emplace(scid, rid);
|
ep.connid_map.emplace(scid, rid);
|
||||||
auto [itr, b] = ep.conns.emplace(rid, nullptr);
|
auto [itr, b] = ep.conns.emplace(rid, nullptr);
|
||||||
|
|
||||||
auto control_stream = ci.template get_new_stream<oxen::quic::BTRequestStream>();
|
auto control_stream = ci.get_stream<oxen::quic::BTRequestStream>(0);
|
||||||
itr->second = std::make_shared<link::Connection>(ci.shared_from_this(), control_stream, rc);
|
itr->second = std::make_shared<link::Connection>(ci.shared_from_this(), control_stream, rc);
|
||||||
log::critical(logcat, "Successfully configured inbound connection fom {}; storing RC...", rid);
|
log::critical(logcat, "Successfully configured inbound connection fom {}; storing RC...", rid);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue