| Hit | Total | Coverage | |
|---|---|---|---|
| Lines | 35 | 35 | 100.0% |
| Functions | 0 | 0 | - |
| Branches | 0 | 0 | - |
| Line | Branch | Hits | Source code |
|---|---|---|---|
| 1 | part of 'worker.dart'; |
||
| 2 | |
||
| 3 | class _Stats { |
||
| 4 | 11 | _Stats(Worker w) |
|
| 5 | 11 | : _idle = Timestamp.now(), |
|
| 6 | _worker = w; |
||
| 7 | |
||
| 8 | final Worker _worker; |
||
| 9 | |
||
| 10 | 10 | void start() { |
|
| 11 | 30 | _idle = _started = Timestamp.now(); |
|
| 12 | } |
||
| 13 | |
||
| 14 | 11 | void stop() { |
|
| 15 | 22 | _stopped = Timestamp.now(); |
|
| 16 | } |
||
| 17 | |
||
| 18 | 10 | void beginWork() { |
|
| 19 | 20 | _workload++; |
|
| 20 | 30 | if (_workload > _maxWorkload) { |
|
| 21 | 20 | _maxWorkload = _workload; |
|
| 22 | } |
||
| 23 | } |
||
| 24 | |
||
| 25 | 10 | void endWork([dynamic _]) { |
|
| 26 | 20 | _workload--; |
|
| 27 | 20 | _totalWorkload++; |
|
| 28 | 20 | if (_workload == 0) { |
|
| 29 | 20 | _idle = Timestamp.now(); |
|
| 30 | } |
||
| 31 | } |
||
| 32 | |
||
| 33 | 4 | void failed() { |
|
| 34 | 8 | _totalErrors++; |
|
| 35 | } |
||
| 36 | |
||
| 37 | /// Start timestamp |
||
| 38 | Timestamp? _started; |
||
| 39 | |
||
| 40 | /// Stopped timestamp |
||
| 41 | Timestamp? _stopped; |
||
| 42 | |
||
| 43 | /// Idle timestamp. |
||
| 44 | Timestamp _idle; |
||
| 45 | |
||
| 46 | /// Current workload. |
||
| 47 | int _workload = 0; |
||
| 48 | |
||
| 49 | /// Maximum acceptable workload. |
||
| 50 | int _maxWorkload = 0; |
||
| 51 | |
||
| 52 | /// Total processed workload. |
||
| 53 | int _totalWorkload = 0; |
||
| 54 | |
||
| 55 | /// Total errors. |
||
| 56 | int _totalErrors = 0; |
||
| 57 | |
||
| 58 | 6 | Duration _getUpTime(Timestamp timestamp) => |
|
| 59 | 18 | (_started == null) ? Duration.zero : timestamp.elapsedSince(_started!); |
|
| 60 | |
||
| 61 | 6 | Duration _getIdleTime(Timestamp timestamp) => |
|
| 62 | 24 | (_workload > 0) ? Duration.zero : timestamp.elapsedSince(_idle); |
|
| 63 | |
||
| 64 | /// Indicates if the [Worker] has been stopped. |
||
| 65 | 22 | bool get isStopped => _stopped != null; |
|
| 66 | |
||
| 67 | 6 | WorkerStat get snapshot { |
|
| 68 | 6 | final ts = Timestamp.now(); |
|
| 69 | 6 | return WorkerStatImpl.create( |
|
| 70 | 12 | _worker.runtimeType, |
|
| 71 | 12 | _worker.hashCode, |
|
| 72 | 6 | isStopped, |
|
| 73 | 6 | _workload, |
|
| 74 | 6 | _maxWorkload, |
|
| 75 | 6 | _totalWorkload, |
|
| 76 | 6 | _totalErrors, |
|
| 77 | 12 | _getUpTime(_stopped ?? ts), |
|
| 78 | 6 | _getIdleTime(ts), |
|
| 79 | 18 | _worker._channel?.getActiveConnections() ?? 0, |
|
| 80 | ); |
||
| 81 | } |
||
| 82 | } |