diff options
Diffstat (limited to 'core/sync')
| -rw-r--r-- | core/sync/chan/chan.odin | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/core/sync/chan/chan.odin b/core/sync/chan/chan.odin index 2c34f7bb3..17c251158 100644 --- a/core/sync/chan/chan.odin +++ b/core/sync/chan/chan.odin @@ -7,6 +7,14 @@ import "core:mem" import "core:sync" import "core:math/rand" +when ODIN_TEST { +/* +Hook for testing _try_select_raw allowing the test harness to manipulate the +channels prior to the select actually operating on them. +*/ +__try_select_raw_pause : proc() = nil +} + /* Determines what operations `Chan` supports. */ @@ -1221,6 +1229,12 @@ try_select_raw :: proc "odin" (recvs: []^Raw_Chan, sends: []^Raw_Chan, send_msgs return -1, .None } + when ODIN_TEST { + if __try_select_raw_pause != nil { + __try_select_raw_pause() + } + } + candidate_idx := rand.int_max(count) if count > 0 else 0 sel := candidates[candidate_idx] |