From 8a7e8780609f5d132f34d3aaaa58bfa54ea84368 Mon Sep 17 00:00:00 2001
From: Victor Seva <vseva@sipwise.com>
Date: Mon, 27 Jan 2014 11:28:53 +0100
Subject: [PATCH] MT#5633 bin/ulog_parser.pl: fix
 7facd87c61ad65b335534d91f9b88e0e60510965

Now we are sending HTTP querys. Fix the detection of the proper first line
with the right pid.
---
 bin/ulog_parser.pl | 30 ++++++++++++++++++++++++++++--
 1 file changed, 28 insertions(+), 2 deletions(-)

diff --git a/bin/ulog_parser.pl b/bin/ulog_parser.pl
index 428f3770..3e41aba1 100755
--- a/bin/ulog_parser.pl
+++ b/bin/ulog_parser.pl
@@ -95,6 +95,31 @@ sub save_data
 my $pid;
 my $log;
 my $line;
+sub first_line
+{
+  $pid="unknown";
+  my $pid_read;
+  do
+  {
+    $line = <$log>;
+    #print "read line\n";
+    if(!$line) { $line = ''; return ($line ne '');}
+    else
+    {
+      ($pid_read) = ($line =~ m/.+proxy\[(\d+)\]: DEBUG: <script>: start of route MAIN.*$/);
+        if($pid_read) {
+            $pid = $pid_read;
+            #print "pid:".$pid."\n";
+        }
+        else {
+          $pid_read = '';
+          #print "what?".$line."\n";
+        }
+    }
+  } while($pid_read ne $pid);
+  return ($line ne '');
+}
+
 sub next_line
 {
   my $pid_read;
@@ -131,7 +156,8 @@ $output_dir = abs_path($output_dir);
 my $out;
 open($log, "<$filename") or die "Couldn't open kamailio log, $!";
 
-while(next_line())
+first_line();
+do
 {
   my ($mode, $route, $msgid, $msgid_t, $json, $msg, $pjson, $callid, $method);
   # Jun 25 14:52:16 spce proxy[11248]: DEBUG: debugger [debugger_api.c:427]: dbg_cfg_dump(): msg out:{
@@ -196,7 +222,7 @@ while(next_line())
       }
     }
   }
-} #while
+} while(next_line());
 if($data->{'msgid'} ne '') { save_data(); }
 close($log);
 #EOF