goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 49575302 72.84 ns/op 151.02 MB/s Benchmark______Pub0b_Payload-16 46826690 73.13 ns/op 150.41 MB/s Benchmark______Pub0b_Payload-16 47061872 75.28 ns/op 146.12 MB/s Benchmark______Pub0b_Payload-16 46368433 73.30 ns/op 150.07 MB/s Benchmark______Pub0b_Payload-16 47253424 72.82 ns/op 151.06 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45309975 73.33 ns/op 259.09 MB/s Benchmark______Pub8b_Payload-16 48068157 73.32 ns/op 259.12 MB/s Benchmark______Pub8b_Payload-16 46148617 73.48 ns/op 258.57 MB/s Benchmark______Pub8b_Payload-16 49221766 73.28 ns/op 259.28 MB/s Benchmark______Pub8b_Payload-16 46558386 73.40 ns/op 258.85 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43941998 78.66 ns/op 559.35 MB/s Benchmark_____Pub32b_Payload-16 44130922 77.96 ns/op 564.36 MB/s Benchmark_____Pub32b_Payload-16 46419362 79.24 ns/op 555.27 MB/s Benchmark_____Pub32b_Payload-16 43373258 77.48 ns/op 567.92 MB/s Benchmark_____Pub32b_Payload-16 46167630 77.33 ns/op 569.00 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39815433 86.59 ns/op 1628.44 MB/s Benchmark____Pub128B_Payload-16 39682423 86.97 ns/op 1621.16 MB/s Benchmark____Pub128B_Payload-16 34589865 87.98 ns/op 1602.61 MB/s Benchmark____Pub128B_Payload-16 39544672 87.63 ns/op 1609.02 MB/s Benchmark____Pub128B_Payload-16 38804545 87.38 ns/op 1613.58 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35381887 96.73 ns/op 2780.79 MB/s Benchmark____Pub256B_Payload-16 35217228 97.60 ns/op 2756.03 MB/s Benchmark____Pub256B_Payload-16 32355217 95.97 ns/op 2802.88 MB/s Benchmark____Pub256B_Payload-16 36394600 95.24 ns/op 2824.42 MB/s Benchmark____Pub256B_Payload-16 31699797 95.98 ns/op 2802.80 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25782627 139.9 ns/op 7422.14 MB/s Benchmark______Pub1K_Payload-16 23875564 137.8 ns/op 7533.73 MB/s Benchmark______Pub1K_Payload-16 23922446 139.6 ns/op 7433.33 MB/s Benchmark______Pub1K_Payload-16 23948972 140.3 ns/op 7400.60 MB/s Benchmark______Pub1K_Payload-16 22112960 153.4 ns/op 6767.99 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5631804 622.1 ns/op 6607.13 MB/s Benchmark______Pub4K_Payload-16 5900524 659.3 ns/op 6233.67 MB/s Benchmark______Pub4K_Payload-16 5746788 616.1 ns/op 6671.31 MB/s Benchmark______Pub4K_Payload-16 5670531 623.2 ns/op 6595.46 MB/s Benchmark______Pub4K_Payload-16 5369775 621.2 ns/op 6616.26 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2767261 1271 ns/op 6454.43 MB/s Benchmark______Pub8K_Payload-16 2701821 1276 ns/op 6432.99 MB/s Benchmark______Pub8K_Payload-16 2744461 1275 ns/op 6434.73 MB/s Benchmark______Pub8K_Payload-16 2559951 1277 ns/op 6425.99 MB/s Benchmark______Pub8K_Payload-16 2781073 1271 ns/op 6455.21 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 684506 5414 ns/op 6054.69 MB/s Benchmark_____Pub32K_Payload-16 573566 5437 ns/op 6029.96 MB/s Benchmark_____Pub32K_Payload-16 649753 5426 ns/op 6042.04 MB/s Benchmark_____Pub32K_Payload-16 655879 5526 ns/op 5932.80 MB/s Benchmark_____Pub32K_Payload-16 652878 5376 ns/op 6098.18 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32441962 94.12 ns/op 116.87 MB/s Benchmark__AuthPub0b_Payload-16 36292424 96.04 ns/op 114.54 MB/s Benchmark__AuthPub0b_Payload-16 36112190 94.84 ns/op 115.98 MB/s Benchmark__AuthPub0b_Payload-16 34546927 94.14 ns/op 116.85 MB/s Benchmark__AuthPub0b_Payload-16 36094534 95.68 ns/op 114.97 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15569728 229.6 ns/op Benchmark_____________PubSub-16 15337954 230.0 ns/op Benchmark_____________PubSub-16 15371568 230.6 ns/op Benchmark_____________PubSub-16 15431408 229.4 ns/op Benchmark_____________PubSub-16 15491463 229.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15520203 228.0 ns/op Benchmark_____PubSubTwoConns-16 15669262 229.6 ns/op Benchmark_____PubSubTwoConns-16 15565436 227.4 ns/op Benchmark_____PubSubTwoConns-16 15482919 227.7 ns/op Benchmark_____PubSubTwoConns-16 15473986 228.6 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:48502->127.0.0.1:42805: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54752->127.0.0.1:42825: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:53202->127.0.0.1:34985: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50384->127.0.0.1:44313: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:48662->127.0.0.1:36905: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 Benchmark___PubSubAccsImport bench_test.go:58: Failed read of PONG: -ERR 'Authorization Violation' --- FAIL: Benchmark___PubSubAccsImport Benchmark_____PubTwoQueueSub Benchmark_____PubTwoQueueSub-16 14256384 247.6 ns/op Benchmark_____PubTwoQueueSub-16 14360563 247.5 ns/op Benchmark_____PubTwoQueueSub-16 14373378 248.5 ns/op Benchmark_____PubTwoQueueSub-16 14414365 247.5 ns/op Benchmark_____PubTwoQueueSub-16 14341291 248.2 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14342757 246.7 ns/op Benchmark____PubFourQueueSub-16 14207539 247.3 ns/op Benchmark____PubFourQueueSub-16 14279263 247.0 ns/op Benchmark____PubFourQueueSub-16 14247780 245.9 ns/op Benchmark____PubFourQueueSub-16 14342438 248.1 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14336781 247.9 ns/op Benchmark___PubEightQueueSub-16 14231972 247.9 ns/op Benchmark___PubEightQueueSub-16 14186181 246.2 ns/op Benchmark___PubEightQueueSub-16 14307049 247.3 ns/op Benchmark___PubEightQueueSub-16 14392443 247.2 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23232 155666 ns/op Benchmark_PubSub512kTwoConns-16 23062 157217 ns/op Benchmark_PubSub512kTwoConns-16 23088 154054 ns/op Benchmark_PubSub512kTwoConns-16 23144 156375 ns/op Benchmark_PubSub512kTwoConns-16 23128 156985 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15005956 231.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15234580 231.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15092168 230.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15136848 231.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15112261 230.9 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14899448 231.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15116398 231.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15124806 231.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15059371 232.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15236313 231.5 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11474036 310.5 ns/op Benchmark____RoutedPubSub_0b-16 11463404 310.7 ns/op Benchmark____RoutedPubSub_0b-16 11504476 312.3 ns/op Benchmark____RoutedPubSub_0b-16 11233377 316.8 ns/op Benchmark____RoutedPubSub_0b-16 11485016 316.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6791314 533.5 ns/op Benchmark____RoutedPubSub_1K-16 6403125 538.8 ns/op Benchmark____RoutedPubSub_1K-16 6608826 526.3 ns/op Benchmark____RoutedPubSub_1K-16 6500414 532.5 ns/op Benchmark____RoutedPubSub_1K-16 6530578 537.2 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84708 42104 ns/op Benchmark__RoutedPubSub_100K-16 86198 41896 ns/op Benchmark__RoutedPubSub_100K-16 85290 41372 ns/op Benchmark__RoutedPubSub_100K-16 86984 40948 ns/op Benchmark__RoutedPubSub_100K-16 84252 41708 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 10013478 307.9 ns/op Benchmark____Routed2QueueSub-16 9921136 315.9 ns/op Benchmark____Routed2QueueSub-16 9950842 313.3 ns/op Benchmark____Routed2QueueSub-16 9831688 315.1 ns/op Benchmark____Routed2QueueSub-16 9734404 312.3 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9734530 319.6 ns/op Benchmark____Routed4QueueSub-16 9535081 318.3 ns/op Benchmark____Routed4QueueSub-16 9524708 322.7 ns/op Benchmark____Routed4QueueSub-16 11136920 321.2 ns/op Benchmark____Routed4QueueSub-16 9598776 319.3 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9229281 328.2 ns/op Benchmark____Routed8QueueSub-16 9474747 328.8 ns/op Benchmark____Routed8QueueSub-16 9253929 330.8 ns/op Benchmark____Routed8QueueSub-16 9451608 320.9 ns/op Benchmark____Routed8QueueSub-16 11126911 327.8 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8751063 352.0 ns/op Benchmark___Routed16QueueSub-16 9012346 346.1 ns/op Benchmark___Routed16QueueSub-16 8814004 342.4 ns/op Benchmark___Routed16QueueSub-16 8979548 342.1 ns/op Benchmark___Routed16QueueSub-16 8888631 338.3 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6360567 548.4 ns/op Benchmark____________RouteCompressOff-16 6558423 552.2 ns/op Benchmark____________RouteCompressOff-16 6364101 549.6 ns/op Benchmark____________RouteCompressOff-16 6259548 541.8 ns/op Benchmark____________RouteCompressOff-16 6331257 548.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6317540 556.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6271129 551.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6451129 549.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6353419 551.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6557060 551.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6344652 556.1 ns/op Benchmark_________RouteCompressS2Fast-16 6328957 550.2 ns/op Benchmark_________RouteCompressS2Fast-16 6349993 548.3 ns/op Benchmark_________RouteCompressS2Fast-16 6428788 488.7 ns/op Benchmark_________RouteCompressS2Fast-16 6471933 553.8 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6381902 548.0 ns/op Benchmark_______RouteCompressS2Better-16 6553609 548.2 ns/op Benchmark_______RouteCompressS2Better-16 6450124 552.3 ns/op Benchmark_______RouteCompressS2Better-16 6392724 548.3 ns/op Benchmark_______RouteCompressS2Better-16 6364584 553.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6451365 553.4 ns/op Benchmark_________RouteCompressS2Best-16 6493039 556.2 ns/op Benchmark_________RouteCompressS2Best-16 6455941 550.6 ns/op Benchmark_________RouteCompressS2Best-16 6426798 543.6 ns/op Benchmark_________RouteCompressS2Best-16 6440494 551.6 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4681554 766.2 ns/op 324.96 MB/s Benchmark______FanOut_8x1x10-16 4690424 763.4 ns/op 326.17 MB/s Benchmark______FanOut_8x1x10-16 4679234 767.5 ns/op 324.43 MB/s Benchmark______FanOut_8x1x10-16 4701031 760.0 ns/op 327.65 MB/s Benchmark______FanOut_8x1x10-16 4675671 760.7 ns/op 327.34 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 559664 6241 ns/op 371.56 MB/s Benchmark_____FanOut_8x1x100-16 543367 6101 ns/op 380.07 MB/s Benchmark_____FanOut_8x1x100-16 553063 6015 ns/op 385.52 MB/s Benchmark_____FanOut_8x1x100-16 540409 6061 ns/op 382.60 MB/s Benchmark_____FanOut_8x1x100-16 537693 6002 ns/op 386.40 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47851 74150 ns/op 310.44 MB/s Benchmark____FanOut_8x10x100-16 48674 74469 ns/op 309.11 MB/s Benchmark____FanOut_8x10x100-16 47919 74831 ns/op 307.61 MB/s Benchmark____FanOut_8x10x100-16 48609 74593 ns/op 308.60 MB/s Benchmark____FanOut_8x10x100-16 48639 75061 ns/op 306.67 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6142 591623 ns/op 405.70 MB/s Benchmark___FanOut_8x10x1000-16 6007 592469 ns/op 405.12 MB/s Benchmark___FanOut_8x10x1000-16 5776 593875 ns/op 404.16 MB/s Benchmark___FanOut_8x10x1000-16 6080 610048 ns/op 393.44 MB/s Benchmark___FanOut_8x10x1000-16 5912 598831 ns/op 400.81 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5109 699283 ns/op 328.94 MB/s Benchmark___FanOut_8x100x100-16 5055 704030 ns/op 326.72 MB/s Benchmark___FanOut_8x100x100-16 4951 702808 ns/op 327.29 MB/s Benchmark___FanOut_8x100x100-16 5010 699824 ns/op 328.68 MB/s Benchmark___FanOut_8x100x100-16 4982 697385 ns/op 329.83 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 578 6071959 ns/op 395.26 MB/s Benchmark__FanOut_8x100x1000-16 580 6073584 ns/op 395.16 MB/s Benchmark__FanOut_8x100x1000-16 576 6061639 ns/op 395.94 MB/s Benchmark__FanOut_8x100x1000-16 591 6063011 ns/op 395.85 MB/s Benchmark__FanOut_8x100x1000-16 576 6069814 ns/op 395.40 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 538 6605305 ns/op 378.49 MB/s Benchmark__FanOut_8x10x10000-16 540 6569248 ns/op 380.56 MB/s Benchmark__FanOut_8x10x10000-16 529 6695865 ns/op 373.37 MB/s Benchmark__FanOut_8x10x10000-16 538 6571245 ns/op 380.45 MB/s Benchmark__FanOut_8x10x10000-16 532 6718567 ns/op 372.11 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 956 3731529 ns/op 308.19 MB/s Benchmark___FanOut_8x500x100-16 951 3724140 ns/op 308.80 MB/s Benchmark___FanOut_8x500x100-16 955 3712936 ns/op 309.73 MB/s Benchmark___FanOut_8x500x100-16 961 3728596 ns/op 308.43 MB/s Benchmark___FanOut_8x500x100-16 948 3726917 ns/op 308.57 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 356196 9434 ns/op 1552.02 MB/s Benchmark___FanOut_128x1x100-16 363216 9434 ns/op 1551.93 MB/s Benchmark___FanOut_128x1x100-16 351055 9438 ns/op 1551.30 MB/s Benchmark___FanOut_128x1x100-16 365518 9392 ns/op 1558.91 MB/s Benchmark___FanOut_128x1x100-16 359424 9470 ns/op 1545.97 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32758 110431 ns/op 1314.31 MB/s Benchmark__FanOut_128x10x100-16 33169 108987 ns/op 1331.73 MB/s Benchmark__FanOut_128x10x100-16 32782 109364 ns/op 1327.13 MB/s Benchmark__FanOut_128x10x100-16 32959 109841 ns/op 1321.37 MB/s Benchmark__FanOut_128x10x100-16 32896 109062 ns/op 1330.81 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3976 876979 ns/op 1664.97 MB/s Benchmark_FanOut_128x10x1000-16 4039 862508 ns/op 1692.90 MB/s Benchmark_FanOut_128x10x1000-16 4087 876606 ns/op 1665.68 MB/s Benchmark_FanOut_128x10x1000-16 4202 868146 ns/op 1681.91 MB/s Benchmark_FanOut_128x10x1000-16 4004 867646 ns/op 1682.88 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3615 1004563 ns/op 1443.55 MB/s Benchmark_FanOut_128x100x100-16 3572 1008057 ns/op 1438.55 MB/s Benchmark_FanOut_128x100x100-16 3598 1009851 ns/op 1436.00 MB/s Benchmark_FanOut_128x100x100-16 3505 1003224 ns/op 1445.48 MB/s Benchmark_FanOut_128x100x100-16 3475 999719 ns/op 1450.55 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 384 9221241 ns/op 1583.32 MB/s BenchmarkFanOut_128x100x1000-16 392 9106811 ns/op 1603.21 MB/s BenchmarkFanOut_128x100x1000-16 387 9158257 ns/op 1594.21 MB/s BenchmarkFanOut_128x100x1000-16 390 9258489 ns/op 1576.95 MB/s BenchmarkFanOut_128x100x1000-16 392 9105704 ns/op 1603.41 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 370 9533499 ns/op 1541.95 MB/s BenchmarkFanOut_128x10x10000-16 378 9576716 ns/op 1534.99 MB/s BenchmarkFanOut_128x10x10000-16 375 9728183 ns/op 1511.09 MB/s BenchmarkFanOut_128x10x10000-16 369 9604495 ns/op 1530.55 MB/s BenchmarkFanOut_128x10x10000-16 373 9519247 ns/op 1544.25 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 679 5237312 ns/op 1384.32 MB/s BenchmarkFanOut__128x500x100-16 675 5285382 ns/op 1371.73 MB/s BenchmarkFanOut__128x500x100-16 685 5237665 ns/op 1384.23 MB/s BenchmarkFanOut__128x500x100-16 681 5239310 ns/op 1383.80 MB/s BenchmarkFanOut__128x500x100-16 669 5246574 ns/op 1381.88 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1930 1845325 ns/op 2866.99 MB/s Benchmark_FanOut_512x100x100-16 1942 1832219 ns/op 2887.50 MB/s Benchmark_FanOut_512x100x100-16 1946 1833128 ns/op 2886.06 MB/s Benchmark_FanOut_512x100x100-16 1944 1838646 ns/op 2877.40 MB/s Benchmark_FanOut_512x100x100-16 1944 1822975 ns/op 2902.14 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16586973 ns/op 3195.31 MB/s Benchmark__FanOut_512x100x1k-16 214 16764654 ns/op 3161.44 MB/s Benchmark__FanOut_512x100x1k-16 218 16660115 ns/op 3181.28 MB/s Benchmark__FanOut_512x100x1k-16 217 16532583 ns/op 3205.82 MB/s Benchmark__FanOut_512x100x1k-16 217 16659097 ns/op 3181.48 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2997 1141180 ns/op 9140.57 MB/s Benchmark____FanOut_1kx10x1k-16 3144 1138702 ns/op 9160.46 MB/s Benchmark____FanOut_1kx10x1k-16 3188 1140858 ns/op 9143.15 MB/s Benchmark____FanOut_1kx10x1k-16 2911 1149550 ns/op 9074.02 MB/s Benchmark____FanOut_1kx10x1k-16 3084 1149798 ns/op 9072.06 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2822 1249669 ns/op 8339.04 MB/s Benchmark__FanOut_1kx100x100-16 2782 1242267 ns/op 8388.73 MB/s Benchmark__FanOut_1kx100x100-16 2798 1239373 ns/op 8408.32 MB/s Benchmark__FanOut_1kx100x100-16 2772 1243246 ns/op 8382.12 MB/s Benchmark__FanOut_1kx100x100-16 2834 1244920 ns/op 8370.85 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4361322 760.9 ns/op 327.24 MB/s Benchmark_____RFanOut_8x1x10-16 4505841 767.1 ns/op 324.61 MB/s Benchmark_____RFanOut_8x1x10-16 4490012 780.2 ns/op 319.14 MB/s Benchmark_____RFanOut_8x1x10-16 4491303 765.4 ns/op 325.32 MB/s Benchmark_____RFanOut_8x1x10-16 4523295 791.7 ns/op 314.52 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 522609 6351 ns/op 365.16 MB/s Benchmark____RFanOut_8x1x100-16 533329 6394 ns/op 362.67 MB/s Benchmark____RFanOut_8x1x100-16 494566 6069 ns/op 382.10 MB/s Benchmark____RFanOut_8x1x100-16 507271 6142 ns/op 377.57 MB/s Benchmark____RFanOut_8x1x100-16 529375 6382 ns/op 363.37 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47212 74033 ns/op 310.93 MB/s Benchmark___RFanOut_8x10x100-16 48285 74618 ns/op 308.49 MB/s Benchmark___RFanOut_8x10x100-16 48364 74476 ns/op 309.08 MB/s Benchmark___RFanOut_8x10x100-16 47858 74331 ns/op 309.68 MB/s Benchmark___RFanOut_8x10x100-16 48462 74278 ns/op 309.90 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5800 593102 ns/op 404.68 MB/s Benchmark__RFanOut_8x10x1000-16 6000 592128 ns/op 405.35 MB/s Benchmark__RFanOut_8x10x1000-16 6074 596409 ns/op 402.44 MB/s Benchmark__RFanOut_8x10x1000-16 5946 594195 ns/op 403.94 MB/s Benchmark__RFanOut_8x10x1000-16 6056 595283 ns/op 403.20 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5058 701927 ns/op 327.70 MB/s Benchmark__RFanOut_8x100x100-16 5012 701970 ns/op 327.68 MB/s Benchmark__RFanOut_8x100x100-16 5094 702380 ns/op 327.49 MB/s Benchmark__RFanOut_8x100x100-16 5029 703060 ns/op 327.17 MB/s Benchmark__RFanOut_8x100x100-16 5036 703610 ns/op 326.91 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 582 6082108 ns/op 394.60 MB/s Benchmark_RFanOut_8x100x1000-16 589 6116848 ns/op 392.36 MB/s Benchmark_RFanOut_8x100x1000-16 577 6152442 ns/op 390.09 MB/s Benchmark_RFanOut_8x100x1000-16 586 6074756 ns/op 395.08 MB/s Benchmark_RFanOut_8x100x1000-16 560 6085021 ns/op 394.41 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 534 6743657 ns/op 370.72 MB/s Benchmark_RFanOut_8x10x10000-16 536 6605108 ns/op 378.50 MB/s Benchmark_RFanOut_8x10x10000-16 540 6574906 ns/op 380.24 MB/s Benchmark_RFanOut_8x10x10000-16 534 6590539 ns/op 379.33 MB/s Benchmark_RFanOut_8x10x10000-16 543 6658249 ns/op 375.48 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2834 1168633 ns/op 8925.85 MB/s Benchmark_RFanOut_1kx10x1000-16 2878 1156920 ns/op 9016.21 MB/s Benchmark_RFanOut_1kx10x1000-16 2985 1146728 ns/op 9096.35 MB/s Benchmark_RFanOut_1kx10x1000-16 2797 1155097 ns/op 9030.44 MB/s Benchmark_RFanOut_1kx10x1000-16 3206 1126532 ns/op 9259.43 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7080711 503.9 ns/op 4123.80 MB/s Benchmark_____FanIn_1kx100x1-16 6950654 507.6 ns/op 4093.68 MB/s Benchmark_____FanIn_1kx100x1-16 6978973 504.5 ns/op 4118.93 MB/s Benchmark_____FanIn_1kx100x1-16 6957162 504.0 ns/op 4123.05 MB/s Benchmark_____FanIn_1kx100x1-16 6919804 503.5 ns/op 4127.24 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2623294 1388 ns/op 5924.39 MB/s Benchmark_____FanIn_4kx100x1-16 2624239 1375 ns/op 5981.41 MB/s Benchmark_____FanIn_4kx100x1-16 2632270 1350 ns/op 6092.29 MB/s Benchmark_____FanIn_4kx100x1-16 2666034 1344 ns/op 6119.45 MB/s Benchmark_____FanIn_4kx100x1-16 2650568 1365 ns/op 6022.84 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1718920 2112 ns/op 7773.57 MB/s Benchmark_____FanIn_8kx100x1-16 1691895 2095 ns/op 7835.12 MB/s Benchmark_____FanIn_8kx100x1-16 1720354 2090 ns/op 7855.27 MB/s Benchmark_____FanIn_8kx100x1-16 1694100 2122 ns/op 7736.53 MB/s Benchmark_____FanIn_8kx100x1-16 1688451 2114 ns/op 7764.68 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 874615 4164 ns/op 7876.63 MB/s Benchmark____FanIn_16kx100x1-16 864103 4155 ns/op 7893.88 MB/s Benchmark____FanIn_16kx100x1-16 859495 4124 ns/op 7954.09 MB/s Benchmark____FanIn_16kx100x1-16 874124 4121 ns/op 7959.76 MB/s Benchmark____FanIn_16kx100x1-16 868694 4210 ns/op 7790.05 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7671405378 vs 10849021500 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35138->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34874->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5637885765 vs 10849021500 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38318->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38256->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 167671 19868 ns/op 6598.68 MB/s Benchmark____FanIn_64kx100x1-16 163082 19733 ns/op 6643.88 MB/s Benchmark____FanIn_64kx100x1-16 168997 20006 ns/op 6553.29 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 208302010 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47686->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48504->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48390->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48168->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 775659530 vs 11470375000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37398->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37612->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 131221090 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38960->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38910->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 4301849440 vs 9386044000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42282->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41972->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 300327190 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43420->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43636->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5477408 645.3 ns/op 440.13 MB/s Benchmark___BumpPubCount_1x3-16 5525738 649.5 ns/op 437.25 MB/s Benchmark___BumpPubCount_1x3-16 5514949 649.5 ns/op 437.25 MB/s Benchmark___BumpPubCount_1x3-16 5538540 650.8 ns/op 436.42 MB/s Benchmark___BumpPubCount_1x3-16 5587029 644.3 ns/op 440.81 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5216860 678.9 ns/op 418.33 MB/s Benchmark___BumpPubCount_2x3-16 5242047 676.9 ns/op 419.56 MB/s Benchmark___BumpPubCount_2x3-16 5272436 681.3 ns/op 416.85 MB/s Benchmark___BumpPubCount_2x3-16 5191984 676.5 ns/op 419.81 MB/s Benchmark___BumpPubCount_2x3-16 5288254 676.6 ns/op 419.75 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5418739 648.9 ns/op 437.69 MB/s Benchmark___BumpPubCount_5x3-16 5539203 647.0 ns/op 438.94 MB/s Benchmark___BumpPubCount_5x3-16 5455258 644.9 ns/op 440.37 MB/s Benchmark___BumpPubCount_5x3-16 5503201 647.6 ns/op 438.55 MB/s Benchmark___BumpPubCount_5x3-16 5549499 648.0 ns/op 438.25 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5547982 645.0 ns/op 440.30 MB/s Benchmark__BumpPubCount_10x3-16 4738954 647.4 ns/op 438.70 MB/s Benchmark__BumpPubCount_10x3-16 5583196 645.9 ns/op 439.73 MB/s Benchmark__BumpPubCount_10x3-16 5597924 642.5 ns/op 442.05 MB/s Benchmark__BumpPubCount_10x3-16 5567762 644.8 ns/op 440.48 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12107608 267.6 ns/op 3886.29 MB/s Benchmark____GWs_Opt_1kx01x0-16 11969769 273.3 ns/op 3805.25 MB/s Benchmark____GWs_Opt_1kx01x0-16 12486355 268.7 ns/op 3870.81 MB/s Benchmark____GWs_Opt_1kx01x0-16 13160781 274.7 ns/op 3785.66 MB/s Benchmark____GWs_Opt_1kx01x0-16 12380001 282.6 ns/op 3680.50 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10202528 350.9 ns/op 5882.25 MB/s Benchmark____GWs_Opt_2kx01x0-16 10515886 348.8 ns/op 5917.90 MB/s Benchmark____GWs_Opt_2kx01x0-16 10327118 322.6 ns/op 6398.60 MB/s Benchmark____GWs_Opt_2kx01x0-16 10687478 348.3 ns/op 5926.44 MB/s Benchmark____GWs_Opt_2kx01x0-16 10480782 335.4 ns/op 6154.54 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5395473 664.8 ns/op 6185.24 MB/s Benchmark____GWs_Opt_4kx01x0-16 5639746 638.3 ns/op 6442.16 MB/s Benchmark____GWs_Opt_4kx01x0-16 5414392 648.5 ns/op 6340.71 MB/s Benchmark____GWs_Opt_4kx01x0-16 5459730 655.9 ns/op 6269.65 MB/s Benchmark____GWs_Opt_4kx01x0-16 5528637 696.5 ns/op 5903.52 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27392652 111.0 ns/op 9372.95 MB/s Benchmark____GWs_Opt_1kx10x0-16 32776507 113.1 ns/op 9194.27 MB/s Benchmark____GWs_Opt_1kx10x0-16 27878296 112.2 ns/op 9270.21 MB/s Benchmark____GWs_Opt_1kx10x0-16 25084549 122.5 ns/op 8490.64 MB/s Benchmark____GWs_Opt_1kx10x0-16 30894039 107.1 ns/op 9713.86 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25768458 159.3 ns/op 12955.97 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:48198->127.0.0.1:45773: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:51362->127.0.0.1:45073: use of closed network connection --- FAIL: Benchmark____GWs_Opt_2kx10x0-16 Benchmark____GWs_Opt_2kx10x0-16 25518675 163.0 ns/op 12660.83 MB/s Benchmark____GWs_Opt_2kx10x0-16 23942592 165.6 ns/op 12463.33 MB/s Benchmark____GWs_Opt_2kx10x0-16 24937084 151.3 ns/op 13639.91 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 9977190 325.2 ns/op 12645.72 MB/s Benchmark____GWs_Opt_4kx10x0-16 12360705 288.9 ns/op 14232.98 MB/s Benchmark____GWs_Opt_4kx10x0-16 12478389 280.7 ns/op 14650.84 MB/s Benchmark____GWs_Opt_4kx10x0-16 11058241 301.5 ns/op 13639.31 MB/s Benchmark____GWs_Opt_4kx10x0-16 12315960 316.3 ns/op 13001.40 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6177418 551.8 ns/op 5663.36 MB/s Benchmark____GWs_Opt_1kx01x1-16 6548132 549.9 ns/op 5682.65 MB/s Benchmark____GWs_Opt_1kx01x1-16 6414279 551.4 ns/op 5667.34 MB/s Benchmark____GWs_Opt_1kx01x1-16 6532490 552.6 ns/op 5655.44 MB/s Benchmark____GWs_Opt_1kx01x1-16 6604561 545.8 ns/op 5725.37 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4592991 767.4 ns/op 8075.23 MB/s Benchmark____GWs_Opt_2kx01x1-16 4582016 749.3 ns/op 8270.93 MB/s Benchmark____GWs_Opt_2kx01x1-16 4878370 751.2 ns/op 8249.43 MB/s Benchmark____GWs_Opt_2kx01x1-16 4512115 755.2 ns/op 8205.51 MB/s Benchmark____GWs_Opt_2kx01x1-16 4727853 770.6 ns/op 8041.95 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2462017 1369 ns/op 9012.52 MB/s Benchmark____GWs_Opt_4kx01x1-16 2545980 2143 ns/op 5758.62 MB/s Benchmark____GWs_Opt_4kx01x1-16 2489692 1379 ns/op 8946.25 MB/s Benchmark____GWs_Opt_4kx01x1-16 2637282 1381 ns/op 8938.01 MB/s Benchmark____GWs_Opt_4kx01x1-16 2587998 1388 ns/op 8891.60 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6522848 554.7 ns/op 5633.95 MB/s Benchmark____GWs_Opt_1kx10x1-16 6667069 555.6 ns/op 5624.32 MB/s Benchmark____GWs_Opt_1kx10x1-16 6294990 555.7 ns/op 5623.48 MB/s Benchmark____GWs_Opt_1kx10x1-16 6339139 553.1 ns/op 5650.01 MB/s Benchmark____GWs_Opt_1kx10x1-16 6643903 754.9 ns/op 4139.43 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4296662 845.4 ns/op 7330.22 MB/s Benchmark____GWs_Opt_2kx10x1-16 4535568 838.6 ns/op 7390.02 MB/s Benchmark____GWs_Opt_2kx10x1-16 4114884 838.8 ns/op 7388.36 MB/s Benchmark____GWs_Opt_2kx10x1-16 3883960 845.9 ns/op 7326.14 MB/s Benchmark____GWs_Opt_2kx10x1-16 4724040 909.9 ns/op 6810.40 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2287564 1538 ns/op 8022.24 MB/s Benchmark____GWs_Opt_4kx10x1-16 2253523 1517 ns/op 8136.92 MB/s Benchmark____GWs_Opt_4kx10x1-16 2362357 1507 ns/op 8190.41 MB/s Benchmark____GWs_Opt_4kx10x1-16 2354193 1535 ns/op 8040.28 MB/s Benchmark____GWs_Opt_4kx10x1-16 2282307 1504 ns/op 8205.87 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12618568 298.3 ns/op 3485.84 MB/s Benchmark____GWs_Int_1kx01x0-16 11919874 284.5 ns/op 3656.10 MB/s Benchmark____GWs_Int_1kx01x0-16 11994478 286.6 ns/op 3628.26 MB/s Benchmark____GWs_Int_1kx01x0-16 12655617 294.2 ns/op 3534.47 MB/s Benchmark____GWs_Int_1kx01x0-16 12557617 286.8 ns/op 3625.93 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9937641 331.5 ns/op 6226.91 MB/s Benchmark____GWs_Int_2kx01x0-16 9925958 353.7 ns/op 5835.62 MB/s Benchmark____GWs_Int_2kx01x0-16 10434728 336.4 ns/op 6134.65 MB/s Benchmark____GWs_Int_2kx01x0-16 10154486 336.9 ns/op 6127.24 MB/s Benchmark____GWs_Int_2kx01x0-16 9836311 352.3 ns/op 5857.96 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5694787 655.8 ns/op 6270.53 MB/s Benchmark____GWs_Int_4kx01x0-16 5581395 656.7 ns/op 6261.40 MB/s Benchmark____GWs_Int_4kx01x0-16 5420270 666.2 ns/op 6172.00 MB/s Benchmark____GWs_Int_4kx01x0-16 5474263 648.2 ns/op 6343.54 MB/s Benchmark____GWs_Int_4kx01x0-16 5517116 711.8 ns/op 5776.64 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31656330 112.3 ns/op 9258.22 MB/s Benchmark____GWs_Int_1kx10x0-16 30937557 117.2 ns/op 8870.62 MB/s Benchmark____GWs_Int_1kx10x0-16 28979205 114.0 ns/op 9121.48 MB/s Benchmark____GWs_Int_1kx10x0-16 31302428 111.5 ns/op 9326.22 MB/s Benchmark____GWs_Int_1kx10x0-16 31878105 110.5 ns/op 9408.55 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 23233464 141.7 ns/op 14570.63 MB/s Benchmark____GWs_Int_2kx10x0-16 21695978 145.4 ns/op 14193.62 MB/s Benchmark____GWs_Int_2kx10x0-16 26198696 147.4 ns/op 14003.07 MB/s Benchmark____GWs_Int_2kx10x0-16 24613414 138.3 ns/op 14921.96 MB/s Benchmark____GWs_Int_2kx10x0-16 26071813 153.2 ns/op 13469.79 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12594457 313.3 ns/op 13125.01 MB/s Benchmark____GWs_Int_4kx10x0-16 11576936 283.0 ns/op 14528.68 MB/s Benchmark____GWs_Int_4kx10x0-16 10854520 292.1 ns/op 14075.59 MB/s Benchmark____GWs_Int_4kx10x0-16 12779980 307.3 ns/op 13381.00 MB/s Benchmark____GWs_Int_4kx10x0-16 11362476 325.5 ns/op 12634.51 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6389554 562.1 ns/op 5559.09 MB/s Benchmark____GWs_Int_1kx01x1-16 6343815 549.9 ns/op 5683.11 MB/s Benchmark____GWs_Int_1kx01x1-16 6365770 563.7 ns/op 5544.11 MB/s Benchmark____GWs_Int_1kx01x1-16 6455940 554.7 ns/op 5633.43 MB/s Benchmark____GWs_Int_1kx01x1-16 6399030 562.3 ns/op 5557.27 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4706900 773.7 ns/op 8009.69 MB/s Benchmark____GWs_Int_2kx01x1-16 4696665 842.5 ns/op 7355.91 MB/s Benchmark____GWs_Int_2kx01x1-16 4700227 781.2 ns/op 7932.93 MB/s Benchmark____GWs_Int_2kx01x1-16 4634180 779.8 ns/op 7946.62 MB/s Benchmark____GWs_Int_2kx01x1-16 4696812 761.2 ns/op 8141.51 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2600907 1382 ns/op 8927.15 MB/s Benchmark____GWs_Int_4kx01x1-16 2646190 1383 ns/op 8922.04 MB/s Benchmark____GWs_Int_4kx01x1-16 2477488 1375 ns/op 8973.42 MB/s Benchmark____GWs_Int_4kx01x1-16 2612716 1384 ns/op 8917.80 MB/s Benchmark____GWs_Int_4kx01x1-16 2289985 1484 ns/op 8314.51 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6570496 564.3 ns/op 5538.30 MB/s Benchmark____GWs_Int_1kx10x1-16 6101478 547.0 ns/op 5713.46 MB/s Benchmark____GWs_Int_1kx10x1-16 6522207 564.7 ns/op 5533.56 MB/s Benchmark____GWs_Int_1kx10x1-16 6632203 546.3 ns/op 5719.78 MB/s Benchmark____GWs_Int_1kx10x1-16 6309426 553.2 ns/op 5649.46 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4071723 843.5 ns/op 7347.09 MB/s Benchmark____GWs_Int_2kx10x1-16 4110998 825.5 ns/op 7506.63 MB/s Benchmark____GWs_Int_2kx10x1-16 4726861 851.7 ns/op 7276.16 MB/s Benchmark____GWs_Int_2kx10x1-16 4313656 840.7 ns/op 7371.27 MB/s Benchmark____GWs_Int_2kx10x1-16 4268560 860.3 ns/op 7202.89 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2426023 1520 ns/op 8120.60 MB/s Benchmark____GWs_Int_4kx10x1-16 2156739 1491 ns/op 8275.61 MB/s Benchmark____GWs_Int_4kx10x1-16 2454196 1523 ns/op 8103.25 MB/s Benchmark____GWs_Int_4kx10x1-16 2460820 1519 ns/op 8125.26 MB/s Benchmark____GWs_Int_4kx10x1-16 2316123 1514 ns/op 8153.60 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8408227 437.7 ns/op 233.01 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8404234 439.1 ns/op 232.31 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8319572 435.9 ns/op 233.98 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8218951 433.3 ns/op 235.39 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8289555 437.1 ns/op 233.38 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 616864 5018 ns/op 35.27 MB/s Benchmark__GWs_Reqs_1SubEach-16 762472 5214 ns/op 33.95 MB/s Benchmark__GWs_Reqs_1SubEach-16 725854 5232 ns/op 33.83 MB/s Benchmark__GWs_Reqs_1SubEach-16 737774 5241 ns/op 33.77 MB/s Benchmark__GWs_Reqs_1SubEach-16 778724 5327 ns/op 33.23 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2099.198s