Multicast socket API

chrome/test/data/extensions/api_test/socket/api/background.js

 // Copyright (c) 2012 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.
 
 // net/tools/testserver/testserver.py is picky about the format of what it
 // calls its "echo" messages. One might go so far as to mutter to oneself that
 // it isn't an echo server at all.
 //
 // The response is based on the request but obfuscated using a random key.
 const request = "0100000005320000005hello";
@@ skipping 24 matching lines @@
 function arrayBuffer2String(buf, callback) {
   var blob = new Blob([new Uint8Array(buf)]);
   var f = new FileReader();
   f.onload = function(e) {
     callback(e.target.result);
   };
   f.readAsText(blob);
 }
 
 var testSocketCreation = function() {
-  function onGetInfo(info) {
-    chrome.test.assertEq(info.socketType, protocol);
-    chrome.test.assertFalse(info.connected);
+  function onCreate(socketInfo) {
+    function onGetInfo(info) {
+      chrome.test.assertEq(info.socketType, protocol);
+      chrome.test.assertFalse(info.connected);
 
-    if (info.peerAddress || info.peerPort) {
-      chrome.test.fail('Unconnected socket should not have peer');
-    }
-    if (info.localAddress || info.localPort) {
-      chrome.test.fail('Unconnected socket should not have local binding');
+      if (info.peerAddress || info.peerPort) {
+        chrome.test.fail('Unconnected socket should not have peer');
+      }
+      if (info.localAddress || info.localPort) {
+        chrome.test.fail('Unconnected socket should not have local binding');
+      }
+
+      socket.destroy(socketInfo.socketId);
+
+      chrome.test.succeed();
     }
 
-    // TODO(miket): this doesn't work yet. It's possible this will become
-    // automatic, but either way we can't forget to clean up.
-    //
-    //socket.destroy(socketInfo.socketId);
-
-    chrome.test.succeed();
-  }
-
-  function onCreate(socketInfo) {
     chrome.test.assertTrue(socketInfo.socketId > 0);
 
     // Obtaining socket information before a connect() call should be safe, but
     // return empty values.
     socket.getInfo(socketInfo.socketId, onGetInfo);
   }
 
   socket.create(protocol, {}, onCreate);
 };
 
@@ skipping 154 matching lines @@
   function onServerSocketCreate(socketInfo) {
     socketId = socketInfo.socketId;
     socket.listen(socketId, address, port, onListen);
   }
 
   socket.create('tcp', {}, onServerSocketCreate);
 };
 
 var onMessageReply = function(message) {
   var parts = message.split(":");
-  test_type = parts[0];
+  var test_type = parts[0];
   address = parts[1];
   port = parseInt(parts[2]);
   console.log("Running tests, protocol " + protocol + ", echo server " +
               address + ":" + port);
   if (test_type == 'tcp_server') {
     chrome.test.runTests([ testSocketListening ]);
+  } else if (test_type == 'multicast') {
+    console.log("Running multicast tests");
+    chrome.test.runTests([ testMulticast ]);
   } else {
     protocol = test_type;
     chrome.test.runTests([ testSocketCreation, testSending ]);
   }
 };
 
 // Find out which protocol we're supposed to test, and which echo server we
 // should be using, then kick off the tests.
 chrome.test.sendMessage("info_please", onMessageReply);