Accommodate extension point
This commit is contained in:
parent
c951cea508
commit
650463ff20
|
@ -303,12 +303,17 @@ impl TunnelRelay {
|
||||||
fn handle_inbound_packet(&mut self, t: &mut Activation, p: P::Packet<AnyValue>) -> ActorResult {
|
fn handle_inbound_packet(&mut self, t: &mut Activation, p: P::Packet<AnyValue>) -> ActorResult {
|
||||||
tracing::debug!(packet = ?p, "-->");
|
tracing::debug!(packet = ?p, "-->");
|
||||||
match p {
|
match p {
|
||||||
|
P::Packet::Extension(b) => {
|
||||||
|
let P::Extension { label, fields } = *b;
|
||||||
|
tracing::info!(?label, ?fields, "received Extension from peer");
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
P::Packet::Error(b) => {
|
P::Packet::Error(b) => {
|
||||||
tracing::info!(message = ?b.message.clone(),
|
tracing::info!(message = ?b.message.clone(),
|
||||||
detail = ?b.detail.clone(),
|
detail = ?b.detail.clone(),
|
||||||
"received Error from peer");
|
"received Error from peer");
|
||||||
Err(*b)
|
Err(*b)
|
||||||
},
|
}
|
||||||
P::Packet::Turn(b) => {
|
P::Packet::Turn(b) => {
|
||||||
let P::Turn(events) = *b;
|
let P::Turn(events) = *b;
|
||||||
for P::TurnEvent { oid, event } in events {
|
for P::TurnEvent { oid, event } in events {
|
||||||
|
|
Loading…
Reference in New Issue