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 49768195 74.65 ns/op 147.35 MB/s Benchmark______Pub0b_Payload-16 47030210 74.07 ns/op 148.52 MB/s Benchmark______Pub0b_Payload-16 46963278 72.38 ns/op 151.98 MB/s Benchmark______Pub0b_Payload-16 46989820 74.39 ns/op 147.87 MB/s Benchmark______Pub0b_Payload-16 47238045 74.83 ns/op 146.99 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45738956 72.87 ns/op 260.75 MB/s Benchmark______Pub8b_Payload-16 46443484 73.15 ns/op 259.74 MB/s Benchmark______Pub8b_Payload-16 40033066 76.09 ns/op 249.69 MB/s Benchmark______Pub8b_Payload-16 49265432 73.04 ns/op 260.13 MB/s Benchmark______Pub8b_Payload-16 45333249 74.47 ns/op 255.13 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44297530 76.75 ns/op 573.27 MB/s Benchmark_____Pub32b_Payload-16 44332248 77.10 ns/op 570.69 MB/s Benchmark_____Pub32b_Payload-16 44199296 76.79 ns/op 573.01 MB/s Benchmark_____Pub32b_Payload-16 44523368 76.89 ns/op 572.25 MB/s Benchmark_____Pub32b_Payload-16 38609707 77.84 ns/op 565.23 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 41734706 86.17 ns/op 1636.33 MB/s Benchmark____Pub128B_Payload-16 39821391 86.71 ns/op 1626.20 MB/s Benchmark____Pub128B_Payload-16 40109382 86.10 ns/op 1637.62 MB/s Benchmark____Pub128B_Payload-16 39769537 86.52 ns/op 1629.73 MB/s Benchmark____Pub128B_Payload-16 37912809 86.08 ns/op 1638.05 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 31821549 94.67 ns/op 2841.44 MB/s Benchmark____Pub256B_Payload-16 31396501 103.4 ns/op 2601.31 MB/s Benchmark____Pub256B_Payload-16 31479520 96.53 ns/op 2786.76 MB/s Benchmark____Pub256B_Payload-16 37945100 93.81 ns/op 2867.39 MB/s Benchmark____Pub256B_Payload-16 36250282 95.65 ns/op 2812.28 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22512640 154.4 ns/op 6720.68 MB/s Benchmark______Pub1K_Payload-16 23653437 139.4 ns/op 7445.27 MB/s Benchmark______Pub1K_Payload-16 24204834 138.7 ns/op 7483.11 MB/s Benchmark______Pub1K_Payload-16 26481658 139.4 ns/op 7444.33 MB/s Benchmark______Pub1K_Payload-16 23442768 143.0 ns/op 7256.96 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5695256 609.8 ns/op 6740.37 MB/s Benchmark______Pub4K_Payload-16 5441472 620.3 ns/op 6626.03 MB/s Benchmark______Pub4K_Payload-16 5307620 617.9 ns/op 6651.06 MB/s Benchmark______Pub4K_Payload-16 5590755 626.1 ns/op 6564.34 MB/s Benchmark______Pub4K_Payload-16 5757625 617.5 ns/op 6655.74 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2790144 1277 ns/op 6423.53 MB/s Benchmark______Pub8K_Payload-16 2710076 1288 ns/op 6372.89 MB/s Benchmark______Pub8K_Payload-16 2695582 1286 ns/op 6380.17 MB/s Benchmark______Pub8K_Payload-16 2749688 1277 ns/op 6427.25 MB/s Benchmark______Pub8K_Payload-16 2665562 1275 ns/op 6434.08 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 663646 5354 ns/op 6123.00 MB/s Benchmark_____Pub32K_Payload-16 562641 5407 ns/op 6062.53 MB/s Benchmark_____Pub32K_Payload-16 669734 5380 ns/op 6093.69 MB/s Benchmark_____Pub32K_Payload-16 653366 5377 ns/op 6096.54 MB/s Benchmark_____Pub32K_Payload-16 658645 5539 ns/op 5918.63 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31801737 95.26 ns/op 115.47 MB/s Benchmark__AuthPub0b_Payload-16 31822425 99.25 ns/op 110.83 MB/s Benchmark__AuthPub0b_Payload-16 32179759 94.85 ns/op 115.97 MB/s Benchmark__AuthPub0b_Payload-16 35934687 96.19 ns/op 114.36 MB/s Benchmark__AuthPub0b_Payload-16 33841604 95.41 ns/op 115.29 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15310688 231.3 ns/op Benchmark_____________PubSub-16 15269042 231.7 ns/op Benchmark_____________PubSub-16 15276627 232.2 ns/op Benchmark_____________PubSub-16 15284014 231.8 ns/op Benchmark_____________PubSub-16 15400065 233.1 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15190791 231.1 ns/op Benchmark_____PubSubTwoConns-16 15449851 231.1 ns/op Benchmark_____PubSubTwoConns-16 15292060 230.8 ns/op Benchmark_____PubSubTwoConns-16 15397860 231.1 ns/op Benchmark_____PubSubTwoConns-16 15169423 231.3 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54528->127.0.0.1:44861: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54492->127.0.0.1:42069: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:32980->127.0.0.1:40695: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57104->127.0.0.1:35629: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34668->127.0.0.1:35149: 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 14042492 251.0 ns/op Benchmark_____PubTwoQueueSub-16 14114610 250.5 ns/op Benchmark_____PubTwoQueueSub-16 14206017 250.3 ns/op Benchmark_____PubTwoQueueSub-16 14151691 250.8 ns/op Benchmark_____PubTwoQueueSub-16 13960641 251.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14023048 251.1 ns/op Benchmark____PubFourQueueSub-16 14127289 250.7 ns/op Benchmark____PubFourQueueSub-16 14192671 250.3 ns/op Benchmark____PubFourQueueSub-16 14205538 251.3 ns/op Benchmark____PubFourQueueSub-16 14157877 251.2 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14321882 251.1 ns/op Benchmark___PubEightQueueSub-16 14128438 250.3 ns/op Benchmark___PubEightQueueSub-16 14138953 250.4 ns/op Benchmark___PubEightQueueSub-16 13954698 252.3 ns/op Benchmark___PubEightQueueSub-16 14078827 252.1 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22646 160391 ns/op Benchmark_PubSub512kTwoConns-16 22665 156509 ns/op Benchmark_PubSub512kTwoConns-16 22884 155564 ns/op Benchmark_PubSub512kTwoConns-16 23076 156350 ns/op Benchmark_PubSub512kTwoConns-16 23340 154372 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14877384 233.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 14955666 234.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 14940183 234.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 14643164 234.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 14990061 233.2 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14950045 234.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 14865180 234.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 14793517 232.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 14899731 234.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15016027 233.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11164880 315.5 ns/op Benchmark____RoutedPubSub_0b-16 11562726 314.7 ns/op Benchmark____RoutedPubSub_0b-16 11346073 314.7 ns/op Benchmark____RoutedPubSub_0b-16 11222467 313.8 ns/op Benchmark____RoutedPubSub_0b-16 11223352 314.3 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6665348 532.7 ns/op Benchmark____RoutedPubSub_1K-16 6505398 532.3 ns/op Benchmark____RoutedPubSub_1K-16 6696950 540.3 ns/op Benchmark____RoutedPubSub_1K-16 6521434 539.4 ns/op Benchmark____RoutedPubSub_1K-16 6672412 757.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 79992 45490 ns/op Benchmark__RoutedPubSub_100K-16 83503 45327 ns/op Benchmark__RoutedPubSub_100K-16 73460 48414 ns/op Benchmark__RoutedPubSub_100K-16 80726 46601 ns/op Benchmark__RoutedPubSub_100K-16 78669 45407 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9549921 322.0 ns/op Benchmark____Routed2QueueSub-16 9898114 325.4 ns/op Benchmark____Routed2QueueSub-16 9608784 317.2 ns/op Benchmark____Routed2QueueSub-16 9498877 318.8 ns/op Benchmark____Routed2QueueSub-16 9687258 315.4 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9701592 320.7 ns/op Benchmark____Routed4QueueSub-16 9488140 326.1 ns/op Benchmark____Routed4QueueSub-16 9515686 320.0 ns/op Benchmark____Routed4QueueSub-16 9467872 325.3 ns/op Benchmark____Routed4QueueSub-16 9393416 322.2 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9222628 337.2 ns/op Benchmark____Routed8QueueSub-16 10826202 331.7 ns/op Benchmark____Routed8QueueSub-16 9293778 336.4 ns/op Benchmark____Routed8QueueSub-16 9080473 335.2 ns/op Benchmark____Routed8QueueSub-16 9348048 326.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8719377 346.3 ns/op Benchmark___Routed16QueueSub-16 10378467 345.1 ns/op Benchmark___Routed16QueueSub-16 8800466 355.8 ns/op Benchmark___Routed16QueueSub-16 8782796 342.3 ns/op Benchmark___Routed16QueueSub-16 10437327 341.0 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6132744 549.3 ns/op Benchmark____________RouteCompressOff-16 6576412 549.2 ns/op Benchmark____________RouteCompressOff-16 6392892 560.1 ns/op Benchmark____________RouteCompressOff-16 6429516 549.1 ns/op Benchmark____________RouteCompressOff-16 6472576 552.8 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6380931 547.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6374608 545.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6634470 543.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6563023 551.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6461148 555.7 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6391015 550.2 ns/op Benchmark_________RouteCompressS2Fast-16 6331023 555.7 ns/op Benchmark_________RouteCompressS2Fast-16 6444658 547.9 ns/op Benchmark_________RouteCompressS2Fast-16 6485926 546.5 ns/op Benchmark_________RouteCompressS2Fast-16 6310489 497.4 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6571851 556.7 ns/op Benchmark_______RouteCompressS2Better-16 6374598 548.1 ns/op Benchmark_______RouteCompressS2Better-16 6418754 540.2 ns/op Benchmark_______RouteCompressS2Better-16 6366585 550.2 ns/op Benchmark_______RouteCompressS2Better-16 6363230 552.5 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6357568 545.2 ns/op Benchmark_________RouteCompressS2Best-16 6538023 540.8 ns/op Benchmark_________RouteCompressS2Best-16 6416902 544.9 ns/op Benchmark_________RouteCompressS2Best-16 6533865 550.7 ns/op Benchmark_________RouteCompressS2Best-16 6348886 542.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4653374 772.9 ns/op 322.15 MB/s Benchmark______FanOut_8x1x10-16 4633976 774.2 ns/op 321.63 MB/s Benchmark______FanOut_8x1x10-16 4623441 774.3 ns/op 321.57 MB/s Benchmark______FanOut_8x1x10-16 4600124 772.5 ns/op 322.33 MB/s Benchmark______FanOut_8x1x10-16 4631461 770.9 ns/op 322.99 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 560191 6117 ns/op 379.11 MB/s Benchmark_____FanOut_8x1x100-16 516692 6160 ns/op 376.47 MB/s Benchmark_____FanOut_8x1x100-16 566704 6151 ns/op 377.00 MB/s Benchmark_____FanOut_8x1x100-16 571537 6066 ns/op 382.31 MB/s Benchmark_____FanOut_8x1x100-16 550279 6058 ns/op 382.81 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47654 74664 ns/op 308.30 MB/s Benchmark____FanOut_8x10x100-16 47908 75213 ns/op 306.05 MB/s Benchmark____FanOut_8x10x100-16 47284 74898 ns/op 307.34 MB/s Benchmark____FanOut_8x10x100-16 47694 74830 ns/op 307.62 MB/s Benchmark____FanOut_8x10x100-16 47644 75813 ns/op 303.63 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5815 610568 ns/op 393.11 MB/s Benchmark___FanOut_8x10x1000-16 5649 594211 ns/op 403.93 MB/s Benchmark___FanOut_8x10x1000-16 5978 594507 ns/op 403.73 MB/s Benchmark___FanOut_8x10x1000-16 6000 594860 ns/op 403.49 MB/s Benchmark___FanOut_8x10x1000-16 5808 598071 ns/op 401.32 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5018 706692 ns/op 325.49 MB/s Benchmark___FanOut_8x100x100-16 5047 714844 ns/op 321.78 MB/s Benchmark___FanOut_8x100x100-16 4989 705525 ns/op 326.03 MB/s Benchmark___FanOut_8x100x100-16 4963 705023 ns/op 326.26 MB/s Benchmark___FanOut_8x100x100-16 5068 707574 ns/op 325.08 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 584 6118480 ns/op 392.26 MB/s Benchmark__FanOut_8x100x1000-16 565 6117079 ns/op 392.35 MB/s Benchmark__FanOut_8x100x1000-16 571 6144107 ns/op 390.62 MB/s Benchmark__FanOut_8x100x1000-16 550 6292901 ns/op 381.39 MB/s Benchmark__FanOut_8x100x1000-16 577 6130120 ns/op 391.51 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 525 6732931 ns/op 371.31 MB/s Benchmark__FanOut_8x10x10000-16 525 6771569 ns/op 369.19 MB/s Benchmark__FanOut_8x10x10000-16 522 6649921 ns/op 375.95 MB/s Benchmark__FanOut_8x10x10000-16 529 6687949 ns/op 373.81 MB/s Benchmark__FanOut_8x10x10000-16 518 6655047 ns/op 375.66 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 950 3759138 ns/op 305.93 MB/s Benchmark___FanOut_8x500x100-16 943 3765987 ns/op 305.37 MB/s Benchmark___FanOut_8x500x100-16 954 3754909 ns/op 306.27 MB/s Benchmark___FanOut_8x500x100-16 960 3803815 ns/op 302.33 MB/s Benchmark___FanOut_8x500x100-16 960 3738914 ns/op 307.58 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 353619 9512 ns/op 1539.15 MB/s Benchmark___FanOut_128x1x100-16 362233 9461 ns/op 1547.47 MB/s Benchmark___FanOut_128x1x100-16 362534 9565 ns/op 1530.61 MB/s Benchmark___FanOut_128x1x100-16 358539 9445 ns/op 1550.07 MB/s Benchmark___FanOut_128x1x100-16 360921 9421 ns/op 1554.09 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32463 110125 ns/op 1317.97 MB/s Benchmark__FanOut_128x10x100-16 32138 110379 ns/op 1314.93 MB/s Benchmark__FanOut_128x10x100-16 32490 111033 ns/op 1307.19 MB/s Benchmark__FanOut_128x10x100-16 32322 110843 ns/op 1309.43 MB/s Benchmark__FanOut_128x10x100-16 32452 110269 ns/op 1316.24 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4039 868097 ns/op 1682.00 MB/s Benchmark_FanOut_128x10x1000-16 4156 875325 ns/op 1668.11 MB/s Benchmark_FanOut_128x10x1000-16 4058 864806 ns/op 1688.40 MB/s Benchmark_FanOut_128x10x1000-16 4106 867178 ns/op 1683.78 MB/s Benchmark_FanOut_128x10x1000-16 3968 870537 ns/op 1677.29 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3464 1009391 ns/op 1436.65 MB/s Benchmark_FanOut_128x100x100-16 3483 1003223 ns/op 1445.48 MB/s Benchmark_FanOut_128x100x100-16 3553 1010611 ns/op 1434.92 MB/s Benchmark_FanOut_128x100x100-16 3466 1003028 ns/op 1445.76 MB/s Benchmark_FanOut_128x100x100-16 3496 1003677 ns/op 1444.83 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 388 9236770 ns/op 1580.65 MB/s BenchmarkFanOut_128x100x1000-16 386 9177071 ns/op 1590.94 MB/s BenchmarkFanOut_128x100x1000-16 380 9280353 ns/op 1573.23 MB/s BenchmarkFanOut_128x100x1000-16 381 9249427 ns/op 1578.49 MB/s BenchmarkFanOut_128x100x1000-16 380 9168400 ns/op 1592.44 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 375 9670852 ns/op 1520.05 MB/s BenchmarkFanOut_128x10x10000-16 369 9650870 ns/op 1523.19 MB/s BenchmarkFanOut_128x10x10000-16 379 9679903 ns/op 1518.62 MB/s BenchmarkFanOut_128x10x10000-16 369 9562331 ns/op 1537.30 MB/s BenchmarkFanOut_128x10x10000-16 374 9639023 ns/op 1525.07 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 682 5252389 ns/op 1380.35 MB/s BenchmarkFanOut__128x500x100-16 678 5246435 ns/op 1381.92 MB/s BenchmarkFanOut__128x500x100-16 676 5260288 ns/op 1378.28 MB/s BenchmarkFanOut__128x500x100-16 676 5279557 ns/op 1373.25 MB/s BenchmarkFanOut__128x500x100-16 681 5283920 ns/op 1372.11 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1942 1857500 ns/op 2848.20 MB/s Benchmark_FanOut_512x100x100-16 1936 1825672 ns/op 2897.85 MB/s Benchmark_FanOut_512x100x100-16 1971 1824109 ns/op 2900.33 MB/s Benchmark_FanOut_512x100x100-16 1923 1831845 ns/op 2888.09 MB/s Benchmark_FanOut_512x100x100-16 1939 1834155 ns/op 2884.45 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16610504 ns/op 3190.78 MB/s Benchmark__FanOut_512x100x1k-16 216 16471740 ns/op 3217.66 MB/s Benchmark__FanOut_512x100x1k-16 217 16775942 ns/op 3159.32 MB/s Benchmark__FanOut_512x100x1k-16 214 16811468 ns/op 3152.64 MB/s Benchmark__FanOut_512x100x1k-16 216 16601386 ns/op 3192.54 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2970 1169499 ns/op 8919.24 MB/s Benchmark____FanOut_1kx10x1k-16 2793 1142515 ns/op 9129.89 MB/s Benchmark____FanOut_1kx10x1k-16 3024 1147017 ns/op 9094.06 MB/s Benchmark____FanOut_1kx10x1k-16 2794 1163632 ns/op 8964.21 MB/s Benchmark____FanOut_1kx10x1k-16 3267 1143741 ns/op 9120.11 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2775 1248891 ns/op 8344.24 MB/s Benchmark__FanOut_1kx100x100-16 2733 1259174 ns/op 8276.09 MB/s Benchmark__FanOut_1kx100x100-16 2806 1253952 ns/op 8310.55 MB/s Benchmark__FanOut_1kx100x100-16 2802 1257586 ns/op 8286.54 MB/s Benchmark__FanOut_1kx100x100-16 2751 1251392 ns/op 8327.56 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4291519 793.6 ns/op 313.76 MB/s Benchmark_____RFanOut_8x1x10-16 4556266 807.8 ns/op 308.23 MB/s Benchmark_____RFanOut_8x1x10-16 4551337 795.9 ns/op 312.85 MB/s Benchmark_____RFanOut_8x1x10-16 4337815 836.3 ns/op 297.75 MB/s Benchmark_____RFanOut_8x1x10-16 4449130 789.0 ns/op 315.60 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 543286 6309 ns/op 367.57 MB/s Benchmark____RFanOut_8x1x100-16 525139 6107 ns/op 379.74 MB/s Benchmark____RFanOut_8x1x100-16 507255 6100 ns/op 380.14 MB/s Benchmark____RFanOut_8x1x100-16 545808 6463 ns/op 358.82 MB/s Benchmark____RFanOut_8x1x100-16 540552 6085 ns/op 381.12 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48067 75266 ns/op 305.84 MB/s Benchmark___RFanOut_8x10x100-16 47232 74758 ns/op 307.91 MB/s Benchmark___RFanOut_8x10x100-16 47983 74880 ns/op 307.41 MB/s Benchmark___RFanOut_8x10x100-16 48088 74803 ns/op 307.73 MB/s Benchmark___RFanOut_8x10x100-16 47358 74813 ns/op 307.69 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5968 597868 ns/op 401.46 MB/s Benchmark__RFanOut_8x10x1000-16 6046 600755 ns/op 399.53 MB/s Benchmark__RFanOut_8x10x1000-16 5875 598153 ns/op 401.27 MB/s Benchmark__RFanOut_8x10x1000-16 5803 598691 ns/op 400.91 MB/s Benchmark__RFanOut_8x10x1000-16 5912 602772 ns/op 398.19 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4965 708967 ns/op 324.44 MB/s Benchmark__RFanOut_8x100x100-16 5016 707183 ns/op 325.26 MB/s Benchmark__RFanOut_8x100x100-16 5017 704878 ns/op 326.32 MB/s Benchmark__RFanOut_8x100x100-16 4861 705518 ns/op 326.03 MB/s Benchmark__RFanOut_8x100x100-16 4992 704568 ns/op 326.47 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 578 6144076 ns/op 390.62 MB/s Benchmark_RFanOut_8x100x1000-16 584 6154087 ns/op 389.99 MB/s Benchmark_RFanOut_8x100x1000-16 579 6202119 ns/op 386.97 MB/s Benchmark_RFanOut_8x100x1000-16 570 6142241 ns/op 390.74 MB/s Benchmark_RFanOut_8x100x1000-16 572 6124084 ns/op 391.90 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 517 6886210 ns/op 363.05 MB/s Benchmark_RFanOut_8x10x10000-16 532 6817809 ns/op 366.69 MB/s Benchmark_RFanOut_8x10x10000-16 516 6758973 ns/op 369.88 MB/s Benchmark_RFanOut_8x10x10000-16 522 6701462 ns/op 373.06 MB/s Benchmark_RFanOut_8x10x10000-16 536 6737365 ns/op 371.07 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2966 1134823 ns/op 9191.78 MB/s Benchmark_RFanOut_1kx10x1000-16 3156 1152982 ns/op 9047.01 MB/s Benchmark_RFanOut_1kx10x1000-16 3145 1149352 ns/op 9075.58 MB/s Benchmark_RFanOut_1kx10x1000-16 3204 1150528 ns/op 9066.30 MB/s Benchmark_RFanOut_1kx10x1000-16 2958 1177358 ns/op 8859.70 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6918391 507.9 ns/op 4091.57 MB/s Benchmark_____FanIn_1kx100x1-16 6991599 504.0 ns/op 4123.35 MB/s Benchmark_____FanIn_1kx100x1-16 6923523 504.2 ns/op 4121.77 MB/s Benchmark_____FanIn_1kx100x1-16 6968415 505.6 ns/op 4109.96 MB/s Benchmark_____FanIn_1kx100x1-16 6952447 504.5 ns/op 4119.20 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2637786 1367 ns/op 6016.76 MB/s Benchmark_____FanIn_4kx100x1-16 2654127 1368 ns/op 6010.51 MB/s Benchmark_____FanIn_4kx100x1-16 2632706 1352 ns/op 6079.20 MB/s Benchmark_____FanIn_4kx100x1-16 2623927 1379 ns/op 5964.34 MB/s Benchmark_____FanIn_4kx100x1-16 2657012 1363 ns/op 6032.44 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1703248 2089 ns/op 7856.18 MB/s Benchmark_____FanIn_8kx100x1-16 1685923 2088 ns/op 7862.14 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 21168432 vs 13763995200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44136->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44150->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark_____FanIn_8kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43418->127.0.0.1:5222: write: connection reset by peer Benchmark_____FanIn_8kx100x1-16 1711054 2125 ns/op 7723.74 MB/s Benchmark_____FanIn_8kx100x1-16 1713075 2139 ns/op 7672.01 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 883921 4086 ns/op 8027.73 MB/s Benchmark____FanIn_16kx100x1-16 862106 4362 ns/op 7518.85 MB/s Benchmark____FanIn_16kx100x1-16 866418 4121 ns/op 7958.50 MB/s Benchmark____FanIn_16kx100x1-16 866048 4103 ns/op 7994.55 MB/s Benchmark____FanIn_16kx100x1-16 876067 4091 ns/op 8016.86 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3326093667 vs 11432443200 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41130->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:40948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40958->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 169486 19857 ns/op 6602.26 MB/s Benchmark____FanIn_64kx100x1-16 172137 19746 ns/op 6639.67 MB/s Benchmark____FanIn_64kx100x1-16 175246 20067 ns/op 6533.32 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5016443325 vs 11065346400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45244->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44910->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45000->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: 2759444500 vs 11457266000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47626->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:48034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47462->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: 643914080 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49480->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: 484377550 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51090->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: 602620730 vs 11562138000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54246->127.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:54596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54278->127.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:53982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54186->127.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:54450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54264->127.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:54662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54692->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:53830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54682->127.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:53800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53856->127.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:54496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53952->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: 441642210 vs 11588356000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57126->127.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:56636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56822->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56898->127.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:57094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56738->127.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:56940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56828->127.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:57238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57282->127.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:56906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56892->127.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:56808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56978->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:57202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57272->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5556704 645.0 ns/op 440.32 MB/s Benchmark___BumpPubCount_1x3-16 5582629 639.3 ns/op 444.22 MB/s Benchmark___BumpPubCount_1x3-16 5583462 642.4 ns/op 442.08 MB/s Benchmark___BumpPubCount_1x3-16 5576232 644.5 ns/op 440.63 MB/s Benchmark___BumpPubCount_1x3-16 5587923 640.8 ns/op 443.18 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5303182 671.1 ns/op 423.21 MB/s Benchmark___BumpPubCount_2x3-16 5236392 671.3 ns/op 423.06 MB/s Benchmark___BumpPubCount_2x3-16 5282364 674.0 ns/op 421.34 MB/s Benchmark___BumpPubCount_2x3-16 5291338 667.5 ns/op 425.44 MB/s Benchmark___BumpPubCount_2x3-16 5299887 673.2 ns/op 421.88 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5584653 640.6 ns/op 443.34 MB/s Benchmark___BumpPubCount_5x3-16 5629588 638.3 ns/op 444.90 MB/s Benchmark___BumpPubCount_5x3-16 5602585 640.0 ns/op 443.75 MB/s Benchmark___BumpPubCount_5x3-16 5606445 639.4 ns/op 444.19 MB/s Benchmark___BumpPubCount_5x3-16 5590004 638.1 ns/op 445.08 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5598234 639.3 ns/op 444.22 MB/s Benchmark__BumpPubCount_10x3-16 5601818 640.6 ns/op 443.35 MB/s Benchmark__BumpPubCount_10x3-16 5632204 638.8 ns/op 444.56 MB/s Benchmark__BumpPubCount_10x3-16 5609280 641.9 ns/op 442.44 MB/s Benchmark__BumpPubCount_10x3-16 5618328 640.2 ns/op 443.60 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11591660 274.3 ns/op 3791.19 MB/s Benchmark____GWs_Opt_1kx01x0-16 12864426 278.9 ns/op 3729.01 MB/s Benchmark____GWs_Opt_1kx01x0-16 12606278 275.4 ns/op 3775.75 MB/s Benchmark____GWs_Opt_1kx01x0-16 12324859 277.3 ns/op 3749.80 MB/s Benchmark____GWs_Opt_1kx01x0-16 12317272 285.1 ns/op 3647.74 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10372453 343.5 ns/op 6008.24 MB/s Benchmark____GWs_Opt_2kx01x0-16 10486297 352.9 ns/op 5848.48 MB/s Benchmark____GWs_Opt_2kx01x0-16 10410025 357.0 ns/op 5780.80 MB/s Benchmark____GWs_Opt_2kx01x0-16 10410308 325.3 ns/op 6344.46 MB/s Benchmark____GWs_Opt_2kx01x0-16 10337616 352.0 ns/op 5862.84 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5959968 607.9 ns/op 6764.10 MB/s Benchmark____GWs_Opt_4kx01x0-16 5987318 606.2 ns/op 6783.61 MB/s Benchmark____GWs_Opt_4kx01x0-16 5854140 621.5 ns/op 6616.15 MB/s Benchmark____GWs_Opt_4kx01x0-16 5833304 599.9 ns/op 6854.77 MB/s Benchmark____GWs_Opt_4kx01x0-16 5388752 624.1 ns/op 6588.94 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28764870 113.3 ns/op 9181.95 MB/s Benchmark____GWs_Opt_1kx10x0-16 31364298 111.4 ns/op 9338.24 MB/s Benchmark____GWs_Opt_1kx10x0-16 29393347 113.4 ns/op 9174.80 MB/s Benchmark____GWs_Opt_1kx10x0-16 22867340 161.2 ns/op 6451.26 MB/s Benchmark____GWs_Opt_1kx10x0-16 30362846 108.7 ns/op 9570.67 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25840768 162.3 ns/op 12714.81 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:60312->127.0.0.1:33625: use of closed network connection --- FAIL: Benchmark____GWs_Opt_2kx10x0-16 Benchmark____GWs_Opt_2kx10x0-16 25684863 145.0 ns/op 14237.05 MB/s Benchmark____GWs_Opt_2kx10x0-16 25262924 145.7 ns/op 14170.14 MB/s Benchmark____GWs_Opt_2kx10x0-16 23802236 147.7 ns/op 13969.94 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12665174 312.9 ns/op 13142.58 MB/s Benchmark____GWs_Opt_4kx10x0-16 11648481 284.7 ns/op 14441.80 MB/s Benchmark____GWs_Opt_4kx10x0-16 10907892 420.5 ns/op 9778.95 MB/s Benchmark____GWs_Opt_4kx10x0-16 11078209 354.5 ns/op 11598.13 MB/s Benchmark____GWs_Opt_4kx10x0-16 11516204 322.0 ns/op 12768.65 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6540682 544.7 ns/op 5737.46 MB/s Benchmark____GWs_Opt_1kx01x1-16 6614826 542.9 ns/op 5755.62 MB/s Benchmark____GWs_Opt_1kx01x1-16 6384111 537.8 ns/op 5810.24 MB/s Benchmark____GWs_Opt_1kx01x1-16 6521077 542.5 ns/op 5760.15 MB/s Benchmark____GWs_Opt_1kx01x1-16 6590389 542.6 ns/op 5759.20 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4846826 774.4 ns/op 8002.28 MB/s Benchmark____GWs_Opt_2kx01x1-16 4761012 753.8 ns/op 8220.81 MB/s Benchmark____GWs_Opt_2kx01x1-16 4642549 1198 ns/op 5171.79 MB/s Benchmark____GWs_Opt_2kx01x1-16 4536471 760.3 ns/op 8150.71 MB/s Benchmark____GWs_Opt_2kx01x1-16 4819153 854.0 ns/op 7256.56 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2678036 2165 ns/op 5699.32 MB/s Benchmark____GWs_Opt_4kx01x1-16 2328592 1376 ns/op 8970.76 MB/s Benchmark____GWs_Opt_4kx01x1-16 2618550 1358 ns/op 9086.46 MB/s Benchmark____GWs_Opt_4kx01x1-16 2668484 1351 ns/op 9133.81 MB/s Benchmark____GWs_Opt_4kx01x1-16 2602182 2171 ns/op 5684.84 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6560992 552.7 ns/op 5654.53 MB/s Benchmark____GWs_Opt_1kx10x1-16 6091970 548.0 ns/op 5702.88 MB/s Benchmark____GWs_Opt_1kx10x1-16 6365974 559.6 ns/op 5583.92 MB/s Benchmark____GWs_Opt_1kx10x1-16 6457621 560.3 ns/op 5577.46 MB/s Benchmark____GWs_Opt_1kx10x1-16 6261247 549.4 ns/op 5687.58 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4088839 830.7 ns/op 7459.90 MB/s Benchmark____GWs_Opt_2kx10x1-16 4271193 838.9 ns/op 7386.62 MB/s Benchmark____GWs_Opt_2kx10x1-16 4029411 811.4 ns/op 7637.40 MB/s Benchmark____GWs_Opt_2kx10x1-16 4075275 841.2 ns/op 7366.48 MB/s Benchmark____GWs_Opt_2kx10x1-16 4250433 842.0 ns/op 7359.44 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2413688 1506 ns/op 8195.77 MB/s Benchmark____GWs_Opt_4kx10x1-16 1000000 3721 ns/op 3316.49 MB/s Benchmark____GWs_Opt_4kx10x1-16 2370397 1499 ns/op 8230.25 MB/s Benchmark____GWs_Opt_4kx10x1-16 2280386 1526 ns/op 8085.87 MB/s Benchmark____GWs_Opt_4kx10x1-16 2330344 1498 ns/op 8239.52 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12796998 300.2 ns/op 3463.99 MB/s Benchmark____GWs_Int_1kx01x0-16 11845003 289.7 ns/op 3590.13 MB/s Benchmark____GWs_Int_1kx01x0-16 12554200 288.2 ns/op 3608.84 MB/s Benchmark____GWs_Int_1kx01x0-16 11505230 295.6 ns/op 3518.39 MB/s Benchmark____GWs_Int_1kx01x0-16 11871326 291.0 ns/op 3574.27 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10119900 363.9 ns/op 5672.04 MB/s Benchmark____GWs_Int_2kx01x0-16 9981249 353.7 ns/op 5835.79 MB/s Benchmark____GWs_Int_2kx01x0-16 9077760 356.0 ns/op 5797.18 MB/s Benchmark____GWs_Int_2kx01x0-16 10144962 361.9 ns/op 5703.60 MB/s Benchmark____GWs_Int_2kx01x0-16 9966733 348.1 ns/op 5928.96 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5957220 634.5 ns/op 6480.89 MB/s Benchmark____GWs_Int_4kx01x0-16 5810643 640.2 ns/op 6423.35 MB/s Benchmark____GWs_Int_4kx01x0-16 5646504 628.8 ns/op 6539.58 MB/s Benchmark____GWs_Int_4kx01x0-16 5480212 622.8 ns/op 6602.52 MB/s Benchmark____GWs_Int_4kx01x0-16 5772666 634.9 ns/op 6477.07 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30873063 112.2 ns/op 9271.70 MB/s Benchmark____GWs_Int_1kx10x0-16 29486395 114.9 ns/op 9050.77 MB/s Benchmark____GWs_Int_1kx10x0-16 30552296 111.5 ns/op 9324.32 MB/s Benchmark____GWs_Int_1kx10x0-16 30980893 112.1 ns/op 9276.10 MB/s Benchmark____GWs_Int_1kx10x0-16 29947058 111.2 ns/op 9355.67 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25465892 147.3 ns/op 14015.24 MB/s Benchmark____GWs_Int_2kx10x0-16 25612777 137.4 ns/op 15021.41 MB/s Benchmark____GWs_Int_2kx10x0-16 25779616 139.5 ns/op 14799.30 MB/s Benchmark____GWs_Int_2kx10x0-16 25497312 146.0 ns/op 14136.70 MB/s Benchmark____GWs_Int_2kx10x0-16 25261346 139.5 ns/op 14796.61 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12524950 286.9 ns/op 14332.11 MB/s Benchmark____GWs_Int_4kx10x0-16 13374147 285.5 ns/op 14402.91 MB/s Benchmark____GWs_Int_4kx10x0-16 12501272 278.8 ns/op 14747.54 MB/s Benchmark____GWs_Int_4kx10x0-16 12850536 306.7 ns/op 13409.02 MB/s Benchmark____GWs_Int_4kx10x0-16 12516006 294.6 ns/op 13957.61 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6501476 660.0 ns/op 4734.65 MB/s Benchmark____GWs_Int_1kx01x1-16 6717039 565.5 ns/op 5525.99 MB/s Benchmark____GWs_Int_1kx01x1-16 6698252 553.4 ns/op 5647.25 MB/s Benchmark____GWs_Int_1kx01x1-16 6486916 550.4 ns/op 5677.81 MB/s Benchmark____GWs_Int_1kx01x1-16 6713065 557.2 ns/op 5608.81 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4693370 758.7 ns/op 8168.22 MB/s Benchmark____GWs_Int_2kx01x1-16 4715287 759.8 ns/op 8155.80 MB/s Benchmark____GWs_Int_2kx01x1-16 4747549 1155 ns/op 5365.00 MB/s Benchmark____GWs_Int_2kx01x1-16 4779885 766.5 ns/op 8085.19 MB/s Benchmark____GWs_Int_2kx01x1-16 4799086 745.8 ns/op 8309.38 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2637944 1363 ns/op 9056.17 MB/s Benchmark____GWs_Int_4kx01x1-16 2718529 1361 ns/op 9066.22 MB/s Benchmark____GWs_Int_4kx01x1-16 2282166 1357 ns/op 9093.98 MB/s Benchmark____GWs_Int_4kx01x1-16 2270224 1375 ns/op 8974.66 MB/s Benchmark____GWs_Int_4kx01x1-16 2257321 1568 ns/op 7870.31 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6481444 551.0 ns/op 5671.45 MB/s Benchmark____GWs_Int_1kx10x1-16 6650016 553.8 ns/op 5643.26 MB/s Benchmark____GWs_Int_1kx10x1-16 6131373 542.2 ns/op 5763.14 MB/s Benchmark____GWs_Int_1kx10x1-16 6501224 550.0 ns/op 5682.14 MB/s Benchmark____GWs_Int_1kx10x1-16 6524780 845.9 ns/op 3694.09 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4173543 849.8 ns/op 7292.40 MB/s Benchmark____GWs_Int_2kx10x1-16 3988779 840.2 ns/op 7375.21 MB/s Benchmark____GWs_Int_2kx10x1-16 3913300 837.1 ns/op 7403.01 MB/s Benchmark____GWs_Int_2kx10x1-16 4268346 827.7 ns/op 7486.56 MB/s Benchmark____GWs_Int_2kx10x1-16 4167548 837.9 ns/op 7396.07 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2183599 1517 ns/op 8135.32 MB/s Benchmark____GWs_Int_4kx10x1-16 2359592 1433 ns/op 8609.79 MB/s Benchmark____GWs_Int_4kx10x1-16 2126750 1527 ns/op 8083.67 MB/s Benchmark____GWs_Int_4kx10x1-16 2290284 1534 ns/op 8042.84 MB/s Benchmark____GWs_Int_4kx10x1-16 2312046 1552 ns/op 7951.50 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8380566 429.1 ns/op 237.69 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8378980 436.4 ns/op 233.75 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8354007 437.5 ns/op 233.12 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8312689 432.5 ns/op 235.83 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8048733 433.0 ns/op 235.57 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 621442 5070 ns/op 34.91 MB/s Benchmark__GWs_Reqs_1SubEach-16 806042 5228 ns/op 33.86 MB/s Benchmark__GWs_Reqs_1SubEach-16 771297 5309 ns/op 33.34 MB/s Benchmark__GWs_Reqs_1SubEach-16 740290 5243 ns/op 33.76 MB/s Benchmark__GWs_Reqs_1SubEach-16 708164 5330 ns/op 33.21 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2088.114s