diff options
| author | Rickard Green <[email protected]> | 2012-12-21 03:10:21 +0100 |
|---|---|---|
| committer | Rickard Green <[email protected]> | 2013-01-23 14:36:16 +0100 |
| commit | e3373f0602282040ae7a75b5b7ebbdcae2789c17 (patch) | |
| tree | 6bf3274a0c0704770ee702c4ab60a32c293984bf /erts/emulator/beam/erl_port_task.c | |
| parent | b4d9950e94ab0aedb3a2d2944a8b40f94f738f99 (diff) | |
| download | otp-e3373f0602282040ae7a75b5b7ebbdcae2789c17.tar.gz otp-e3373f0602282040ae7a75b5b7ebbdcae2789c17.tar.bz2 otp-e3373f0602282040ae7a75b5b7ebbdcae2789c17.zip | |
Bump reductions also for immediate driver calls
Diffstat (limited to 'erts/emulator/beam/erl_port_task.c')
| -rw-r--r-- | erts/emulator/beam/erl_port_task.c | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/erts/emulator/beam/erl_port_task.c b/erts/emulator/beam/erl_port_task.c index 8ceadcdb8c..09c8e760f4 100644 --- a/erts/emulator/beam/erl_port_task.c +++ b/erts/emulator/beam/erl_port_task.c @@ -35,6 +35,11 @@ #include "dtrace-wrapper.h" #include <stdarg.h> +/* + * ERTS_PORT_CALLBACK_VREDS: Limit the amount of callback calls we do... + */ +#define ERTS_PORT_CALLBACK_VREDS (CONTEXT_REDS/5) + #if defined(DEBUG) && 0 #define ERTS_HARD_DEBUG_TASK_QUEUES #else @@ -1544,6 +1549,7 @@ erts_port_task_execute(ErtsRunQueue *runq, Port **curr_port_pp) ErtsPortTask *execq; int processing_busy_q; int res = 0; + int vreds = 0; int reds = ERTS_PORT_REDS_EXECUTE; erts_aint_t io_tasks_executed = 0; int fpe_was_unmasked; @@ -1688,6 +1694,9 @@ erts_port_task_execute(ErtsRunQueue *runq, Port **curr_port_pp) break; } + vreds += ERTS_PORT_CALLBACK_VREDS; + reds += ERTS_PORT_CALLBACK_VREDS; + if (reds >= CONTEXT_REDS) break; } @@ -1757,6 +1766,7 @@ erts_port_task_execute(ErtsRunQueue *runq, Port **curr_port_pp) res = (erts_smp_atomic_read_nob(&erts_port_task_outstanding_io_tasks) != (erts_aint_t) 0); + reds -= vreds; runq->scheduler->reductions += reds; ERTS_SMP_LC_ASSERT(erts_smp_lc_runq_is_locked(runq)); |