Implements RTP header dumping.

chrome/browser/resources/hangout_services/thunk.js

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 chrome.runtime.onMessageExternal.addListener(
     function(message, sender, sendResponse) {
       function doSendResponse(value, error) {
         var errorMessage = error || chrome.extension.lastError;
         sendResponse({'value': value, 'error': errorMessage});
       }
@@ skipping 57 matching lines @@
           return false;
         } else if (method == 'logging.stop') {
           chrome.webrtcLoggingPrivate.stop(
               sender.tab.id, origin, doSendResponse);
           return true;
         } else if (method == 'logging.upload') {
           chrome.webrtcLoggingPrivate.upload(
               sender.tab.id, origin, doSendResponse);
           return true;
         } else if (method == 'logging.stopAndUpload') {
-          chrome.webrtcLoggingPrivate.stop(sender.tab.id, origin, function() {
-            chrome.webrtcLoggingPrivate.upload(
-                sender.tab.id, origin, doSendResponse);
+          stopAllRtpDump(sender.tab.id, origin, function() {
+            chrome.webrtcLoggingPrivate.stop(sender.tab.id, origin, function() {
+              chrome.webrtcLoggingPrivate.upload(
+                  sender.tab.id, origin, doSendResponse);
+            });
           });
           return true;
         } else if (method == 'logging.discard') {
           chrome.webrtcLoggingPrivate.discard(
               sender.tab.id, origin, doSendResponse);
           return true;
         } else if (method == 'getSinks') {
           chrome.webrtcAudioPrivate.getSinks(doSendResponse);
           return true;
         } else if (method == 'getActiveSink') {
@@ skipping 17 matching lines @@
           // check if it's loaded; if it's not, the extension system will
           // call the callback with no arguments and set
           // chrome.runtime.lastError.
           doSendResponse();
           return false;
         } else if (method == 'getNaclArchitecture') {
           chrome.runtime.getPlatformInfo(function(obj) {
             doSendResponse(obj.nacl_arch);
           });
           return true;
+        } else if (method == 'logging.startRtpDump') {
+          var incoming = message['incoming'] || false;
+          var outgoing = message['outgoing'] || false;
+          chrome.webrtcLoggingPrivate.startRtpDump(
+              sender.tab.id, origin, incoming, outgoing, doSendResponse);
+          return true;
+        } else if (method == 'logging.stopRtpDump') {
+          var incoming = message['incoming'] || false;
+          var outgoing = message['outgoing'] || false;
+          chrome.webrtcLoggingPrivate.stopRtpDump(
+              sender.tab.id, origin, incoming, outgoing, doSendResponse);
+          return true;
         }
         throw new Error('Unknown method: ' + method);
       } catch (e) {
         doSendResponse(null, e.name + ': ' + e.message);
       }
     }
 );
 
 // If Hangouts connects with a port named 'onSinksChangedListener', we
 // will register a listener and send it a message {'eventName':
@@ skipping 73 matching lines @@
       'pluginCpuUsage': pluginProcessCpu
     });
   }
 
   chrome.processes.onUpdated.addListener(processListener);
   port.onDisconnect.addListener(function() {
     chrome.processes.onUpdated.removeListener(processListener);
   });
 }
 
+function stopAllRtpDump(tabId, origin, callback) {
+  // Stops incoming and outgoing separately, otherwise stopRtpDump will fail if
+  // either type of dump has not been started.
+  chrome.webrtcLoggingPrivate.stopRtpDump(
+      tabId, origin, true, false,
+      function() {
+        chrome.webrtcLoggingPrivate.stopRtpDump(
+            tabId, origin, false, true, callback);
+      });
+}
+
 chrome.runtime.onConnectExternal.addListener(function(port) {
   if (port.name == 'onSinksChangedListener') {
     onSinksChangedPort(port);
   } else if (port.name == 'chooseDesktopMedia') {
     onChooseDesktopMediaPort(port);
   } else if (port.name == 'processCpu') {
     onProcessCpu(port);
   } else {
     // Unknown port type.
     port.disconnect();
   }
 });