riakpbc crash stacktrace

gistfile1.txt

2013/12/03 23:40:13 ADDED 2rKAq1snVFT978yI0mHt8XwAOod from line 2362324
2013/12/03 23:40:18 ADDED GMR5zWC2PKhG2Y6TVpdxhhLAO3X from line 2362325
2013/12/03 23:40:23 ERROR from line 2362326
2013/12/03 23:40:23 ERROR from line 2362327
panic: interface conversion: interface is *riakpbc.RpbPutResp, not []uint8

goroutine 11 [running]:
github.com/mrb/riakpbc.(*Node).Ping(0xc200083730, 0xc20008c4b0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:153 +0xde
github.com/mrb/riakpbc.(*Pool).Ping(0xc20008c510)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:69 +0xb1
github.com/mrb/riakpbc.(*Client).BackgroundNodePing(0xc2000b7040)
	/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/write-or-delete-logs/main.go:106 +0x1dd
main.main()
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:189 +0x6da

goroutine 2 [syscall]:

goroutine 4 [semacquire]:
sync.runtime_Semacquire(0xc2000831dc)
	/usr/local/go/src/pkg/runtime/zsema_linux_amd64.c:165 +0x2e
sync.(*Mutex).Lock(0xc2000831d8)
	/usr/local/go/src/pkg/sync/mutex.go:66 +0xbb
github.com/mrb/riakpbc.(*Node).ReqResp(0xc200083190, 0x516260, 0xc2000f75e0, 0x593a10, 0xa, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:87 +0x5c
github.com/mrb/riakpbc.(*Node).Ping(0xc200083190, 0xc20008c4b0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:149 +0x9a
github.com/mrb/riakpbc.(*Pool).Ping(0xc20008c4d0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:69 +0xb1
github.com/mrb/riakpbc.(*Client).BackgroundNodePing(0xc20007fa00)
	/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 5 [IO wait]:
net.runtime_pollWait(0x7fe604184f00, 0x72, 0x0)
	/usr/local/go/src/pkg/runtime/znetpoll_linux_amd64.c:118 +0x82
net.(*pollDesc).WaitRead(0xc200095110, 0xb, 0xc200063780)
	/usr/local/go/src/pkg/net/fd_poll_runtime.go:75 +0x31
net.(*netFD).Read(0xc200095090, 0xc200000ab0, 0x4, 0x4, 0x0, ...)
	/usr/local/go/src/pkg/net/fd_unix.go:195 +0x2b3
net.(*conn).Read(0xc2000000f0, 0xc200000ab0, 0x4, 0x4, 0xc200000ab8, ...)
	/usr/local/go/src/pkg/net/net.go:123 +0xc3
io.ReadAtLeast(0xc200063e70, 0xc2000000f0, 0xc200000ab0, 0x4, 0x4, ...)
	/usr/local/go/src/pkg/io/io.go:284 +0xf7
io.ReadFull(0xc200063e70, 0xc2000000f0, 0xc200000ab0, 0x4, 0x4, ...)
	/usr/local/go/src/pkg/io/io.go:302 +0x6f
github.com/mrb/riakpbc.(*Node).read(0xc200083190, 0x0, 0x0, 0x0, 0x0, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:172 +0x16a
github.com/mrb/riakpbc.(*Node).response(0xc200083190, 0x0, 0x0, 0x0, 0x0, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:198 +0x49
github.com/mrb/riakpbc.(*Node).ReqResp(0xc200083190, 0x577560, 0xc20009c9a0, 0x593a50, 0x9, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:106 +0x1bd
github.com/mrb/riakpbc.(*Client).ReqResp(0xc20007fa00, 0x577560, 0xc20009c9a0, 0x593a50, 0x9, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:167 +0xdf
main.putToRiak(0xc20007fa00, 0x7fff278226b6, 0x6, 0xc2000d4c00, 0x178, ...)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:28 +0x16f
main.(*RiakWorker).process(0xc200063870, 0xc20017e450)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:84 +0x51
main.(*RiakWorker).Run(0xc200063870, 0xc20009d000)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:77 +0x67
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:184 +0x64e

goroutine 6 [chan receive]:
main.listenOnResultsChannels(0xc200063800, 0xc200063870, 0xc20009d060)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:126 +0x47
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:185 +0x6a3

goroutine 8 [IO wait]:
net.runtime_pollWait(0x7fe604184e60, 0x72, 0x0)
	/usr/local/go/src/pkg/runtime/znetpoll_linux_amd64.c:118 +0x82
net.(*pollDesc).WaitRead(0xc200095230, 0xb, 0xc200063780)
	/usr/local/go/src/pkg/net/fd_poll_runtime.go:75 +0x31
net.(*netFD).Read(0xc2000951b0, 0xc200000ae8, 0x4, 0x4, 0x0, ...)
	/usr/local/go/src/pkg/net/fd_unix.go:195 +0x2b3
net.(*conn).Read(0xc200000178, 0xc200000ae8, 0x4, 0x4, 0xc200000af0, ...)
	/usr/local/go/src/pkg/net/net.go:123 +0xc3
io.ReadAtLeast(0xc200063e70, 0xc200000178, 0xc200000ae8, 0x4, 0x4, ...)
	/usr/local/go/src/pkg/io/io.go:284 +0xf7
io.ReadFull(0xc200063e70, 0xc200000178, 0xc200000ae8, 0x4, 0x4, ...)
	/usr/local/go/src/pkg/io/io.go:302 +0x6f
github.com/mrb/riakpbc.(*Node).read(0xc200083460, 0x0, 0x0, 0x0, 0x0, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:172 +0x16a
github.com/mrb/riakpbc.(*Node).response(0xc200083460, 0x0, 0x0, 0x0, 0x0, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:198 +0x49
github.com/mrb/riakpbc.(*Node).ReqResp(0xc200083460, 0x516260, 0xc2000f7360, 0x593a10, 0xa, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:106 +0x1bd
github.com/mrb/riakpbc.(*Node).Ping(0xc200083460, 0xc20008c4b0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/node.go:149 +0x9a
github.com/mrb/riakpbc.(*Pool).Ping(0xc20008c4f0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:69 +0xb1
github.com/mrb/riakpbc.(*Client).BackgroundNodePing(0xc20007fd00)
	/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(0xc20008c4fc)
	/usr/local/go/src/pkg/runtime/zsema_linux_amd64.c:165 +0x2e
sync.(*Mutex).Lock(0xc20008c4f8)
	/usr/local/go/src/pkg/sync/mutex.go:66 +0xbb
github.com/mrb/riakpbc.(*Pool).SelectNode(0xc20008c4f0, 0x0, 0x0, 0x0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:45 +0x59
github.com/mrb/riakpbc.(*Client).SelectNode(0xc20007fd00, 0x7fe615235000, 0x40bbd6, 0x215235000)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:90 +0x29
github.com/mrb/riakpbc.(*Client).ReqResp(0xc20007fd00, 0x577560, 0xc20009ca50, 0x593a50, 0x9, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:163 +0x5a
main.putToRiak(0xc20007fd00, 0x7fff278226b6, 0x6, 0xc2000e8000, 0x160, ...)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:28 +0x16f
main.(*RiakWorker).process(0xc200063ae0, 0xc20017e4b0)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:84 +0x51
main.(*RiakWorker).Run(0xc200063ae0, 0xc20009d000)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:77 +0x67
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:184 +0x64e

goroutine 10 [chan receive]:
main.listenOnResultsChannels(0xc200063a00, 0xc200063ae0, 0xc20009d060)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:126 +0x47
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:185 +0x6a3

goroutine 12 [runnable]:
sync.runtime_Semacquire(0xc20008c51c)
	/usr/local/go/src/pkg/runtime/zsema_linux_amd64.c:165 +0x2e
sync.(*Mutex).Lock(0xc20008c518)
	/usr/local/go/src/pkg/sync/mutex.go:66 +0xbb
github.com/mrb/riakpbc.(*Pool).SelectNode(0xc20008c510, 0x0, 0x0, 0x0)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/pool.go:45 +0x59
github.com/mrb/riakpbc.(*Client).SelectNode(0xc2000b7040, 0x7fe615235000, 0x40bbd6, 0x215235000)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:90 +0x29
github.com/mrb/riakpbc.(*Client).ReqResp(0xc2000b7040, 0x577560, 0xc20009cb00, 0x593a50, 0x9, ...)
	/home/jeremiah/code/go/src/github.com/mrb/riakpbc/client.go:163 +0x5a
main.putToRiak(0xc2000b7040, 0x7fff278226b6, 0x6, 0xc2000e7800, 0x1d6, ...)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:28 +0x16f
main.(*RiakWorker).process(0xc200063d50, 0xc20017e4e0)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:84 +0x51
main.(*RiakWorker).Run(0xc200063d50, 0xc20009d000)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:77 +0x67
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:184 +0x64e

goroutine 13 [chan receive]:
main.listenOnResultsChannels(0xc200063d00, 0xc200063d50, 0xc20009d060)
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:126 +0x47
created by main.main
	/home/jeremiah/code/go/src/github.com/jjmalina/write-or-delete-logs/main.go:185 +0x6a3