Commit 7ff21b6
committed
Prepare trust DB read concurrency
Trust database decisions used a process-global LMDB read transaction and cursor guarded by update_lock. That made future decision readers share mutable cursor state and serialize all lookups behind the update mutex; LMDB was also capped at four readers with no metric when reader slots were full.
The fix opens private short-lived LMDB read transactions and cursors for trust lookups under a shared read lock, while trust DB rebuild and update paths keep exclusive writer ownership. The DBI is initialized with the environment, max readers are sized for the planned 32-worker cap plus maintenance readers, and resettable metrics report cheap lookup count and reader-slots-full counters. Lookup latency stays in the armed decision timing report through the existing trust_db_lookup total, lock_wait, and read stage rows instead of adding per-lookup clock reads to normal metrics collection.
Tests add concurrent trust DB lookup coverage and metrics reset/report checks in trustdb_lmdb_test, including assertions that lookup average/max timing fields are absent from the metrics report.1 parent e8e6c8e commit 7ff21b6
11 files changed
Lines changed: 573 additions & 157 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
110 | 110 | | |
111 | 111 | | |
112 | 112 | | |
| 113 | + | |
| 114 | + | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
| 121 | + | |
| 122 | + | |
| 123 | + | |
| 124 | + | |
| 125 | + | |
113 | 126 | | |
114 | 127 | | |
115 | 128 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
89 | 89 | | |
90 | 90 | | |
91 | 91 | | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
92 | 96 | | |
93 | 97 | | |
94 | 98 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
505 | 505 | | |
506 | 506 | | |
507 | 507 | | |
508 | | - | |
| 508 | + | |
509 | 509 | | |
510 | 510 | | |
511 | 511 | | |
| |||
516 | 516 | | |
517 | 517 | | |
518 | 518 | | |
519 | | - | |
520 | | - | |
| 519 | + | |
| 520 | + | |
| 521 | + | |
521 | 522 | | |
522 | 523 | | |
523 | 524 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1012 | 1012 | | |
1013 | 1013 | | |
1014 | 1014 | | |
| 1015 | + | |
1015 | 1016 | | |
1016 | 1017 | | |
1017 | 1018 | | |
| |||
0 commit comments