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 49962912 72.25 ns/op 152.25 MB/s Benchmark______Pub0b_Payload-16 46506354 72.97 ns/op 150.75 MB/s Benchmark______Pub0b_Payload-16 47127778 71.76 ns/op 153.28 MB/s Benchmark______Pub0b_Payload-16 42715627 71.90 ns/op 153.00 MB/s Benchmark______Pub0b_Payload-16 47447127 76.25 ns/op 144.27 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 47057499 73.05 ns/op 260.11 MB/s Benchmark______Pub8b_Payload-16 46651902 72.88 ns/op 260.70 MB/s Benchmark______Pub8b_Payload-16 46469636 72.51 ns/op 262.02 MB/s Benchmark______Pub8b_Payload-16 46922748 72.77 ns/op 261.09 MB/s Benchmark______Pub8b_Payload-16 40300233 74.93 ns/op 253.55 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44063998 78.03 ns/op 563.85 MB/s Benchmark_____Pub32b_Payload-16 44005129 78.85 ns/op 558.00 MB/s Benchmark_____Pub32b_Payload-16 38142408 82.36 ns/op 534.26 MB/s Benchmark_____Pub32b_Payload-16 44219272 77.21 ns/op 569.86 MB/s Benchmark_____Pub32b_Payload-16 38196992 78.61 ns/op 559.69 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 34522342 88.23 ns/op 1598.17 MB/s Benchmark____Pub128B_Payload-16 39421167 89.16 ns/op 1581.40 MB/s Benchmark____Pub128B_Payload-16 39432280 89.35 ns/op 1578.09 MB/s Benchmark____Pub128B_Payload-16 39299703 87.81 ns/op 1605.78 MB/s Benchmark____Pub128B_Payload-16 34354777 87.54 ns/op 1610.76 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35946937 96.43 ns/op 2789.60 MB/s Benchmark____Pub256B_Payload-16 35335093 95.05 ns/op 2830.10 MB/s Benchmark____Pub256B_Payload-16 35946045 94.97 ns/op 2832.51 MB/s Benchmark____Pub256B_Payload-16 37760248 109.3 ns/op 2460.82 MB/s Benchmark____Pub256B_Payload-16 31120412 104.6 ns/op 2571.96 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24023640 148.0 ns/op 7015.70 MB/s Benchmark______Pub1K_Payload-16 23858278 138.2 ns/op 7513.53 MB/s Benchmark______Pub1K_Payload-16 24284647 144.9 ns/op 7162.01 MB/s Benchmark______Pub1K_Payload-16 23809048 158.4 ns/op 6552.24 MB/s Benchmark______Pub1K_Payload-16 23512934 137.6 ns/op 7545.27 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5558661 626.9 ns/op 6556.16 MB/s Benchmark______Pub4K_Payload-16 5695207 624.2 ns/op 6584.08 MB/s Benchmark______Pub4K_Payload-16 5730343 618.4 ns/op 6646.33 MB/s Benchmark______Pub4K_Payload-16 5704930 614.8 ns/op 6685.07 MB/s Benchmark______Pub4K_Payload-16 5555300 611.0 ns/op 6726.33 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2770165 1274 ns/op 6439.43 MB/s Benchmark______Pub8K_Payload-16 2760148 1296 ns/op 6333.66 MB/s Benchmark______Pub8K_Payload-16 2769165 1291 ns/op 6357.37 MB/s Benchmark______Pub8K_Payload-16 2701258 1276 ns/op 6432.89 MB/s Benchmark______Pub8K_Payload-16 2776340 1268 ns/op 6472.00 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 721326 5262 ns/op 6230.05 MB/s Benchmark_____Pub32K_Payload-16 671712 5353 ns/op 6124.58 MB/s Benchmark_____Pub32K_Payload-16 661087 5379 ns/op 6094.99 MB/s Benchmark_____Pub32K_Payload-16 608835 5324 ns/op 6157.85 MB/s Benchmark_____Pub32K_Payload-16 670860 7923 ns/op 4137.58 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31804153 97.43 ns/op 112.91 MB/s Benchmark__AuthPub0b_Payload-16 32852281 95.66 ns/op 114.99 MB/s Benchmark__AuthPub0b_Payload-16 36059443 95.38 ns/op 115.33 MB/s Benchmark__AuthPub0b_Payload-16 35911077 95.37 ns/op 115.34 MB/s Benchmark__AuthPub0b_Payload-16 32804042 96.39 ns/op 114.12 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15724330 227.1 ns/op Benchmark_____________PubSub-16 15601693 226.8 ns/op Benchmark_____________PubSub-16 15787358 227.1 ns/op Benchmark_____________PubSub-16 15780896 225.8 ns/op Benchmark_____________PubSub-16 15664320 227.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15697082 227.5 ns/op Benchmark_____PubSubTwoConns-16 15493534 225.3 ns/op Benchmark_____PubSubTwoConns-16 15615414 225.1 ns/op Benchmark_____PubSubTwoConns-16 15591987 227.4 ns/op Benchmark_____PubSubTwoConns-16 15860538 226.2 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:37208->127.0.0.1:35449: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:47704->127.0.0.1:36889: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43874->127.0.0.1:41557: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43688->127.0.0.1:40129: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:38236->127.0.0.1:34007: 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 14335359 248.7 ns/op Benchmark_____PubTwoQueueSub-16 14141259 248.4 ns/op Benchmark_____PubTwoQueueSub-16 14265010 248.9 ns/op Benchmark_____PubTwoQueueSub-16 14264898 247.2 ns/op Benchmark_____PubTwoQueueSub-16 14279458 247.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14352988 247.8 ns/op Benchmark____PubFourQueueSub-16 14318070 248.6 ns/op Benchmark____PubFourQueueSub-16 14263516 247.8 ns/op Benchmark____PubFourQueueSub-16 14392630 248.0 ns/op Benchmark____PubFourQueueSub-16 14334958 247.4 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14425756 248.0 ns/op Benchmark___PubEightQueueSub-16 14420626 248.2 ns/op Benchmark___PubEightQueueSub-16 14332684 247.5 ns/op Benchmark___PubEightQueueSub-16 14285139 246.5 ns/op Benchmark___PubEightQueueSub-16 14322883 248.1 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23088 157811 ns/op Benchmark_PubSub512kTwoConns-16 21726 155771 ns/op Benchmark_PubSub512kTwoConns-16 23277 157242 ns/op Benchmark_PubSub512kTwoConns-16 22825 157581 ns/op Benchmark_PubSub512kTwoConns-16 22945 159551 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15290323 230.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15312411 229.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15145717 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15235500 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15073971 230.8 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14994451 230.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 14982591 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15213271 231.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15047586 229.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15073420 230.9 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11292638 310.8 ns/op Benchmark____RoutedPubSub_0b-16 11134636 317.9 ns/op Benchmark____RoutedPubSub_0b-16 11411443 313.9 ns/op Benchmark____RoutedPubSub_0b-16 11149366 320.2 ns/op Benchmark____RoutedPubSub_0b-16 10954746 317.1 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6657052 540.4 ns/op Benchmark____RoutedPubSub_1K-16 6569112 538.8 ns/op Benchmark____RoutedPubSub_1K-16 6726926 538.1 ns/op Benchmark____RoutedPubSub_1K-16 6645415 537.6 ns/op Benchmark____RoutedPubSub_1K-16 6136518 532.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 81594 43986 ns/op Benchmark__RoutedPubSub_100K-16 81216 46102 ns/op Benchmark__RoutedPubSub_100K-16 79939 43666 ns/op Benchmark__RoutedPubSub_100K-16 77811 43934 ns/op Benchmark__RoutedPubSub_100K-16 80964 44496 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9645151 320.7 ns/op Benchmark____Routed2QueueSub-16 9725293 315.5 ns/op Benchmark____Routed2QueueSub-16 11288174 316.0 ns/op Benchmark____Routed2QueueSub-16 9540549 320.2 ns/op Benchmark____Routed2QueueSub-16 9741066 327.6 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9587502 317.4 ns/op Benchmark____Routed4QueueSub-16 11044468 321.1 ns/op Benchmark____Routed4QueueSub-16 9266300 324.6 ns/op Benchmark____Routed4QueueSub-16 9701382 321.6 ns/op Benchmark____Routed4QueueSub-16 9644289 322.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9328614 325.1 ns/op Benchmark____Routed8QueueSub-16 9484936 340.4 ns/op Benchmark____Routed8QueueSub-16 9287876 328.8 ns/op Benchmark____Routed8QueueSub-16 10897254 326.9 ns/op Benchmark____Routed8QueueSub-16 10980080 323.8 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8915886 352.4 ns/op Benchmark___Routed16QueueSub-16 10414177 348.6 ns/op Benchmark___Routed16QueueSub-16 10432999 341.7 ns/op Benchmark___Routed16QueueSub-16 8732320 346.7 ns/op Benchmark___Routed16QueueSub-16 8780437 350.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6307824 545.9 ns/op Benchmark____________RouteCompressOff-16 6375546 547.4 ns/op Benchmark____________RouteCompressOff-16 6257100 551.0 ns/op Benchmark____________RouteCompressOff-16 6525750 550.9 ns/op Benchmark____________RouteCompressOff-16 6410652 551.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6515786 556.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6356508 550.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6469669 554.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6572203 557.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6430335 548.1 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6315447 550.0 ns/op Benchmark_________RouteCompressS2Fast-16 6239558 548.7 ns/op Benchmark_________RouteCompressS2Fast-16 6551577 550.4 ns/op Benchmark_________RouteCompressS2Fast-16 6416814 559.7 ns/op Benchmark_________RouteCompressS2Fast-16 6381490 552.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6344638 549.8 ns/op Benchmark_______RouteCompressS2Better-16 6467238 553.7 ns/op Benchmark_______RouteCompressS2Better-16 6385822 555.9 ns/op Benchmark_______RouteCompressS2Better-16 6533300 548.3 ns/op Benchmark_______RouteCompressS2Better-16 6447867 550.2 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6535147 546.5 ns/op Benchmark_________RouteCompressS2Best-16 6473625 557.0 ns/op Benchmark_________RouteCompressS2Best-16 6492273 548.3 ns/op Benchmark_________RouteCompressS2Best-16 6516799 551.7 ns/op Benchmark_________RouteCompressS2Best-16 6440594 544.0 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4598978 764.3 ns/op 325.78 MB/s Benchmark______FanOut_8x1x10-16 4678724 764.5 ns/op 325.70 MB/s Benchmark______FanOut_8x1x10-16 4683566 764.5 ns/op 325.70 MB/s Benchmark______FanOut_8x1x10-16 4671098 763.1 ns/op 326.31 MB/s Benchmark______FanOut_8x1x10-16 4639459 763.6 ns/op 326.09 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 530330 6075 ns/op 381.73 MB/s Benchmark_____FanOut_8x1x100-16 545064 6086 ns/op 381.04 MB/s Benchmark_____FanOut_8x1x100-16 562272 6169 ns/op 375.89 MB/s Benchmark_____FanOut_8x1x100-16 578733 6086 ns/op 381.06 MB/s Benchmark_____FanOut_8x1x100-16 542868 6068 ns/op 382.14 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47698 75622 ns/op 304.39 MB/s Benchmark____FanOut_8x10x100-16 47601 75600 ns/op 304.48 MB/s Benchmark____FanOut_8x10x100-16 47389 75634 ns/op 304.35 MB/s Benchmark____FanOut_8x10x100-16 47578 75393 ns/op 305.32 MB/s Benchmark____FanOut_8x10x100-16 47508 75226 ns/op 306.00 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5833 611832 ns/op 392.30 MB/s Benchmark___FanOut_8x10x1000-16 5814 606629 ns/op 395.66 MB/s Benchmark___FanOut_8x10x1000-16 5552 609765 ns/op 393.63 MB/s Benchmark___FanOut_8x10x1000-16 5775 608896 ns/op 394.19 MB/s Benchmark___FanOut_8x10x1000-16 5984 610017 ns/op 393.46 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4864 718307 ns/op 320.22 MB/s Benchmark___FanOut_8x100x100-16 4954 716727 ns/op 320.93 MB/s Benchmark___FanOut_8x100x100-16 4822 720903 ns/op 319.07 MB/s Benchmark___FanOut_8x100x100-16 4868 721053 ns/op 319.00 MB/s Benchmark___FanOut_8x100x100-16 4869 723260 ns/op 318.03 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 544 6282865 ns/op 381.99 MB/s Benchmark__FanOut_8x100x1000-16 555 6326762 ns/op 379.34 MB/s Benchmark__FanOut_8x100x1000-16 559 6359349 ns/op 377.40 MB/s Benchmark__FanOut_8x100x1000-16 553 6322868 ns/op 379.58 MB/s Benchmark__FanOut_8x100x1000-16 556 6334501 ns/op 378.88 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 520 6998821 ns/op 357.21 MB/s Benchmark__FanOut_8x10x10000-16 519 6817440 ns/op 366.71 MB/s Benchmark__FanOut_8x10x10000-16 513 6897408 ns/op 362.46 MB/s Benchmark__FanOut_8x10x10000-16 514 7001091 ns/op 357.09 MB/s Benchmark__FanOut_8x10x10000-16 525 6783266 ns/op 368.56 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 931 3830470 ns/op 300.23 MB/s Benchmark___FanOut_8x500x100-16 930 3825718 ns/op 300.60 MB/s Benchmark___FanOut_8x500x100-16 933 3808563 ns/op 301.96 MB/s Benchmark___FanOut_8x500x100-16 925 3813349 ns/op 301.58 MB/s Benchmark___FanOut_8x500x100-16 930 3828133 ns/op 300.41 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 365074 9573 ns/op 1529.45 MB/s Benchmark___FanOut_128x1x100-16 367833 9574 ns/op 1529.32 MB/s Benchmark___FanOut_128x1x100-16 363969 9575 ns/op 1529.15 MB/s Benchmark___FanOut_128x1x100-16 364270 9560 ns/op 1531.43 MB/s Benchmark___FanOut_128x1x100-16 353378 9570 ns/op 1529.81 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32331 111404 ns/op 1302.84 MB/s Benchmark__FanOut_128x10x100-16 32364 111989 ns/op 1296.03 MB/s Benchmark__FanOut_128x10x100-16 32348 112012 ns/op 1295.77 MB/s Benchmark__FanOut_128x10x100-16 32043 112908 ns/op 1285.48 MB/s Benchmark__FanOut_128x10x100-16 32365 111561 ns/op 1301.00 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3933 901923 ns/op 1618.92 MB/s Benchmark_FanOut_128x10x1000-16 4095 897665 ns/op 1626.60 MB/s Benchmark_FanOut_128x10x1000-16 3796 887740 ns/op 1644.78 MB/s Benchmark_FanOut_128x10x1000-16 4010 894217 ns/op 1632.87 MB/s Benchmark_FanOut_128x10x1000-16 3996 901866 ns/op 1619.02 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3552 1031658 ns/op 1405.64 MB/s Benchmark_FanOut_128x100x100-16 3454 1019402 ns/op 1422.54 MB/s Benchmark_FanOut_128x100x100-16 3459 1020803 ns/op 1420.59 MB/s Benchmark_FanOut_128x100x100-16 3450 1021317 ns/op 1419.87 MB/s Benchmark_FanOut_128x100x100-16 3406 1023739 ns/op 1416.52 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 369 9423195 ns/op 1549.38 MB/s BenchmarkFanOut_128x100x1000-16 379 9391251 ns/op 1554.65 MB/s BenchmarkFanOut_128x100x1000-16 380 9516074 ns/op 1534.26 MB/s BenchmarkFanOut_128x100x1000-16 372 9390872 ns/op 1554.72 MB/s BenchmarkFanOut_128x100x1000-16 379 9380922 ns/op 1556.37 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 364 9731188 ns/op 1510.62 MB/s BenchmarkFanOut_128x10x10000-16 369 9778841 ns/op 1503.26 MB/s BenchmarkFanOut_128x10x10000-16 367 9697366 ns/op 1515.89 MB/s BenchmarkFanOut_128x10x10000-16 366 9858943 ns/op 1491.05 MB/s BenchmarkFanOut_128x10x10000-16 366 9782313 ns/op 1502.73 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 662 5341216 ns/op 1357.40 MB/s BenchmarkFanOut__128x500x100-16 673 5316629 ns/op 1363.67 MB/s BenchmarkFanOut__128x500x100-16 655 5345827 ns/op 1356.22 MB/s BenchmarkFanOut__128x500x100-16 670 5412288 ns/op 1339.57 MB/s BenchmarkFanOut__128x500x100-16 664 5361140 ns/op 1352.35 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1909 1859246 ns/op 2845.52 MB/s Benchmark_FanOut_512x100x100-16 1928 1855040 ns/op 2851.97 MB/s Benchmark_FanOut_512x100x100-16 1921 1842695 ns/op 2871.08 MB/s Benchmark_FanOut_512x100x100-16 1953 1851665 ns/op 2857.17 MB/s Benchmark_FanOut_512x100x100-16 1932 1861020 ns/op 2842.81 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16883556 ns/op 3139.18 MB/s Benchmark__FanOut_512x100x1k-16 214 16797925 ns/op 3155.18 MB/s Benchmark__FanOut_512x100x1k-16 212 16732013 ns/op 3167.61 MB/s Benchmark__FanOut_512x100x1k-16 211 16820243 ns/op 3151.00 MB/s Benchmark__FanOut_512x100x1k-16 212 16931133 ns/op 3130.36 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2823 1180075 ns/op 8839.30 MB/s Benchmark____FanOut_1kx10x1k-16 3028 1168422 ns/op 8927.45 MB/s Benchmark____FanOut_1kx10x1k-16 3108 1157651 ns/op 9010.52 MB/s Benchmark____FanOut_1kx10x1k-16 3201 1151096 ns/op 9061.83 MB/s Benchmark____FanOut_1kx10x1k-16 3007 1147416 ns/op 9090.90 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2763 1274407 ns/op 8177.17 MB/s Benchmark__FanOut_1kx100x100-16 2798 1273489 ns/op 8183.06 MB/s Benchmark__FanOut_1kx100x100-16 2750 1273562 ns/op 8182.59 MB/s Benchmark__FanOut_1kx100x100-16 2740 1292290 ns/op 8064.01 MB/s Benchmark__FanOut_1kx100x100-16 2720 1278592 ns/op 8150.40 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4456405 781.8 ns/op 318.52 MB/s Benchmark_____RFanOut_8x1x10-16 4408639 768.9 ns/op 323.84 MB/s Benchmark_____RFanOut_8x1x10-16 4496290 784.4 ns/op 317.44 MB/s Benchmark_____RFanOut_8x1x10-16 4383039 778.5 ns/op 319.86 MB/s Benchmark_____RFanOut_8x1x10-16 4486657 803.8 ns/op 309.78 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 543150 6454 ns/op 359.32 MB/s Benchmark____RFanOut_8x1x100-16 537056 6297 ns/op 368.26 MB/s Benchmark____RFanOut_8x1x100-16 527496 6166 ns/op 376.11 MB/s Benchmark____RFanOut_8x1x100-16 545803 6253 ns/op 370.85 MB/s Benchmark____RFanOut_8x1x100-16 538762 6233 ns/op 372.08 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47389 75559 ns/op 304.65 MB/s Benchmark___RFanOut_8x10x100-16 47655 76347 ns/op 301.51 MB/s Benchmark___RFanOut_8x10x100-16 46527 77703 ns/op 296.24 MB/s Benchmark___RFanOut_8x10x100-16 47425 75870 ns/op 303.40 MB/s Benchmark___RFanOut_8x10x100-16 47756 75486 ns/op 304.94 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5740 609562 ns/op 393.76 MB/s Benchmark__RFanOut_8x10x1000-16 5912 611755 ns/op 392.34 MB/s Benchmark__RFanOut_8x10x1000-16 5774 620878 ns/op 386.58 MB/s Benchmark__RFanOut_8x10x1000-16 5563 615722 ns/op 389.82 MB/s Benchmark__RFanOut_8x10x1000-16 5739 608815 ns/op 394.24 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4896 717821 ns/op 320.44 MB/s Benchmark__RFanOut_8x100x100-16 4863 713551 ns/op 322.36 MB/s Benchmark__RFanOut_8x100x100-16 4874 712345 ns/op 322.90 MB/s Benchmark__RFanOut_8x100x100-16 4924 714749 ns/op 321.82 MB/s Benchmark__RFanOut_8x100x100-16 4872 724043 ns/op 317.69 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 568 6425096 ns/op 373.54 MB/s Benchmark_RFanOut_8x100x1000-16 553 6421317 ns/op 373.76 MB/s Benchmark_RFanOut_8x100x1000-16 565 6360371 ns/op 377.34 MB/s Benchmark_RFanOut_8x100x1000-16 543 6506182 ns/op 368.88 MB/s Benchmark_RFanOut_8x100x1000-16 555 6541833 ns/op 366.87 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 520 6834184 ns/op 365.81 MB/s Benchmark_RFanOut_8x10x10000-16 504 6753102 ns/op 370.20 MB/s Benchmark_RFanOut_8x10x10000-16 519 6901977 ns/op 362.22 MB/s Benchmark_RFanOut_8x10x10000-16 505 7036407 ns/op 355.30 MB/s Benchmark_RFanOut_8x10x10000-16 511 6876193 ns/op 363.58 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3009 1167596 ns/op 8933.78 MB/s Benchmark_RFanOut_1kx10x1000-16 2707 1136684 ns/op 9176.73 MB/s Benchmark_RFanOut_1kx10x1000-16 2955 1169801 ns/op 8916.93 MB/s Benchmark_RFanOut_1kx10x1000-16 3214 1165448 ns/op 8950.24 MB/s Benchmark_RFanOut_1kx10x1000-16 3044 1145224 ns/op 9108.29 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6869002 510.0 ns/op 4074.71 MB/s Benchmark_____FanIn_1kx100x1-16 6894031 508.1 ns/op 4089.75 MB/s Benchmark_____FanIn_1kx100x1-16 6923654 506.9 ns/op 4099.33 MB/s Benchmark_____FanIn_1kx100x1-16 6903834 508.6 ns/op 4085.38 MB/s Benchmark_____FanIn_1kx100x1-16 6953043 507.6 ns/op 4093.69 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2590531 1383 ns/op 5944.85 MB/s Benchmark_____FanIn_4kx100x1-16 2652093 1379 ns/op 5963.93 MB/s Benchmark_____FanIn_4kx100x1-16 2532966 1355 ns/op 6068.98 MB/s Benchmark_____FanIn_4kx100x1-16 2648043 1344 ns/op 6116.36 MB/s Benchmark_____FanIn_4kx100x1-16 2589974 1356 ns/op 6064.92 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1692157 2125 ns/op 7724.88 MB/s Benchmark_____FanIn_8kx100x1-16 1684348 2121 ns/op 7737.45 MB/s Benchmark_____FanIn_8kx100x1-16 1692438 2112 ns/op 7770.39 MB/s Benchmark_____FanIn_8kx100x1-16 1659044 2130 ns/op 7707.33 MB/s Benchmark_____FanIn_8kx100x1-16 1695854 2151 ns/op 7629.28 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 862474 4167 ns/op 7870.69 MB/s Benchmark____FanIn_16kx100x1-16 869223 4152 ns/op 7899.52 MB/s Benchmark____FanIn_16kx100x1-16 869814 4143 ns/op 7917.54 MB/s Benchmark____FanIn_16kx100x1-16 840596 4184 ns/op 7840.10 MB/s Benchmark____FanIn_16kx100x1-16 865708 4212 ns/op 7786.43 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 9596500329 vs 10888353300 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56242->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:55908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56616->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 160692 20059 ns/op 6535.97 MB/s Benchmark____FanIn_64kx100x1-16 168386 19810 ns/op 6618.02 MB/s Benchmark____FanIn_64kx100x1-16 168177 20014 ns/op 6550.51 MB/s Benchmark____FanIn_64kx100x1-16 165291 20017 ns/op 6549.80 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1018700390 vs 11732555000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54980->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:54668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54610->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: 244482850 vs 11680119000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57618->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: 296918850 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59764->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: 569061690 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33166->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:33022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33540->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: 167664110 vs 11286849000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35838->127.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:35776->127.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:35852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35796->127.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:36116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36134->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:36216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35986->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5568061 647.3 ns/op 438.73 MB/s Benchmark___BumpPubCount_1x3-16 5524414 646.1 ns/op 439.55 MB/s Benchmark___BumpPubCount_1x3-16 5534169 648.7 ns/op 437.79 MB/s Benchmark___BumpPubCount_1x3-16 5498166 647.9 ns/op 438.33 MB/s Benchmark___BumpPubCount_1x3-16 5477401 652.8 ns/op 435.07 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5256422 679.8 ns/op 417.75 MB/s Benchmark___BumpPubCount_2x3-16 5271373 676.0 ns/op 420.14 MB/s Benchmark___BumpPubCount_2x3-16 5191323 678.4 ns/op 418.63 MB/s Benchmark___BumpPubCount_2x3-16 5296812 680.9 ns/op 417.10 MB/s Benchmark___BumpPubCount_2x3-16 5286512 673.6 ns/op 421.61 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5503816 650.9 ns/op 436.32 MB/s Benchmark___BumpPubCount_5x3-16 5522023 650.5 ns/op 436.60 MB/s Benchmark___BumpPubCount_5x3-16 5515030 650.9 ns/op 436.30 MB/s Benchmark___BumpPubCount_5x3-16 5532298 651.5 ns/op 435.92 MB/s Benchmark___BumpPubCount_5x3-16 5478640 648.4 ns/op 437.97 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5538842 648.2 ns/op 438.14 MB/s Benchmark__BumpPubCount_10x3-16 5531973 649.2 ns/op 437.49 MB/s Benchmark__BumpPubCount_10x3-16 5529560 647.3 ns/op 438.76 MB/s Benchmark__BumpPubCount_10x3-16 5569034 648.7 ns/op 437.77 MB/s Benchmark__BumpPubCount_10x3-16 5475885 648.1 ns/op 438.20 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11787487 275.0 ns/op 3781.20 MB/s Benchmark____GWs_Opt_1kx01x0-16 12815626 273.8 ns/op 3798.27 MB/s Benchmark____GWs_Opt_1kx01x0-16 12439576 295.3 ns/op 3521.50 MB/s Benchmark____GWs_Opt_1kx01x0-16 12897500 271.5 ns/op 3830.19 MB/s Benchmark____GWs_Opt_1kx01x0-16 12702916 277.7 ns/op 3745.15 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 8933888 339.5 ns/op 6079.70 MB/s Benchmark____GWs_Opt_2kx01x0-16 10321516 338.1 ns/op 6104.00 MB/s Benchmark____GWs_Opt_2kx01x0-16 10705296 335.4 ns/op 6153.28 MB/s Benchmark____GWs_Opt_2kx01x0-16 9935718 326.0 ns/op 6330.77 MB/s Benchmark____GWs_Opt_2kx01x0-16 10697851 345.3 ns/op 5977.12 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5557285 604.2 ns/op 6805.65 MB/s Benchmark____GWs_Opt_4kx01x0-16 5663644 622.0 ns/op 6611.04 MB/s Benchmark____GWs_Opt_4kx01x0-16 5920992 604.6 ns/op 6800.63 MB/s Benchmark____GWs_Opt_4kx01x0-16 5803858 623.2 ns/op 6598.51 MB/s Benchmark____GWs_Opt_4kx01x0-16 5755466 614.0 ns/op 6697.14 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28351848 114.4 ns/op 9090.58 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:49840->127.0.0.1:40365: use of closed network connection --- FAIL: Benchmark____GWs_Opt_1kx10x0-16 Benchmark____GWs_Opt_1kx10x0-16 30323094 112.5 ns/op 9241.28 MB/s Benchmark____GWs_Opt_1kx10x0-16 30976988 109.9 ns/op 9459.23 MB/s Benchmark____GWs_Opt_1kx10x0-16 30639520 113.9 ns/op 9129.56 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23680508 150.2 ns/op 13738.56 MB/s Benchmark____GWs_Opt_2kx10x0-16 25541037 146.7 ns/op 14070.02 MB/s Benchmark____GWs_Opt_2kx10x0-16 25499043 154.6 ns/op 13346.71 MB/s Benchmark____GWs_Opt_2kx10x0-16 25784076 147.0 ns/op 14037.20 MB/s Benchmark____GWs_Opt_2kx10x0-16 24827853 177.0 ns/op 11662.83 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11260190 300.7 ns/op 13672.76 MB/s Benchmark____GWs_Opt_4kx10x0-16 12813573 327.8 ns/op 12545.55 MB/s Benchmark____GWs_Opt_4kx10x0-16 12085704 303.8 ns/op 13536.48 MB/s Benchmark____GWs_Opt_4kx10x0-16 12337356 306.7 ns/op 13407.03 MB/s Benchmark____GWs_Opt_4kx10x0-16 10819387 295.2 ns/op 13929.78 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6416250 548.8 ns/op 5694.09 MB/s Benchmark____GWs_Opt_1kx01x1-16 6337446 547.1 ns/op 5712.35 MB/s Benchmark____GWs_Opt_1kx01x1-16 6588103 545.3 ns/op 5730.70 MB/s Benchmark____GWs_Opt_1kx01x1-16 6475164 552.0 ns/op 5661.00 MB/s Benchmark____GWs_Opt_1kx01x1-16 6639849 555.6 ns/op 5624.10 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4629085 770.5 ns/op 8042.47 MB/s Benchmark____GWs_Opt_2kx01x1-16 4679275 754.9 ns/op 8209.01 MB/s Benchmark____GWs_Opt_2kx01x1-16 4702939 765.1 ns/op 8099.75 MB/s Benchmark____GWs_Opt_2kx01x1-16 4551108 769.1 ns/op 8057.87 MB/s Benchmark____GWs_Opt_2kx01x1-16 4686751 770.2 ns/op 8045.84 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2624028 1380 ns/op 8945.25 MB/s Benchmark____GWs_Opt_4kx01x1-16 2643201 1388 ns/op 8893.72 MB/s Benchmark____GWs_Opt_4kx01x1-16 2631505 1373 ns/op 8985.91 MB/s Benchmark____GWs_Opt_4kx01x1-16 2465590 1381 ns/op 8937.32 MB/s Benchmark____GWs_Opt_4kx01x1-16 2577010 1378 ns/op 8952.50 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6065296 549.4 ns/op 5687.87 MB/s Benchmark____GWs_Opt_1kx10x1-16 6068271 554.3 ns/op 5637.52 MB/s Benchmark____GWs_Opt_1kx10x1-16 5981032 564.4 ns/op 5536.65 MB/s Benchmark____GWs_Opt_1kx10x1-16 6465488 559.5 ns/op 5585.17 MB/s Benchmark____GWs_Opt_1kx10x1-16 6670258 559.7 ns/op 5583.40 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 3975300 855.4 ns/op 7244.41 MB/s Benchmark____GWs_Opt_2kx10x1-16 4093359 855.0 ns/op 7248.22 MB/s Benchmark____GWs_Opt_2kx10x1-16 4087078 817.4 ns/op 7581.65 MB/s Benchmark____GWs_Opt_2kx10x1-16 4174598 854.4 ns/op 7252.98 MB/s Benchmark____GWs_Opt_2kx10x1-16 4170156 849.1 ns/op 7298.73 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2432160 1505 ns/op 8200.47 MB/s Benchmark____GWs_Opt_4kx10x1-16 2379778 1445 ns/op 8539.62 MB/s Benchmark____GWs_Opt_4kx10x1-16 2360572 1519 ns/op 8121.80 MB/s Benchmark____GWs_Opt_4kx10x1-16 2396590 1564 ns/op 7888.53 MB/s Benchmark____GWs_Opt_4kx10x1-16 2382955 1534 ns/op 8045.74 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12302718 293.1 ns/op 3547.82 MB/s Benchmark____GWs_Int_1kx01x0-16 12885188 288.7 ns/op 3601.97 MB/s Benchmark____GWs_Int_1kx01x0-16 12203883 282.8 ns/op 3676.99 MB/s Benchmark____GWs_Int_1kx01x0-16 12813343 283.2 ns/op 3672.88 MB/s Benchmark____GWs_Int_1kx01x0-16 12924159 288.9 ns/op 3599.44 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9561823 346.7 ns/op 5953.39 MB/s Benchmark____GWs_Int_2kx01x0-16 10229629 359.7 ns/op 5738.16 MB/s Benchmark____GWs_Int_2kx01x0-16 10230223 344.2 ns/op 5995.98 MB/s Benchmark____GWs_Int_2kx01x0-16 10308702 357.7 ns/op 5770.53 MB/s Benchmark____GWs_Int_2kx01x0-16 10048220 349.5 ns/op 5904.84 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 6001304 620.5 ns/op 6626.65 MB/s Benchmark____GWs_Int_4kx01x0-16 5727050 633.7 ns/op 6488.46 MB/s Benchmark____GWs_Int_4kx01x0-16 5713765 636.6 ns/op 6459.04 MB/s Benchmark____GWs_Int_4kx01x0-16 5590227 631.1 ns/op 6515.60 MB/s Benchmark____GWs_Int_4kx01x0-16 5809876 615.7 ns/op 6678.75 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31273832 120.3 ns/op 8642.88 MB/s Benchmark____GWs_Int_1kx10x0-16 31952186 109.7 ns/op 9481.80 MB/s Benchmark____GWs_Int_1kx10x0-16 31420966 109.3 ns/op 9515.12 MB/s Benchmark____GWs_Int_1kx10x0-16 31974505 109.7 ns/op 9481.41 MB/s Benchmark____GWs_Int_1kx10x0-16 31742934 111.3 ns/op 9344.31 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 26225050 156.6 ns/op 13179.06 MB/s Benchmark____GWs_Int_2kx10x0-16 25889931 143.0 ns/op 14435.01 MB/s Benchmark____GWs_Int_2kx10x0-16 25873530 143.7 ns/op 14359.08 MB/s Benchmark____GWs_Int_2kx10x0-16 26397429 153.0 ns/op 13487.97 MB/s Benchmark____GWs_Int_2kx10x0-16 24419400 150.2 ns/op 13745.28 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:55: Failed read: read tcp 127.0.0.1:33170->127.0.0.1:38195: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 13060404 284.6 ns/op 14450.71 MB/s Benchmark____GWs_Int_4kx10x0-16 13300966 282.5 ns/op 14557.26 MB/s Benchmark____GWs_Int_4kx10x0-16 11324827 292.9 ns/op 14038.95 MB/s Benchmark____GWs_Int_4kx10x0-16 12947260 283.9 ns/op 14484.15 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6357428 559.9 ns/op 5581.75 MB/s Benchmark____GWs_Int_1kx01x1-16 6569515 561.9 ns/op 5561.59 MB/s Benchmark____GWs_Int_1kx01x1-16 6706197 889.6 ns/op 3512.79 MB/s Benchmark____GWs_Int_1kx01x1-16 6239586 564.1 ns/op 5539.45 MB/s Benchmark____GWs_Int_1kx01x1-16 6432944 563.8 ns/op 5542.32 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4625581 771.6 ns/op 8031.45 MB/s Benchmark____GWs_Int_2kx01x1-16 4757536 761.3 ns/op 8140.05 MB/s Benchmark____GWs_Int_2kx01x1-16 4783561 759.0 ns/op 8164.74 MB/s Benchmark____GWs_Int_2kx01x1-16 4559914 763.9 ns/op 8112.11 MB/s Benchmark____GWs_Int_2kx01x1-16 4540395 763.8 ns/op 8113.53 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2585587 1369 ns/op 9013.00 MB/s Benchmark____GWs_Int_4kx01x1-16 2318367 1382 ns/op 8931.53 MB/s Benchmark____GWs_Int_4kx01x1-16 2656033 1369 ns/op 9017.17 MB/s Benchmark____GWs_Int_4kx01x1-16 2616951 1367 ns/op 9030.31 MB/s Benchmark____GWs_Int_4kx01x1-16 1000000 3632 ns/op 3397.44 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6486360 564.2 ns/op 5538.35 MB/s Benchmark____GWs_Int_1kx10x1-16 6246844 679.3 ns/op 4600.11 MB/s Benchmark____GWs_Int_1kx10x1-16 6277827 562.6 ns/op 5554.21 MB/s Benchmark____GWs_Int_1kx10x1-16 6254547 575.3 ns/op 5431.58 MB/s Benchmark____GWs_Int_1kx10x1-16 6177459 563.4 ns/op 5546.76 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4161100 829.4 ns/op 7471.68 MB/s Benchmark____GWs_Int_2kx10x1-16 4096240 1160 ns/op 5343.43 MB/s Benchmark____GWs_Int_2kx10x1-16 4075358 838.7 ns/op 7388.58 MB/s Benchmark____GWs_Int_2kx10x1-16 4106798 840.5 ns/op 7373.29 MB/s Benchmark____GWs_Int_2kx10x1-16 4069920 870.8 ns/op 7116.33 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2286613 1528 ns/op 8075.64 MB/s Benchmark____GWs_Int_4kx10x1-16 2309200 1493 ns/op 8264.02 MB/s Benchmark____GWs_Int_4kx10x1-16 2288828 1509 ns/op 8179.86 MB/s Benchmark____GWs_Int_4kx10x1-16 2434046 1589 ns/op 7767.35 MB/s Benchmark____GWs_Int_4kx10x1-16 2135673 1585 ns/op 7786.91 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8326329 436.5 ns/op 233.69 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8336425 439.5 ns/op 232.08 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8052600 439.7 ns/op 231.96 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8015751 440.8 ns/op 231.41 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8542852 434.2 ns/op 234.93 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 617842 5023 ns/op 35.24 MB/s Benchmark__GWs_Reqs_1SubEach-16 788830 5272 ns/op 33.57 MB/s Benchmark__GWs_Reqs_1SubEach-16 743774 5277 ns/op 33.54 MB/s Benchmark__GWs_Reqs_1SubEach-16 765650 5349 ns/op 33.09 MB/s Benchmark__GWs_Reqs_1SubEach-16 751300 5183 ns/op 34.15 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2063.017s