guyboertje

irb(main):067:0> s2 = Supervisor2.new
=> #<Supervisor2:0x5fbdfdcf>
irb(main):068:0> s2.run
sleeping for 30
=> [#<Thread:0x156b88f5 run>, #<Thread:0x3bf9ce3e run>]
irb(main):069:0> s2.stop
=> [#<Thread:0x156b88f5 dead>, #<Thread:0x3bf9ce3e run>]
irb(main):070:0> s3 = Supervisor3.new
=> #<Supervisor3:0x71def8f8>
irb(main):071:0> s3.run

guyboertje

# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/filters/translate"

describe LogStash::Filters::Translate do

  let(:config) { Hash.new }
  subject { described_class.new(config) }

  describe "exact translation" do

guyboertje

def enqueue(event)
  q1 = SizedQueue.new(1)

  tt = Thread.new(q1) do |q|
    sleep 5
    q.push 42
  end

  wt = Thread.new(q1) do |q|
    @otherqueue.push event

guyboertje

namespace "queue" do
  desc "print out contents of checkpoint file (specify path)"
  task "print-checkpoint", [:ckpfile] do |t, args|
    bin = IO.read(args.ckpfile, mode: "rb")
      # + Short.BYTES    // version 16 bits
      # + Integer.BYTES  // pageNum 32 bits
      # + Integer.BYTES  // firstUnackedPageNum 32 bits
      # + Long.BYTES     // firstUnackedSeqNum 64 bits
      # + Long.BYTES     // minSeqNum 64 bits
      # + Integer.BYTES  // eventCount  32 bits

guyboertje

<?xml version="1.0" encoding="UTF-8" ?>
<ExecutionLogModel>
  <LogEvent level="INFO" time="2018-07-10T04:12:26Z" shapename="initializing..." shapetype="initializing..." shapelabel="" shapeextendedinfo="">
    <Message>Executing Process Performance Management- Past(Child)-STAGE (Continuation f_0_0)</Message>
  </LogEvent>
  <LogEvent level="INFO" time="2018-07-10T04:12:26Z" shapename="shape10" shapetype="Try/Catch" shapelabel="" shapeextendedinfo="">
    <Message>Executing Try/Catch Shape continuation as f_0_0 with 1 document(s).</Message>
  </LogEvent>
  <LogEvent level="INFO" time="2018-07-10T04:12:26Z" shapename="shape10" shapetype="Try/Catch" shapelabel="" shapeextendedinfo="">
    <Message>Shape executed successfully in 82 ms.</Message>