()
| 448 | } |
| 449 | |
| 450 | function maybeClearDrainRetry() { |
| 451 | if (queueSize === 0 && queueDrainRetryTimeout) { |
| 452 | clearTimeout(queueDrainRetryTimeout) |
| 453 | queueDrainRetryTimeout = null |
| 454 | } |
| 455 | } |
| 456 | |
| 457 | function getOrCreateOwnerState(ownerKey: string, ownerWeight: number): OwnerState { |
| 458 | const existing = ownerStates.get(ownerKey) |