aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorSverker Eriksson <[email protected]>2012-07-05 15:59:33 +0200
committerSverker Eriksson <[email protected]>2012-07-05 15:59:33 +0200
commit866cf9343b289d94c144600af1765e6754cfb593 (patch)
tree4ce3413ffac24d2a0afe57fed33750c76d038b69
parent13fb710888b866830b673d019485ad58756fd23f (diff)
parent6dce0a74e95eee03c9d3999ed192f4a0e6295919 (diff)
downloadotp-866cf9343b289d94c144600af1765e6754cfb593.tar.gz
otp-866cf9343b289d94c144600af1765e6754cfb593.tar.bz2
otp-866cf9343b289d94c144600af1765e6754cfb593.zip
Merge branch 'sverk/missing-distr-stats'
* sverk/missing-distr-stats: Fix missing accounting for outbound distribution bytes.
-rw-r--r--erts/emulator/beam/dist.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/erts/emulator/beam/dist.c b/erts/emulator/beam/dist.c
index 300c2b708f..5db68f6d45 100644
--- a/erts/emulator/beam/dist.c
+++ b/erts/emulator/beam/dist.c
@@ -1969,6 +1969,7 @@ erts_dist_command(Port *prt, int reds_limit)
bw(foq.first->extp, size);
#endif
reds += ERTS_PORT_REDS_DIST_CMD_DATA(size);
+ erts_smp_atomic_add_nob(&erts_bytes_out, size);
fob = foq.first;
obufsize += size_obuf(fob);
foq.first = foq.first->next;
@@ -2052,6 +2053,7 @@ erts_dist_command(Port *prt, int reds_limit)
bw(oq.first->extp, size);
#endif
reds += ERTS_PORT_REDS_DIST_CMD_DATA(size);
+ erts_smp_atomic_add_nob(&erts_bytes_out, size);
fob = oq.first;
obufsize += size_obuf(fob);
oq.first = oq.first->next;