rafrombrc

Code that's running:

                outputError <- err
                fmt.Println("t.connection (pre): ", t.connection)
                if t.connection != nil {
                    fmt.Println("t.connection (post): ", t.connection)
                    fmt.Println("err: ", err)
                    t.connection.Close()
                    t.connection = nil

rafrombrc

package main

import (
	"flag"
	"log"
	"math/rand"
	"net"
	"strconv"
	"strings"
)

rafrombrc

require("circular_buffer")
require("cjson")

 -- 300 rows, 11 cols, 1s per row
cbuf = circular_buffer.new(300, 11, 1)
cbuf_idxs = {}
for i=2, 12, 1 do
	cbuf_idxs[i-1] = cbuf:set_header(i-1, tostring(i), "sum")
end

rafrombrc

panic: runtime error: send on closed channel

goroutine 26 [running]:
runtime.panic(0x854940, 0x1017efe)
	/usr/local/go/src/pkg/runtime/panic.c:266 +0xb6
github.com/thoj/go-ircevent.(*Connection).Privmsg(0xc210050640, 0x0, 0x0, 0x0, 0x0)
	/heka/build/heka/src/github.com/thoj/go-ircevent/irc.go:226 +0x13f
github.com/mozilla-services/heka/plugins/irc.(*IRCOutput).Privmsg(0xc210090320, 0x0, 0x0, 0x0, 0x0, ...)
	/heka/build/heka/src/github.com/mozilla-services/heka/plugins/irc/irc_output.go:102 +0xab
github.com/mozilla-services/heka/plugins/irc.SendFromOutQueue(0xc210090320, 0x7f1195bf5060, 0xc21000fbe0, 0x0, 0x0, ...)

rafrombrc

require("circular_buffer")
require("string")
require("cjson")

local idx_num
local stat_value
local debug

-- # rows, # cols, # seconds per row
cbuf = circular_buffer.new(300, 1, 1)

rafrombrc

require("circular_buffer")
require("cjson")

 -- 300 rows, 11 cols, 1s per row
cbuf = circular_buffer.new(300, 11, 1)
cbuf_idxs = {}
for i=2, 12, 1 do
	cbuf_idxs[i-1] = cbuf:set_header(i-1, tostring(i), "sum")
end

rafrombrc

/***** BEGIN LICENSE BLOCK *****
# This Source Code Form is subject to the terms of the Mozilla Public
# License, v. 2.0. If a copy of the MPL was not distributed with this file,
# You can obtain one at http://mozilla.org/MPL/2.0/.
#
# The Initial Developer of the Original Code is the Mozilla Foundation.
# Portions created by the Initial Developer are Copyright (C) 2014
# the Initial Developer. All Rights Reserved.
#
# Contributor(s):

rafrombrc

/***** BEGIN LICENSE BLOCK *****
# This Source Code Form is subject to the terms of the Mozilla Public
# License, v. 2.0. If a copy of the MPL was not distributed with this file,
# You can obtain one at http://mozilla.org/MPL/2.0/.
#
# The Initial Developer of the Original Code is the Mozilla Foundation.
# Portions created by the Initial Developer are Copyright (C) 2012-2014
# the Initial Developer. All Rights Reserved.
#
# Contributor(s):

rafrombrc

[hekad]
maxprocs = 4
base_dir = "/home/rob/go/heka/var/cache/hekad"
#max_pack_idle = 2
#cpuprof = "cpu.prof"
memprof = "mem.prof"

[TcpInput]
address = "127.0.0.1:5565"
parser_type = "message.proto"

rafrombrc

[LogstreamerInput]
log_directory = "/var/log"
file_match = 'auth\.log'

[PayloadEncoder]
append_newlines = false

[LogOutput]
message_matcher = "TRUE"
encoder = "PayloadEncoder"