| <!DOCTYPE html> |
| <html> |
| <head> |
| <title>mock-media-source</title> |
| <script src="mock-media-source.js"></script> |
| <script src="../video-test.js"></script> |
| <script> |
| var source; |
| var sourceBuffer; |
| var initSegment; |
| var exception; |
| |
| async function appendPtsRange(firstPts, lastPts, timescale = 1, gap = 0, step = null) { |
| var resultException = null; |
| if (step == null) |
| step = timescale; |
| for (var pts = firstPts; pts <= lastPts; pts += step) { |
| try { |
| consoleWrite('Appending PTS='+pts / timescale); |
| sourceBuffer.appendBuffer(makeASample(pts, pts, step - gap, timescale, 1, SAMPLE_FLAG.SYNC, 1)); |
| await waitFor(sourceBuffer, 'updateend'); |
| } catch (e) { |
| resultException = e; |
| sourceBuffer.abort(); |
| break; |
| } |
| } |
| return resultException; |
| } |
| |
| async function appendConcatenateSamples(start, end) { |
| var resultException = null; |
| const samples = []; |
| for (let time = start; time <= end; time++) |
| samples.push(makeASample(time, time, 1, 1, 1, time === start ? SAMPLE_FLAG.SYNC : SAMPLE_FLAG.NONE)); |
| |
| try { |
| consoleWrite('Appending PTS='+start+'-'+end ); |
| sourceBuffer.appendBuffer(concatenateSamples(samples)); |
| await waitFor(sourceBuffer, 'updateend'); |
| } catch (e) { |
| resultException = e; |
| sourceBuffer.abort(); |
| } |
| return resultException; |
| } |
| |
| if (window.internals) |
| internals.initializeMockMediaSource(); |
| |
| window.addEventListener('load', async() => { |
| findMediaElement(); |
| source = new MediaSource(); |
| |
| const videoSource = document.createElement('source'); |
| videoSource.type = 'video/mock; codecs=mock'; |
| videoSource.src = URL.createObjectURL(source); |
| video.appendChild(videoSource); |
| |
| await waitFor(source, 'sourceopen'); |
| sourceBuffer = source.addSourceBuffer("video/mock; codecs=mock"); |
| initSegment = makeAInit(350, [makeATrack(1, 'mock', TRACK_KIND.VIDEO)]); |
| sourceBuffer.appendBuffer(initSegment); |
| await waitFor(sourceBuffer, 'updateend'); |
| waitFor(sourceBuffer, 'error'); |
| |
| internals.settings.setMaximumSourceBufferSize(1000); |
| |
| exception = await appendPtsRange(0, 12); |
| testExpected('exception', 'QuotaExceededError: The quota has been exceeded.', '!='); |
| |
| exception = await appendConcatenateSamples(13, 15); |
| testExpected('exception', 'QuotaExceededError: The quota has been exceeded.', '=='); |
| |
| // To exercise eviction ahead of current time we must add over 30s of data. |
| internals.settings.setMaximumSourceBufferSize(3000); |
| |
| // Ensure that small gaps that would be ignored during playback are also ignored by eviction. |
| // We use a gap of 2/1000 as gaps of 1/1000th are removed and 2002/24000 is the maximum gap ignored during playback. |
| sourceBuffer.remove(0, Infinity); |
| await waitFor(sourceBuffer, 'updateend'); |
| exception = await appendPtsRange(0, 60000, 1000, 2); |
| testExpected('exception', 'QuotaExceededError: The quota has been exceeded.', '=='); |
| // Check that appendBuffer removed all the small gaps in the data less than the threshold. |
| testExpected(sourceBuffer.buffered.length, '1', '=='); |
| |
| // Ensure that if current time is close enough to the buffered data that the nearest range isn't evicted. |
| sourceBuffer.remove(0, Infinity); |
| await waitFor(sourceBuffer, 'updateend'); |
| exception = await appendPtsRange(2, 60002, 1000); |
| testExpected('exception', 'QuotaExceededError: The quota has been exceeded.', '=='); |
| |
| internals.settings.setMaximumSourceBufferSize(4000); |
| // Ensure that small gaps that would be ignored during playback are also ignored by eviction. |
| // We use a gap of 2000/24000 which is less than the 2002/24000 gap ignored during playback. |
| // Gaps are removed during append, so we remove data to create a gap <= 2000/24000. |
| sourceBuffer.remove(0, Infinity); |
| await waitFor(sourceBuffer, 'updateend'); |
| exception = await appendPtsRange(0, 29); |
| testExpected('exception', 'QuotaExceededError: The quota has been exceeded.', '!='); |
| // Add 30 to 32s in smaller granularity. |
| exception = await appendPtsRange(720000, 768000 - 1, 24000, 0, 2000); |
| testExpected('exception', 'QuotaExceededError: The quota has been exceeded.', '!='); |
| testExpected(sourceBuffer.buffered.length, '1', '=='); |
| // Create a small 2000/24000 gap in the data at 31s. |
| sourceBuffer.remove(744000 / 24000, (744000 + 2000) / 24000); |
| await waitFor(sourceBuffer, 'updateend'); |
| testExpected(sourceBuffer.buffered.length, '2', '=='); |
| exception = await appendPtsRange(32, 60); |
| testExpected('exception', 'QuotaExceededError: The quota has been exceeded.', '=='); |
| |
| endTest(); |
| }); |
| </script> |
| </head> |
| <body> |
| <video></video> |
| </body> |
| </html> |
