Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

nsqd: bench=BenchmarkProtocolV2Sub256 panics #617

Merged
merged 1 commit into from Aug 7, 2015
Merged

nsqd: bench=BenchmarkProtocolV2Sub256 panics #617

merged 1 commit into from Aug 7, 2015

Conversation

mreiferson
Copy link
Member

in nsqd dir:

go test -bench=BenchmarkProtocolV2Sub256
2015/08/06 22:27:56 http: TLS handshake error from 127.0.0.1:36493: tls: client didn't provide a certificate
2015/08/06 22:27:56 LOOKUPD: querying http://127.0.0.1:56163/channels?topic=cluster_test1438892876
PASS
BenchmarkProtocolV2Sub256   panic: runtime error: invalid memory address or nil pointer dereference
[signal 0xb code=0x1 addr=0x0 pc=0x4ca3d7]

goroutine 1023 [running]:
github.com/bitly/nsq/nsqd.readValidate(0x0, 0x7fe40366cc10, 0xc2080fca48, 0x7fe400000000, 0x8b6590, 0x2, 0x0, 0x0, 0x0)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/protocol_v2_test.go:103 +0x517
github.com/bitly/nsq/nsqd.sub(0x0, 0x7fe403680dc8, 0xc2080fca48, 0xc2085c07c0, 0x17, 0x8bd8d0, 0x2)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/protocol_v2_test.go:79 +0x32d
github.com/bitly/nsq/nsqd.subWorker(0x1, 0x1, 0xc2086a6210, 0xc2085c07c0, 0x17, 0xc2086c4fc0, 0xc2086c4f60)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/protocol_v2_test.go:1588 +0x2b9
github.com/bitly/nsq/nsqd.func·029()
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/protocol_v2_test.go:1566 +0x75
created by github.com/bitly/nsq/nsqd.benchmarkProtocolV2Sub
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/protocol_v2_test.go:1568 +0x745

goroutine 1 [chan receive]:
testing.(*B).run(0xc20806aa00, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/testing/benchmark.go:180 +0x67
testing.RunBenchmarks(0x9aa280, 0xb03c40, 0x2a, 0x2a)
    /usr/lib/go/src/testing/benchmark.go:312 +0x649
testing.(*M).Run(0xc208032410, 0xb102e0)
    /usr/lib/go/src/testing/testing.go:494 +0x1a5
main.main()
    github.com/bitly/nsq/nsqd/_test/_testmain.go:278 +0x1d5

goroutine 78 [select]:
github.com/bitly/nsq/nsqd.(*diskQueue).ioLoop(0xc208074180)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:606 +0x6f1
created by github.com/bitly/nsq/nsqd.newDiskQueue
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:97 +0x41f

goroutine 962 [select]:
net/http.(*persistConn).writeLoop(0xc20830c2c0)
    /usr/lib/go/src/net/http/transport.go:945 +0x41d
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:661 +0xcbc

goroutine 80 [select]:
github.com/bitly/nsq/nsqd.(*diskQueue).ioLoop(0xc208074480)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:606 +0x6f1
created by github.com/bitly/nsq/nsqd.newDiskQueue
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:97 +0x41f

goroutine 82 [select]:
github.com/bitly/nsq/nsqd.(*diskQueue).ioLoop(0xc208074600)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:606 +0x6f1
created by github.com/bitly/nsq/nsqd.newDiskQueue
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:97 +0x41f

goroutine 433 [IO wait]:
net.(*pollDesc).Wait(0xc2086563e0, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc2086563e0, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).accept(0xc208656380, 0x0, 0x7fe40366ac08, 0xc208649fd8)
    /usr/lib/go/src/net/fd_unix.go:419 +0x40b
net.(*TCPListener).AcceptTCP(0xc2082170b8, 0xc20809ae60, 0x0, 0x0)
    /usr/lib/go/src/net/tcpsock_posix.go:234 +0x4e
net.(*TCPListener).Accept(0xc2082170b8, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/tcpsock_posix.go:244 +0x4c
github.com/bitly/nsq/internal/protocol.TCPServer(0x7fe40366b628, 0xc2082170b8, 0x7fe4036790a0, 0xc2082170e0, 0x7fe40366c698, 0xc208648460)
    /home/dieter/go/src/github.com/bitly/nsq/internal/protocol/tcp_server.go:20 +0x184
github.com/bitly/nsq/nsqlookupd.func·001()
    /home/dieter/go/src/github.com/bitly/nsq/nsqlookupd/nsqlookupd.go:53 +0xd5
github.com/bitly/nsq/internal/util.func·001()
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:14 +0x2f
created by github.com/bitly/nsq/internal/util.(*WaitGroupWrapper).Wrap
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:16 +0xf7

goroutine 84 [select]:
github.com/bitly/nsq/nsqd.(*diskQueue).ioLoop(0xc208074000)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:606 +0x6f1
created by github.com/bitly/nsq/nsqd.newDiskQueue
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:97 +0x41f

goroutine 918 [IO wait]:
net.(*pollDesc).Wait(0xc208656140, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc208656140, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc2086560e0, 0xc2082d1000, 0x1000, 0x1000, 0x0, 0x7fe40366ac08, 0xc208648f18)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc2086730a8, 0xc2082d1000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
github.com/bitly/nsq/internal/http_api.(*deadlinedConn).Read(0xc2087acde0, 0xc2082d1000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /home/dieter/go/src/github.com/bitly/nsq/internal/http_api/api_request.go:22 +0x11d
net/http.noteEOFReader.Read(0x7fe40367ab68, 0xc2087acde0, 0xc2083c1d38, 0xc2082d1000, 0x1000, 0x1000, 0x7ebb60, 0x0, 0x0)
    /usr/lib/go/src/net/http/transport.go:1270 +0x6e
net/http.(*noteEOFReader).Read(0xc2087ace00, 0xc2082d1000, 0x1000, 0x1000, 0xc208012000, 0x0, 0x0)
    <autogenerated>:125 +0xd4
bufio.(*Reader).fill(0xc2085f2000)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).Peek(0xc2085f2000, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:132 +0xf0
net/http.(*persistConn).readLoop(0xc2083c1ce0)
    /usr/lib/go/src/net/http/transport.go:842 +0xa4
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:660 +0xc9f

goroutine 197 [IO wait]:
net.(*pollDesc).Wait(0xc208172840, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc208172840, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc2081727e0, 0xc208332000, 0x1000, 0x1000, 0x0, 0x7fe40366ac08, 0xc2081fe670)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc208216288, 0xc208332000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
net/http.(*liveSwitchReader).Read(0xc208300688, 0xc208332000, 0x1000, 0x1000, 0xc2081fe628, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:214 +0xab
io.(*LimitedReader).Read(0xc2080f5700, 0xc208332000, 0x1000, 0x1000, 0xc208176580, 0x0, 0x0)
    /usr/lib/go/src/io/io.go:408 +0xce
bufio.(*Reader).fill(0xc208031b00)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).ReadSlice(0xc208031b00, 0xc208099a0a, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:295 +0x257
bufio.(*Reader).ReadLine(0xc208031b00, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:324 +0x62
net/textproto.(*Reader).readLineSlice(0xc20803db90, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:55 +0x9e
net/textproto.(*Reader).ReadLine(0xc20803db90, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:36 +0x4f
net/http.ReadRequest(0xc208031b00, 0xc2081fc1a0, 0x0, 0x0)
    /usr/lib/go/src/net/http/request.go:598 +0xcb
net/http.(*conn).readRequest(0xc208300640, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:586 +0x26f
net/http.(*conn).serve(0xc208300640)
    /usr/lib/go/src/net/http/server.go:1162 +0x69e
created by net/http.(*Server).Serve
    /usr/lib/go/src/net/http/server.go:1751 +0x35e

goroutine 1025 [select]:
github.com/bitly/nsq/nsqd.(*protocolV2).messagePump(0xc2080fca78, 0xc208176580, 0xc2086c5260)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/protocol_v2.go:259 +0x951
created by github.com/bitly/nsq/nsqd.(*protocolV2).IOLoop
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/protocol_v2.go:51 +0x156

goroutine 1021 [chan send]:
github.com/bitly/nsq/nsqd.(*Channel).messagePump(0xc20864c000)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/channel.go:572 +0x306
created by github.com/bitly/nsq/nsqd.NewChannel
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/channel.go:115 +0x51e

goroutine 1013 [select]:
github.com/bitly/nsq/nsqd.(*NSQD).queueScanLoop(0xc2086c0000)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/nsqd.go:661 +0x56b
github.com/bitly/nsq/nsqd.func·008()
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/nsqd.go:260 +0x2a
github.com/bitly/nsq/internal/util.func·001()
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:14 +0x2f
created by github.com/bitly/nsq/internal/util.(*WaitGroupWrapper).Wrap
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:16 +0xf7

goroutine 1014 [select]:
github.com/bitly/nsq/nsqd.(*NSQD).idPump(0xc2086c0000)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/nsqd.go:537 +0x3cb
github.com/bitly/nsq/nsqd.func·009()
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/nsqd.go:261 +0x2a
github.com/bitly/nsq/internal/util.func·001()
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:14 +0x2f
created by github.com/bitly/nsq/internal/util.(*WaitGroupWrapper).Wrap
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:16 +0xf7

goroutine 961 [IO wait]:
net.(*pollDesc).Wait(0xc208010a70, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc208010a70, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc208010a10, 0xc208355000, 0x1000, 0x1000, 0x0, 0x7fe40366ac08, 0xc208174bc8)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc2080fc210, 0xc208355000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
net/http.noteEOFReader.Read(0x7fe40366cc10, 0xc2080fc210, 0xc20830c318, 0xc208355000, 0x1000, 0x1000, 0x7ebb60, 0x0, 0x0)
    /usr/lib/go/src/net/http/transport.go:1270 +0x6e
net/http.(*noteEOFReader).Read(0xc2083685a0, 0xc208355000, 0x1000, 0x1000, 0xc208012000, 0x0, 0x0)
    <autogenerated>:125 +0xd4
bufio.(*Reader).fill(0xc20866cba0)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).Peek(0xc20866cba0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:132 +0xf0
net/http.(*persistConn).readLoop(0xc20830c2c0)
    /usr/lib/go/src/net/http/transport.go:842 +0xa4
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:660 +0xc9f

goroutine 1024 [IO wait]:
net.(*pollDesc).Wait(0xc2082a6840, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc2082a6840, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc2082a67e0, 0xc2082c2000, 0x4000, 0x4000, 0x0, 0x7fe40366ac08, 0xc2085b3768)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc2080fca70, 0xc2082c2000, 0x4000, 0x4000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
bufio.(*Reader).fill(0xc2086c5140)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).ReadSlice(0xc2086c5140, 0xecd55ba0a, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:295 +0x257
github.com/bitly/nsq/nsqd.(*protocolV2).IOLoop(0xc2080fca78, 0x7fe40366cb88, 0xc2080fca70, 0x0, 0x0)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/protocol_v2.go:63 +0x25e
github.com/bitly/nsq/nsqd.(*tcpServer).Handle(0xc2080fc058, 0x7fe40366cb88, 0xc2080fca70)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/tcp.go:43 +0x5a8
created by github.com/bitly/nsq/internal/protocol.TCPServer
    /home/dieter/go/src/github.com/bitly/nsq/internal/protocol/tcp_server.go:33 +0x644

goroutine 195 [select]:
net/http.(*persistConn).readLoop(0xc2080e8790)
    /usr/lib/go/src/net/http/transport.go:928 +0x9ce
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:660 +0xc9f

goroutine 196 [select]:
net/http.(*persistConn).writeLoop(0xc2080e8790)
    /usr/lib/go/src/net/http/transport.go:945 +0x41d
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:661 +0xcbc

goroutine 201 [IO wait]:
net.(*pollDesc).Wait(0xc2082411e0, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc2082411e0, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc208241180, 0xc20830a400, 0x400, 0x400, 0x0, 0x7fe40366ac08, 0xc2081ff920)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc20803e208, 0xc20830a400, 0x400, 0x400, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
crypto/tls.(*block).readFromUntil(0xc2083d6480, 0x7fe40366cc10, 0xc20803e208, 0x5, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:454 +0xe6
crypto/tls.(*Conn).readRecord(0xc20800c840, 0x17, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:539 +0x2da
crypto/tls.(*Conn).Read(0xc20800c840, 0xc2083f8000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:904 +0x166
net/http.noteEOFReader.Read(0x7fe403676200, 0xc20800c840, 0xc2080452e8, 0xc2083f8000, 0x1000, 0x1000, 0x7ebb60, 0x0, 0x0)
    /usr/lib/go/src/net/http/transport.go:1270 +0x6e
net/http.(*noteEOFReader).Read(0xc2082619e0, 0xc2083f8000, 0x1000, 0x1000, 0xc208012000, 0x0, 0x0)
    <autogenerated>:125 +0xd4
bufio.(*Reader).fill(0xc20825aae0)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).Peek(0xc20825aae0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:132 +0xf0
net/http.(*persistConn).readLoop(0xc208045290)
    /usr/lib/go/src/net/http/transport.go:842 +0xa4
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:660 +0xc9f

goroutine 200 [IO wait]:
net.(*pollDesc).Wait(0xc208241250, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc208241250, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc2082411f0, 0xc2082c6000, 0x800, 0x800, 0x0, 0x7fe40366ac08, 0xc2081ff880)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc20803efc0, 0xc2082c6000, 0x800, 0x800, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
crypto/tls.(*block).readFromUntil(0xc2080a7da0, 0x7fe40366cc10, 0xc20803efc0, 0x5, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:454 +0xe6
crypto/tls.(*Conn).readRecord(0xc20800cb00, 0x17, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:539 +0x2da
crypto/tls.(*Conn).Read(0xc20800cb00, 0xc20832e000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:904 +0x166
net/http.(*liveSwitchReader).Read(0xc2080f2e08, 0xc20832e000, 0x1000, 0x1000, 0x8, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:214 +0xab
io.(*LimitedReader).Read(0xc20824ace0, 0xc20832e000, 0x1000, 0x1000, 0x400, 0x0, 0x0)
    /usr/lib/go/src/io/io.go:408 +0xce
bufio.(*Reader).fill(0xc2082432c0)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).ReadSlice(0xc2082432c0, 0xc2080a7e0a, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:295 +0x257
bufio.(*Reader).ReadLine(0xc2082432c0, 0x0, 0x0, 0x0, 0xc2080a7e00, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:324 +0x62
net/textproto.(*Reader).readLineSlice(0xc20825dd10, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:55 +0x9e
net/textproto.(*Reader).ReadLine(0xc20825dd10, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:36 +0x4f
net/http.ReadRequest(0xc2082432c0, 0xc20838a8f0, 0x0, 0x0)
    /usr/lib/go/src/net/http/request.go:598 +0xcb
net/http.(*conn).readRequest(0xc2080f2dc0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:586 +0x26f
net/http.(*conn).serve(0xc2080f2dc0)
    /usr/lib/go/src/net/http/server.go:1162 +0x69e
created by net/http.(*Server).Serve
    /usr/lib/go/src/net/http/server.go:1751 +0x35e

goroutine 202 [select]:
net/http.(*persistConn).writeLoop(0xc208045290)
    /usr/lib/go/src/net/http/transport.go:945 +0x41d
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:661 +0xcbc

goroutine 215 [IO wait]:
net.(*pollDesc).Wait(0xc208255cd0, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc208255cd0, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc208255c70, 0xc2082d7000, 0x1000, 0x1000, 0x0, 0x7fe40366ac08, 0xc2081049f8)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc208216a50, 0xc2082d7000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
net/http.(*liveSwitchReader).Read(0xc2080f34e8, 0xc2082d7000, 0x1000, 0x1000, 0xc2081049f0, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:214 +0xab
io.(*LimitedReader).Read(0xc208261d40, 0xc2082d7000, 0x1000, 0x1000, 0xc2081769a0, 0x0, 0x0)
    /usr/lib/go/src/io/io.go:408 +0xce
bufio.(*Reader).fill(0xc208242d80)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).ReadSlice(0xc208242d80, 0xc208474a0a, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:295 +0x257
bufio.(*Reader).ReadLine(0xc208242d80, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:324 +0x62
net/textproto.(*Reader).readLineSlice(0xc2083d78c0, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:55 +0x9e
net/textproto.(*Reader).ReadLine(0xc2083d78c0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:36 +0x4f
net/http.ReadRequest(0xc208242d80, 0xc2081fc820, 0x0, 0x0)
    /usr/lib/go/src/net/http/request.go:598 +0xcb
net/http.(*conn).readRequest(0xc2080f34a0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:586 +0x26f
net/http.(*conn).serve(0xc2080f34a0)
    /usr/lib/go/src/net/http/server.go:1162 +0x69e
created by net/http.(*Server).Serve
    /usr/lib/go/src/net/http/server.go:1751 +0x35e

goroutine 216 [select]:
net/http.(*persistConn).readLoop(0xc20830dce0)
    /usr/lib/go/src/net/http/transport.go:928 +0x9ce
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:660 +0xc9f

goroutine 217 [select]:
net/http.(*persistConn).writeLoop(0xc20830dce0)
    /usr/lib/go/src/net/http/transport.go:945 +0x41d
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:661 +0xcbc

goroutine 224 [IO wait]:
net.(*pollDesc).Wait(0xc2081733a0, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc2081733a0, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc208173340, 0xc2083a4000, 0x400, 0x400, 0x0, 0x7fe40366ac08, 0xc208175990)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc20803f318, 0xc2083a4000, 0x400, 0x400, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
crypto/tls.(*block).readFromUntil(0xc2082d37d0, 0x7fe40366cc10, 0xc20803f318, 0x5, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:454 +0xe6
crypto/tls.(*Conn).readRecord(0xc20800cdc0, 0x17, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:539 +0x2da
crypto/tls.(*Conn).Read(0xc20800cdc0, 0xc20840b000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:904 +0x166
net/http.noteEOFReader.Read(0x7fe403676200, 0xc20800cdc0, 0xc20839e898, 0xc20840b000, 0x1000, 0x1000, 0x7ebb60, 0x0, 0x0)
    /usr/lib/go/src/net/http/transport.go:1270 +0x6e
net/http.(*noteEOFReader).Read(0xc2083687a0, 0xc20840b000, 0x1000, 0x1000, 0xc208012000, 0x0, 0x0)
    <autogenerated>:125 +0xd4
bufio.(*Reader).fill(0xc20833aea0)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).Peek(0xc20833aea0, 0x1, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:132 +0xf0
net/http.(*persistConn).readLoop(0xc20839e840)
    /usr/lib/go/src/net/http/transport.go:842 +0xa4
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:660 +0xc9f

goroutine 223 [IO wait]:
net.(*pollDesc).Wait(0xc208173410, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc208173410, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc2081733b0, 0xc20830bc00, 0x400, 0x400, 0x0, 0x7fe40366ac08, 0xc2081758d0)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc2082160c0, 0xc20830bc00, 0x400, 0x400, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
crypto/tls.(*block).readFromUntil(0xc20825d050, 0x7fe40366cc10, 0xc2082160c0, 0x5, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:454 +0xe6
crypto/tls.(*Conn).readRecord(0xc20800d080, 0x17, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:539 +0x2da
crypto/tls.(*Conn).Read(0xc20800d080, 0xc208409000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/crypto/tls/conn.go:904 +0x166
net/http.(*liveSwitchReader).Read(0xc2080f3ee8, 0xc208409000, 0x1000, 0x1000, 0x8, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:214 +0xab
io.(*LimitedReader).Read(0xc20824a5a0, 0xc208409000, 0x1000, 0x1000, 0x400, 0x0, 0x0)
    /usr/lib/go/src/io/io.go:408 +0xce
bufio.(*Reader).fill(0xc20813db00)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).ReadSlice(0xc20813db00, 0xc20825d00a, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:295 +0x257
bufio.(*Reader).ReadLine(0xc20813db00, 0x0, 0x0, 0x0, 0xc20825d000, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:324 +0x62
net/textproto.(*Reader).readLineSlice(0xc208366660, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:55 +0x9e
net/textproto.(*Reader).ReadLine(0xc208366660, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:36 +0x4f
net/http.ReadRequest(0xc20813db00, 0xc2083b0a90, 0x0, 0x0)
    /usr/lib/go/src/net/http/request.go:598 +0xcb
net/http.(*conn).readRequest(0xc2080f3ea0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:586 +0x26f
net/http.(*conn).serve(0xc2080f3ea0)
    /usr/lib/go/src/net/http/server.go:1162 +0x69e
created by net/http.(*Server).Serve
    /usr/lib/go/src/net/http/server.go:1751 +0x35e

goroutine 225 [select]:
net/http.(*persistConn).writeLoop(0xc20839e840)
    /usr/lib/go/src/net/http/transport.go:945 +0x41d
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:661 +0xcbc

goroutine 1016 [select]:
github.com/bitly/nsq/nsqd.(*diskQueue).ioLoop(0xc2087a2180)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:606 +0x6f1
created by github.com/bitly/nsq/nsqd.newDiskQueue
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:97 +0x41f

goroutine 956 [select]:
github.com/bitly/nsq/nsqd.(*diskQueue).ioLoop(0xc2087a2000)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:606 +0x6f1
created by github.com/bitly/nsq/nsqd.newDiskQueue
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:97 +0x41f

goroutine 338 [chan send]:
github.com/bitly/nsq/nsqd.func·003()
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/lookup.go:44 +0x4c
created by github.com/bitly/nsq/nsqd.func·004
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/lookup.go:45 +0x644

goroutine 337 [IO wait]:
net.(*pollDesc).Wait(0xc20839b950, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc20839b950, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc20839b8f0, 0xc2083f6000, 0x1000, 0x1000, 0x0, 0x7fe40366ac08, 0xc2082fccf8)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc20839ca48, 0xc2083f6000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
github.com/bitly/nsq/nsqlookupd.(*ClientV1).Read(0xc20800b200, 0xc2083f6000, 0x1000, 0x1000, 0x501145, 0x0, 0x0)
    <autogenerated>:3 +0x89
bufio.(*Reader).fill(0xc20833b9e0)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).ReadSlice(0xc20833b9e0, 0xa, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:295 +0x257
bufio.(*Reader).ReadBytes(0xc20833b9e0, 0xa, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:374 +0xd2
bufio.(*Reader).ReadString(0xc20833b9e0, 0xc20800b20a, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:414 +0x58
github.com/bitly/nsq/nsqlookupd.(*LookupProtocolV1).IOLoop(0xc20839ca50, 0x7fe40366cb88, 0xc20839ca48, 0x0, 0x0)
    /home/dieter/go/src/github.com/bitly/nsq/nsqlookupd/lookup_protocol_v1.go:32 +0x171
github.com/bitly/nsq/nsqlookupd.(*tcpServer).Handle(0xc20839c0b8, 0x7fe40366cb88, 0xc20839ca48)
    /home/dieter/go/src/github.com/bitly/nsq/nsqlookupd/tcp.go:43 +0x5a8
created by github.com/bitly/nsq/internal/protocol.TCPServer
    /home/dieter/go/src/github.com/bitly/nsq/internal/protocol/tcp_server.go:33 +0x644

goroutine 1012 [IO wait]:
net.(*pollDesc).Wait(0xc2082a6220, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc2082a6220, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).accept(0xc2082a61c0, 0x0, 0x7fe40366ac08, 0xc2085b2f18)
    /usr/lib/go/src/net/fd_unix.go:419 +0x40b
net.(*TCPListener).AcceptTCP(0xc2080fc080, 0xb08f00, 0x0, 0x0)
    /usr/lib/go/src/net/tcpsock_posix.go:234 +0x4e
net.(*TCPListener).Accept(0xc2080fc080, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/tcpsock_posix.go:244 +0x4c
net/http.(*Server).Serve(0xc2086c4660, 0x7fe40366b628, 0xc2080fc080, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:1728 +0x92
github.com/bitly/nsq/internal/http_api.Serve(0x7fe40366b628, 0xc2080fc080, 0x7fe40366c800, 0xc2085c0200, 0x8b3fd0, 0x4, 0x7fe40366c698, 0xc2085b2030)
    /home/dieter/go/src/github.com/bitly/nsq/internal/http_api/http_server.go:18 +0x26b
github.com/bitly/nsq/nsqd.func·007()
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/nsqd.go:257 +0xf8
github.com/bitly/nsq/internal/util.func·001()
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:14 +0x2f
created by github.com/bitly/nsq/internal/util.(*WaitGroupWrapper).Wrap
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:16 +0xf7

goroutine 336 [chan send]:
github.com/bitly/nsq/nsqd.func·003()
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/lookup.go:44 +0x4c
created by github.com/bitly/nsq/nsqd.func·004
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/lookup.go:45 +0x644

goroutine 1019 [select]:
github.com/bitly/nsq/nsqd.(*NSQD).queueScanWorker(0xc2086c0000, 0xc2086c4720, 0xc2083a2100, 0xc2086c4780)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/nsqd.go:619 +0x1a2
github.com/bitly/nsq/nsqd.func·014()
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/nsqd.go:608 +0x4f
github.com/bitly/nsq/internal/util.func·001()
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:14 +0x2f
created by github.com/bitly/nsq/internal/util.(*WaitGroupWrapper).Wrap
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:16 +0xf7

goroutine 920 [IO wait]:
net.(*pollDesc).Wait(0xc208656220, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc208656220, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc2086561c0, 0xc20828b000, 0x1000, 0x1000, 0x0, 0x7fe40366ac08, 0xc208648000)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc2086730b8, 0xc20828b000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
net/http.(*liveSwitchReader).Read(0xc2089e76c8, 0xc20828b000, 0x1000, 0x1000, 0xc2083cdf98, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:214 +0xab
io.(*LimitedReader).Read(0xc2087acea0, 0xc20828b000, 0x1000, 0x1000, 0x5183cb, 0x0, 0x0)
    /usr/lib/go/src/io/io.go:408 +0xce
bufio.(*Reader).fill(0xc20840ce40)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).ReadSlice(0xc20840ce40, 0xa, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:295 +0x257
bufio.(*Reader).ReadLine(0xc20840ce40, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:324 +0x62
net/textproto.(*Reader).readLineSlice(0xc20825c3f0, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:55 +0x9e
net/textproto.(*Reader).ReadLine(0xc20825c3f0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:36 +0x4f
net/http.ReadRequest(0xc20840ce40, 0xc20838b5f0, 0x0, 0x0)
    /usr/lib/go/src/net/http/request.go:598 +0xcb
net/http.(*conn).readRequest(0xc2089e7680, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:586 +0x26f
net/http.(*conn).serve(0xc2089e7680)
    /usr/lib/go/src/net/http/server.go:1162 +0x69e
created by net/http.(*Server).Serve
    /usr/lib/go/src/net/http/server.go:1751 +0x35e

goroutine 335 [IO wait]:
net.(*pollDesc).Wait(0xc20839af40, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc20839af40, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc20839aee0, 0xc2083f1000, 0x1000, 0x1000, 0x0, 0x7fe40366ac08, 0xc2082fc268)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc20839c968, 0xc2083f1000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
github.com/bitly/nsq/nsqlookupd.(*ClientV1).Read(0xc208157fc0, 0xc2083f1000, 0x1000, 0x1000, 0x501145, 0x0, 0x0)
    <autogenerated>:3 +0x89
bufio.(*Reader).fill(0xc20833b860)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).ReadSlice(0xc20833b860, 0xa, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:295 +0x257
bufio.(*Reader).ReadBytes(0xc20833b860, 0xa, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:374 +0xd2
bufio.(*Reader).ReadString(0xc20833b860, 0xc208157f0a, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:414 +0x58
github.com/bitly/nsq/nsqlookupd.(*LookupProtocolV1).IOLoop(0xc20839c978, 0x7fe40366cb88, 0xc20839c968, 0x0, 0x0)
    /home/dieter/go/src/github.com/bitly/nsq/nsqlookupd/lookup_protocol_v1.go:32 +0x171
github.com/bitly/nsq/nsqlookupd.(*tcpServer).Handle(0xc2080fddd0, 0x7fe40366cb88, 0xc20839c968)
    /home/dieter/go/src/github.com/bitly/nsq/nsqlookupd/tcp.go:43 +0x5a8
created by github.com/bitly/nsq/internal/protocol.TCPServer
    /home/dieter/go/src/github.com/bitly/nsq/internal/protocol/tcp_server.go:33 +0x644

goroutine 434 [IO wait]:
net.(*pollDesc).Wait(0xc208656450, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc208656450, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).accept(0xc2086563f0, 0x0, 0x7fe40366ac08, 0xc2086cf2a8)
    /usr/lib/go/src/net/fd_unix.go:419 +0x40b
net.(*TCPListener).AcceptTCP(0xc208217100, 0xc208082d60, 0x0, 0x0)
    /usr/lib/go/src/net/tcpsock_posix.go:234 +0x4e
net.(*TCPListener).Accept(0xc208217100, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/tcpsock_posix.go:244 +0x4c
net/http.(*Server).Serve(0xc2085f3f80, 0x7fe40366b628, 0xc208217100, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:1728 +0x92
github.com/bitly/nsq/internal/http_api.Serve(0x7fe40366b628, 0xc208217100, 0x7fe4036790c8, 0xc208368680, 0x8b3fd0, 0x4, 0x7fe40366c698, 0xc208648460)
    /home/dieter/go/src/github.com/bitly/nsq/internal/http_api/http_server.go:18 +0x26b
github.com/bitly/nsq/nsqlookupd.func·002()
    /home/dieter/go/src/github.com/bitly/nsq/nsqlookupd/nsqlookupd.go:66 +0xdb
github.com/bitly/nsq/internal/util.func·001()
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:14 +0x2f
created by github.com/bitly/nsq/internal/util.(*WaitGroupWrapper).Wrap
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:16 +0xf7

goroutine 1020 [select]:
github.com/bitly/nsq/nsqd.(*diskQueue).ioLoop(0xc2087a2300)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:606 +0x6f1
created by github.com/bitly/nsq/nsqd.newDiskQueue
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/diskqueue.go:97 +0x41f

goroutine 919 [select]:
net/http.(*persistConn).writeLoop(0xc2083c1ce0)
    /usr/lib/go/src/net/http/transport.go:945 +0x41d
created by net/http.(*Transport).dialConn
    /usr/lib/go/src/net/http/transport.go:661 +0xcbc

goroutine 1010 [chan receive]:
github.com/bitly/nsq/nsqd.benchmarkProtocolV2Sub(0xc20806aa00, 0x100)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/protocol_v2_test.go:1569 +0x770
github.com/bitly/nsq/nsqd.BenchmarkProtocolV2Sub256(0xc20806aa00)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/protocol_v2_test.go:1625 +0x31
testing.(*B).runN(0xc20806aa00, 0x1)
    /usr/lib/go/src/testing/benchmark.go:124 +0x95
testing.(*B).launch(0xc20806aa00)
    /usr/lib/go/src/testing/benchmark.go:199 +0x78
created by testing.(*B).run
    /usr/lib/go/src/testing/benchmark.go:179 +0x3e

goroutine 1017 [select]:
github.com/bitly/nsq/nsqd.(*Topic).messagePump(0xc20830c160)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/topic.go:230 +0xdb5
github.com/bitly/nsq/nsqd.func·015()
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/topic.go:66 +0x2a
github.com/bitly/nsq/internal/util.func·001()
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:14 +0x2f
created by github.com/bitly/nsq/internal/util.(*WaitGroupWrapper).Wrap
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:16 +0xf7

goroutine 1011 [IO wait]:
net.(*pollDesc).Wait(0xc2082a61b0, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc2082a61b0, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).accept(0xc2082a6150, 0x0, 0x7fe40366ac08, 0xc2085b3440)
    /usr/lib/go/src/net/fd_unix.go:419 +0x40b
net.(*TCPListener).AcceptTCP(0xc2080fc048, 0xc20814ce60, 0x0, 0x0)
    /usr/lib/go/src/net/tcpsock_posix.go:234 +0x4e
net.(*TCPListener).Accept(0xc2080fc048, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/tcpsock_posix.go:244 +0x4c
github.com/bitly/nsq/internal/protocol.TCPServer(0x7fe40366b628, 0xc2080fc048, 0x7fe40366c760, 0xc2080fc058, 0x7fe40366c698, 0xc2085b2030)
    /home/dieter/go/src/github.com/bitly/nsq/internal/protocol/tcp_server.go:20 +0x184
github.com/bitly/nsq/nsqd.func·005()
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/nsqd.go:230 +0xf2
github.com/bitly/nsq/internal/util.func·001()
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:14 +0x2f
created by github.com/bitly/nsq/internal/util.(*WaitGroupWrapper).Wrap
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:16 +0xf7

goroutine 963 [IO wait]:
net.(*pollDesc).Wait(0xc208010b50, 0x72, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:84 +0x47
net.(*pollDesc).WaitRead(0xc208010b50, 0x0, 0x0)
    /usr/lib/go/src/net/fd_poll_runtime.go:89 +0x43
net.(*netFD).Read(0xc208010af0, 0xc208433000, 0x1000, 0x1000, 0x0, 0x7fe40366ac08, 0xc208174998)
    /usr/lib/go/src/net/fd_unix.go:242 +0x40f
net.(*conn).Read(0xc2080fc2e8, 0xc208433000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/net.go:121 +0xdc
net/http.(*liveSwitchReader).Read(0xc2089e60e8, 0xc208433000, 0x1000, 0x1000, 0xc208174958, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:214 +0xab
io.(*LimitedReader).Read(0xc208368a00, 0xc208433000, 0x1000, 0x1000, 0xc208368a80, 0x0, 0x0)
    /usr/lib/go/src/io/io.go:408 +0xce
bufio.(*Reader).fill(0xc20866ce40)
    /usr/lib/go/src/bufio/bufio.go:97 +0x1ce
bufio.(*Reader).ReadSlice(0xc20866ce40, 0xa, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:295 +0x257
bufio.(*Reader).ReadLine(0xc20866ce40, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/bufio/bufio.go:324 +0x62
net/textproto.(*Reader).readLineSlice(0xc20864e4e0, 0x0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:55 +0x9e
net/textproto.(*Reader).ReadLine(0xc20864e4e0, 0x0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/textproto/reader.go:36 +0x4f
net/http.ReadRequest(0xc20866ce40, 0xc20838a4e0, 0x0, 0x0)
    /usr/lib/go/src/net/http/request.go:598 +0xcb
net/http.(*conn).readRequest(0xc2089e60a0, 0x0, 0x0, 0x0)
    /usr/lib/go/src/net/http/server.go:586 +0x26f
net/http.(*conn).serve(0xc2089e60a0)
    /usr/lib/go/src/net/http/server.go:1162 +0x69e
created by net/http.(*Server).Serve
    /usr/lib/go/src/net/http/server.go:1751 +0x35e

goroutine 1015 [select]:
github.com/bitly/nsq/nsqd.(*NSQD).lookupLoop(0xc2086c0000)
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/lookup.go:80 +0x343d
github.com/bitly/nsq/nsqd.func·010()
    /home/dieter/go/src/github.com/bitly/nsq/nsqd/nsqd.go:262 +0x2a
github.com/bitly/nsq/internal/util.func·001()
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:14 +0x2f
created by github.com/bitly/nsq/internal/util.(*WaitGroupWrapper).Wrap
    /home/dieter/go/src/github.com/bitly/nsq/internal/util/wait_group_wrapper.go:16 +0xf7
exit status 2
FAIL    github.com/bitly/nsq/nsqd   7.745s

@mreiferson mreiferson changed the title bench=BenchmarkProtocolV2Sub256 panics nsqd: bench=BenchmarkProtocolV2Sub256 panics Aug 7, 2015
@mreiferson
Copy link
Member

fixed

mreiferson added a commit that referenced this pull request Aug 7, 2015
@mreiferson
Merge pull request #617 from mreiferson/bench_fixes_617
2460a4f 
nsqd: bench=BenchmarkProtocolV2Sub256 panics
@mreiferson mreiferson merged commit 2460a4f into nsqio:master Aug 7, 2015
@mreiferson mreiferson deleted the bench_fixes_617 branch August 7, 2015 04:21
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
bug test
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.

None yet
1 participant
@mreiferson