From 44b56000116a473082d7bcfef911f510972b9cec Mon Sep 17 00:00:00 2001
From: Rickard Green <rickard@erlang.org>
Date: Wed, 24 Apr 2019 14:42:45 +0200
Subject: Fix distribution queue size adjustment

---
 erts/emulator/beam/dist.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/erts/emulator/beam/dist.c b/erts/emulator/beam/dist.c
index 27599f38e0..d15db760a2 100644
--- a/erts/emulator/beam/dist.c
+++ b/erts/emulator/beam/dist.c
@@ -3455,6 +3455,8 @@ dist_ctrl_get_data_1(BIF_ALIST_1)
         obufsize -= size_obuf(obuf);
         if (reds < 0) {
             erts_de_runlock(dep);
+            if (obufsize)
+                erts_atomic_add_nob(&dep->qsize, (erts_aint_t) -obufsize);
             ERTS_BIF_YIELD1(bif_export[BIF_dist_ctrl_get_data_1],
                             BIF_P, BIF_ARG_1);
         }
-- 
cgit v1.2.3