mirror of
https://github.com/Niko1221/Strata.git
synced 2026-11-07 06:15:58 -10:00
serve/test_admit_order: the engine stand-in sets the arrivals deque the coalescing code reads
This commit is contained in:
1 parent
b6fc410ee5
commit
203df526f1
1 file changed
+2
@@ -6,6 +6,7 @@
|
||||
from __future__ import annotations
|
||||
|
||||
import sys
|
||||
import collections
|
||||
import threading
|
||||
import time
|
||||
import unittest
|
||||
@@ -25,6 +26,7 @@ def engine_without_process(n=2):
|
||||
e.slot_claims, e.slot_releasing, e._orphan_seen = set(), set(), {}
|
||||
e.slot_cv = threading.Condition()
|
||||
e.waiting, e.admitting, e.wait_lens, e.ctl_epoch = 0, 0, [], 0
|
||||
e.arrivals = collections.deque(maxlen=64)
|
||||
e.ctl = threading.Lock()
|
||||
e.gen = 1
|
||||
e.up = True
|
||||
|
||||
Reference in new issue
Block a user