diff options
Diffstat (limited to 'remoting')
| -rw-r--r-- | remoting/protocol/rtp_reader.cc | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/remoting/protocol/rtp_reader.cc b/remoting/protocol/rtp_reader.cc index 50c2d82..8f8da7a 100644 --- a/remoting/protocol/rtp_reader.cc +++ b/remoting/protocol/rtp_reader.cc @@ -43,7 +43,7 @@ void RtpReader::Init(net::Socket* socket, } void RtpReader::OnDataReceived(net::IOBuffer* buffer, int data_size) { - RtpPacket* packet = new RtpPacket(); + scoped_ptr<RtpPacket> packet(new RtpPacket()); int header_size = UnpackRtpHeader(reinterpret_cast<uint8*>(buffer->data()), data_size, packet->mutable_header()); if (header_size < 0) { @@ -73,9 +73,8 @@ void RtpReader::OnDataReceived(net::IOBuffer* buffer, int data_size) { int16 delta = sequence_number - max_sequence_number_; if (delta <= -kMaxMisorder || delta > kMaxDropout) { - // TODO(sergeyu): Do we need to handle restarted trasmission? + // TODO(sergeyu): Do we need to handle restarted transmission? LOG(WARNING) << "Received RTP packet with invalid sequence number."; - delete packet; return; } @@ -91,7 +90,7 @@ void RtpReader::OnDataReceived(net::IOBuffer* buffer, int data_size) { ++total_packets_received_; - on_message_callback_.Run(packet); + on_message_callback_.Run(packet.release()); } void RtpReader::GetReceiverReport(RtcpReceiverReport* report) { |