Git-Mirrors/veilidchat
1
0
Fork 0
mirror of https://gitlab.com/veilid/veilidchat.git synced 2024-10-01 06:55:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

parallelize getAllItems

Browse Source
This commit is contained in:
Christien Rioux 2024-04-28 21:18:30 -04:00
parent 0b4de3ad13
commit 7e9254faac
5 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
packages/veilid_support/lib/dht_support/src/dht_record/dht_record_pool.dart
View File

@ -24,6 +24,9 @@ const int? defaultWatchDurationSecs = null; // 600
const int watchRenewalNumerator = 4; const int watchRenewalNumerator = 4;
const int watchRenewalDenominator = 5; const int watchRenewalDenominator = 5;
// Maximum number of concurrent DHT operations to perform on the network
const int maxDHTConcurrency = 8;
typedef DHTRecordPoolLogger = void Function(String message); typedef DHTRecordPoolLogger = void Function(String message);
/// Record pool that managed DHTRecords and allows for tagged deletion /// Record pool that managed DHTRecords and allows for tagged deletion

1
packages/veilid_support/lib/dht_support/src/dht_short_array/dht_short_array.dart
View File

@ -1,6 +1,7 @@
import 'dart:async'; import 'dart:async';
import 'dart:typed_data'; import 'dart:typed_data';
import 'package:collection/collection.dart';
import 'package:mutex/mutex.dart'; import 'package:mutex/mutex.dart';
import 'package:protobuf/protobuf.dart'; import 'package:protobuf/protobuf.dart';

13
packages/veilid_support/lib/dht_support/src/dht_short_array/dht_short_array_read.dart
View File

@ -93,12 +93,17 @@ class _DHTShortArrayRead implements DHTShortArrayRead {
Future<List<Uint8List>?> getAllItems({bool forceRefresh = false}) async { Future<List<Uint8List>?> getAllItems({bool forceRefresh = false}) async {
final out = <Uint8List>[]; final out = <Uint8List>[];
for (var pos = 0; pos < _head.length; pos++) { final chunks = Iterable<int>.generate(_head.length)
final elem = await getItem(pos, forceRefresh: forceRefresh); .slices(maxDHTConcurrency)
if (elem == null) { .map((chunk) =>
chunk.map((pos) => getItem(pos, forceRefresh: forceRefresh)));
for (final chunk in chunks) {
final elems = await chunk.wait;
if (elems.contains(null)) {
return null; return null;
} }
out.add(elem); out.addAll(elems.cast<Uint8List>());
} }
return out; return out;

2
packages/veilid_support/pubspec.lock
View File

@ -168,7 +168,7 @@ packages:
source: hosted source: hosted
version: "4.10.0" version: "4.10.0"
collection: collection:
dependency: transitive dependency: "direct main"
description: description:
name: collection name: collection
sha256: ee67cb0715911d28db6bf4af1026078bd6f0128b07a5f66fb2ed94ec6783c09a sha256: ee67cb0715911d28db6bf4af1026078bd6f0128b07a5f66fb2ed94ec6783c09a

1
packages/veilid_support/pubspec.yaml
View File

@ -12,6 +12,7 @@ dependencies:
bloc: ^8.1.3 bloc: ^8.1.3
bloc_tools: bloc_tools:
path: ../bloc_tools path: ../bloc_tools
collection: ^1.18.0
equatable: ^2.0.5 equatable: ^2.0.5
fast_immutable_collections: ^10.1.1 fast_immutable_collections: ^10.1.1
freezed_annotation: ^2.4.1 freezed_annotation: ^2.4.1