riakpbc crash

gistfile1.txt

2013/11/22 13:33:59 ADDED 1VjPs9KAvFG52GuZJQsRvzgBN99 from line 2867651
2013/11/22 13:34:09 ADDED error from line 2867652
2013/11/22 13:34:09 ADDED error from line 2867653
2013/11/22 13:34:09 ADDED error from line 2867654
panic: interface conversion: interface is *riakpbc.RpbPutResp, not []uint8

goroutine 4 [running]:
github.com/mrb/riakpbc.(*Node).Ping(0xc200082190, 0xc20008b4b0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:141 +0xda
github.com/mrb/riakpbc.(*Pool).Ping(0xc20008b4d0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:69 +0xb1
github.com/mrb/riakpbc.(*Client).BackgroundNodePing(0xc200063a40)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:80 +0x8d
created by github.com/mrb/riakpbc.(*Client).Dial
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:64 +0x25d

goroutine 1 [chan send]:
main.stdinToChannel(0xc20009d000)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:121 +0x1cd
main.main()
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:200 +0x6da

goroutine 2 [syscall]:

goroutine 5 [runnable]:
sync.runtime_Semacquire(0xc20008b4dc)
	/usr/local/go/src/pkg/runtime/zsema_linux_amd64.c:165 +0x2e
sync.(*Mutex).Lock(0xc20008b4d8)
	/usr/local/go/src/pkg/sync/mutex.go:66 +0xbb
github.com/mrb/riakpbc.(*Pool).SelectNode(0xc20008b4d0, 0x0, 0x0, 0x0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:45 +0x59
github.com/mrb/riakpbc.(*Client).SelectNode(0xc200063a40, 0x7f0f6674d000, 0x18, 0x7f0f6674d000)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:90 +0x29
github.com/mrb/riakpbc.(*Client).ReqResp(0xc200063a40, 0x5780c0, 0xc20009c9a0, 0x594270, 0x9, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:163 +0x5a
main.putToRiak(0xc200063a40, 0x7fffcb75a6e2, 0x6, 0xc20010aa80, 0x161, ...)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:47 +0x561
main.(*RiakWorker).process(0xc20008c840, 0xc200094680)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:101 +0x51
main.(*RiakWorker).Run(0xc20008c840, 0xc20009d000)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:94 +0x67
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:195 +0x64e

goroutine 6 [chan receive]:
main.listenOnResultsChannels(0xc20008c800, 0xc20008c840, 0xc20009d060)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:141 +0x3f
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:196 +0x6a3

goroutine 8 [IO wait]:
net.runtime_pollWait(0x7f0f5569ce60, 0x72, 0x0)
	/usr/local/go/src/pkg/runtime/znetpoll_linux_amd64.c:118 +0x82
net.(*pollDesc).WaitRead(0xc20017a980, 0xb, 0xc20008c750)
	/usr/local/go/src/pkg/net/fd_poll_runtime.go:75 +0x31
net.(*netFD).Read(0xc20017a900, 0xc200115f98, 0x4, 0x4, 0x0, ...)
	/usr/local/go/src/pkg/net/fd_unix.go:195 +0x2b3
net.(*conn).Read(0xc2000eec00, 0xc200115f98, 0x4, 0x4, 0xc200115fa0, ...)
	/usr/local/go/src/pkg/net/net.go:123 +0xc3
io.ReadAtLeast(0xc20008cf60, 0xc2000eec00, 0xc200115f98, 0x4, 0x4, ...)
	/usr/local/go/src/pkg/io/io.go:284 +0xf7
io.ReadFull(0xc20008cf60, 0xc2000eec00, 0xc200115f98, 0x4, 0x4, ...)
	/usr/local/go/src/pkg/io/io.go:302 +0x6f
github.com/mrb/riakpbc.(*Node).read(0xc200082460, 0x0, 0x0, 0x0, 0x0, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:160 +0x16a
github.com/mrb/riakpbc.(*Node).response(0xc200082460, 0x0, 0x0, 0x0, 0x0, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:186 +0x49
github.com/mrb/riakpbc.(*Node).ReqResp(0xc200082460, 0x516800, 0xc200094740, 0x594230, 0xa, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:95 +0x12b
github.com/mrb/riakpbc.(*Node).Ping(0xc200082460, 0xc20008b4b0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:140 +0xa0
github.com/mrb/riakpbc.(*Pool).Ping(0xc20008b4f0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:69 +0xb1
github.com/mrb/riakpbc.(*Client).BackgroundNodePing(0xc200063d40)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:80 +0x8d
created by github.com/mrb/riakpbc.(*Client).Dial
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:64 +0x25d

goroutine 9 [semacquire]:
sync.runtime_Semacquire(0xc20008b4fc)
	/usr/local/go/src/pkg/runtime/zsema_linux_amd64.c:165 +0x2e
sync.(*Mutex).Lock(0xc20008b4f8)
	/usr/local/go/src/pkg/sync/mutex.go:66 +0xbb
github.com/mrb/riakpbc.(*Pool).SelectNode(0xc20008b4f0, 0x0, 0x0, 0x0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:45 +0x59
github.com/mrb/riakpbc.(*Client).SelectNode(0xc200063d40, 0x7f0f6674d000, 0x18, 0x7f0f6674d000)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:90 +0x29
github.com/mrb/riakpbc.(*Client).ReqResp(0xc200063d40, 0x5780c0, 0xc20009cb00, 0x594270, 0x9, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:163 +0x5a
main.putToRiak(0xc200063d40, 0x7fffcb75a6e2, 0x6, 0xc20007f780, 0x161, ...)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:47 +0x561
main.(*RiakWorker).process(0xc20008cab0, 0xc200094ae0)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:101 +0x51
main.(*RiakWorker).Run(0xc20008cab0, 0xc20009d000)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:94 +0x67
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:195 +0x64e

goroutine 10 [chan receive]:
main.listenOnResultsChannels(0xc20008ca00, 0xc20008cab0, 0xc20009d060)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:141 +0x3f
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:196 +0x6a3

goroutine 11 [IO wait]:
net.runtime_pollWait(0x7f0f5569cdc0, 0x72, 0x0)
	/usr/local/go/src/pkg/runtime/znetpoll_linux_amd64.c:118 +0x82
net.(*pollDesc).WaitRead(0xc20017af20, 0xb, 0xc20008c750)
	/usr/local/go/src/pkg/net/fd_poll_runtime.go:75 +0x31
net.(*netFD).Read(0xc20017aea0, 0xc200115e38, 0x4, 0x4, 0x0, ...)
	/usr/local/go/src/pkg/net/fd_unix.go:195 +0x2b3
net.(*conn).Read(0xc2000eeaf0, 0xc200115e38, 0x4, 0x4, 0xc200115e40, ...)
	/usr/local/go/src/pkg/net/net.go:123 +0xc3
io.ReadAtLeast(0xc20008cf60, 0xc2000eeaf0, 0xc200115e38, 0x4, 0x4, ...)
	/usr/local/go/src/pkg/io/io.go:284 +0xf7
io.ReadFull(0xc20008cf60, 0xc2000eeaf0, 0xc200115e38, 0x4, 0x4, ...)
	/usr/local/go/src/pkg/io/io.go:302 +0x6f
github.com/mrb/riakpbc.(*Node).read(0xc200082730, 0x0, 0x0, 0x0, 0x0, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:160 +0x16a
github.com/mrb/riakpbc.(*Node).response(0xc200082730, 0x0, 0x0, 0x0, 0x0, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:186 +0x49
github.com/mrb/riakpbc.(*Node).ReqResp(0xc200082730, 0x516800, 0xc200094760, 0x594230, 0xa, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:95 +0x12b
github.com/mrb/riakpbc.(*Node).Ping(0xc200082730, 0xc20008b4b0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:140 +0xa0
github.com/mrb/riakpbc.(*Pool).Ping(0xc20008b510)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:69 +0xb1
github.com/mrb/riakpbc.(*Client).BackgroundNodePing(0xc2000b7080)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:80 +0x8d
created by github.com/mrb/riakpbc.(*Client).Dial
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:64 +0x25d

goroutine 12 [semacquire]:
sync.runtime_Semacquire(0xc20008b51c)
	/usr/local/go/src/pkg/runtime/zsema_linux_amd64.c:165 +0x2e
sync.(*Mutex).Lock(0xc20008b518)
	/usr/local/go/src/pkg/sync/mutex.go:66 +0xbb
github.com/mrb/riakpbc.(*Pool).SelectNode(0xc20008b510, 0x0, 0x0, 0x0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:45 +0x59
github.com/mrb/riakpbc.(*Client).SelectNode(0xc2000b7080, 0x7f0f6674d000, 0x18, 0x7f0f6674d000)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:90 +0x29
github.com/mrb/riakpbc.(*Client).ReqResp(0xc2000b7080, 0x5780c0, 0xc20009ca50, 0x594270, 0x9, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:163 +0x5a
main.putToRiak(0xc2000b7080, 0x7fffcb75a6e2, 0x6, 0xc20007f180, 0x17c, ...)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:47 +0x561
main.(*RiakWorker).process(0xc20008cd20, 0xc200094980)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:101 +0x51
main.(*RiakWorker).Run(0xc20008cd20, 0xc20009d000)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:94 +0x67
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:195 +0x64e

goroutine 13 [chan receive]:
main.listenOnResultsChannels(0xc20008cd00, 0xc20008cd20, 0xc20009d060)
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:141 +0x3f
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/log-processing/main.go:196 +0x6a3