![]() The status manager syncBatch() method processes the current state of the cache, which should include all entries in the channel. Flush the channel before we call a batch to avoid unnecessary work and to unblock pod workers when the node is congested. Discovered while investigating long shutdown intervals on the node where the status channel stayed full for tens of seconds. Add a for loop around the select statement to avoid unnecessary invocations of the wait.Forever closure each time. |
||
---|---|---|
.. | ||
testing | ||
BUILD | ||
generate_test.go | ||
generate.go | ||
status_manager_test.go | ||
status_manager.go |