Index: remoting/client/rectangle_update_decoder.cc |
diff --git a/remoting/client/rectangle_update_decoder.cc b/remoting/client/rectangle_update_decoder.cc |
index 741357d0875673cf0d27d8994031cba8019db60f..106c9934bbec89ea5361db5b3629fd61bf70540c 100644 |
--- a/remoting/client/rectangle_update_decoder.cc |
+++ b/remoting/client/rectangle_update_decoder.cc |
@@ -255,36 +255,28 @@ void RectangleUpdateDecoder::ProcessVideoPacket(scoped_ptr<VideoPacket> packet, |
} |
// Measure the latency between the last packet being received and presented. |
- bool last_packet = (packet->flags() & VideoPacket::LAST_PACKET) != 0; |
- base::Time decode_start; |
- if (last_packet) |
- decode_start = base::Time::Now(); |
+ base::Time decode_start = base::Time::Now(); |
- base::Closure decode_done = |
- base::Bind(&RectangleUpdateDecoder::OnPacketDone, this, |
- last_packet, decode_start, done); |
+ base::Closure decode_done = base::Bind( |
+ &RectangleUpdateDecoder::OnPacketDone, this, decode_start, done); |
decode_task_runner_->PostTask(FROM_HERE, base::Bind( |
&RectangleUpdateDecoder::DecodePacket, this, |
base::Passed(&packet), decode_done)); |
} |
-void RectangleUpdateDecoder::OnPacketDone(bool last_packet, |
- base::Time decode_start, |
+void RectangleUpdateDecoder::OnPacketDone(base::Time decode_start, |
const base::Closure& done) { |
if (!main_task_runner_->BelongsToCurrentThread()) { |
main_task_runner_->PostTask(FROM_HERE, base::Bind( |
&RectangleUpdateDecoder::OnPacketDone, this, |
- last_packet, decode_start, done)); |
+ decode_start, done)); |
return; |
} |
- // Record the latency between the final packet being received and |
- // presented. |
- if (last_packet) { |
- stats_.video_decode_ms()->Record( |
- (base::Time::Now() - decode_start).InMilliseconds()); |
- } |
+ // Record the latency between the packet being received and presented. |
+ stats_.video_decode_ms()->Record( |
+ (base::Time::Now() - decode_start).InMilliseconds()); |
done.Run(); |
} |