From 25c06132cee2a8cb7a5293970bf6be58a97d1a38 Mon Sep 17 00:00:00 2001
From: Jordan Sissel <jls@semicomplete.com>
Date: Mon, 21 Sep 2009 06:43:33 +0000
Subject: [PATCH] - Add logparsed. Runs N processes with a parser for each
 process.

---
 bin/logparsed.rb | 55 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 55 insertions(+)
 create mode 100644 bin/logparsed.rb

diff --git a/bin/logparsed.rb b/bin/logparsed.rb
new file mode 100644
index 000000000..573c41f21
--- /dev/null
+++ b/bin/logparsed.rb
@@ -0,0 +1,55 @@
+#!/usr/bin/env ruby
+
+require 'rubygems'
+require 'ruby-prof'
+require 'lib/net/servers/parser'
+
+#class String
+  #alias_method :orig_scan, :scan
+  #def scan(*args)
+    #raise
+    #return orig_scan(*args)
+  #end
+#end
+
+if ENV.has_key?("PROFILE")
+  RubyProf.start
+end
+
+def main(args)
+
+  if args.length != 1
+    puts "Usage: #{$0} configfile"
+    return 1
+  end
+  Thread::abort_on_exception = true
+  s = LogStash::Net::Servers::Parser.new(args[0])
+  s.run
+
+  if ENV.has_key?("PROFILE")
+    result = RubyProf.stop
+    printer = RubyProf::FlatPrinter.new(result)
+    printer.print(STDOUT, 0)
+  end
+
+  return 0
+end
+
+procs = 4
+if procs > 1
+  children = []
+  1.upto(procs) do |c|
+    pid = fork do
+      exit main(ARGV)
+    end
+    children << pid
+  end
+
+  while children.length > 0
+    pid = Process.waitpid(children[0], 0)
+    children.delete(pid)
+    puts "pid #{pid} died"
+  end
+else
+  exit main(ARGV)
+end