136 lines
3.6 KiB
HTML
136 lines
3.6 KiB
HTML
<!doctype html>
|
|
<html>
|
|
<head>
|
|
<meta charset="utf-8">
|
|
<title>Testing basic binary data channel from offerer to receiver</title>
|
|
<script src="../../resources/testharness.js"></script>
|
|
<script src="../../resources/testharnessreport.js"></script>
|
|
</head>
|
|
<body>
|
|
<script src ="../routines.js"></script>
|
|
<script>
|
|
var localChannel;
|
|
var remoteChannel;
|
|
|
|
function closeDataChannels() {
|
|
localChannel.close();
|
|
remoteChannel.close();
|
|
closeConnections();
|
|
}
|
|
|
|
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 checkArrayBuffer(array, length)
|
|
{
|
|
if (array.byteLength !== length)
|
|
return false;
|
|
|
|
var a = new Uint8Array(array);
|
|
for (var cptr = 0; cptr < length; cptr++) {
|
|
if (a[cptr] !== cptr + 1)
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function checkArrayBufferView(array, length)
|
|
{
|
|
if (array.byteLength !== length)
|
|
return false;
|
|
|
|
var a = new Uint8Array(array);
|
|
for (var cptr = 0; cptr < length; cptr++) {
|
|
if (a[cptr] !== cptr + length + 1)
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function testArrayBuffer(array, length)
|
|
{
|
|
test(() => {
|
|
assert_true(checkArrayBuffer(array, length));
|
|
}, "test array buffer " + length);
|
|
}
|
|
|
|
function testArrayBufferView(array, length)
|
|
{
|
|
test(() => {
|
|
assert_true(checkArrayBufferView(array, length));
|
|
}, "test array buffer view " + length);
|
|
}
|
|
|
|
function receiveMessages(event) {
|
|
try {
|
|
if (++counter === 1)
|
|
testArrayBuffer(event.data, 1);
|
|
else if (counter === 2)
|
|
testArrayBuffer(event.data, 2);
|
|
else if (counter === 3)
|
|
testArrayBuffer(event.data, 3);
|
|
else if (counter === 4)
|
|
testArrayBuffer(event.data, 4);
|
|
else if (counter === 5)
|
|
testArrayBufferView(event.data, 1);
|
|
else if (counter === 6)
|
|
testArrayBufferView(event.data, 2);
|
|
else if (counter === 7)
|
|
testArrayBufferView(event.data, 3);
|
|
else if (counter === 8) {
|
|
testArrayBufferView(event.data, 4);
|
|
closeDataChannels();
|
|
finishTest();
|
|
} else
|
|
assert_unreached();
|
|
} catch(e) {
|
|
console.log(e);
|
|
}
|
|
}
|
|
|
|
function sendMessages(channel)
|
|
{
|
|
channel.send(createArrayBuffer(1));
|
|
channel.send(createArrayBuffer(2));
|
|
channel.send(createArrayBuffer(3));
|
|
channel.send(createArrayBuffer(4));
|
|
channel.send(createArrayBufferView(1));
|
|
channel.send(createArrayBufferView(2));
|
|
channel.send(createArrayBufferView(3));
|
|
channel.send(createArrayBufferView(4));
|
|
}
|
|
|
|
var finishTest;
|
|
promise_test((test) => {
|
|
counter = 0;
|
|
return new Promise((resolve, reject) => {
|
|
finishTest = resolve;
|
|
createConnections((localConnection) => {
|
|
localChannel = localConnection.createDataChannel('sendDataChannel');
|
|
localChannel.binaryType = "arraybuffer";
|
|
localChannel.onopen = () => { sendMessages(localChannel) };
|
|
}, (remoteConnection) => {
|
|
remoteConnection.ondatachannel = (event) => {
|
|
remoteChannel = event.channel;
|
|
remoteChannel.binaryType = "arraybuffer";
|
|
remoteChannel.onmessage = receiveMessages;
|
|
};
|
|
});
|
|
setTimeout(() => { reject("Test timed out"); }, 5000);
|
|
});
|
|
}, "Basic binary data channel exchange from offerer to receiver");
|
|
|
|
</script>
|
|
</body>
|
|
</html>
|