Add some tests to make sure message ports properly queue up message.

LayoutTests/http/tests/serviceworker/chromium/postmessage-after-terminate.html

Index: LayoutTests/http/tests/serviceworker/chromium/postmessage-after-terminate.html
diff --git a/LayoutTests/http/tests/serviceworker/chromium/postmessage-after-terminate.html b/LayoutTests/http/tests/serviceworker/chromium/postmessage-after-terminate.html
index f3aea71aae68b27d3096fb92b26b170c4eeef95f..f81bea3adc3b3d6484ecd4ea07670a0bafd3c7b0 100644
--- a/LayoutTests/http/tests/serviceworker/chromium/postmessage-after-terminate.html
+++ b/LayoutTests/http/tests/serviceworker/chromium/postmessage-after-terminate.html
@@ -15,6 +15,12 @@ function send_ping(worker) {
     });
 }
 
+function delay(ms) {
+  return new Promise(function(resolve) {
+      window.setTimeout(resolve, ms);
+    });
+}
+
 promise_test(function(test) {
     var worker = 'resources/ping-worker.js';
     var scope = 'resources/blank.html';
@@ -43,4 +49,114 @@ promise_test(function(test) {
           return service_worker_unregister_and_done(test, scope);
       });
   }, 'postMessage to a terminated service worker.');
+
+async_test(function(t) {
+    var worker_script = 'resources/postmessage-worker.js';
+    var scope = 'resources/postmessage-worker-scope';
+    var worker;
+    var registration;
+    var port;
+
+    service_worker_unregister_and_register(
+        t, worker_script, scope)
+      .then(function(r) {
+          registration = r;
+          return wait_for_activated(t, registration);
+        })
+      .then(function() {
+          worker = registration.active;
+          return internals.terminateServiceWorker(worker);
+        })
+      .then(function() {
+          var messageChannel = new MessageChannel();
+          port = messageChannel.port1;
+          port.onmessage = t.step_func(on_message);
+          port.postMessage({value: 0});
+          worker.postMessage({port: messageChannel.port2},
+                             [messageChannel.port2]);
+          port.postMessage({value: 1});
+          // Asynchronously sending more messages gives chrome a chance to be in
+          // a slightly different state, so wait a minimal amount of time.
+          return delay(1);
+        })
+      .then(function() {
+          port.postMessage({value: 2});
+          port.postMessage({done: true});
+        })
+      .catch(unreached_rejection(t));
+
+    var result = [];
+    var expected = [
+      'Acking value: 0',
+      'Acking value: 1',
+      'Acking value: 2',
+    ];
+
+    function on_message(e) {
+      var message = e.data;
+      if (message === 'quit') {
+        assert_array_equals(result, expected,
+                            'Worker should post back expected values.');
+        service_worker_unregister_and_done(t, scope);
+      } else {
+        result.push(message);
+      }
+    }
+  }, 'postMessage on a port that was sent to a terminated service worker');
+
+async_test(function(t) {
+    var worker_script = 'resources/postmessage-port-worker.js';
+    var scope = 'resources/postmessage-port-worker-scope';
+    var worker;
+    var registration;
+    var port;
+
+    service_worker_unregister_and_register(
+        t, worker_script, scope)
+      .then(function(r) {
+          registration = r;
+          return wait_for_activated(t, registration);
+        })
+      .then(function() {
+          worker = registration.active;
+          return internals.terminateServiceWorker(worker);
+        })
+      .then(function() {
+          var innerChannel = new MessageChannel();
+          var outerChannel = new MessageChannel();
+          port = innerChannel.port1;
+          port.onmessage = t.step_func(on_message);
+          port.postMessage({value: 0});
+          outerChannel.port1.postMessage({port: innerChannel.port2},
+                                         [innerChannel.port2]);
+          worker.postMessage({port: outerChannel.port2}, [outerChannel.port2]);
+          port.postMessage({value: 1});
+          // Asynchronously sending more messages gives chrome a chance to be in
+          // a slightly different state, so wait a minimal amount of time.
+          return delay(1);
+        })
+      .then(function() {
+          port.postMessage({value: 2});
+          port.postMessage({done: true});
+        })
+      .catch(unreached_rejection(t));
+
+    var result = [];
+    var expected = [
+      'Acking value: 0',
+      'Acking value: 1',
+      'Acking value: 2',
+    ];
+
+    function on_message(e) {
+      var message = e.data;
+      if (message === 'quit') {
+        assert_array_equals(result, expected,
+                            'Worker should post back expected values.');
+        service_worker_unregister_and_done(t, scope);
+      } else {
+        result.push(message);
+      }
+    }
+  }, 'postMessage on a port that was sent on a port that was sent to a terminated service worker');
 </script>