commit a573079d8f00cb7af417b3e567c0e1caa9a44a5e
author Sapan Bhatia <gwsapan@gmail.com> Thu Mar 02 11:02:13 2017 +0100
committer Zack Williams <zdw@cs.arizona.edu> Thu Mar 02 08:05:19 2017 -0800
tree 504a934e7664269dcf11617bbb77d92b76e1e035
parent 46dfda6e53a7671d0ce443671e0320c3b19ea340

CORD-1002: Fix a hang (long wait) in logstash_tail

Change-Id: Ie2e07665759d86877bcbfa34f2d923f69aada46a

elk-logger/logstash_tail

diff --git a/elk-logger/logstash_tail b/elk-logger/logstash_tail
index a4d6f29..6b29718 100755
--- a/elk-logger/logstash_tail
+++ b/elk-logger/logstash_tail
@@ -25,7 +25,6 @@
 parse.add_argument('--format', dest='format', action='store',default=None, help='Format e.g. Ansible')
 parse.add_argument('--hostport', dest='hostport', action='store',default=None, help='Logstash UDP host:port')
 parse.add_argument('--file', dest='filename', action='store',default=None, help='Filename to follow')
- 
 
 args = parse.parse_args()
 
@@ -95,8 +94,6 @@
     inp = ''
     lc = 0
 
-    
-
     if (args.filename):
         source = follow(open(args.filename))
 
@@ -108,6 +105,8 @@
 
         if (l==""):
             break
+        elif len(l)>200:
+            continue
 
         inp += l
         lc = len(inp.split('\n'))