Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -77,6 +77,7 @@ public override async Task Cleanup()
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct, true)]
[DataRow(ConnectionMode.Gateway, true)]
[DataRow(ConnectionMode.Direct, false)]
Expand All @@ -87,6 +88,7 @@ public override async Task PointSuccessOperationsTest(ConnectionMode mode, bool
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
[DataRow(ConnectionMode.Gateway)]
public override async Task PointReadFailureOperationsTest(ConnectionMode mode)
Expand All @@ -95,6 +97,7 @@ public override async Task PointReadFailureOperationsTest(ConnectionMode mode)
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
[DataRow(ConnectionMode.Gateway)]
public override async Task StreamReadFailureOperationsTest(ConnectionMode mode)
Expand All @@ -103,6 +106,7 @@ public override async Task StreamReadFailureOperationsTest(ConnectionMode mode)
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
[DataRow(ConnectionMode.Gateway)]
public override async Task StreamOperationsTest(ConnectionMode mode)
Expand All @@ -111,6 +115,7 @@ public override async Task StreamOperationsTest(ConnectionMode mode)
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
[DataRow(ConnectionMode.Gateway)]
public override async Task BatchOperationsTest(ConnectionMode mode)
Expand All @@ -119,6 +124,7 @@ public override async Task BatchOperationsTest(ConnectionMode mode)
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
[DataRow(ConnectionMode.Gateway)]
public override async Task SingleOperationMultipleTimesTest(ConnectionMode mode)
Expand All @@ -127,6 +133,7 @@ public override async Task SingleOperationMultipleTimesTest(ConnectionMode mode)
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
[DataRow(ConnectionMode.Gateway)]
public override async Task QueryOperationSinglePartitionTest(ConnectionMode mode)
Expand All @@ -135,6 +142,7 @@ public override async Task QueryOperationSinglePartitionTest(ConnectionMode mode
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
[DataRow(ConnectionMode.Gateway)]
public override async Task QueryMultiPageSinglePartitionOperationTest(ConnectionMode mode)
Expand All @@ -143,6 +151,7 @@ public override async Task QueryMultiPageSinglePartitionOperationTest(Connection
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
[DataRow(ConnectionMode.Gateway)]
public override async Task QueryOperationCrossPartitionTest(ConnectionMode mode)
Expand All @@ -151,6 +160,7 @@ public override async Task QueryOperationCrossPartitionTest(ConnectionMode mode)
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
[DataRow(ConnectionMode.Gateway)]
public override async Task QueryOperationMutiplePageCrossPartitionTest(ConnectionMode mode)
Expand All @@ -159,6 +169,7 @@ public override async Task QueryOperationMutiplePageCrossPartitionTest(Connectio
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
[DataRow(ConnectionMode.Gateway)]
public override async Task QueryOperationInvalidContinuationTokenTest(ConnectionMode mode)
Expand All @@ -167,6 +178,7 @@ public override async Task QueryOperationInvalidContinuationTokenTest(Connection
}

[TestMethod]
[Timeout(300000)]
[DataRow(ConnectionMode.Direct)]
public override async Task CreateItemWithSubStatusCodeTest(ConnectionMode mode)
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -214,7 +214,7 @@ public async Task AvailabilityStrategyNoTriggerTest(bool isPreferredLocationsEmp
.Build(),
result:
FaultInjectionResultBuilder.GetResultBuilder(FaultInjectionServerErrorType.ResponseDelay)
.WithDelay(TimeSpan.FromMilliseconds(200))
.WithDelay(TimeSpan.FromMilliseconds(500))
.Build())
.WithDuration(TimeSpan.FromMinutes(90))
.Build();
Expand Down Expand Up @@ -243,7 +243,7 @@ public async Task AvailabilityStrategyNoTriggerTest(bool isPreferredLocationsEmp
ConnectionMode = ConnectionMode.Direct,
ApplicationPreferredRegions = isPreferredLocationsEmpty ? new List<string>() : new List<string>() { region1, region2 },
AvailabilityStrategy = AvailabilityStrategy.CrossRegionHedgingStrategy(
threshold: TimeSpan.FromMilliseconds(150),
threshold: TimeSpan.FromMilliseconds(300),
thresholdStep: TimeSpan.FromMilliseconds(50)),
Serializer = this.cosmosSystemTextJsonSerializer
};
Expand Down Expand Up @@ -585,7 +585,7 @@ public async Task AvailabilityStrategyAllFaultsTests(string operation, string co
ConnectionMode = ConnectionMode.Direct,
ApplicationPreferredRegions = isPreferredLocationsEmpty ? new List<string>() :new List<string>() { region1, region2 },
AvailabilityStrategy = AvailabilityStrategy.CrossRegionHedgingStrategy(
threshold: TimeSpan.FromMilliseconds(100),
threshold: TimeSpan.FromMilliseconds(200),
thresholdStep: TimeSpan.FromMilliseconds(50)),
Serializer = this.cosmosSystemTextJsonSerializer
};
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -794,7 +794,7 @@ public async Task ReadItemAsync_WithCircuitBreakerEnabledAndSingleMasterAccountA
await this.TryCreateItems(itemsList);

//Must Ensure the data is replicated to all regions
await Task.Delay(3000);
await Task.Delay(5000);

bool isRegion1Available = true;
bool isRegion2Available = true;
Expand Down Expand Up @@ -1055,7 +1055,7 @@ public async Task ReadItemAsync_WithCircuitBreakerDisabledAndSingleMasterAccount
await this.TryCreateItems(itemsList);

//Must Ensure the data is replicated to all regions
await Task.Delay(3000);
await Task.Delay(5000);

int consecutiveFailureCount = 10;
for (int attemptCount = 1; attemptCount <= consecutiveFailureCount; attemptCount++)
Expand Down
Loading
Loading