From 44142d82d0e31958c0bb0f7de3a0124e82299e93 Mon Sep 17 00:00:00 2001
From: Kevin <kevinyeti@gmail.com>
Date: Thu, 26 Apr 2018 17:58:51 +0800
Subject: [PATCH] Agent.Cocohub 1.0.0.20

---
 src/Agent.Cocohub/Agent.Cocohub.csproj |  6 +++---
 src/Agent.Cocohub/AgentThread.cs       | 25 ++++++++++++++++---------
 2 files changed, 19 insertions(+), 12 deletions(-)

diff --git a/src/Agent.Cocohub/Agent.Cocohub.csproj b/src/Agent.Cocohub/Agent.Cocohub.csproj
index 7403693..f51195e 100644
--- a/src/Agent.Cocohub/Agent.Cocohub.csproj
+++ b/src/Agent.Cocohub/Agent.Cocohub.csproj
@@ -3,9 +3,9 @@
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
-    <Version>1.0.0.19</Version>
-    <FileVersion>1.0.0.19</FileVersion>
-    <AssemblyVersion>1.0.0.19</AssemblyVersion>
+    <Version>1.0.0.20</Version>
+    <FileVersion>1.0.0.20</FileVersion>
+    <AssemblyVersion>1.0.0.20</AssemblyVersion>
   </PropertyGroup>
 
   <ItemGroup>
diff --git a/src/Agent.Cocohub/AgentThread.cs b/src/Agent.Cocohub/AgentThread.cs
index eed7dbb..3894028 100644
--- a/src/Agent.Cocohub/AgentThread.cs
+++ b/src/Agent.Cocohub/AgentThread.cs
@@ -41,19 +41,22 @@ internal static void CoreFetch()
             {
                 try
                 {
+                    if (_logs.Count > 1000)
+                    {
+                        Thread.Sleep(1000);
+                        continue;
+                    }
+
                     var logs = LogReader.Fetch();
                     if (logs == null || logs.Length == 0)
                     {
-                        Thread.Sleep(3000);
+                        Thread.Sleep(1000);
                         continue;
                     }
 
                     Parallel.ForEach(logs, (log) => { _logs.Enqueue(log); });
 
-                    if (logs.Length >= 5000)
-                        Thread.Sleep(1000);
-                    else
-                        Thread.Sleep(10000);
+                    Thread.Sleep(1000);
                 }
                 catch(Exception ex) 
                 {
@@ -72,10 +75,10 @@ internal static void CoreWrite()
             {
                 try
                 {
-                    int loop = _logs.Count > 10000 ? 10000 : _logs.Count;
+                    int loop = _logs.Count > 5000 ? 5000 : _logs.Count;
                     if (loop == 0)
                     {
-                        Thread.Sleep(3000);
+                        Thread.Sleep(1000);
                         continue;
                     }
                     List<LogEntity> entities = new List<LogEntity>();
@@ -100,11 +103,15 @@ internal static void CoreWrite()
                         _error.Clear();
                         _error = null;
                     }
-                    
+
                     if (entities.Count > 0)
+                    {
                         _write(entities);
+                        entities.Clear();
+                        entities = null;
+                    }
 
-                    if (loop >= 10000)
+                    if (loop >= 5000)
                         Thread.Sleep(1000);
                     else
                         Thread.Sleep(3000);