aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorRick Reed <[email protected]>2012-03-16 15:40:16 -0700
committerSverker Eriksson <[email protected]>2012-06-21 11:28:47 +0200
commit6dce0a74e95eee03c9d3999ed192f4a0e6295919 (patch)
tree559f4782aa2174af79757dfa9fbe27345cd49236
parentc2388ad41790c266b0e78724b95ec92d2951b43a (diff)
downloadotp-6dce0a74e95eee03c9d3999ed192f4a0e6295919.tar.gz
otp-6dce0a74e95eee03c9d3999ed192f4a0e6295919.tar.bz2
otp-6dce0a74e95eee03c9d3999ed192f4a0e6295919.zip
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;