diff options
Diffstat (limited to 'test/foundationdb/foundationdb_concurrent_test.go')
| -rw-r--r-- | test/foundationdb/foundationdb_concurrent_test.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/test/foundationdb/foundationdb_concurrent_test.go b/test/foundationdb/foundationdb_concurrent_test.go index b0ecaf742..de49ecc61 100644 --- a/test/foundationdb/foundationdb_concurrent_test.go +++ b/test/foundationdb/foundationdb_concurrent_test.go @@ -65,9 +65,9 @@ func TestFoundationDBStore_ConcurrentInserts(t *testing.T) { expectedTotal := numGoroutines * entriesPerGoroutine actualCount := 0 - _, err := store.ListDirectoryEntries(ctx, "/concurrent", "", true, 10000, func(entry *filer.Entry) bool { + _, err := store.ListDirectoryEntries(ctx, "/concurrent", "", true, 10000, func(entry *filer.Entry) (bool, error) { actualCount++ - return true + return true, nil }) if err != nil { t.Fatalf("ListDirectoryEntries failed: %v", err) @@ -265,9 +265,9 @@ func TestFoundationDBStore_ConcurrentTransactions(t *testing.T) { totalExpectedEntries := successCount * entriesPerTransaction actualCount := 0 - _, err := store.ListDirectoryEntries(ctx, "/transactions", "", true, 10000, func(entry *filer.Entry) bool { + _, err := store.ListDirectoryEntries(ctx, "/transactions", "", true, 10000, func(entry *filer.Entry) (bool, error) { actualCount++ - return true + return true, nil }) if err != nil { t.Fatalf("ListDirectoryEntries failed: %v", err) @@ -335,9 +335,9 @@ func TestFoundationDBStore_ConcurrentDirectoryOperations(t *testing.T) { dirPath := fmt.Sprintf("/worker%d/dir%d", w, d) fileCount := 0 - _, err := store.ListDirectoryEntries(ctx, dirPath, "", true, 1000, func(entry *filer.Entry) bool { + _, err := store.ListDirectoryEntries(ctx, dirPath, "", true, 1000, func(entry *filer.Entry) (bool, error) { fileCount++ - return true + return true, nil }) if err != nil { t.Errorf("ListDirectoryEntries failed for %s: %v", dirPath, err) |