diff options
| author | Lukas Larsson <[email protected]> | 2018-10-18 10:25:31 +0200 |
|---|---|---|
| committer | Lukas Larsson <[email protected]> | 2018-12-03 13:33:53 +0100 |
| commit | d4440ce1793638f8daca35a32936d3005cc3be7a (patch) | |
| tree | 02debd4e39d6d79c11c1606b0648c28dd0abb758 /erts/emulator | |
| parent | 4f68b86b22806fb052def64926ae7340facaed53 (diff) | |
| download | otp-d4440ce1793638f8daca35a32936d3005cc3be7a.tar.gz otp-d4440ce1793638f8daca35a32936d3005cc3be7a.tar.bz2 otp-d4440ce1793638f8daca35a32936d3005cc3be7a.zip | |
erts: Optimize driver_set_timer(0) to fire at once
By optimizing driver_set_timer for 0 we can use it
instead of select to do a yield in the driver.
Use full for delay_send in the inet driver.
OTP-15472
Diffstat (limited to 'erts/emulator')
| -rw-r--r-- | erts/emulator/beam/erl_hl_timer.c | 26 |
1 files changed, 17 insertions, 9 deletions
diff --git a/erts/emulator/beam/erl_hl_timer.c b/erts/emulator/beam/erl_hl_timer.c index 6ec6f8065e..ef7a55fa38 100644 --- a/erts/emulator/beam/erl_hl_timer.c +++ b/erts/emulator/beam/erl_hl_timer.c @@ -3041,15 +3041,23 @@ erts_set_port_timer(Port *c_prt, Sint64 tmo) check_canceled_queue(esdp, esdp->timer_service); - timeout_pos = get_timeout_pos(erts_get_monotonic_time(esdp), tmo); - - create_timer = (tmo < ERTS_TIMER_WHEEL_MSEC - ? create_tw_timer - : create_hl_timer); - tmr = (void *) create_timer(esdp, timeout_pos, 0, ERTS_TMR_PORT, - (void *) c_prt, c_prt->common.id, - THE_NON_VALUE, NULL, NULL, NULL); - erts_atomic_set_relb(&c_prt->common.timer, (erts_aint_t) tmr); + if (tmo == 0) { + erts_atomic_set_relb(&c_prt->common.timer, ERTS_PTMR_TIMEDOUT); + erts_port_task_schedule(c_prt->common.id, + &c_prt->timeout_task, + ERTS_PORT_TASK_TIMEOUT); + } else { + + timeout_pos = get_timeout_pos(erts_get_monotonic_time(esdp), tmo); + + create_timer = (tmo < ERTS_TIMER_WHEEL_MSEC + ? create_tw_timer + : create_hl_timer); + tmr = (void *) create_timer(esdp, timeout_pos, 0, ERTS_TMR_PORT, + (void *) c_prt, c_prt->common.id, + THE_NON_VALUE, NULL, NULL, NULL); + erts_atomic_set_relb(&c_prt->common.timer, (erts_aint_t) tmr); + } } void |