Skip to content

Commit 0f264c8

Browse files
fix: lint
1 parent 92811fe commit 0f264c8

File tree

5 files changed

+40
-41
lines changed

5 files changed

+40
-41
lines changed

benchmark/BenchmarkRunner/Benchmarks/MysqlWriteBenchmark.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public async Task IterationSetup()
3737
await MysqlDatabaseHelper.CleanupWriteTableAsync(_connectionString);
3838
Helpers.InvokeGarbageCollection();
3939
}
40-
40+
4141
private async Task PrepareTestDataAsync()
4242
{
4343
await MysqlDatabaseHelper.CleanupDatabaseAsync(_connectionString);

benchmark/BenchmarkRunner/Benchmarks/PostgresqlWriteBenchmark.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ public async Task IterationSetup()
3737
await PostgresqlDatabaseHelper.CleanupWriteTableAsync(_connectionString);
3838
Helpers.InvokeGarbageCollection();
3939
}
40-
40+
4141
private async Task PrepareTestDataAsync()
4242
{
4343
PostgresqlDatabaseHelper.CleanupDatabaseAsync(_connectionString).GetAwaiter().GetResult();

benchmark/BenchmarkRunner/Program.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,19 +36,19 @@ public static async Task Main(string[] args)
3636
{
3737
case "mysql":
3838
var mysqlRunner = new MysqlRunner(
39-
Config.GetMysqlConnectionString(),
39+
Config.GetMysqlConnectionString(),
4040
loggerFactory.CreateLogger<MysqlRunner>());
4141
await mysqlRunner.RunAsync();
4242
break;
4343
case "postgresql":
4444
var postgresqlRunner = new PostgresqlRunner(
45-
Config.GetPostgresConnectionString(),
45+
Config.GetPostgresConnectionString(),
4646
loggerFactory.CreateLogger<PostgresqlRunner>());
4747
await postgresqlRunner.RunAsync();
4848
break;
4949
case "sqlite":
5050
var sqliteRunner = new SqliteRunner(
51-
Config.GetSqliteConnectionString(),
51+
Config.GetSqliteConnectionString(),
5252
loggerFactory.CreateLogger<SqliteRunner>());
5353
await sqliteRunner.RunAsync();
5454
break;
Lines changed: 34 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -1,35 +1,34 @@
1-
using System.Linq;
2-
3-
namespace BenchmarkRunner.Utils;
4-
5-
public static class Helpers
6-
{
7-
public static void InvokeGarbageCollection()
8-
{
9-
GC.Collect();
10-
GC.WaitForPendingFinalizers();
11-
GC.Collect();
12-
}
13-
14-
public static async Task InsertInBatchesAsync<T>(List<T> items, int batchSize, Func<List<T>, Task> insertBatch)
15-
{
16-
for (int i = 0; i < items.Count; i += batchSize)
17-
{
18-
var batch = items.Skip(i).Take(batchSize).ToList();
19-
await insertBatch(batch);
20-
}
21-
}
22-
23-
public static async Task<List<T>> ExecuteConcurrentlyAsync<T>(int concurrency, Func<int, Task<List<T>>> taskFactory)
24-
{
25-
var tasks = new List<Task<List<T>>>();
26-
for (int i = 0; i < concurrency; i++)
27-
{
28-
tasks.Add(taskFactory(i));
29-
}
30-
31-
var results = await Task.WhenAll(tasks);
32-
return [.. results.SelectMany(r => r)];
33-
}
34-
}
35-
1+
using System.Linq;
2+
3+
namespace BenchmarkRunner.Utils;
4+
5+
public static class Helpers
6+
{
7+
public static void InvokeGarbageCollection()
8+
{
9+
GC.Collect();
10+
GC.WaitForPendingFinalizers();
11+
GC.Collect();
12+
}
13+
14+
public static async Task InsertInBatchesAsync<T>(List<T> items, int batchSize, Func<List<T>, Task> insertBatch)
15+
{
16+
for (int i = 0; i < items.Count; i += batchSize)
17+
{
18+
var batch = items.Skip(i).Take(batchSize).ToList();
19+
await insertBatch(batch);
20+
}
21+
}
22+
23+
public static async Task<List<T>> ExecuteConcurrentlyAsync<T>(int concurrency, Func<int, Task<List<T>>> taskFactory)
24+
{
25+
var tasks = new List<Task<List<T>>>();
26+
for (int i = 0; i < concurrency; i++)
27+
{
28+
tasks.Add(taskFactory(i));
29+
}
30+
31+
var results = await Task.WhenAll(tasks);
32+
return [.. results.SelectMany(r => r)];
33+
}
34+
}

benchmark/BenchmarkRunner/Utils/SqliteDatabaseHelper.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ public static void CleanupDatabase(string connectionString)
2424
if (string.IsNullOrEmpty(dbFilename))
2525
return;
2626

27-
var filesToDelete = new [] {
27+
var filesToDelete = new[] {
2828
dbFilename,
2929
dbFilename + "-wal",
3030
dbFilename + "-shm"

0 commit comments

Comments
 (0)