[skywalking] branch master updated: Fixed buffer lost. (#3118)

[wusheng]

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git


The following commit(s) were added to refs/heads/master by this push:
     new 8d70533  Fixed buffer lost. (#3118)
8d70533 is described below

commit 8d70533921caa15d10b5586ddd66930e9c1bd418
Author: 彭勇升 pengys <pen...@apache.org>
AuthorDate: Fri Jul 19 22:07:53 2019 +0800

    Fixed buffer lost. (#3118)
---
 .../apache/skywalking/oap/server/library/buffer/DataStreamReader.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/oap-server/server-library/library-buffer/src/main/java/org/apache/skywalking/oap/server/library/buffer/DataStreamReader.java
 
b/oap-server/server-library/library-buffer/src/main/java/org/apache/skywalking/oap/server/library/buffer/DataStreamReader.java
index 12849bf..8f72c1e 100644
--- 
a/oap-server/server-library/library-buffer/src/main/java/org/apache/skywalking/oap/server/library/buffer/DataStreamReader.java
+++ 
b/oap-server/server-library/library-buffer/src/main/java/org/apache/skywalking/oap/server/library/buffer/DataStreamReader.java
@@ -145,6 +145,10 @@ public class DataStreamReader<MESSAGE_TYPE extends 
GeneratedMessageV3> {
                     }
                 }
             }
+
+            if (bufferDataCollection.size() > 0) {
+                reCall();
+            }
         } catch (IOException e) {
             logger.error(e.getMessage(), e);
         }