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 49858152 72.25 ns/op 152.24 MB/s Benchmark______Pub0b_Payload-16 47093575 71.99 ns/op 152.79 MB/s Benchmark______Pub0b_Payload-16 47122050 72.45 ns/op 151.84 MB/s Benchmark______Pub0b_Payload-16 46946576 72.30 ns/op 152.14 MB/s Benchmark______Pub0b_Payload-16 46633538 72.20 ns/op 152.36 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46790522 73.76 ns/op 257.58 MB/s Benchmark______Pub8b_Payload-16 46336538 72.85 ns/op 260.80 MB/s Benchmark______Pub8b_Payload-16 46867156 72.78 ns/op 261.06 MB/s Benchmark______Pub8b_Payload-16 48828492 72.69 ns/op 261.39 MB/s Benchmark______Pub8b_Payload-16 46165484 72.62 ns/op 261.65 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44742110 76.59 ns/op 574.45 MB/s Benchmark_____Pub32b_Payload-16 46797236 79.35 ns/op 554.49 MB/s Benchmark_____Pub32b_Payload-16 46621965 76.15 ns/op 577.82 MB/s Benchmark_____Pub32b_Payload-16 44292802 76.39 ns/op 575.96 MB/s Benchmark_____Pub32b_Payload-16 47133927 76.34 ns/op 576.38 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 40034462 86.07 ns/op 1638.29 MB/s Benchmark____Pub128B_Payload-16 40123538 85.68 ns/op 1645.74 MB/s Benchmark____Pub128B_Payload-16 40116619 85.96 ns/op 1640.25 MB/s Benchmark____Pub128B_Payload-16 37637948 87.01 ns/op 1620.57 MB/s Benchmark____Pub128B_Payload-16 41053725 87.42 ns/op 1612.91 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35647068 94.30 ns/op 2852.64 MB/s Benchmark____Pub256B_Payload-16 31956559 94.80 ns/op 2837.59 MB/s Benchmark____Pub256B_Payload-16 35743269 95.79 ns/op 2808.23 MB/s Benchmark____Pub256B_Payload-16 31940743 94.60 ns/op 2843.67 MB/s Benchmark____Pub256B_Payload-16 38120865 99.92 ns/op 2692.13 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23864032 144.8 ns/op 7167.56 MB/s Benchmark______Pub1K_Payload-16 26468650 143.8 ns/op 7216.22 MB/s Benchmark______Pub1K_Payload-16 25951801 133.3 ns/op 7787.65 MB/s Benchmark______Pub1K_Payload-16 24550440 135.7 ns/op 7650.48 MB/s Benchmark______Pub1K_Payload-16 24464062 138.0 ns/op 7519.11 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5693364 633.8 ns/op 6484.99 MB/s Benchmark______Pub4K_Payload-16 5824680 615.9 ns/op 6673.18 MB/s Benchmark______Pub4K_Payload-16 5463560 630.5 ns/op 6518.27 MB/s Benchmark______Pub4K_Payload-16 5672686 627.2 ns/op 6553.33 MB/s Benchmark______Pub4K_Payload-16 5495924 620.1 ns/op 6628.05 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2771415 1272 ns/op 6449.32 MB/s Benchmark______Pub8K_Payload-16 2785263 1296 ns/op 6332.73 MB/s Benchmark______Pub8K_Payload-16 2766333 1280 ns/op 6412.22 MB/s Benchmark______Pub8K_Payload-16 2713706 1271 ns/op 6454.39 MB/s Benchmark______Pub8K_Payload-16 2684806 1263 ns/op 6495.40 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 673258 5762 ns/op 5689.62 MB/s Benchmark_____Pub32K_Payload-16 549276 5507 ns/op 5952.44 MB/s Benchmark_____Pub32K_Payload-16 667350 5401 ns/op 6069.44 MB/s Benchmark_____Pub32K_Payload-16 668269 5438 ns/op 6028.25 MB/s Benchmark_____Pub32K_Payload-16 660172 5594 ns/op 5860.82 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 33244432 92.47 ns/op 118.96 MB/s Benchmark__AuthPub0b_Payload-16 37015820 92.14 ns/op 119.38 MB/s Benchmark__AuthPub0b_Payload-16 35194992 92.52 ns/op 118.90 MB/s Benchmark__AuthPub0b_Payload-16 32636046 92.27 ns/op 119.21 MB/s Benchmark__AuthPub0b_Payload-16 37102987 92.87 ns/op 118.44 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15403929 230.0 ns/op Benchmark_____________PubSub-16 15503078 230.3 ns/op Benchmark_____________PubSub-16 15425490 230.3 ns/op Benchmark_____________PubSub-16 15320210 232.2 ns/op Benchmark_____________PubSub-16 15532701 230.4 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15621223 228.8 ns/op Benchmark_____PubSubTwoConns-16 15398728 229.0 ns/op Benchmark_____PubSubTwoConns-16 15474066 230.5 ns/op Benchmark_____PubSubTwoConns-16 15477265 229.1 ns/op Benchmark_____PubSubTwoConns-16 15381501 229.5 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:60136->127.0.0.1:44161: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:39202->127.0.0.1:45847: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57932->127.0.0.1:36787: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57124->127.0.0.1:38793: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34048->127.0.0.1:34757: 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 14253932 248.1 ns/op Benchmark_____PubTwoQueueSub-16 14316499 249.0 ns/op Benchmark_____PubTwoQueueSub-16 14302989 248.6 ns/op Benchmark_____PubTwoQueueSub-16 14230915 250.0 ns/op Benchmark_____PubTwoQueueSub-16 14250860 249.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14169674 249.6 ns/op Benchmark____PubFourQueueSub-16 14112074 249.3 ns/op Benchmark____PubFourQueueSub-16 14244072 248.9 ns/op Benchmark____PubFourQueueSub-16 14079093 248.5 ns/op Benchmark____PubFourQueueSub-16 14216680 248.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14247409 249.5 ns/op Benchmark___PubEightQueueSub-16 14175102 248.5 ns/op Benchmark___PubEightQueueSub-16 14088814 246.6 ns/op Benchmark___PubEightQueueSub-16 14165748 246.9 ns/op Benchmark___PubEightQueueSub-16 14228151 249.0 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23020 155129 ns/op Benchmark_PubSub512kTwoConns-16 23301 155767 ns/op Benchmark_PubSub512kTwoConns-16 23167 155572 ns/op Benchmark_PubSub512kTwoConns-16 23270 155362 ns/op Benchmark_PubSub512kTwoConns-16 23042 154552 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14929351 231.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15019219 232.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15078862 232.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15301918 233.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15033321 232.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15138614 232.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 14948151 232.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 14896142 234.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15223387 232.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15114787 232.5 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11692520 315.3 ns/op Benchmark____RoutedPubSub_0b-16 11551666 317.0 ns/op Benchmark____RoutedPubSub_0b-16 11021308 315.4 ns/op Benchmark____RoutedPubSub_0b-16 11190156 315.7 ns/op Benchmark____RoutedPubSub_0b-16 11277960 315.2 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6520173 544.1 ns/op Benchmark____RoutedPubSub_1K-16 6560329 544.8 ns/op Benchmark____RoutedPubSub_1K-16 6704340 541.9 ns/op Benchmark____RoutedPubSub_1K-16 6517285 539.1 ns/op Benchmark____RoutedPubSub_1K-16 6510344 539.7 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84501 42357 ns/op Benchmark__RoutedPubSub_100K-16 84093 44675 ns/op Benchmark__RoutedPubSub_100K-16 68043 50483 ns/op Benchmark__RoutedPubSub_100K-16 79776 50759 ns/op Benchmark__RoutedPubSub_100K-16 69974 50015 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9611902 324.5 ns/op Benchmark____Routed2QueueSub-16 9628174 329.1 ns/op Benchmark____Routed2QueueSub-16 9478176 321.1 ns/op Benchmark____Routed2QueueSub-16 9244647 326.5 ns/op Benchmark____Routed2QueueSub-16 9829356 320.8 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9513753 326.9 ns/op Benchmark____Routed4QueueSub-16 9433318 326.0 ns/op Benchmark____Routed4QueueSub-16 9638703 332.0 ns/op Benchmark____Routed4QueueSub-16 9327283 324.4 ns/op Benchmark____Routed4QueueSub-16 9541497 324.7 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9336403 324.4 ns/op Benchmark____Routed8QueueSub-16 9341608 330.7 ns/op Benchmark____Routed8QueueSub-16 9115586 330.5 ns/op Benchmark____Routed8QueueSub-16 9370324 329.2 ns/op Benchmark____Routed8QueueSub-16 9208960 338.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8688122 352.5 ns/op Benchmark___Routed16QueueSub-16 8799529 356.2 ns/op Benchmark___Routed16QueueSub-16 8743933 358.1 ns/op Benchmark___Routed16QueueSub-16 8651079 348.3 ns/op Benchmark___Routed16QueueSub-16 8829078 352.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6425744 550.7 ns/op Benchmark____________RouteCompressOff-16 6383936 547.2 ns/op Benchmark____________RouteCompressOff-16 6497540 550.5 ns/op Benchmark____________RouteCompressOff-16 6485017 548.9 ns/op Benchmark____________RouteCompressOff-16 6401262 543.8 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6506430 551.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6482980 549.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6442411 548.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6502327 545.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6324544 557.4 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6378712 546.5 ns/op Benchmark_________RouteCompressS2Fast-16 6411010 551.9 ns/op Benchmark_________RouteCompressS2Fast-16 6536066 547.1 ns/op Benchmark_________RouteCompressS2Fast-16 6345016 546.8 ns/op Benchmark_________RouteCompressS2Fast-16 6324375 548.0 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6579591 556.1 ns/op Benchmark_______RouteCompressS2Better-16 6592224 548.3 ns/op Benchmark_______RouteCompressS2Better-16 6222267 545.3 ns/op Benchmark_______RouteCompressS2Better-16 6387483 559.1 ns/op Benchmark_______RouteCompressS2Better-16 6438790 548.7 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6412066 549.0 ns/op Benchmark_________RouteCompressS2Best-16 6387432 553.7 ns/op Benchmark_________RouteCompressS2Best-16 6423211 553.5 ns/op Benchmark_________RouteCompressS2Best-16 6438682 547.9 ns/op Benchmark_________RouteCompressS2Best-16 6389431 553.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4620597 790.2 ns/op 315.12 MB/s Benchmark______FanOut_8x1x10-16 4608368 778.9 ns/op 319.67 MB/s Benchmark______FanOut_8x1x10-16 4601119 777.5 ns/op 320.24 MB/s Benchmark______FanOut_8x1x10-16 4600812 775.8 ns/op 320.96 MB/s Benchmark______FanOut_8x1x10-16 4617307 785.7 ns/op 316.91 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 522428 6311 ns/op 367.46 MB/s Benchmark_____FanOut_8x1x100-16 545563 6171 ns/op 375.78 MB/s Benchmark_____FanOut_8x1x100-16 548970 6214 ns/op 373.21 MB/s Benchmark_____FanOut_8x1x100-16 543536 6297 ns/op 368.26 MB/s Benchmark_____FanOut_8x1x100-16 543975 6306 ns/op 367.74 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47022 76190 ns/op 302.13 MB/s Benchmark____FanOut_8x10x100-16 46932 77247 ns/op 297.99 MB/s Benchmark____FanOut_8x10x100-16 46938 76492 ns/op 300.93 MB/s Benchmark____FanOut_8x10x100-16 46387 76418 ns/op 301.22 MB/s Benchmark____FanOut_8x10x100-16 46812 77316 ns/op 297.73 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5616 619340 ns/op 387.54 MB/s Benchmark___FanOut_8x10x1000-16 5523 619728 ns/op 387.30 MB/s Benchmark___FanOut_8x10x1000-16 5479 632312 ns/op 379.59 MB/s Benchmark___FanOut_8x10x1000-16 5461 615789 ns/op 389.77 MB/s Benchmark___FanOut_8x10x1000-16 5570 625862 ns/op 383.50 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4885 729749 ns/op 315.20 MB/s Benchmark___FanOut_8x100x100-16 4851 732089 ns/op 314.20 MB/s Benchmark___FanOut_8x100x100-16 4803 731720 ns/op 314.35 MB/s Benchmark___FanOut_8x100x100-16 4831 743308 ns/op 309.45 MB/s Benchmark___FanOut_8x100x100-16 4810 730456 ns/op 314.90 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 548 6532146 ns/op 367.42 MB/s Benchmark__FanOut_8x100x1000-16 550 6473318 ns/op 370.76 MB/s Benchmark__FanOut_8x100x1000-16 548 6485175 ns/op 370.08 MB/s Benchmark__FanOut_8x100x1000-16 549 6529025 ns/op 367.59 MB/s Benchmark__FanOut_8x100x1000-16 550 6564810 ns/op 365.59 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 516 7090949 ns/op 352.56 MB/s Benchmark__FanOut_8x10x10000-16 499 6972362 ns/op 358.56 MB/s Benchmark__FanOut_8x10x10000-16 519 6964516 ns/op 358.97 MB/s Benchmark__FanOut_8x10x10000-16 522 6933303 ns/op 360.58 MB/s Benchmark__FanOut_8x10x10000-16 514 7024261 ns/op 355.91 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 922 3870378 ns/op 297.13 MB/s Benchmark___FanOut_8x500x100-16 934 3855424 ns/op 298.29 MB/s Benchmark___FanOut_8x500x100-16 922 3849838 ns/op 298.72 MB/s Benchmark___FanOut_8x500x100-16 927 3856306 ns/op 298.22 MB/s Benchmark___FanOut_8x500x100-16 916 3869587 ns/op 297.19 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 355360 9664 ns/op 1514.93 MB/s Benchmark___FanOut_128x1x100-16 348812 9633 ns/op 1519.88 MB/s Benchmark___FanOut_128x1x100-16 358172 9622 ns/op 1521.59 MB/s Benchmark___FanOut_128x1x100-16 353336 9623 ns/op 1521.46 MB/s Benchmark___FanOut_128x1x100-16 363139 9653 ns/op 1516.77 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32085 112572 ns/op 1289.32 MB/s Benchmark__FanOut_128x10x100-16 31731 112915 ns/op 1285.41 MB/s Benchmark__FanOut_128x10x100-16 31695 113141 ns/op 1282.83 MB/s Benchmark__FanOut_128x10x100-16 32001 112921 ns/op 1285.34 MB/s Benchmark__FanOut_128x10x100-16 31990 113017 ns/op 1284.24 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3921 905154 ns/op 1613.14 MB/s Benchmark_FanOut_128x10x1000-16 3741 905406 ns/op 1612.69 MB/s Benchmark_FanOut_128x10x1000-16 3944 902087 ns/op 1618.63 MB/s Benchmark_FanOut_128x10x1000-16 3960 908729 ns/op 1606.80 MB/s Benchmark_FanOut_128x10x1000-16 4048 905382 ns/op 1612.73 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3400 1038810 ns/op 1395.96 MB/s Benchmark_FanOut_128x100x100-16 3374 1040195 ns/op 1394.10 MB/s Benchmark_FanOut_128x100x100-16 3345 1031896 ns/op 1405.32 MB/s Benchmark_FanOut_128x100x100-16 3409 1034386 ns/op 1401.93 MB/s Benchmark_FanOut_128x100x100-16 3384 1040866 ns/op 1393.21 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 370 9633735 ns/op 1515.52 MB/s BenchmarkFanOut_128x100x1000-16 370 9693523 ns/op 1506.17 MB/s BenchmarkFanOut_128x100x1000-16 373 9817308 ns/op 1487.18 MB/s BenchmarkFanOut_128x100x1000-16 369 9714383 ns/op 1502.94 MB/s BenchmarkFanOut_128x100x1000-16 368 9789082 ns/op 1491.47 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 357 9913624 ns/op 1482.82 MB/s BenchmarkFanOut_128x10x10000-16 366 9967818 ns/op 1474.76 MB/s BenchmarkFanOut_128x10x10000-16 360 10012452 ns/op 1468.19 MB/s BenchmarkFanOut_128x10x10000-16 363 9951710 ns/op 1477.15 MB/s BenchmarkFanOut_128x10x10000-16 362 9926806 ns/op 1480.85 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 661 5367071 ns/op 1350.86 MB/s BenchmarkFanOut__128x500x100-16 657 5369446 ns/op 1350.26 MB/s BenchmarkFanOut__128x500x100-16 658 5371177 ns/op 1349.82 MB/s BenchmarkFanOut__128x500x100-16 655 5355217 ns/op 1353.85 MB/s BenchmarkFanOut__128x500x100-16 656 5362631 ns/op 1351.97 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1903 1868885 ns/op 2830.85 MB/s Benchmark_FanOut_512x100x100-16 1893 1878773 ns/op 2815.95 MB/s Benchmark_FanOut_512x100x100-16 1910 1876487 ns/op 2819.38 MB/s Benchmark_FanOut_512x100x100-16 1914 1871800 ns/op 2826.44 MB/s Benchmark_FanOut_512x100x100-16 1905 1871737 ns/op 2826.53 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 210 17113486 ns/op 3097.00 MB/s Benchmark__FanOut_512x100x1k-16 212 17249801 ns/op 3072.53 MB/s Benchmark__FanOut_512x100x1k-16 213 17006634 ns/op 3116.46 MB/s Benchmark__FanOut_512x100x1k-16 208 17091752 ns/op 3100.94 MB/s Benchmark__FanOut_512x100x1k-16 210 17048132 ns/op 3108.88 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2952 1187038 ns/op 8787.45 MB/s Benchmark____FanOut_1kx10x1k-16 3140 1171883 ns/op 8901.09 MB/s Benchmark____FanOut_1kx10x1k-16 3048 1166345 ns/op 8943.35 MB/s Benchmark____FanOut_1kx10x1k-16 3171 1152005 ns/op 9054.68 MB/s Benchmark____FanOut_1kx10x1k-16 2853 1186971 ns/op 8787.94 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2742 1281456 ns/op 8132.19 MB/s Benchmark__FanOut_1kx100x100-16 2788 1270146 ns/op 8204.60 MB/s Benchmark__FanOut_1kx100x100-16 2726 1278490 ns/op 8151.05 MB/s Benchmark__FanOut_1kx100x100-16 2731 1279322 ns/op 8145.75 MB/s Benchmark__FanOut_1kx100x100-16 2734 1278678 ns/op 8149.85 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4419987 794.6 ns/op 313.38 MB/s Benchmark_____RFanOut_8x1x10-16 4377369 798.5 ns/op 311.82 MB/s Benchmark_____RFanOut_8x1x10-16 4325220 807.8 ns/op 308.26 MB/s Benchmark_____RFanOut_8x1x10-16 4359862 791.0 ns/op 314.79 MB/s Benchmark_____RFanOut_8x1x10-16 4464667 792.0 ns/op 314.38 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 553804 7001 ns/op 331.26 MB/s Benchmark____RFanOut_8x1x100-16 533491 6271 ns/op 369.81 MB/s Benchmark____RFanOut_8x1x100-16 544856 6461 ns/op 358.94 MB/s Benchmark____RFanOut_8x1x100-16 505556 6303 ns/op 367.89 MB/s Benchmark____RFanOut_8x1x100-16 511629 6408 ns/op 361.90 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46152 77621 ns/op 296.56 MB/s Benchmark___RFanOut_8x10x100-16 46309 78031 ns/op 295.00 MB/s Benchmark___RFanOut_8x10x100-16 47032 76558 ns/op 300.67 MB/s Benchmark___RFanOut_8x10x100-16 46624 77653 ns/op 296.44 MB/s Benchmark___RFanOut_8x10x100-16 46192 77566 ns/op 296.77 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5505 626909 ns/op 382.86 MB/s Benchmark__RFanOut_8x10x1000-16 5721 641547 ns/op 374.13 MB/s Benchmark__RFanOut_8x10x1000-16 5542 634789 ns/op 378.11 MB/s Benchmark__RFanOut_8x10x1000-16 5665 626046 ns/op 383.39 MB/s Benchmark__RFanOut_8x10x1000-16 5416 623807 ns/op 384.76 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4896 731387 ns/op 314.50 MB/s Benchmark__RFanOut_8x100x100-16 4846 720972 ns/op 319.04 MB/s Benchmark__RFanOut_8x100x100-16 4791 736239 ns/op 312.42 MB/s Benchmark__RFanOut_8x100x100-16 4828 725748 ns/op 316.94 MB/s Benchmark__RFanOut_8x100x100-16 4813 731861 ns/op 314.29 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 541 6477295 ns/op 370.53 MB/s Benchmark_RFanOut_8x100x1000-16 537 6441293 ns/op 372.60 MB/s Benchmark_RFanOut_8x100x1000-16 547 6460213 ns/op 371.51 MB/s Benchmark_RFanOut_8x100x1000-16 538 6416433 ns/op 374.04 MB/s Benchmark_RFanOut_8x100x1000-16 547 6595922 ns/op 363.86 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 523 6908671 ns/op 361.87 MB/s Benchmark_RFanOut_8x10x10000-16 508 6924606 ns/op 361.03 MB/s Benchmark_RFanOut_8x10x10000-16 507 7170512 ns/op 348.65 MB/s Benchmark_RFanOut_8x10x10000-16 514 6936147 ns/op 360.43 MB/s Benchmark_RFanOut_8x10x10000-16 504 7005564 ns/op 356.86 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3051 1176691 ns/op 8864.72 MB/s Benchmark_RFanOut_1kx10x1000-16 3001 1158931 ns/op 9000.57 MB/s Benchmark_RFanOut_1kx10x1000-16 3081 1165544 ns/op 8949.50 MB/s Benchmark_RFanOut_1kx10x1000-16 3007 1169495 ns/op 8919.27 MB/s Benchmark_RFanOut_1kx10x1000-16 3132 1150003 ns/op 9070.44 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6953818 513.0 ns/op 4050.78 MB/s Benchmark_____FanIn_1kx100x1-16 6895444 511.1 ns/op 4066.06 MB/s Benchmark_____FanIn_1kx100x1-16 6900955 511.6 ns/op 4062.01 MB/s Benchmark_____FanIn_1kx100x1-16 6820700 527.3 ns/op 3940.88 MB/s Benchmark_____FanIn_1kx100x1-16 6920276 513.3 ns/op 4048.67 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2623939 1375 ns/op 5981.68 MB/s Benchmark_____FanIn_4kx100x1-16 2638704 1366 ns/op 6020.57 MB/s Benchmark_____FanIn_4kx100x1-16 2630036 1384 ns/op 5939.87 MB/s Benchmark_____FanIn_4kx100x1-16 2652007 1363 ns/op 6031.63 MB/s Benchmark_____FanIn_4kx100x1-16 2629154 1388 ns/op 5921.97 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1710686 2123 ns/op 7732.64 MB/s Benchmark_____FanIn_8kx100x1-16 1699770 2145 ns/op 7650.67 MB/s Benchmark_____FanIn_8kx100x1-16 1696903 2147 ns/op 7644.11 MB/s Benchmark_____FanIn_8kx100x1-16 1723728 2090 ns/op 7851.73 MB/s Benchmark_____FanIn_8kx100x1-16 1678094 2101 ns/op 7812.73 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 866442 4139 ns/op 7925.14 MB/s Benchmark____FanIn_16kx100x1-16 875331 4123 ns/op 7954.48 MB/s Benchmark____FanIn_16kx100x1-16 876873 4110 ns/op 7980.41 MB/s Benchmark____FanIn_16kx100x1-16 871893 4142 ns/op 7919.22 MB/s Benchmark____FanIn_16kx100x1-16 855325 4146 ns/op 7911.95 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 168993 19902 ns/op 6587.57 MB/s Benchmark____FanIn_64kx100x1-16 169437 20104 ns/op 6521.38 MB/s Benchmark____FanIn_64kx100x1-16 166209 19914 ns/op 6583.66 MB/s Benchmark____FanIn_64kx100x1-16 181453 19967 ns/op 6566.17 MB/s Benchmark____FanIn_64kx100x1-16 163011 20374 ns/op 6434.78 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 194930830 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52994->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52932->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52290->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52350->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:52330->127.0.0.1:5222: write: broken pipe bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1723964590 vs 11535920000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34558->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35052->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: 858115140 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36682->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: 885906220 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38596->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:38520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38500->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: 873714850 vs 11496593000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41054->127.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:40674->127.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:41516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40690->127.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: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: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:40898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41130->127.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:40788->127.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:40870->127.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:41014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41190->127.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: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: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:41044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41444->127.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:40642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40978->127.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: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:41188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40672->127.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:40982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41228->127.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:41536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41422->127.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:41292->127.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: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:41290->127.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:41148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41332->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5441158 654.3 ns/op 434.04 MB/s Benchmark___BumpPubCount_1x3-16 5477235 652.6 ns/op 435.16 MB/s Benchmark___BumpPubCount_1x3-16 5493765 650.8 ns/op 436.36 MB/s Benchmark___BumpPubCount_1x3-16 5505474 656.5 ns/op 432.58 MB/s Benchmark___BumpPubCount_1x3-16 5493885 653.4 ns/op 434.67 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5158701 680.8 ns/op 417.17 MB/s Benchmark___BumpPubCount_2x3-16 5215995 687.0 ns/op 413.39 MB/s Benchmark___BumpPubCount_2x3-16 5212663 690.8 ns/op 411.15 MB/s Benchmark___BumpPubCount_2x3-16 5129278 684.2 ns/op 415.11 MB/s Benchmark___BumpPubCount_2x3-16 5223634 690.5 ns/op 411.28 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5487855 652.2 ns/op 435.43 MB/s Benchmark___BumpPubCount_5x3-16 5473898 653.6 ns/op 434.55 MB/s Benchmark___BumpPubCount_5x3-16 5406380 651.8 ns/op 435.71 MB/s Benchmark___BumpPubCount_5x3-16 5357571 653.6 ns/op 434.54 MB/s Benchmark___BumpPubCount_5x3-16 5171136 659.2 ns/op 430.80 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5510900 655.4 ns/op 433.32 MB/s Benchmark__BumpPubCount_10x3-16 5453812 648.3 ns/op 438.06 MB/s Benchmark__BumpPubCount_10x3-16 5496922 651.3 ns/op 436.08 MB/s Benchmark__BumpPubCount_10x3-16 5512620 655.1 ns/op 433.53 MB/s Benchmark__BumpPubCount_10x3-16 5478237 654.2 ns/op 434.12 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11920471 274.5 ns/op 3788.05 MB/s Benchmark____GWs_Opt_1kx01x0-16 13137837 272.9 ns/op 3810.71 MB/s Benchmark____GWs_Opt_1kx01x0-16 12469614 278.1 ns/op 3739.81 MB/s Benchmark____GWs_Opt_1kx01x0-16 12527373 274.7 ns/op 3786.18 MB/s Benchmark____GWs_Opt_1kx01x0-16 12725636 271.5 ns/op 3830.80 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10441580 348.8 ns/op 5916.66 MB/s Benchmark____GWs_Opt_2kx01x0-16 10282390 350.8 ns/op 5883.48 MB/s Benchmark____GWs_Opt_2kx01x0-16 9916600 337.7 ns/op 6111.51 MB/s Benchmark____GWs_Opt_2kx01x0-16 10693192 349.1 ns/op 5913.15 MB/s Benchmark____GWs_Opt_2kx01x0-16 10580815 348.1 ns/op 5929.75 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5610813 631.0 ns/op 6517.01 MB/s Benchmark____GWs_Opt_4kx01x0-16 5575099 633.0 ns/op 6496.17 MB/s Benchmark____GWs_Opt_4kx01x0-16 5583304 613.3 ns/op 6704.40 MB/s Benchmark____GWs_Opt_4kx01x0-16 5767234 633.1 ns/op 6495.16 MB/s Benchmark____GWs_Opt_4kx01x0-16 5353621 636.8 ns/op 6457.75 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30217863 112.0 ns/op 9283.23 MB/s Benchmark____GWs_Opt_1kx10x0-16 30830248 107.3 ns/op 9694.91 MB/s Benchmark____GWs_Opt_1kx10x0-16 30858974 110.3 ns/op 9427.00 MB/s Benchmark____GWs_Opt_1kx10x0-16 32178991 110.2 ns/op 9436.08 MB/s Benchmark____GWs_Opt_1kx10x0-16 31836092 111.9 ns/op 9297.08 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 20755993 144.8 ns/op 14250.15 MB/s Benchmark____GWs_Opt_2kx10x0-16 24815037 147.8 ns/op 13964.71 MB/s Benchmark____GWs_Opt_2kx10x0-16 26212620 138.7 ns/op 14882.69 MB/s Benchmark____GWs_Opt_2kx10x0-16 20223835 176.2 ns/op 11714.22 MB/s Benchmark____GWs_Opt_2kx10x0-16 24356722 175.1 ns/op 11786.92 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11663108 312.2 ns/op 13172.81 MB/s Benchmark____GWs_Opt_4kx10x0-16 10380406 699.0 ns/op 5882.42 MB/s Benchmark____GWs_Opt_4kx10x0-16 11627552 315.0 ns/op 13055.34 MB/s Benchmark____GWs_Opt_4kx10x0-16 10997973 333.4 ns/op 12333.82 MB/s Benchmark____GWs_Opt_4kx10x0-16 8554759 395.5 ns/op 10398.09 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6585890 554.5 ns/op 5635.95 MB/s Benchmark____GWs_Opt_1kx01x1-16 6451635 546.0 ns/op 5723.41 MB/s Benchmark____GWs_Opt_1kx01x1-16 6498278 548.0 ns/op 5702.84 MB/s Benchmark____GWs_Opt_1kx01x1-16 6391350 1072 ns/op 2914.45 MB/s Benchmark____GWs_Opt_1kx01x1-16 6616860 550.2 ns/op 5679.80 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4513128 761.3 ns/op 8139.94 MB/s Benchmark____GWs_Opt_2kx01x1-16 4651714 768.5 ns/op 8064.20 MB/s Benchmark____GWs_Opt_2kx01x1-16 4757938 766.3 ns/op 8086.76 MB/s Benchmark____GWs_Opt_2kx01x1-16 4780416 766.7 ns/op 8082.37 MB/s Benchmark____GWs_Opt_2kx01x1-16 4664954 768.7 ns/op 8061.72 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2570143 1368 ns/op 9022.04 MB/s Benchmark____GWs_Opt_4kx01x1-16 2625604 1369 ns/op 9013.22 MB/s Benchmark____GWs_Opt_4kx01x1-16 2601340 1506 ns/op 8194.71 MB/s Benchmark____GWs_Opt_4kx01x1-16 2572213 1628 ns/op 7580.24 MB/s Benchmark____GWs_Opt_4kx01x1-16 2607980 1376 ns/op 8969.45 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5934350 589.6 ns/op 5299.99 MB/s Benchmark____GWs_Opt_1kx10x1-16 6013255 560.7 ns/op 5573.08 MB/s Benchmark____GWs_Opt_1kx10x1-16 6163981 563.6 ns/op 5544.92 MB/s Benchmark____GWs_Opt_1kx10x1-16 6221924 562.5 ns/op 5555.36 MB/s Benchmark____GWs_Opt_1kx10x1-16 6106140 563.9 ns/op 5542.04 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4156905 857.5 ns/op 7227.07 MB/s Benchmark____GWs_Opt_2kx10x1-16 4015158 853.6 ns/op 7259.82 MB/s Benchmark____GWs_Opt_2kx10x1-16 4016066 853.0 ns/op 7264.91 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:36366->127.0.0.1:44161: use of closed network connection --- FAIL: Benchmark____GWs_Opt_2kx10x1-16 Benchmark____GWs_Opt_2kx10x1-16 4034094 853.7 ns/op 7258.98 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2315160 1523 ns/op 8102.15 MB/s Benchmark____GWs_Opt_4kx10x1-16 2346314 1550 ns/op 7962.15 MB/s Benchmark____GWs_Opt_4kx10x1-16 2422629 1521 ns/op 8114.34 MB/s Benchmark____GWs_Opt_4kx10x1-16 2327354 1565 ns/op 7884.76 MB/s Benchmark____GWs_Opt_4kx10x1-16 2371225 1596 ns/op 7730.88 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11968498 283.8 ns/op 3665.13 MB/s Benchmark____GWs_Int_1kx01x0-16 12597326 289.7 ns/op 3590.07 MB/s Benchmark____GWs_Int_1kx01x0-16 12045457 287.0 ns/op 3624.25 MB/s Benchmark____GWs_Int_1kx01x0-16 12557670 298.3 ns/op 3486.20 MB/s Benchmark____GWs_Int_1kx01x0-16 12430677 280.6 ns/op 3705.77 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10175697 367.2 ns/op 5621.10 MB/s Benchmark____GWs_Int_2kx01x0-16 9528666 336.8 ns/op 6129.05 MB/s Benchmark____GWs_Int_2kx01x0-16 9259297 358.2 ns/op 5762.66 MB/s Benchmark____GWs_Int_2kx01x0-16 10013404 366.1 ns/op 5637.65 MB/s Benchmark____GWs_Int_2kx01x0-16 10324118 354.7 ns/op 5819.71 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5638038 632.1 ns/op 6504.88 MB/s Benchmark____GWs_Int_4kx01x0-16 5608353 646.1 ns/op 6364.24 MB/s Benchmark____GWs_Int_4kx01x0-16 5527544 638.9 ns/op 6435.75 MB/s Benchmark____GWs_Int_4kx01x0-16 5474025 629.5 ns/op 6532.54 MB/s Benchmark____GWs_Int_4kx01x0-16 5780887 649.5 ns/op 6330.77 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 28890031 113.1 ns/op 9197.12 MB/s Benchmark____GWs_Int_1kx10x0-16 31671630 117.4 ns/op 8854.96 MB/s Benchmark____GWs_Int_1kx10x0-16 31893235 114.7 ns/op 9070.94 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:35828->127.0.0.1:46807: use of closed network connection --- FAIL: Benchmark____GWs_Int_1kx10x0-16 Benchmark____GWs_Int_1kx10x0-16 31902468 112.9 ns/op 9208.46 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24255890 147.0 ns/op 14040.58 MB/s Benchmark____GWs_Int_2kx10x0-16 25775912 141.2 ns/op 14612.47 MB/s Benchmark____GWs_Int_2kx10x0-16 25340978 142.3 ns/op 14505.71 MB/s Benchmark____GWs_Int_2kx10x0-16 25187587 138.3 ns/op 14928.82 MB/s Benchmark____GWs_Int_2kx10x0-16 25949220 145.9 ns/op 14149.64 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 10241030 300.2 ns/op 13699.53 MB/s Benchmark____GWs_Int_4kx10x0-16 10920758 285.1 ns/op 14423.13 MB/s Benchmark____GWs_Int_4kx10x0-16 12628376 330.5 ns/op 12443.18 MB/s Benchmark____GWs_Int_4kx10x0-16 10382378 380.7 ns/op 10800.26 MB/s Benchmark____GWs_Int_4kx10x0-16 13065628 294.8 ns/op 13947.89 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6234249 565.1 ns/op 5529.78 MB/s Benchmark____GWs_Int_1kx01x1-16 6479923 561.2 ns/op 5568.35 MB/s Benchmark____GWs_Int_1kx01x1-16 6336855 568.8 ns/op 5494.04 MB/s Benchmark____GWs_Int_1kx01x1-16 6674384 558.8 ns/op 5592.56 MB/s Benchmark____GWs_Int_1kx01x1-16 6310747 955.0 ns/op 3272.26 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4617441 769.8 ns/op 8050.39 MB/s Benchmark____GWs_Int_2kx01x1-16 4112251 776.6 ns/op 7979.45 MB/s Benchmark____GWs_Int_2kx01x1-16 4733054 788.2 ns/op 7862.06 MB/s Benchmark____GWs_Int_2kx01x1-16 4333034 785.7 ns/op 7886.76 MB/s Benchmark____GWs_Int_2kx01x1-16 4529646 804.2 ns/op 7705.74 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2586561 1552 ns/op 7949.37 MB/s Benchmark____GWs_Int_4kx01x1-16 2250177 1375 ns/op 8975.49 MB/s Benchmark____GWs_Int_4kx01x1-16 2620893 1390 ns/op 8881.53 MB/s Benchmark____GWs_Int_4kx01x1-16 2624878 1426 ns/op 8656.16 MB/s Benchmark____GWs_Int_4kx01x1-16 2526765 1387 ns/op 8894.89 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 5964846 558.9 ns/op 5591.39 MB/s Benchmark____GWs_Int_1kx10x1-16 6170422 568.0 ns/op 5501.29 MB/s Benchmark____GWs_Int_1kx10x1-16 6124107 559.0 ns/op 5590.55 MB/s Benchmark____GWs_Int_1kx10x1-16 6528548 557.2 ns/op 5608.44 MB/s Benchmark____GWs_Int_1kx10x1-16 6564026 568.1 ns/op 5500.96 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4103043 853.9 ns/op 7256.93 MB/s Benchmark____GWs_Int_2kx10x1-16 4098946 848.0 ns/op 7307.78 MB/s Benchmark____GWs_Int_2kx10x1-16 4071939 861.0 ns/op 7197.08 MB/s Benchmark____GWs_Int_2kx10x1-16 4216413 849.4 ns/op 7296.09 MB/s Benchmark____GWs_Int_2kx10x1-16 4243893 860.3 ns/op 7202.98 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2276349 1535 ns/op 8041.29 MB/s Benchmark____GWs_Int_4kx10x1-16 2147827 1550 ns/op 7963.80 MB/s Benchmark____GWs_Int_4kx10x1-16 2231432 3603 ns/op 3425.08 MB/s Benchmark____GWs_Int_4kx10x1-16 2236971 1535 ns/op 8038.85 MB/s Benchmark____GWs_Int_4kx10x1-16 2359033 1510 ns/op 8171.81 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8411884 440.6 ns/op 231.52 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8030374 444.7 ns/op 229.35 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7935600 446.3 ns/op 228.55 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8100783 440.1 ns/op 231.78 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8113100 450.9 ns/op 226.20 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 618908 5003 ns/op 35.38 MB/s Benchmark__GWs_Reqs_1SubEach-16 782194 5251 ns/op 33.71 MB/s Benchmark__GWs_Reqs_1SubEach-16 716418 5237 ns/op 33.80 MB/s Benchmark__GWs_Reqs_1SubEach-16 713054 5241 ns/op 33.77 MB/s Benchmark__GWs_Reqs_1SubEach-16 741571 5298 ns/op 33.41 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2098.734s