| <!doctype html> |
| <html> |
| <head> |
| <meta charset="utf-8"> |
| <title>Testing bufferedAmount oafter close</title> |
| <script src="../../resources/testharness.js"></script> |
| <script src="../../resources/testharnessreport.js"></script> |
| </head> |
| <body> |
| <script src ="../routines.js"></script> |
| <script> |
| window.addEventListener("unhandledrejection", event => { |
| event.preventDefault(); |
| }); |
| |
| var localChannel; |
| |
| function closeDataChannels() { |
| localChannel.close(); |
| closeConnections(); |
| } |
| |
| var string = "abcdefghij"; |
| var longString; |
| for (var cptr = 0; cptr < 100; ++cptr) |
| longString += string; |
| |
| function sendMessages(channel) |
| { |
| channel.send(longString); |
| } |
| |
| function createArrayBuffer(length) |
| { |
| var array = new Uint8Array(length); |
| for (var cptr = 0; cptr < length; cptr++) |
| array[cptr] = cptr + 1; |
| return array; |
| } |
| |
| function createArrayBufferView(length) |
| { |
| return createArrayBuffer(2 * length).subarray(length, 2 * length); |
| } |
| |
| function sendBlob(channel) |
| { |
| channel.send(new Blob([createArrayBuffer(1000)], "")); |
| } |
| |
| function sendArrayBuffer(channel) |
| { |
| channel.send(createArrayBuffer(1000)); |
| } |
| |
| function sendArrayBuffer(channel) |
| { |
| channel.send(createArrayBufferView(1000)); |
| } |
| |
| async function doDataChannelTest(writeChannel) |
| { |
| await new Promise((resolve, reject) => { |
| createConnections((localConnection) => { |
| localChannel = localConnection.createDataChannel('sendDataChannel'); |
| assert_equals(localChannel.bufferedAmountLowThreshold, 0, "default bufferedAmountLowThreshold value"); |
| localChannel.onopen = resolve; |
| }, (remoteConnection) => { |
| remoteConnection.ondatachannel = (event) => { |
| event.channel.onmessage = () => { }; |
| }; |
| }); |
| setTimeout(() => reject('timed out 1'), 5000); |
| }); |
| |
| const promise = new Promise((resolve, reject) => { |
| localChannel.onbufferedamountlow = resolve; |
| setTimeout(() => reject('timed out 2'), 5000); |
| }); |
| |
| writeChannel(localChannel); |
| |
| const currentBufferedAmount = localChannel.bufferedAmount; |
| assert_greater_than_equal(currentBufferedAmount, 1000); |
| closeDataChannels(); |
| assert_equals(localChannel.bufferedAmount, currentBufferedAmount); |
| } |
| |
| promise_test(() => { |
| return doDataChannelTest(channel => channel.send(longString)); |
| }, "Close does not affect bufferedAmount - for text"); |
| |
| promise_test(() => { |
| return doDataChannelTest(channel => channel.send(new Blob([createArrayBuffer(1000)]))); |
| }, "Close does not affect bufferedAmount - blob"); |
| |
| promise_test(() => { |
| return doDataChannelTest(channel => channel.send(createArrayBuffer(1000))); |
| }, "Close does not affect bufferedAmount - array buffer"); |
| |
| promise_test(() => { |
| return doDataChannelTest(channel => channel.send(createArrayBuffer(1000))); |
| }, "Close does not affect bufferedAmount - array buffer view"); |
| </script> |
| </body> |
| </html> |
