107 lines
2.9 KiB
HTML
107 lines
2.9 KiB
HTML
<!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>
|