/
scheduler.dart
50 lines (40 loc) · 1.48 KB
/
scheduler.dart
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
// Copyright 2022 MongoDB, Inc.
// SPDX-License-Identifier: Apache-2.0
import 'dart:ffi';
import 'dart:isolate';
import 'package:realm_dart/src/logging.dart';
import 'native/realm_core.dart';
import 'realm_class.dart';
final _receivePortFinalizer = Finalizer<RawReceivePort>((p) => p.close());
final Scheduler scheduler = Scheduler._();
class Scheduler {
late final SchedulerHandle handle;
final RawReceivePort _receivePort = RawReceivePort();
int get nativePort => _receivePort.sendPort.nativePort;
Scheduler._() {
_receivePortFinalizer.attach(this, _receivePort, detach: this);
_receivePort.handler = (dynamic message) {
if (message is List) {
// currently the only `message as List` is from the logger.
final category = LogCategory.fromString(message[0] as String);
final level = LogLevel.values[message[1] as int];
final text = message[2] as String;
Realm.logger.raise((category: category, level: level, message: text));
} else if (message is int) {
realmCore.invokeScheduler(message);
} else {
Realm.logger.log(LogLevel.error, 'Unexpected Scheduler message type: ${message.runtimeType} - $message');
}
};
final sendPort = _receivePort.sendPort;
handle = realmCore.createScheduler(Isolate.current.hashCode, sendPort.nativePort);
}
void stop() {
if (handle.released) {
return;
}
_receivePort.close();
_receivePortFinalizer.detach(this);
handle.release();
}
}