DCHECK(io_message_loop_->BelongsToCurrentThread());
bool handled = true;
IPC_BEGIN_MESSAGE_MAP(CastIPCDispatcher, message)
- IPC_MESSAGE_HANDLER(CastMsg_ReceivedPacket, OnReceivedPacket)
IPC_MESSAGE_HANDLER(CastMsg_NotifyStatusChange, OnNotifyStatusChange)
IPC_MESSAGE_HANDLER(CastMsg_RawEvents, OnRawEvents)
+ IPC_MESSAGE_HANDLER(CastMsg_Rtt, OnRtt)
+ IPC_MESSAGE_HANDLER(CastMsg_RtcpCastMessage, OnRtcpCastMessage)
IPC_MESSAGE_UNHANDLED(handled = false);
IPC_END_MESSAGE_MAP();
return handled;
DCHECK_EQ(this, global_instance_);
}
-void CastIPCDispatcher::OnReceivedPacket(
+void CastIPCDispatcher::OnNotifyStatusChange(
int32 channel_id,
- const media::cast::transport::Packet& packet) {
+ media::cast::CastTransportStatus status) {
CastTransportSenderIPC* sender = id_map_.Lookup(channel_id);
if (sender) {
- sender->OnReceivedPacket(packet);
+ sender->OnNotifyStatusChange(status);
} else {
- DVLOG(1) << "CastIPCDispatcher::OnReceivedPacket "
- << "on non-existing channel.";
+ DVLOG(1)
+ << "CastIPCDispatcher::OnNotifystatusChange on non-existing channel.";
}
}
-void CastIPCDispatcher::OnNotifyStatusChange(
+void CastIPCDispatcher::OnRawEvents(
int32 channel_id,
- media::cast::transport::CastTransportStatus status) {
+ const std::vector<media::cast::PacketEvent>& packet_events,
+ const std::vector<media::cast::FrameEvent>& frame_events) {
CastTransportSenderIPC* sender = id_map_.Lookup(channel_id);
if (sender) {
- sender->OnNotifyStatusChange(status);
+ sender->OnRawEvents(packet_events, frame_events);
} else {
- DVLOG(1)
- << "CastIPCDispatcher::OnNotifystatusChange on non-existing channel.";
+ DVLOG(1) << "CastIPCDispatcher::OnRawEvents on non-existing channel.";
}
}
-void CastIPCDispatcher::OnRawEvents(
+void CastIPCDispatcher::OnRtt(int32 channel_id,
+ uint32 ssrc,
+ const media::cast::RtcpRttReport& rtt_report) {
+ CastTransportSenderIPC* sender = id_map_.Lookup(channel_id);
+ if (sender) {
+ sender->OnRtt(ssrc, rtt_report);
+ } else {
+ DVLOG(1) << "CastIPCDispatcher::OnRtt on non-existing channel.";
+ }
+}
+
+void CastIPCDispatcher::OnRtcpCastMessage(
int32 channel_id,
- const std::vector<media::cast::PacketEvent>& packet_events) {
+ uint32 ssrc,
+ const media::cast::RtcpCastMessage& cast_message) {
CastTransportSenderIPC* sender = id_map_.Lookup(channel_id);
if (sender) {
- sender->OnRawEvents(packet_events);
+ sender->OnRtcpCastMessage(ssrc, cast_message);
} else {
- DVLOG(1) << "CastIPCDispatcher::OnRawEvents on non-existing channel.";
+ DVLOG(1) << "CastIPCDispatcher::OnRtt on non-existing channel.";
}
}