| <html> |
| <head> |
| <link rel="stylesheet" href="../../fast/js/resources/js-test-style.css"> |
| <script src="../../fast/js/resources/js-test-pre.js"></script> |
| <script src="../../fast/js/resources/js-test-post-function.js"></script> |
| <script src="resources/shared.js"></script> |
| </head> |
| <body> |
| <p id="description"></p> |
| <div id="console"></div> |
| <script> |
| |
| description("4 open connections try to setVersion at the same time. 3 connections eventually close, allowing 1 setVersion call to proceed."); |
| if (window.layoutTestController) |
| layoutTestController.waitUntilDone(); |
| |
| connections = [] |
| function test() |
| { |
| if ('webkitIndexedDB' in window) |
| IndexedDB = webkitIndexedDB; |
| else if ('mozIndexedDB' in window) |
| IndexedDB = mozIndexedDB; |
| shouldBeFalse("IndexedDB == null"); |
| openDBConnection(); |
| } |
| |
| function openDBConnection() |
| { |
| result = evalAndLog("IndexedDB.open('set-version-queue')"); |
| result.onsuccess = openSuccess; |
| result.onerror = unexpectedErrorCallback; |
| } |
| |
| function openSuccess() |
| { |
| connection = event.target.result; |
| connection.onversionchange = generateVersionChangeHandler(); |
| connections.push(connection); |
| if (connections.length < 4) |
| openDBConnection(); |
| else { |
| request = evalAndLog("connections[0].setVersion('version 0')"); |
| request.onerror = function(event){ connectionError(event, 0) }; |
| request.onsuccess = unexpectedSuccessCallback; |
| request.onblocked = blocked0; |
| request1 = evalAndLog("connections[1].setVersion('version 1')"); |
| request1.onerror = unexpectedErrorCallback; |
| request1.onsuccess = inSetVersion1; |
| request1.onblocked = blocked1; |
| request2 = evalAndLog("connections[2].setVersion('version 2')"); |
| request2.onerror = function(event){ connectionError(event, 2) }; |
| request2.onsuccess = unexpectedSuccessCallback; |
| request2.onblocked = blocked2; |
| request3 = evalAndLog("connections[3].setVersion('version 3')"); |
| request3.onerror = function(event){ connectionError(event, 3) }; |
| request3.onsuccess = unexpectedSuccessCallback; |
| request3.onblocked = blocked3; |
| debug(""); |
| } |
| } |
| |
| function generateVersionChangeHandler() |
| { |
| var connectionNum = connections.length; |
| return function(event) |
| { |
| shouldBeTrue("event.version.length > 0"); |
| debug("connection[" + connectionNum + "] received versionChangeEvent: " + event.version); |
| } |
| } |
| |
| blocked0fired = false; |
| blocked2fired = false; |
| function blocked0(event) |
| { |
| debug(""); |
| testPassed("connection[0] got blocked event"); |
| shouldBeEqualToString("event.version", "version 0"); |
| debug("Close the connection that received the block event:"); |
| evalAndLog("connections[0].close()"); |
| debug("Close another connection as well, to test 4.7.4-note:"); |
| evalAndLog("connections[3].close()"); |
| evalAndLog("blocked0fired = true"); |
| debug(""); |
| } |
| |
| function blocked1(event) |
| { |
| debug("") |
| testPassed("connection[1] got blocked event"); |
| debug("Ensure that this blocked event is in order:"); |
| shouldBeTrue("blocked0fired"); |
| shouldBeFalse("blocked2fired"); |
| debug("") |
| } |
| |
| function blocked2(event) |
| { |
| debug("") |
| testPassed("connection[2] got blocked event"); |
| shouldBeEqualToString("event.version", "version 2"); |
| evalAndLog("connections[2].close()"); |
| evalAndLog("blocked2fired = true"); |
| debug("") |
| } |
| |
| function blocked3(event) |
| { |
| debug("") |
| testPassed("connection[3] got blocked event"); |
| debug("Note: This means that a connection can receive a blocked event after its close() method has been called. Spec is silent on the issue and this is easiest to implement."); |
| shouldBeEqualToString("event.version", "version 3"); |
| } |
| |
| function connectionError(event, connectionId) |
| { |
| debug("") |
| testPassed("connection[" + connectionId + "] got error event"); |
| shouldBe("event.target.errorCode", "13") |
| if ('webkitIndexedDB' in window) { |
| shouldBe("event.target.webkitErrorMessage.length > 0", "true"); |
| debug(event.target.webkitErrorMessage); |
| } |
| } |
| |
| function inSetVersion1(event) |
| { |
| debug("") |
| testPassed("connection[1] got into SetVersion"); |
| done(); |
| } |
| |
| var successfullyParsed = true; |
| |
| test(); |
| |
| </script> |
| </body> |
| </html> |
