Contents

#! /usr/bin/env ruby

require 'benchmark'
require 'thread'
require 'rubygems'
$LOAD_PATH.unshift(File.join(File.dirname(__FILE__), '..', 'lib'))
$LOAD_PATH.unshift(File.dirname(__FILE__))
require 'gelf'

Thread.abort_on_exception = true

puts "Running on #{RUBY_DESCRIPTION}"
puts "Generating random data..."
srand(1)
RANDOM_DATA = ('A'..'z').to_a
k3_message = (1..3*1024).map { RANDOM_DATA[rand(RANDOM_DATA.count)] }.join

TARGET_HOST = 'localhost'
TARGET_PORT = 12201
DEFAULT_OPTIONS = { '_host' => 'localhost' }
MESSAGES_COUNT = 5000
THREADS_COUNT = 50

SHORT_HASH = { 'short_message' => 'message' }
LONG_HASH  = { 'short_message' => 'message', 'long_message' => k3_message }

def notify(n, hash)
  threads = []
  THREADS_COUNT.times do
    threads << Thread.new do
      (MESSAGES_COUNT / THREADS_COUNT).times { n.notify!(hash) }
    end
  end
  threads.each { |t| t.join }
end

notifier_lan = GELF::Notifier.new(TARGET_HOST, TARGET_PORT, 'LAN', DEFAULT_OPTIONS)
notifier_wan = GELF::Notifier.new(TARGET_HOST, TARGET_PORT, 'WAN', DEFAULT_OPTIONS)

# to create mongo collections, etc.
notifier_lan.notify!(LONG_HASH)
sleep(5)

puts "Sending #{MESSAGES_COUNT} notifications...\n"
tms = Benchmark.bm(25) do |b|
  b.report('lan, short data, 1 chunk ') { notify(notifier_lan, SHORT_HASH) }
  sleep(5)
  b.report('lan,  long data, 1 chunk ') { notify(notifier_lan, LONG_HASH) }
  sleep(5)
  b.report('wan,  long data, 2 chunks') { notify(notifier_wan, LONG_HASH) }
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
gelf-1.4.0.beta1	benchmarks/notifier.rb