refactor video_ack_required
This commit is contained in:
parent
5a0f8d008e
commit
3ec69b6d97
@ -54,6 +54,7 @@ message LoginRequest {
|
|||||||
FileTransfer file_transfer = 7;
|
FileTransfer file_transfer = 7;
|
||||||
PortForward port_forward = 8;
|
PortForward port_forward = 8;
|
||||||
}
|
}
|
||||||
|
bool video_ack_required = 9;
|
||||||
}
|
}
|
||||||
|
|
||||||
message ChatMessage { string text = 1; }
|
message ChatMessage { string text = 1; }
|
||||||
|
@ -684,6 +684,7 @@ impl Connection {
|
|||||||
if let Some(o) = lr.option.as_ref() {
|
if let Some(o) = lr.option.as_ref() {
|
||||||
self.update_option(o).await;
|
self.update_option(o).await;
|
||||||
}
|
}
|
||||||
|
self.video_ack_required = lr.video_ack_required;
|
||||||
if self.authorized {
|
if self.authorized {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
@ -932,9 +933,6 @@ impl Connection {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
Some(misc::Union::video_received(_)) => {
|
Some(misc::Union::video_received(_)) => {
|
||||||
if !self.video_ack_required {
|
|
||||||
self.video_ack_required = true;
|
|
||||||
}
|
|
||||||
video_service::notify_video_frame_feched(self.inner.id, Some(Instant::now().into()));
|
video_service::notify_video_frame_feched(self.inner.id, Some(Instant::now().into()));
|
||||||
}
|
}
|
||||||
_ => {}
|
_ => {}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user