| importScripts('/resources/testharness.js'); |
| importScripts('resources/sync-access-handle-test.js'); |
| |
| 'use strict'; |
| |
| sync_access_handle_test(async (t, handle) => { |
| await handle.flush(); |
| }, 'Test flush on an empty file.'); |
| |
| sync_access_handle_test(async (t, handle) => { |
| if (!('TextEncoder' in self)) { |
| return; |
| } |
| const encoder = new TextEncoder(); |
| const decoder = new TextDecoder(); |
| |
| const text = 'Hello Storage Foundation'; |
| const writeBuffer = new TextEncoder().encode(text); |
| handle.write(writeBuffer, {at: 0}); |
| await handle.flush(); |
| let readBuffer = new Uint8Array(text.length); |
| handle.read(readBuffer, {at: 0}); |
| assert_equals( |
| text, new TextDecoder().decode(readBuffer), |
| 'Check that the written bytes and the read bytes match'); |
| }, |
| 'SyncAccessHandle.read returns bytes written by SyncAccessHandle.write' + |
| ' after SyncAccessHandle.flush'); |
| |
| sync_access_handle_test(async (testCase, handle) => { |
| const flushPromise = handle.flush(); |
| const readBuffer = new Uint8Array(4); |
| assert_throws_dom( |
| 'InvalidStateError', () => handle.read(readBuffer, {at: 0})); |
| assert_equals(await flushPromise, undefined); |
| }, |
| 'SyncAccessHandle.read fails when there is a pending SyncAccessHandle.flush'); |
| |
| sync_access_handle_test(async (testCase, handle) => { |
| const flushPromise = handle.flush(); |
| const writeBuffer = new Uint8Array(4); |
| writeBuffer.set([96, 97, 98, 99]); |
| assert_throws_dom( |
| 'InvalidStateError', () => handle.write(writeBuffer, {at: 0})); |
| assert_equals(await flushPromise, undefined); |
| }, |
| 'SyncAccessHandle.write fails when there is a pending SyncAccessHandle.flush'); |
| |
| done(); |