Chromium Code Reviews| Index: chrome/browser/media/cast_transport_host_filter.cc |
| diff --git a/chrome/browser/media/cast_transport_host_filter.cc b/chrome/browser/media/cast_transport_host_filter.cc |
| index 3f140734c2f728dcc3a414e4c29454de16f3a323..f2285923b7dc9266296c8b8ff6f418606fde9a5d 100644 |
| --- a/chrome/browser/media/cast_transport_host_filter.cc |
| +++ b/chrome/browser/media/cast_transport_host_filter.cc |
| @@ -16,7 +16,7 @@ namespace { |
| // How often to send raw events. |
| const int kSendRawEventsIntervalSecs = 1; |
| -} |
| +} // namespace |
| namespace cast { |
| @@ -49,25 +49,22 @@ bool CastTransportHostFilter::OnMessageReceived(const IPC::Message& message) { |
| return handled; |
| } |
| -void CastTransportHostFilter::ReceivedPacket( |
| - int32 channel_id, |
| - scoped_ptr<media::cast::Packet> packet) { |
| - Send(new CastMsg_ReceivedPacket(channel_id, *packet)); |
| -} |
| - |
| -void CastTransportHostFilter::NotifyStatusChange( |
| - int32 channel_id, |
| +void CastTransportHostFilter::OnStatusChange( |
| media::cast::CastTransportStatus status) { |
| - Send(new CastMsg_NotifyStatusChange(channel_id, status)); |
| + Send(new CastMsg_NotifyStatusChange(channel_id_, status)); |
| } |
| -void CastTransportHostFilter::SendRawEvents( |
| - int32 channel_id, |
| +void CastTransportHostFilter::OnReceivedLoggingEvents( |
| scoped_ptr<std::vector<media::cast::FrameEvent>> frame_events, |
| scoped_ptr<std::vector<media::cast::PacketEvent>> packet_events) { |
| if (frame_events->empty() && packet_events->empty()) |
| return; |
| - Send(new CastMsg_RawEvents(channel_id, *packet_events, *frame_events)); |
| + Send(new CastMsg_RawEvents(channel_id_, *packet_events, *frame_events)); |
| +} |
| + |
| +void CastTransportHostFilter::OnReceivedPackets( |
| + scoped_ptr<media::cast::Packet> packet) { |
| + Send(new CastMsg_ReceivedPacket(channel_id_, *packet)); |
| } |
| void CastTransportHostFilter::SendRtt(int32 channel_id, |
| @@ -102,24 +99,13 @@ void CastTransportHostFilter::OnNew( |
| id_map_.Remove(channel_id); |
| } |
| + channel_id_ = channel_id; |
|
Irfan
2015/12/16 19:44:34
as we discussed, this creates a problem since we w
xjz
2015/12/16 21:58:01
I prefer the second approach, unless there are rea
|
| + media::cast::CastTransportSender::CreateParams transport_params( |
| + g_browser_process->net_log(), &clock_, local_end_point, remote_end_point, |
| + this, base::TimeDelta::FromSeconds(kSendRawEventsIntervalSecs), |
| + make_scoped_ptr(options.DeepCopy()), base::ThreadTaskRunnerHandle::Get()); |
| scoped_ptr<media::cast::CastTransportSender> sender = |
| - media::cast::CastTransportSender::Create( |
| - g_browser_process->net_log(), |
| - &clock_, |
| - local_end_point, |
| - remote_end_point, |
| - make_scoped_ptr(options.DeepCopy()), |
| - base::Bind(&CastTransportHostFilter::NotifyStatusChange, |
| - weak_factory_.GetWeakPtr(), |
| - channel_id), |
| - base::Bind(&CastTransportHostFilter::SendRawEvents, |
| - weak_factory_.GetWeakPtr(), |
| - channel_id), |
| - base::TimeDelta::FromSeconds(kSendRawEventsIntervalSecs), |
| - base::Bind(&CastTransportHostFilter::ReceivedPacket, |
| - weak_factory_.GetWeakPtr(), |
| - channel_id), |
| - base::ThreadTaskRunnerHandle::Get()); |
| + media::cast::CastTransportSender::Create(transport_params); |
| id_map_.AddWithID(sender.release(), channel_id); |
| } |