Index: content/renderer/media/peer_connection_tracker.cc |
diff --git a/content/renderer/media/peer_connection_tracker.cc b/content/renderer/media/peer_connection_tracker.cc |
index 60f3d26b18cd8e4751d9141b7ff23dedcbb1ef4e..6af020175aa40f4a31dcf66712d5d0171e13377e 100644 |
--- a/content/renderer/media/peer_connection_tracker.cc |
+++ b/content/renderer/media/peer_connection_tracker.cc |
@@ -343,6 +343,8 @@ bool PeerConnectionTracker::OnControlMessageReceived( |
IPC_BEGIN_MESSAGE_MAP(PeerConnectionTracker, message) |
IPC_MESSAGE_HANDLER(PeerConnectionTracker_GetAllStats, OnGetAllStats) |
IPC_MESSAGE_HANDLER(PeerConnectionTracker_OnSuspend, OnSuspend) |
+ IPC_MESSAGE_HANDLER(PeerConnectionTracker_StartEventLog, OnStartEventLog) |
+ IPC_MESSAGE_HANDLER(PeerConnectionTracker_StopEventLog, OnStopEventLog) |
IPC_MESSAGE_UNHANDLED(handled = false) |
IPC_END_MESSAGE_MAP() |
return handled; |
@@ -380,6 +382,28 @@ void PeerConnectionTracker::OnSuspend() { |
} |
} |
+void PeerConnectionTracker::OnStartEventLog(int local_id, |
+ IPC::PlatformFileForTransit file, |
+ int64_t max_file_size_bytes) { |
+ DCHECK(main_thread_.CalledOnValidThread()); |
+ for (auto& it : peer_connection_id_map_) { |
+ if (it.second == local_id) { |
+ it.first->StartEventLog(file, max_file_size_bytes); |
+ return; |
+ } |
+ } |
+} |
+ |
+void PeerConnectionTracker::OnStopEventLog(int local_id) { |
+ DCHECK(main_thread_.CalledOnValidThread()); |
+ for (auto& it : peer_connection_id_map_) { |
+ if (it.second == local_id) { |
+ it.first->StopEventLog(); |
+ return; |
+ } |
+ } |
+} |
+ |
void PeerConnectionTracker::RegisterPeerConnection( |
RTCPeerConnectionHandler* pc_handler, |
const webrtc::PeerConnectionInterface::RTCConfiguration& config, |