Updated the table lock policy test timings to attempt to stabilize CI.

Nike-Inc · May 2, 2018 · 6ca3601 · 6ca3601
1 parent 6a26aae
commit 6ca3601
Showing 1 changed file with 25 additions and 19 deletions.
diff --git a/Tests/Tests/Database/TableLockPolicyTests.swift b/Tests/Tests/Database/TableLockPolicyTests.swift
@@ -53,22 +53,28 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
 
         // When
         DispatchQueue.userInitiated.async {
+            print("Starting write")
+
             do {
-                try TestTables.insertDummyAgents(count: 1_000, connection: writeConnection)
+                try TestTables.insertDummyAgents(count: 10_000, connection: writeConnection)
             } catch {
                 writeError = error
             }
 
+            print("Finished write")
             writeExpectation.fulfill()
         }
 
-        DispatchQueue.userInitiated.asyncAfter(seconds: 0.01) {
+        DispatchQueue.userInitiated.asyncAfter(seconds: 0.05) {
+            print("Starting read")
+
             do {
                 readCount = try readConnection.query("SELECT count(*) FROM agents")
             } catch {
                 readError = error
             }
 
+            print("Finished read")
             readExpectation.fulfill()
         }
 
@@ -99,7 +105,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
             sharedCache: true
         )
 
-        try TestTables.insertDummyAgents(count: 1_000, connection: writeConnection)
+        try TestTables.insertDummyAgents(count: 5_000, connection: writeConnection)
 
         let writeExpectation = self.expectation(description: "Write should fail")
         let readExpectation = self.expectation(description: "Read should succeed")
@@ -119,9 +125,9 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
             readExpectation.fulfill()
         }
 
-        DispatchQueue.userInitiated.asyncAfter(seconds: 0.01) {
+        DispatchQueue.userInitiated.asyncAfter(seconds: 0.1) {
             do {
-                try TestTables.insertDummyAgents(count: 1_000, connection: writeConnection)
+                try TestTables.insertDummyAgents(count: 5_000, connection: writeConnection)
             } catch {
                 writeError = error
             }
@@ -132,7 +138,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
         waitForExpectations(timeout: timeout, handler: nil)
 
         // Then
-        XCTAssertEqual(agents.count, 1_002)
+        XCTAssertEqual(agents.count, 5_002)
         XCTAssertNil(readError)
         XCTAssertNotNil(writeError)
 
@@ -156,7 +162,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
             sharedCache: true
         )
 
-        try TestTables.insertDummyAgents(count: 1_000, connection: writeConnection)
+        try TestTables.insertDummyAgents(count: 5_000, connection: writeConnection)
 
         let writeExpectation = self.expectation(description: "Write should fail")
         let readExpectation = self.expectation(description: "Read should succeed")
@@ -176,7 +182,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
             readExpectation.fulfill()
         }
 
-        DispatchQueue.userInitiated.asyncAfter(seconds: 0.01) {
+        DispatchQueue.userInitiated.asyncAfter(seconds: 0.1) {
             do {
                 let dateString = bindingDateFormatter.string(from: Date())
 
@@ -196,7 +202,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
         waitForExpectations(timeout: timeout, handler: nil)
 
         // Then
-        XCTAssertEqual(agents.count, 1_002)
+        XCTAssertEqual(agents.count, 5_002)
         XCTAssertNil(readError)
         XCTAssertNotNil(writeError)
 
@@ -232,15 +238,15 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
         // When
         DispatchQueue.userInitiated.async {
             do {
-                try TestTables.insertDummyAgents(count: 1_000, connection: writeConnection)
+                try TestTables.insertDummyAgents(count: 5_000, connection: writeConnection)
             } catch {
                 writeError = error
             }
 
             writeExpectation.fulfill()
         }
 
-        DispatchQueue.userInitiated.asyncAfter(seconds: 0.01) {
+        DispatchQueue.userInitiated.asyncAfter(seconds: 0.1) {
             do {
                 readCount = try readConnection.query("SELECT count(*) FROM agents")
             } catch {
@@ -255,7 +261,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
         // Then
         XCTAssertNil(writeError)
         XCTAssertNil(readError)
-        XCTAssertEqual(readCount, 1_002)
+        XCTAssertEqual(readCount, 5_002)
     }
 
     func testThatConnectionDoesNotThrowErrorWhenReadLockBlocksWriteLockWithTableLockPolicyEnabled() throws {
@@ -273,7 +279,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
             sharedCache: true
         )
 
-        try TestTables.insertDummyAgents(count: 1_000, connection: writeConnection)
+        try TestTables.insertDummyAgents(count: 5_000, connection: writeConnection)
 
         let writeExpectation = self.expectation(description: "Write should succeed")
         let readExpectation = self.expectation(description: "Read should succeed")
@@ -293,9 +299,9 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
             readExpectation.fulfill()
         }
 
-        DispatchQueue.userInitiated.asyncAfter(seconds: 0.01) {
+        DispatchQueue.userInitiated.asyncAfter(seconds: 0.1) {
             do {
-                try TestTables.insertDummyAgents(count: 1_000, connection: writeConnection)
+                try TestTables.insertDummyAgents(count: 5_000, connection: writeConnection)
             } catch {
                 writeError = error
             }
@@ -306,7 +312,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
         waitForExpectations(timeout: timeout, handler: nil)
 
         // Then
-        XCTAssertEqual(agents.count, 1_002)
+        XCTAssertEqual(agents.count, 5_002)
         XCTAssertNil(readError)
         XCTAssertNil(writeError)
     }
@@ -326,7 +332,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
             sharedCache: true
         )
 
-        try TestTables.insertDummyAgents(count: 1_000, connection: writeConnection)
+        try TestTables.insertDummyAgents(count: 5_000, connection: writeConnection)
 
         let writeExpectation = self.expectation(description: "Write should succeed")
         let readExpectation = self.expectation(description: "Read should succeed")
@@ -346,7 +352,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
             readExpectation.fulfill()
         }
 
-        DispatchQueue.userInitiated.asyncAfter(seconds: 0.01) {
+        DispatchQueue.userInitiated.asyncAfter(seconds: 0.1) {
             do {
                 let dateString = bindingDateFormatter.string(from: Date())
 
@@ -366,7 +372,7 @@ class TableLockPolicyTestCase: BaseConnectionTestCase {
         waitForExpectations(timeout: timeout, handler: nil)
 
         // Then
-        XCTAssertEqual(agents.count, 1_002)
+        XCTAssertEqual(agents.count, 5_002)
         XCTAssertNil(readError)
         XCTAssertNil(writeError)
     }