happened when disconnect from emitter server , I don't known the log is helpful enough , if you need more details to trace , I will add more details later
2018/04/15 19:39:33 [conn] created (63FUOYXV3K244TDPDMNQUTZH5Q)
runtime stack:
runtime.throw(0xb9f620, 0x16)
/usr/local/go/src/runtime/panic.go:619 +0x81
runtime.sysMap(0xc440500000, 0x20000000, 0x5db00, 0x10a4bb8)
/usr/local/go/src/runtime/mem_linux.go:216 +0x20a
runtime.(*mheap).sysAlloc(0x108b480, 0x20000000, 0x5db93)
/usr/local/go/src/runtime/malloc.go:470 +0xd4
runtime.(*mheap).grow(0x108b480, 0x10000, 0x0)
/usr/local/go/src/runtime/mheap.go:907 +0x60
runtime.(*mheap).allocSpanLocked(0x108b480, 0x10000, 0x10a4be0, 0xc51f01)
/usr/local/go/src/runtime/mheap.go:820 +0x301
runtime.(*mheap).allocManual(0x108b480, 0x10000, 0x10a4be0, 0x0)
/usr/local/go/src/runtime/mheap.go:782 +0x53
runtime.stackalloc(0x7ff620000000, 0x622c57, 0x0)
/usr/local/go/src/runtime/stack.go:384 +0x20e
runtime.copystack(0xc42013d980, 0x20000000, 0x7ff66d3f4d01)
/usr/local/go/src/runtime/stack.go:840 +0x7d
runtime.newstack()
/usr/local/go/src/runtime/stack.go:1063 +0x30f
runtime.morestack()
/usr/local/go/src/runtime/asm_amd64.s:480 +0x89
goroutine 1156 [copystack]:
runtime.heapBitsSetType(0xc4201fa7b0, 0x30, 0x30, 0xb64b20)
/usr/local/go/src/runtime/mbitmap.go:864 +0x61c fp=0xc430500378 sp=0xc430500370 pc=0x6256fc
runtime.mallocgc(0x30, 0xb64b20, 0xb08d01, 0x0)
/usr/local/go/src/runtime/malloc.go:740 +0x548 fp=0xc430500418 sp=0xc430500378 pc=0x622658
runtime.newobject(0xb64b20, 0xc420339ce8)
/usr/local/go/src/runtime/malloc.go:839 +0x38 fp=0xc430500448 sp=0xc430500418 pc=0x622c58
runtime.makemap(0xae91a0, 0x1, 0x0, 0xc4305004d0)
/usr/local/go/src/runtime/hashmap.go:312 +0x190 fp=0xc430500488 sp=0xc430500448 pc=0x619600
github.com/emitter-io/emitter/broker/message.toCompressed(0xc420339ce8, 0xc430500578)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:472 +0x64 fp=0xc430500530 sp=0xc430500488 pc=0x9a53d4
github.com/emitter-io/emitter/broker/message.clean(0xc42000e698)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:402 +0x45 fp=0xc430500568 sp=0xc430500530 pc=0x9a4f35
github.com/emitter-io/emitter/broker/message.(*Trie).iinsert(0xc42000e598, 0xc42000f638, 0xc42000e698, 0xc420490ca8, 0x1, 0x1, 0xbfdae0, 0xc42037a6c0, 0xc430500660)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:235 +0x46b fp=0xc4305005e8 sp=0xc430500568 pc=0x9a441b
github.com/emitter-io/emitter/broker/message.(*Trie).iinsert(0xc42000e598, 0xc42000e698, 0xc42000e588, 0xc420490ca4, 0x2, 0x2, 0xbfdae0, 0xc42037a6c0, 0xc420323b40)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:213 +0x28a fp=0xc430500668 sp=0xc4305005e8 pc=0x9a423a
github.com/emitter-io/emitter/broker/message.(*Trie).iinsert(0xc42000e598, 0xc42000e588, 0x0, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xc420188890)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:213 +0x28a fp=0xc4305006e8 sp=0xc430500668 pc=0x9a423a
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:178 +0x75 fp=0xc430500740 sp=0xc4305006e8 pc=0x9a3ea5
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500798 sp=0xc430500740 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305007f0 sp=0xc430500798 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500848 sp=0xc4305007f0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305008a0 sp=0xc430500848 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305008f8 sp=0xc4305008a0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500950 sp=0xc4305008f8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305009a8 sp=0xc430500950 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500a00 sp=0xc4305009a8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500a58 sp=0xc430500a00 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500ab0 sp=0xc430500a58 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500b08 sp=0xc430500ab0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500b60 sp=0xc430500b08 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500bb8 sp=0xc430500b60 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500c10 sp=0xc430500bb8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500c68 sp=0xc430500c10 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500cc0 sp=0xc430500c68 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500d18 sp=0xc430500cc0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500d70 sp=0xc430500d18 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500dc8 sp=0xc430500d70 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500e20 sp=0xc430500dc8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500e78 sp=0xc430500e20 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500ed0 sp=0xc430500e78 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500f28 sp=0xc430500ed0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500f80 sp=0xc430500f28 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430500fd8 sp=0xc430500f80 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501030 sp=0xc430500fd8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501088 sp=0xc430501030 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305010e0 sp=0xc430501088 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501138 sp=0xc4305010e0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501190 sp=0xc430501138 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305011e8 sp=0xc430501190 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501240 sp=0xc4305011e8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501298 sp=0xc430501240 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305012f0 sp=0xc430501298 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501348 sp=0xc4305012f0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305013a0 sp=0xc430501348 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305013f8 sp=0xc4305013a0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501450 sp=0xc4305013f8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305014a8 sp=0xc430501450 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501500 sp=0xc4305014a8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501558 sp=0xc430501500 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305015b0 sp=0xc430501558 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501608 sp=0xc4305015b0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501660 sp=0xc430501608 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305016b8 sp=0xc430501660 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501710 sp=0xc4305016b8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501768 sp=0xc430501710 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305017c0 sp=0xc430501768 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501818 sp=0xc4305017c0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501870 sp=0xc430501818 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305018c8 sp=0xc430501870 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501920 sp=0xc4305018c8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501978 sp=0xc430501920 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305019d0 sp=0xc430501978 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501a28 sp=0xc4305019d0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501a80 sp=0xc430501a28 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501ad8 sp=0xc430501a80 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501b30 sp=0xc430501ad8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501b88 sp=0xc430501b30 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501be0 sp=0xc430501b88 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501c38 sp=0xc430501be0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501c90 sp=0xc430501c38 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501ce8 sp=0xc430501c90 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501d40 sp=0xc430501ce8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501d98 sp=0xc430501d40 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501df0 sp=0xc430501d98 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501e48 sp=0xc430501df0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501ea0 sp=0xc430501e48 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501ef8 sp=0xc430501ea0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501f50 sp=0xc430501ef8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430501fa8 sp=0xc430501f50 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502000 sp=0xc430501fa8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502058 sp=0xc430502000 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305020b0 sp=0xc430502058 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502108 sp=0xc4305020b0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502160 sp=0xc430502108 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305021b8 sp=0xc430502160 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502210 sp=0xc4305021b8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502268 sp=0xc430502210 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305022c0 sp=0xc430502268 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502318 sp=0xc4305022c0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502370 sp=0xc430502318 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305023c8 sp=0xc430502370 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502420 sp=0xc4305023c8 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502478 sp=0xc430502420 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305024d0 sp=0xc430502478 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502528 sp=0xc4305024d0 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502580 sp=0xc430502528 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc4305025d8 sp=0xc430502580 pc=0x9a3f95
github.com/emitter-io/emitter/broker/message.(*Trie).Subscribe(0xc42000e598, 0xc420490ca0, 0x3, 0x3, 0xbfdae0, 0xc42037a6c0, 0xbfdae0, 0xc42037a6c0, 0xc420188800)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/message/subtrie.go:179 +0x165 fp=0xc430502630 sp=0xc4305025d8 pc=0x9a3f95
...additional frames elided...
created by github.com/emitter-io/emitter/broker.(*Service).onAcceptConn
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:267 +0x61
goroutine 1 [select (no cases), 17 minutes]:
github.com/emitter-io/emitter/broker.(*Service).Listen(0xc42008b4a0, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:190 +0x2e5
main.main()
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/main.go:59 +0x375
goroutine 29 [chan receive]:
github.com/emitter-io/emitter/network/listener.muxListener.Accept(...)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:235
github.com/emitter-io/emitter/network/listener.(*muxListener).Accept(0xc4200f5fa0, 0xc4201882b0, 0xc00540, 0xc4200b86e0, 0x0)
<autogenerated>:1 +0x5b
github.com/emitter-io/emitter/vendor/github.com/kelindar/tcp.(*Server).Serve(0xc4200f59c0, 0xbfe120, 0xc4200f5fa0, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/kelindar/tcp/server.go:44 +0x72
github.com/emitter-io/emitter/vendor/github.com/kelindar/tcp.(*Server).Serve-fm(0xbfe120, 0xc4200f5fa0, 0xbfe120, 0xc4200f5fa0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:206 +0x3e
created by github.com/emitter-io/emitter/network/listener.(*Listener).ServeAsync
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:118 +0x97
goroutine 28 [chan receive]:
github.com/emitter-io/emitter/network/listener.muxListener.Accept(...)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:235
github.com/emitter-io/emitter/network/listener.(*muxListener).Accept(0xc4200f5f80, 0xbb72a8, 0xc42008a0a0, 0xbfe5e0, 0xc4201b44b0)
<autogenerated>:1 +0x5b
net/http.(*Server).Serve(0xc420185040, 0xbfe120, 0xc4200f5f80, 0x0, 0x0)
/usr/local/go/src/net/http/server.go:2770 +0x1a5
net/http.(*Server).Serve-fm(0xbfe120, 0xc4200f5f80, 0xbfe120, 0xc4200f5f80)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:205 +0x3e
created by github.com/emitter-io/emitter/network/listener.(*Listener).ServeAsync
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:118 +0x97
goroutine 15 [sleep]:
time.Sleep(0x3b9aca00)
/usr/local/go/src/runtime/time.go:102 +0x166
github.com/emitter-io/emitter/vendor/github.com/valyala/fasthttp.init.1.func1()
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/valyala/fasthttp/header.go:1384 +0x2a
created by github.com/emitter-io/emitter/vendor/github.com/valyala/fasthttp.init.1
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/valyala/fasthttp/header.go:1382 +0x3a
goroutine 14 [sleep]:
time.Sleep(0x3b9aca00)
/usr/local/go/src/runtime/time.go:102 +0x166
github.com/emitter-io/emitter/vendor/github.com/valyala/fasthttp.init.0.func1()
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/valyala/fasthttp/coarseTime.go:21 +0x51
created by github.com/emitter-io/emitter/vendor/github.com/valyala/fasthttp.init.0
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/valyala/fasthttp/coarseTime.go:19 +0xb4
goroutine 18 [syscall, 17 minutes]:
os/signal.signal_recv(0x0)
/usr/local/go/src/runtime/sigqueue.go:139 +0xa6
os/signal.loop()
/usr/local/go/src/os/signal/signal_unix.go:22 +0x22
created by os/signal.init.0
/usr/local/go/src/os/signal/signal_unix.go:28 +0x41
goroutine 19 [select]:
github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh.(*localPeer).actorLoop(0xc420183530, 0xc420068f00)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh/local_peer.go:141 +0xeb
created by github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh.newLocalPeer
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh/local_peer.go:31 +0x112
goroutine 20 [select]:
github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh.(*routes).run(0xc420020e00, 0xc420069020, 0xc420072b40, 0xc420072ba0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh/routes.go:177 +0x115
created by github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh.newRoutes
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh/routes.go:44 +0x312
goroutine 21 [select, 17 minutes]:
github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh.(*connectionMaker).queryLoop(0xc42014f260, 0xc420069080)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh/connection_maker.go:226 +0x118
created by github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh.newConnectionMaker
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh/connection_maker.go:75 +0x168
goroutine 22 [select, 17 minutes]:
github.com/emitter-io/emitter/vendor/github.com/karlseguin/ccache.(*Cache).worker(0xc420082f00)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/karlseguin/ccache/cache.go:159 +0x12b
created by github.com/emitter-io/emitter/vendor/github.com/karlseguin/ccache.(*Cache).restart
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/karlseguin/ccache/cache.go:128 +0xec
goroutine 23 [select, 17 minutes, locked to thread]:
runtime.gopark(0xbb78e8, 0x0, 0xb960ad, 0x6, 0x18, 0x1)
/usr/local/go/src/runtime/proc.go:291 +0x11a
runtime.selectgo(0xc42003cf50, 0xc420072de0)
/usr/local/go/src/runtime/select.go:392 +0xe50
runtime.ensureSigM.func1()
/usr/local/go/src/runtime/signal_unix.go:549 +0x1f4
runtime.goexit()
/usr/local/go/src/runtime/asm_amd64.s:2361 +0x1
goroutine 24 [chan receive, 17 minutes]:
github.com/emitter-io/emitter/broker.(*Service).hookSignals.func1(0xc420069260, 0xc42008b4a0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:458 +0x69
created by github.com/emitter-io/emitter/broker.(*Service).hookSignals
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:457 +0xcb
goroutine 25 [select]:
github.com/emitter-io/emitter/broker.(*Service).notifyPresenceChange.func1(0xc42008b4a0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:220 +0x136
created by github.com/emitter-io/emitter/broker.(*Service).notifyPresenceChange
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:217 +0x3f
goroutine 26 [select]:
github.com/emitter-io/emitter/utils.Repeat.func1(0xc420072a80, 0xc420082fa0, 0xc420188490)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/utils/timer.go:13 +0xd9
created by github.com/emitter-io/emitter/utils.Repeat
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/utils/timer.go:11 +0x70
goroutine 27 [IO wait, 17 minutes]:
internal/poll.runtime_pollWait(0x7ff670d60e30, 0x72, 0x0)
/usr/local/go/src/runtime/netpoll.go:173 +0x57
internal/poll.(*pollDesc).wait(0xc420020f98, 0x72, 0xc420064000, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:85 +0x9b
internal/poll.(*pollDesc).waitRead(0xc420020f98, 0xffffffffffffff00, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:90 +0x3d
internal/poll.(*FD).Accept(0xc420020f80, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_unix.go:372 +0x1a8
net.(*netFD).accept(0xc420020f80, 0x0, 0x0, 0x0)
/usr/local/go/src/net/fd_unix.go:238 +0x42
net.(*TCPListener).accept(0xc42000e5b8, 0x63ba19, 0xc4200827b0, 0xc4201aef90)
/usr/local/go/src/net/tcpsock_posix.go:136 +0x2e
net.(*TCPListener).AcceptTCP(0xc42000e5b8, 0xbb7120, 0xc42000e5b8, 0x0)
/usr/local/go/src/net/tcpsock.go:246 +0x49
github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh.(*Router).listenTCP.func1(0xc42000e5b8, 0xc420185110)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh/router.go:113 +0x59
created by github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh.(*Router).listenTCP
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/weaveworks/mesh/router.go:110 +0x154
goroutine 30 [IO wait]:
internal/poll.runtime_pollWait(0x7ff670d60f00, 0x72, 0x0)
/usr/local/go/src/runtime/netpoll.go:173 +0x57
internal/poll.(*pollDesc).wait(0xc420021018, 0x72, 0xc420064200, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:85 +0x9b
internal/poll.(*pollDesc).waitRead(0xc420021018, 0xffffffffffffff00, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:90 +0x3d
internal/poll.(*FD).Accept(0xc420021000, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_unix.go:372 +0x1a8
net.(*netFD).accept(0xc420021000, 0xc42057fab0, 0x0, 0x0)
/usr/local/go/src/net/fd_unix.go:238 +0x42
net.(*TCPListener).accept(0xc42000e5d8, 0x6699f0, 0xc420439f60, 0xc420439f68)
/usr/local/go/src/net/tcpsock_posix.go:136 +0x2e
net.(*TCPListener).Accept(0xc42000e5d8, 0xbb6c50, 0xc420083040, 0xc008a0, 0xc42057fab0)
/usr/local/go/src/net/tcpsock.go:259 +0x49
github.com/emitter-io/emitter/network/listener.(*Listener).Serve(0xc420083040, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:155 +0x88
created by github.com/emitter-io/emitter/broker.(*Service).listen
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:207 +0x1df
goroutine 31 [runnable]:
github.com/emitter-io/emitter/utils.Repeat.func1(0xc420072a80, 0xc420083180, 0xc4201885f0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/utils/timer.go:13 +0xd9
created by github.com/emitter-io/emitter/utils.Repeat
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/utils/timer.go:11 +0x70
goroutine 45 [IO wait]:
internal/poll.runtime_pollWait(0x7ff670d60bc0, 0x72, 0xc42005f800)
/usr/local/go/src/runtime/netpoll.go:173 +0x57
internal/poll.(*pollDesc).wait(0xc420021798, 0x72, 0xffffffffffffff00, 0xbf7d20, 0x1054810)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:85 +0x9b
internal/poll.(*pollDesc).waitRead(0xc420021798, 0xc420211000, 0x1000, 0x1000)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:90 +0x3d
internal/poll.(*FD).Read(0xc420021780, 0xc420211000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_unix.go:157 +0x17d
net.(*netFD).Read(0xc420021780, 0xc420211000, 0x1000, 0x1000, 0x8, 0x0, 0x0)
/usr/local/go/src/net/fd_unix.go:202 +0x4f
net.(*conn).Read(0xc42000e870, 0xc420211000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:176 +0x6a
github.com/emitter-io/emitter/network/listener.(*sniffer).Read(0xc4200b9cf0, 0xc420211000, 0x1000, 0x1000, 0x8, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:294 +0x143
github.com/emitter-io/emitter/network/listener.(*Conn).Read(0xc4200b9ce0, 0xc420211000, 0x1000, 0x1000, 0x8, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:260 +0x4f
bufio.(*Reader).fill(0xc42022e000)
/usr/local/go/src/bufio/bufio.go:100 +0x11e
bufio.(*Reader).Peek(0xc42022e000, 0x2, 0x6461bc, 0xc420232000, 0x300000002, 0xc420232000, 0xc42005fa98)
/usr/local/go/src/bufio/bufio.go:132 +0x3a
github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket.(*Conn).read(0xc4200c4a00, 0x2, 0x3, 0xc42002c070, 0xc42002c000, 0xc4201e41d8, 0xc4201e41e0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket/conn_read.go:12 +0x40
github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket.(*Conn).advanceFrame(0xc4200c4a00, 0x0, 0x0, 0xc420066838)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket/conn.go:779 +0x5c
github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket.(*Conn).NextReader(0xc4200c4a00, 0xc42001e070, 0xc42001e070, 0x10001, 0x0, 0xbf6660)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket/conn.go:939 +0xa3
github.com/emitter-io/emitter/network/websocket.(*websocketTransport).Read(0xc4201b5620, 0xc420234000, 0x10000, 0x10000, 0x0, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/websocket/websocket.go:105 +0x14e
bufio.(*Reader).Read(0xc42022e120, 0xc420022192, 0x1, 0x1, 0x0, 0x0, 0x0)
/usr/local/go/src/bufio/bufio.go:216 +0x238
io.ReadAtLeast(0xbf63a0, 0xc42022e120, 0xc420022192, 0x1, 0x1, 0x1, 0xac26c0, 0x1, 0xc420022192)
/usr/local/go/src/io/io.go:309 +0x86
io.ReadFull(0xbf63a0, 0xc42022e120, 0xc420022192, 0x1, 0x1, 0x1, 0x0, 0xc42005fe18)
/usr/local/go/src/io/io.go:327 +0x58
github.com/emitter-io/emitter/network/mqtt.decodeStaticHeader(0xbf63a0, 0xc42022e120, 0xbeacec77821b3f96, 0x11155610883, 0x1084c20, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/mqtt/mqtt.go:525 +0x8e
github.com/emitter-io/emitter/network/mqtt.DecodePacket(0xbf63a0, 0xc42022e120, 0x11155610883, 0x1084c20, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/mqtt/mqtt.go:171 +0x42
github.com/emitter-io/emitter/broker.(*Conn).Process(0xc42022e060, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/conn.go:100 +0x158
created by github.com/emitter-io/emitter/broker.(*Service).onAcceptConn
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:267 +0x61
goroutine 1185 [IO wait]:
internal/poll.runtime_pollWait(0x7ff670d60a20, 0x72, 0xc420061800)
/usr/local/go/src/runtime/netpoll.go:173 +0x57
internal/poll.(*pollDesc).wait(0xc420020198, 0x72, 0xffffffffffffff00, 0xbf7d20, 0x1054810)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:85 +0x9b
internal/poll.(*pollDesc).waitRead(0xc420020198, 0xc420230000, 0x1000, 0x1000)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:90 +0x3d
internal/poll.(*FD).Read(0xc420020180, 0xc420230000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_unix.go:157 +0x17d
net.(*netFD).Read(0xc420020180, 0xc420230000, 0x1000, 0x1000, 0xc42056000c, 0x78, 0xc420061978)
/usr/local/go/src/net/fd_unix.go:202 +0x4f
net.(*conn).Read(0xc4203381e8, 0xc420230000, 0x1000, 0x1000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:176 +0x6a
github.com/emitter-io/emitter/network/listener.(*sniffer).Read(0xc4200b8590, 0xc420230000, 0x1000, 0x1000, 0x1, 0xc4200619d0, 0xa479fb)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:294 +0x143
github.com/emitter-io/emitter/network/listener.(*Conn).Read(0xc4200b8580, 0xc420230000, 0x1000, 0x1000, 0x78, 0xff4, 0x78)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:260 +0x4f
bufio.(*Reader).fill(0xc4200683c0)
/usr/local/go/src/bufio/bufio.go:100 +0x11e
bufio.(*Reader).Peek(0xc4200683c0, 0x2, 0x2, 0xbeacec78af5846a8, 0x1127109379e, 0x1084c20, 0xc42056000c)
/usr/local/go/src/bufio/bufio.go:132 +0x3a
github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket.(*Conn).read(0xc4200c4000, 0x2, 0xc4200c4000, 0x6833c2, 0x0, 0xbb7a20, 0xc420061b40)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket/conn_read.go:12 +0x40
github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket.(*Conn).advanceFrame(0xc4200c4000, 0x0, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket/conn.go:779 +0x5c
github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket.(*Conn).NextReader(0xc4200c4000, 0xc42001e070, 0xc42001e070, 0x10001, 0x0, 0xbf6660)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/vendor/github.com/gorilla/websocket/conn.go:939 +0xa3
github.com/emitter-io/emitter/network/websocket.(*websocketTransport).Read(0xc420336d50, 0xc42062e000, 0x10000, 0x10000, 0x0, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/websocket/websocket.go:105 +0x14e
bufio.(*Reader).Read(0xc4200684e0, 0xc42002259e, 0x1, 0x1, 0x0, 0x0, 0x0)
/usr/local/go/src/bufio/bufio.go:216 +0x238
io.ReadAtLeast(0xbf63a0, 0xc4200684e0, 0xc42002259e, 0x1, 0x1, 0x1, 0xac26c0, 0x1, 0xc42002259e)
/usr/local/go/src/io/io.go:309 +0x86
io.ReadFull(0xbf63a0, 0xc4200684e0, 0xc42002259e, 0x1, 0x1, 0x1, 0x9a8d06, 0xc420061e18)
/usr/local/go/src/io/io.go:327 +0x58
github.com/emitter-io/emitter/network/mqtt.decodeStaticHeader(0xbf63a0, 0xc4200684e0, 0xbeacec78af5956b9, 0x112710a47a8, 0x1084c20, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/mqtt/mqtt.go:525 +0x8e
github.com/emitter-io/emitter/network/mqtt.DecodePacket(0xbf63a0, 0xc4200684e0, 0x112710a47a8, 0x1084c20, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/mqtt/mqtt.go:171 +0x42
github.com/emitter-io/emitter/broker.(*Conn).Process(0xc420068420, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/conn.go:100 +0x158
created by github.com/emitter-io/emitter/broker.(*Service).onAcceptConn
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:267 +0x61
goroutine 494 [IO wait]:
internal/poll.runtime_pollWait(0x7ff670d60950, 0x72, 0xc420438ac0)
/usr/local/go/src/runtime/netpoll.go:173 +0x57
internal/poll.(*pollDesc).wait(0xc420020318, 0x72, 0xffffffffffffff00, 0xbf7d20, 0x1054810)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:85 +0x9b
internal/poll.(*pollDesc).waitRead(0xc420020318, 0xc4201c6000, 0x10000, 0x10000)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:90 +0x3d
internal/poll.(*FD).Read(0xc420020300, 0xc4201c6000, 0x10000, 0x10000, 0x0, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_unix.go:157 +0x17d
net.(*netFD).Read(0xc420020300, 0xc4201c6000, 0x10000, 0x10000, 0x2, 0x0, 0x0)
/usr/local/go/src/net/fd_unix.go:202 +0x4f
net.(*conn).Read(0xc42000eec0, 0xc4201c6000, 0x10000, 0x10000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:176 +0x6a
github.com/emitter-io/emitter/network/listener.(*sniffer).Read(0xc42013a220, 0xc4201c6000, 0x10000, 0x10000, 0xc4201e4358, 0xc4201e4360, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:294 +0x143
github.com/emitter-io/emitter/network/listener.(*Conn).Read(0xc42013a210, 0xc4201c6000, 0x10000, 0x10000, 0xb, 0xc420438ce0, 0x6a2912)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:260 +0x4f
bufio.(*Reader).Read(0xc4201c0420, 0xc4200220ae, 0x1, 0x1, 0x1, 0xc420438d60, 0x0)
/usr/local/go/src/bufio/bufio.go:216 +0x238
io.ReadAtLeast(0xbf63a0, 0xc4201c0420, 0xc4200220ae, 0x1, 0x1, 0x1, 0xac26c0, 0x1, 0xc4200220ae)
/usr/local/go/src/io/io.go:309 +0x86
io.ReadFull(0xbf63a0, 0xc4201c0420, 0xc4200220ae, 0x1, 0x1, 0x1, 0xc420020300, 0xbeacec751b4c5c0c)
/usr/local/go/src/io/io.go:327 +0x58
github.com/emitter-io/emitter/network/mqtt.decodeStaticHeader(0xbf63a0, 0xc4201c0420, 0x1084c20, 0x0, 0x0, 0x65ca38)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/mqtt/mqtt.go:525 +0x8e
github.com/emitter-io/emitter/network/mqtt.DecodePacket(0xbf63a0, 0xc4201c0420, 0x10f1a8640fb, 0x1084c20, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/mqtt/mqtt.go:171 +0x42
github.com/emitter-io/emitter/broker.(*Conn).Process(0xc4201c0360, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/conn.go:100 +0x158
created by github.com/emitter-io/emitter/broker.(*Service).onAcceptConn
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:267 +0x61
goroutine 497 [IO wait]:
internal/poll.runtime_pollWait(0x7ff670d60880, 0x72, 0xc42043bac0)
/usr/local/go/src/runtime/netpoll.go:173 +0x57
internal/poll.(*pollDesc).wait(0xc420020398, 0x72, 0xffffffffffffff00, 0xbf7d20, 0x1054810)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:85 +0x9b
internal/poll.(*pollDesc).waitRead(0xc420020398, 0xc420444000, 0x10000, 0x10000)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:90 +0x3d
internal/poll.(*FD).Read(0xc420020380, 0xc420444000, 0x10000, 0x10000, 0x0, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_unix.go:157 +0x17d
net.(*netFD).Read(0xc420020380, 0xc420444000, 0x10000, 0x10000, 0x2, 0x0, 0x0)
/usr/local/go/src/net/fd_unix.go:202 +0x4f
net.(*conn).Read(0xc42000eec8, 0xc420444000, 0x10000, 0x10000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:176 +0x6a
github.com/emitter-io/emitter/network/listener.(*sniffer).Read(0xc42013a2d0, 0xc420444000, 0x10000, 0x10000, 0xc4201e4458, 0xc4201e4460, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:294 +0x143
github.com/emitter-io/emitter/network/listener.(*Conn).Read(0xc42013a2c0, 0xc420444000, 0x10000, 0x10000, 0xb, 0xc42043bce0, 0x6a2912)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:260 +0x4f
bufio.(*Reader).Read(0xc4201c0540, 0xc4200220aa, 0x1, 0x1, 0x1, 0xc42043bd60, 0x0)
/usr/local/go/src/bufio/bufio.go:216 +0x238
io.ReadAtLeast(0xbf63a0, 0xc4201c0540, 0xc4200220aa, 0x1, 0x1, 0x1, 0xac26c0, 0x1, 0xc4200220aa)
/usr/local/go/src/io/io.go:309 +0x86
io.ReadFull(0xbf63a0, 0xc4201c0540, 0xc4200220aa, 0x1, 0x1, 0x1, 0xc420020380, 0xbeacec751b4c07bf)
/usr/local/go/src/io/io.go:327 +0x58
github.com/emitter-io/emitter/network/mqtt.decodeStaticHeader(0xbf63a0, 0xc4201c0540, 0x1084c20, 0x0, 0x0, 0x65ca38)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/mqtt/mqtt.go:525 +0x8e
github.com/emitter-io/emitter/network/mqtt.DecodePacket(0xbf63a0, 0xc4201c0540, 0x10f1a85ecae, 0x1084c20, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/mqtt/mqtt.go:171 +0x42
github.com/emitter-io/emitter/broker.(*Conn).Process(0xc4201c0480, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/conn.go:100 +0x158
created by github.com/emitter-io/emitter/broker.(*Service).onAcceptConn
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:267 +0x61
goroutine 1197 [IO wait]:
internal/poll.runtime_pollWait(0x7ff670d60d60, 0x72, 0xc420434ac0)
/usr/local/go/src/runtime/netpoll.go:173 +0x57
internal/poll.(*pollDesc).wait(0xc420020218, 0x72, 0xffffffffffffff00, 0xbf7d20, 0x1054810)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:85 +0x9b
internal/poll.(*pollDesc).waitRead(0xc420020218, 0xc42063e000, 0x10000, 0x10000)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:90 +0x3d
internal/poll.(*FD).Read(0xc420020200, 0xc42063e000, 0x10000, 0x10000, 0x0, 0x0, 0x0)
/usr/local/go/src/internal/poll/fd_unix.go:157 +0x17d
net.(*netFD).Read(0xc420020200, 0xc42063e000, 0x10000, 0x10000, 0xc420020200, 0xc42063e000, 0x10000)
/usr/local/go/src/net/fd_unix.go:202 +0x4f
net.(*conn).Read(0xc42057fab0, 0xc42063e000, 0x10000, 0x10000, 0x0, 0x0, 0x0)
/usr/local/go/src/net/net.go:176 +0x6a
github.com/emitter-io/emitter/network/listener.(*sniffer).Read(0xc4200b86f0, 0xc42063e000, 0x10000, 0x10000, 0xc420064460, 0x0, 0x6a2b46)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:294 +0x143
github.com/emitter-io/emitter/network/listener.(*Conn).Read(0xc4200b86e0, 0xc42063e000, 0x10000, 0x10000, 0xe, 0x6a2912, 0xc420020200)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/listener/listener.go:260 +0x4f
bufio.(*Reader).Read(0xc4200686c0, 0xc420022561, 0x1, 0x1, 0x1, 0xc420434d60, 0x0)
/usr/local/go/src/bufio/bufio.go:216 +0x238
io.ReadAtLeast(0xbf63a0, 0xc4200686c0, 0xc420022561, 0x1, 0x1, 0x1, 0xac26c0, 0x1, 0xc420022561)
/usr/local/go/src/io/io.go:309 +0x86
io.ReadFull(0xbf63a0, 0xc4200686c0, 0xc420022561, 0x1, 0x1, 0x1, 0xc420020200, 0xbeacec7b4d293ce7)
/usr/local/go/src/io/io.go:327 +0x58
github.com/emitter-io/emitter/network/mqtt.decodeStaticHeader(0xbf63a0, 0xc4200686c0, 0x1084c20, 0x0, 0x0, 0x65ca38)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/mqtt/mqtt.go:525 +0x8e
github.com/emitter-io/emitter/network/mqtt.DecodePacket(0xbf63a0, 0xc4200686c0, 0x114de80dbd8, 0x1084c20, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/network/mqtt/mqtt.go:171 +0x42
github.com/emitter-io/emitter/broker.(*Conn).Process(0xc420068480, 0x0, 0x0)
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/conn.go:100 +0x158
created by github.com/emitter-io/emitter/broker.(*Service).onAcceptConn
/mnt/d/golang/workspace/src/github.com/emitter-io/emitter/broker/service.go:267 +0x61