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 40521823 75.81 ns/op 145.09 MB/s Benchmark______Pub0b_Payload-16 41911591 71.76 ns/op 153.29 MB/s Benchmark______Pub0b_Payload-16 47620586 71.65 ns/op 153.53 MB/s Benchmark______Pub0b_Payload-16 47276761 71.64 ns/op 153.55 MB/s Benchmark______Pub0b_Payload-16 47615144 72.56 ns/op 151.61 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 49832284 72.81 ns/op 260.96 MB/s Benchmark______Pub8b_Payload-16 44175121 72.42 ns/op 262.36 MB/s Benchmark______Pub8b_Payload-16 46883082 72.44 ns/op 262.27 MB/s Benchmark______Pub8b_Payload-16 45458259 72.37 ns/op 262.53 MB/s Benchmark______Pub8b_Payload-16 47072346 72.75 ns/op 261.16 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44236737 76.92 ns/op 572.03 MB/s Benchmark_____Pub32b_Payload-16 44336536 76.93 ns/op 571.98 MB/s Benchmark_____Pub32b_Payload-16 43990512 76.96 ns/op 571.74 MB/s Benchmark_____Pub32b_Payload-16 46548013 77.12 ns/op 570.53 MB/s Benchmark_____Pub32b_Payload-16 44141575 76.93 ns/op 571.94 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39284126 86.85 ns/op 1623.55 MB/s Benchmark____Pub128B_Payload-16 39554308 86.57 ns/op 1628.79 MB/s Benchmark____Pub128B_Payload-16 39730863 87.31 ns/op 1615.02 MB/s Benchmark____Pub128B_Payload-16 38462935 87.15 ns/op 1617.84 MB/s Benchmark____Pub128B_Payload-16 35141902 87.17 ns/op 1617.56 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 29698821 108.5 ns/op 2478.91 MB/s Benchmark____Pub256B_Payload-16 36509772 97.16 ns/op 2768.57 MB/s Benchmark____Pub256B_Payload-16 32069083 102.7 ns/op 2619.24 MB/s Benchmark____Pub256B_Payload-16 37805146 95.66 ns/op 2811.95 MB/s Benchmark____Pub256B_Payload-16 36158719 96.61 ns/op 2784.44 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23501950 137.5 ns/op 7548.31 MB/s Benchmark______Pub1K_Payload-16 25719145 140.5 ns/op 7390.39 MB/s Benchmark______Pub1K_Payload-16 20557491 163.6 ns/op 6342.94 MB/s Benchmark______Pub1K_Payload-16 23503755 150.8 ns/op 6885.18 MB/s Benchmark______Pub1K_Payload-16 24936819 139.7 ns/op 7431.69 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5669412 621.3 ns/op 6615.36 MB/s Benchmark______Pub4K_Payload-16 5570857 616.1 ns/op 6671.16 MB/s Benchmark______Pub4K_Payload-16 5782732 623.6 ns/op 6590.67 MB/s Benchmark______Pub4K_Payload-16 5576344 630.9 ns/op 6514.49 MB/s Benchmark______Pub4K_Payload-16 5690281 616.7 ns/op 6664.42 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2757074 1286 ns/op 6383.08 MB/s Benchmark______Pub8K_Payload-16 2673302 1279 ns/op 6418.01 MB/s Benchmark______Pub8K_Payload-16 2740170 1290 ns/op 6358.88 MB/s Benchmark______Pub8K_Payload-16 2800636 1275 ns/op 6438.59 MB/s Benchmark______Pub8K_Payload-16 2679266 1277 ns/op 6425.68 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 571114 5315 ns/op 6167.94 MB/s Benchmark_____Pub32K_Payload-16 672168 5485 ns/op 5976.71 MB/s Benchmark_____Pub32K_Payload-16 645292 5480 ns/op 5982.17 MB/s Benchmark_____Pub32K_Payload-16 663499 5814 ns/op 5638.27 MB/s Benchmark_____Pub32K_Payload-16 646672 6498 ns/op 5045.26 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 33251913 90.80 ns/op 121.15 MB/s Benchmark__AuthPub0b_Payload-16 33228290 91.12 ns/op 120.71 MB/s Benchmark__AuthPub0b_Payload-16 34676320 90.96 ns/op 120.93 MB/s Benchmark__AuthPub0b_Payload-16 37842898 91.04 ns/op 120.83 MB/s Benchmark__AuthPub0b_Payload-16 36709857 90.79 ns/op 121.16 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15468128 228.7 ns/op Benchmark_____________PubSub-16 15596902 228.0 ns/op Benchmark_____________PubSub-16 15506077 227.8 ns/op Benchmark_____________PubSub-16 15665330 228.9 ns/op Benchmark_____________PubSub-16 15539485 228.4 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15526870 227.8 ns/op Benchmark_____PubSubTwoConns-16 15513357 226.3 ns/op Benchmark_____PubSubTwoConns-16 15813609 227.0 ns/op Benchmark_____PubSubTwoConns-16 15703694 227.4 ns/op Benchmark_____PubSubTwoConns-16 15723154 227.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41134->127.0.0.1:33705: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:37348->127.0.0.1:45037: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46064->127.0.0.1:33805: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:47076->127.0.0.1:38863: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:58444->127.0.0.1:32923: 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 14436110 244.0 ns/op Benchmark_____PubTwoQueueSub-16 14419730 243.8 ns/op Benchmark_____PubTwoQueueSub-16 14583687 243.2 ns/op Benchmark_____PubTwoQueueSub-16 14623628 243.7 ns/op Benchmark_____PubTwoQueueSub-16 14626729 243.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14571964 244.3 ns/op Benchmark____PubFourQueueSub-16 14740590 242.2 ns/op Benchmark____PubFourQueueSub-16 14458614 243.7 ns/op Benchmark____PubFourQueueSub-16 14405506 243.1 ns/op Benchmark____PubFourQueueSub-16 14554168 243.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14539222 243.9 ns/op Benchmark___PubEightQueueSub-16 14721132 243.6 ns/op Benchmark___PubEightQueueSub-16 14397374 243.3 ns/op Benchmark___PubEightQueueSub-16 14437881 243.8 ns/op Benchmark___PubEightQueueSub-16 14542365 243.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22161 156056 ns/op Benchmark_PubSub512kTwoConns-16 22938 156359 ns/op Benchmark_PubSub512kTwoConns-16 22962 156735 ns/op Benchmark_PubSub512kTwoConns-16 22623 158224 ns/op Benchmark_PubSub512kTwoConns-16 22972 156506 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15178740 229.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15234243 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15136476 230.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15348456 230.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15287541 231.1 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15183837 230.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15328266 230.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15197673 231.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15179283 229.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15356052 231.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11365700 312.7 ns/op Benchmark____RoutedPubSub_0b-16 11277633 314.0 ns/op Benchmark____RoutedPubSub_0b-16 11307720 316.0 ns/op Benchmark____RoutedPubSub_0b-16 11208370 310.5 ns/op Benchmark____RoutedPubSub_0b-16 10898228 321.1 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6593480 542.2 ns/op Benchmark____RoutedPubSub_1K-16 6570428 536.8 ns/op Benchmark____RoutedPubSub_1K-16 6523537 535.0 ns/op Benchmark____RoutedPubSub_1K-16 6668042 542.2 ns/op Benchmark____RoutedPubSub_1K-16 6648109 649.4 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 86479 48071 ns/op Benchmark__RoutedPubSub_100K-16 83596 45059 ns/op Benchmark__RoutedPubSub_100K-16 81663 44601 ns/op Benchmark__RoutedPubSub_100K-16 79684 45418 ns/op Benchmark__RoutedPubSub_100K-16 80650 45834 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9825738 327.0 ns/op Benchmark____Routed2QueueSub-16 11377489 313.8 ns/op Benchmark____Routed2QueueSub-16 9683506 314.5 ns/op Benchmark____Routed2QueueSub-16 9971145 316.5 ns/op Benchmark____Routed2QueueSub-16 9980526 312.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9769345 319.3 ns/op Benchmark____Routed4QueueSub-16 9792856 315.0 ns/op Benchmark____Routed4QueueSub-16 11415424 320.7 ns/op Benchmark____Routed4QueueSub-16 9598618 323.8 ns/op Benchmark____Routed4QueueSub-16 9867076 319.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9358545 328.6 ns/op Benchmark____Routed8QueueSub-16 9321348 329.7 ns/op Benchmark____Routed8QueueSub-16 9477147 325.7 ns/op Benchmark____Routed8QueueSub-16 9189426 329.9 ns/op Benchmark____Routed8QueueSub-16 9308464 327.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8930150 342.9 ns/op Benchmark___Routed16QueueSub-16 8726750 347.9 ns/op Benchmark___Routed16QueueSub-16 10465399 341.0 ns/op Benchmark___Routed16QueueSub-16 10461079 342.7 ns/op Benchmark___Routed16QueueSub-16 10521487 344.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6484701 548.1 ns/op Benchmark____________RouteCompressOff-16 6442948 547.4 ns/op Benchmark____________RouteCompressOff-16 6463803 548.7 ns/op Benchmark____________RouteCompressOff-16 6499290 550.2 ns/op Benchmark____________RouteCompressOff-16 6173152 550.1 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6247928 541.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6451747 545.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6574225 546.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6574761 545.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6474603 550.8 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6461199 546.5 ns/op Benchmark_________RouteCompressS2Fast-16 6558622 550.5 ns/op Benchmark_________RouteCompressS2Fast-16 6535519 545.5 ns/op Benchmark_________RouteCompressS2Fast-16 6516559 546.5 ns/op Benchmark_________RouteCompressS2Fast-16 6248850 547.7 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6346897 556.5 ns/op Benchmark_______RouteCompressS2Better-16 6467444 546.1 ns/op Benchmark_______RouteCompressS2Better-16 6474016 550.8 ns/op Benchmark_______RouteCompressS2Better-16 6538261 547.0 ns/op Benchmark_______RouteCompressS2Better-16 6438840 555.5 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6559255 551.1 ns/op Benchmark_________RouteCompressS2Best-16 6633637 545.9 ns/op Benchmark_________RouteCompressS2Best-16 6398604 541.6 ns/op Benchmark_________RouteCompressS2Best-16 6435355 546.6 ns/op Benchmark_________RouteCompressS2Best-16 6309153 544.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4605140 773.6 ns/op 321.89 MB/s Benchmark______FanOut_8x1x10-16 4604124 770.0 ns/op 323.38 MB/s Benchmark______FanOut_8x1x10-16 4651366 777.0 ns/op 320.45 MB/s Benchmark______FanOut_8x1x10-16 4572342 774.7 ns/op 321.41 MB/s Benchmark______FanOut_8x1x10-16 4633839 780.8 ns/op 318.89 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 504254 6118 ns/op 379.04 MB/s Benchmark_____FanOut_8x1x100-16 536000 6093 ns/op 380.62 MB/s Benchmark_____FanOut_8x1x100-16 537418 6179 ns/op 375.32 MB/s Benchmark_____FanOut_8x1x100-16 535117 6129 ns/op 378.39 MB/s Benchmark_____FanOut_8x1x100-16 555446 6096 ns/op 380.40 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48116 75126 ns/op 306.41 MB/s Benchmark____FanOut_8x10x100-16 47937 75667 ns/op 304.21 MB/s Benchmark____FanOut_8x10x100-16 47908 75841 ns/op 303.52 MB/s Benchmark____FanOut_8x10x100-16 47449 76323 ns/op 301.60 MB/s Benchmark____FanOut_8x10x100-16 48043 75261 ns/op 305.86 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5803 599426 ns/op 400.41 MB/s Benchmark___FanOut_8x10x1000-16 5586 598534 ns/op 401.01 MB/s Benchmark___FanOut_8x10x1000-16 5758 601344 ns/op 399.14 MB/s Benchmark___FanOut_8x10x1000-16 5589 607699 ns/op 394.96 MB/s Benchmark___FanOut_8x10x1000-16 5785 606185 ns/op 395.95 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4986 713207 ns/op 322.51 MB/s Benchmark___FanOut_8x100x100-16 4990 722743 ns/op 318.26 MB/s Benchmark___FanOut_8x100x100-16 5013 715089 ns/op 321.66 MB/s Benchmark___FanOut_8x100x100-16 4896 715193 ns/op 321.62 MB/s Benchmark___FanOut_8x100x100-16 4918 714018 ns/op 322.15 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 579 6250816 ns/op 383.95 MB/s Benchmark__FanOut_8x100x1000-16 573 6230115 ns/op 385.23 MB/s Benchmark__FanOut_8x100x1000-16 573 6228390 ns/op 385.34 MB/s Benchmark__FanOut_8x100x1000-16 578 6241979 ns/op 384.50 MB/s Benchmark__FanOut_8x100x1000-16 565 6247804 ns/op 384.14 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 535 6808602 ns/op 367.19 MB/s Benchmark__FanOut_8x10x10000-16 528 6785288 ns/op 368.45 MB/s Benchmark__FanOut_8x10x10000-16 526 6888228 ns/op 362.94 MB/s Benchmark__FanOut_8x10x10000-16 520 6708867 ns/op 372.64 MB/s Benchmark__FanOut_8x10x10000-16 520 6875507 ns/op 363.61 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 939 3790470 ns/op 303.40 MB/s Benchmark___FanOut_8x500x100-16 927 3802656 ns/op 302.43 MB/s Benchmark___FanOut_8x500x100-16 951 3792272 ns/op 303.25 MB/s Benchmark___FanOut_8x500x100-16 943 3797451 ns/op 302.84 MB/s Benchmark___FanOut_8x500x100-16 932 3782710 ns/op 304.02 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 348685 9577 ns/op 1528.74 MB/s Benchmark___FanOut_128x1x100-16 352976 9592 ns/op 1526.43 MB/s Benchmark___FanOut_128x1x100-16 363238 9535 ns/op 1535.44 MB/s Benchmark___FanOut_128x1x100-16 355060 9577 ns/op 1528.79 MB/s Benchmark___FanOut_128x1x100-16 341679 9540 ns/op 1534.71 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32100 112492 ns/op 1290.23 MB/s Benchmark__FanOut_128x10x100-16 32110 112639 ns/op 1288.55 MB/s Benchmark__FanOut_128x10x100-16 32245 112111 ns/op 1294.62 MB/s Benchmark__FanOut_128x10x100-16 32062 111151 ns/op 1305.79 MB/s Benchmark__FanOut_128x10x100-16 32142 111513 ns/op 1301.56 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4020 871442 ns/op 1675.55 MB/s Benchmark_FanOut_128x10x1000-16 3873 888051 ns/op 1644.21 MB/s Benchmark_FanOut_128x10x1000-16 4017 876215 ns/op 1666.42 MB/s Benchmark_FanOut_128x10x1000-16 3943 885201 ns/op 1649.50 MB/s Benchmark_FanOut_128x10x1000-16 4065 884997 ns/op 1649.88 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3573 1015823 ns/op 1427.55 MB/s Benchmark_FanOut_128x100x100-16 3433 1029316 ns/op 1408.84 MB/s Benchmark_FanOut_128x100x100-16 3478 1023393 ns/op 1416.99 MB/s Benchmark_FanOut_128x100x100-16 3528 1014706 ns/op 1429.12 MB/s Benchmark_FanOut_128x100x100-16 3529 1016062 ns/op 1427.22 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 379 9308050 ns/op 1568.55 MB/s BenchmarkFanOut_128x100x1000-16 382 9637579 ns/op 1514.92 MB/s BenchmarkFanOut_128x100x1000-16 374 9320761 ns/op 1566.41 MB/s BenchmarkFanOut_128x100x1000-16 384 9458875 ns/op 1543.54 MB/s BenchmarkFanOut_128x100x1000-16 384 9375589 ns/op 1557.25 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 372 9731861 ns/op 1510.52 MB/s BenchmarkFanOut_128x10x10000-16 372 9828084 ns/op 1495.73 MB/s BenchmarkFanOut_128x10x10000-16 372 9687434 ns/op 1517.44 MB/s BenchmarkFanOut_128x10x10000-16 362 9762744 ns/op 1505.74 MB/s BenchmarkFanOut_128x10x10000-16 374 9806396 ns/op 1499.04 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 670 5369070 ns/op 1350.35 MB/s BenchmarkFanOut__128x500x100-16 668 5350960 ns/op 1354.92 MB/s BenchmarkFanOut__128x500x100-16 654 5333507 ns/op 1359.36 MB/s BenchmarkFanOut__128x500x100-16 666 5349078 ns/op 1355.40 MB/s BenchmarkFanOut__128x500x100-16 668 5334771 ns/op 1359.04 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1945 1851626 ns/op 2857.23 MB/s Benchmark_FanOut_512x100x100-16 1905 1860434 ns/op 2843.70 MB/s Benchmark_FanOut_512x100x100-16 1882 1849692 ns/op 2860.22 MB/s Benchmark_FanOut_512x100x100-16 1942 1852669 ns/op 2855.62 MB/s Benchmark_FanOut_512x100x100-16 1910 1861682 ns/op 2841.80 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 218 16789852 ns/op 3156.70 MB/s Benchmark__FanOut_512x100x1k-16 212 16744347 ns/op 3165.28 MB/s Benchmark__FanOut_512x100x1k-16 213 16585282 ns/op 3195.64 MB/s Benchmark__FanOut_512x100x1k-16 214 16789763 ns/op 3156.72 MB/s Benchmark__FanOut_512x100x1k-16 212 16717518 ns/op 3170.36 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3288 1168711 ns/op 8925.25 MB/s Benchmark____FanOut_1kx10x1k-16 2781 1159690 ns/op 8994.68 MB/s Benchmark____FanOut_1kx10x1k-16 3243 1161362 ns/op 8981.73 MB/s Benchmark____FanOut_1kx10x1k-16 3164 1133942 ns/op 9198.92 MB/s Benchmark____FanOut_1kx10x1k-16 2919 1151674 ns/op 9057.28 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2751 1265411 ns/op 8235.30 MB/s Benchmark__FanOut_1kx100x100-16 2750 1268362 ns/op 8216.14 MB/s Benchmark__FanOut_1kx100x100-16 2776 1267185 ns/op 8223.77 MB/s Benchmark__FanOut_1kx100x100-16 2707 1269381 ns/op 8209.54 MB/s Benchmark__FanOut_1kx100x100-16 2804 1277575 ns/op 8156.89 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4392280 779.7 ns/op 319.35 MB/s Benchmark_____RFanOut_8x1x10-16 4399813 766.0 ns/op 325.06 MB/s Benchmark_____RFanOut_8x1x10-16 4334283 799.6 ns/op 311.39 MB/s Benchmark_____RFanOut_8x1x10-16 4381010 789.8 ns/op 315.29 MB/s Benchmark_____RFanOut_8x1x10-16 4508031 794.9 ns/op 313.24 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 520609 6112 ns/op 379.41 MB/s Benchmark____RFanOut_8x1x100-16 544728 6127 ns/op 378.48 MB/s Benchmark____RFanOut_8x1x100-16 507363 6372 ns/op 363.92 MB/s Benchmark____RFanOut_8x1x100-16 519190 6356 ns/op 364.85 MB/s Benchmark____RFanOut_8x1x100-16 494984 6156 ns/op 376.69 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47540 75125 ns/op 306.41 MB/s Benchmark___RFanOut_8x10x100-16 47774 75482 ns/op 304.96 MB/s Benchmark___RFanOut_8x10x100-16 47358 75008 ns/op 306.89 MB/s Benchmark___RFanOut_8x10x100-16 47629 75332 ns/op 305.57 MB/s Benchmark___RFanOut_8x10x100-16 47383 77902 ns/op 295.49 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5913 603485 ns/op 397.72 MB/s Benchmark__RFanOut_8x10x1000-16 5869 604524 ns/op 397.04 MB/s Benchmark__RFanOut_8x10x1000-16 5740 608510 ns/op 394.44 MB/s Benchmark__RFanOut_8x10x1000-16 5935 616310 ns/op 389.45 MB/s Benchmark__RFanOut_8x10x1000-16 5677 607136 ns/op 395.33 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4897 717292 ns/op 320.68 MB/s Benchmark__RFanOut_8x100x100-16 4970 715125 ns/op 321.65 MB/s Benchmark__RFanOut_8x100x100-16 4900 715100 ns/op 321.66 MB/s Benchmark__RFanOut_8x100x100-16 4914 715637 ns/op 321.42 MB/s Benchmark__RFanOut_8x100x100-16 4785 719014 ns/op 319.91 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 570 6240714 ns/op 384.57 MB/s Benchmark_RFanOut_8x100x1000-16 564 6244685 ns/op 384.33 MB/s Benchmark_RFanOut_8x100x1000-16 529 6218795 ns/op 385.93 MB/s Benchmark_RFanOut_8x100x1000-16 565 6266276 ns/op 383.01 MB/s Benchmark_RFanOut_8x100x1000-16 558 6247686 ns/op 384.15 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 536 6855219 ns/op 364.69 MB/s Benchmark_RFanOut_8x10x10000-16 530 6745627 ns/op 370.61 MB/s Benchmark_RFanOut_8x10x10000-16 518 6781429 ns/op 368.66 MB/s Benchmark_RFanOut_8x10x10000-16 526 6731667 ns/op 371.38 MB/s Benchmark_RFanOut_8x10x10000-16 526 6766324 ns/op 369.48 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3116 1149766 ns/op 9072.32 MB/s Benchmark_RFanOut_1kx10x1000-16 3036 1157187 ns/op 9014.13 MB/s Benchmark_RFanOut_1kx10x1000-16 2875 1140405 ns/op 9146.79 MB/s Benchmark_RFanOut_1kx10x1000-16 2976 1160741 ns/op 8986.53 MB/s Benchmark_RFanOut_1kx10x1000-16 3136 1166379 ns/op 8943.09 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6978702 502.8 ns/op 4132.50 MB/s Benchmark_____FanIn_1kx100x1-16 6974396 504.6 ns/op 4118.51 MB/s Benchmark_____FanIn_1kx100x1-16 6922894 503.4 ns/op 4127.94 MB/s Benchmark_____FanIn_1kx100x1-16 6867135 505.2 ns/op 4113.60 MB/s Benchmark_____FanIn_1kx100x1-16 6948952 503.5 ns/op 4126.81 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2602946 1377 ns/op 5973.05 MB/s Benchmark_____FanIn_4kx100x1-16 2654343 1371 ns/op 5997.69 MB/s Benchmark_____FanIn_4kx100x1-16 2637466 1354 ns/op 6073.77 MB/s Benchmark_____FanIn_4kx100x1-16 2641236 1367 ns/op 6013.86 MB/s Benchmark_____FanIn_4kx100x1-16 2554693 1370 ns/op 5999.99 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1700797 2098 ns/op 7822.09 MB/s Benchmark_____FanIn_8kx100x1-16 1681234 2068 ns/op 7937.75 MB/s Benchmark_____FanIn_8kx100x1-16 1700241 2105 ns/op 7796.14 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 240042960 vs 14021726400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51124->127.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:50980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50950->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51500->127.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 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:51166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50960->127.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:51488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51224->127.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:51454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51212->127.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:50888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50966->127.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:50804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50914->127.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:51246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50886->127.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:51182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51298->127.0.0.1:5222: write: connection reset by peer 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:51520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51446->127.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:51622->127.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:50840->127.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:51060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51382->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51040->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51304->127.0.0.1:5222: write: broken pipe --- FAIL: Benchmark_____FanIn_8kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51564->127.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:51644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51422->127.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:51530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51126->127.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: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:50968->127.0.0.1:5222: write: connection reset by peer Benchmark_____FanIn_8kx100x1-16 1693122 2117 ns/op 7753.44 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 875260 4160 ns/op 7884.72 MB/s Benchmark____FanIn_16kx100x1-16 868699 4095 ns/op 8009.75 MB/s Benchmark____FanIn_16kx100x1-16 869104 4068 ns/op 8063.90 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 123991560 vs 14209826400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44196->127.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:43662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43800->127.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: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:43828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43984->127.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:43914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43734->127.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:43954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44146->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44356->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43696->127.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: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:44132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43670->127.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:44258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43524->127.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:44120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44038->127.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:43992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:44310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43808->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43898->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44192->127.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:43710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43738->127.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:44230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44364->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44346->127.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:44250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43758->127.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:43574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43642->127.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: broken pipe 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:44210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43656->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_16kx100x1-16 Benchmark____FanIn_16kx100x1-16 875772 4124 ns/op 7953.62 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 153199 20153 ns/op 6505.28 MB/s Benchmark____FanIn_64kx100x1-16 153470 20159 ns/op 6503.37 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 8876400624 vs 10953906300 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54980->127.0.0.1:5222: write: connection reset by peer 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:55046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54734->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55028->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55262->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 170318 20080 ns/op 6528.92 MB/s Benchmark____FanIn_64kx100x1-16 170304 20092 ns/op 6525.23 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 792832320 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37212->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: 375441760 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38910->127.0.0.1:5222: write: connection reset by peer bench_test.go: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:38490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38330->127.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:38946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38998->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: 321301590 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40282->127.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: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:40562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39918->127.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:39950->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40320->127.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:40512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40498->127.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:40174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40686->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: 981339740 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41972->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 157308000 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60472->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:60708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32962->127.0.0.1:5222: write: broken pipe Benchmark___BumpPubCount_1x3-16 5553100 642.2 ns/op 442.20 MB/s Benchmark___BumpPubCount_1x3-16 5617358 639.0 ns/op 444.45 MB/s Benchmark___BumpPubCount_1x3-16 5521087 642.0 ns/op 442.36 MB/s Benchmark___BumpPubCount_1x3-16 5578232 637.2 ns/op 445.69 MB/s Benchmark___BumpPubCount_1x3-16 5603544 640.1 ns/op 443.67 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5262104 673.5 ns/op 421.65 MB/s Benchmark___BumpPubCount_2x3-16 5288176 672.7 ns/op 422.18 MB/s Benchmark___BumpPubCount_2x3-16 5317186 674.7 ns/op 420.90 MB/s Benchmark___BumpPubCount_2x3-16 5318308 668.6 ns/op 424.80 MB/s Benchmark___BumpPubCount_2x3-16 5304926 671.4 ns/op 422.97 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5567754 643.6 ns/op 441.24 MB/s Benchmark___BumpPubCount_5x3-16 5468210 643.8 ns/op 441.16 MB/s Benchmark___BumpPubCount_5x3-16 5119538 645.7 ns/op 439.81 MB/s Benchmark___BumpPubCount_5x3-16 5542591 642.0 ns/op 442.39 MB/s Benchmark___BumpPubCount_5x3-16 5535007 642.5 ns/op 442.03 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5603022 644.2 ns/op 440.84 MB/s Benchmark__BumpPubCount_10x3-16 5582532 642.9 ns/op 441.78 MB/s Benchmark__BumpPubCount_10x3-16 5566026 645.4 ns/op 440.02 MB/s Benchmark__BumpPubCount_10x3-16 5603847 640.1 ns/op 443.70 MB/s Benchmark__BumpPubCount_10x3-16 5571148 645.5 ns/op 439.95 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 13318392 275.9 ns/op 3770.14 MB/s Benchmark____GWs_Opt_1kx01x0-16 12601441 282.2 ns/op 3684.99 MB/s Benchmark____GWs_Opt_1kx01x0-16 12966255 269.9 ns/op 3853.50 MB/s Benchmark____GWs_Opt_1kx01x0-16 12695188 278.4 ns/op 3736.01 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:48276->127.0.0.1:43075: use of closed network connection --- FAIL: Benchmark____GWs_Opt_1kx01x0 --- FAIL: Benchmark____GWs_Opt_1kx01x0-16 Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10411867 343.4 ns/op 6009.65 MB/s Benchmark____GWs_Opt_2kx01x0-16 10262845 341.0 ns/op 6052.70 MB/s Benchmark____GWs_Opt_2kx01x0-16 10373400 338.6 ns/op 6094.89 MB/s Benchmark____GWs_Opt_2kx01x0-16 10583132 317.1 ns/op 6509.85 MB/s Benchmark____GWs_Opt_2kx01x0-16 9074403 385.5 ns/op 5354.43 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5881039 619.5 ns/op 6637.77 MB/s Benchmark____GWs_Opt_4kx01x0-16 5614990 621.6 ns/op 6615.02 MB/s Benchmark____GWs_Opt_4kx01x0-16 5801557 627.2 ns/op 6556.20 MB/s Benchmark____GWs_Opt_4kx01x0-16 5789984 619.8 ns/op 6634.40 MB/s Benchmark____GWs_Opt_4kx01x0-16 5785248 611.7 ns/op 6722.73 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27885920 114.9 ns/op 9052.78 MB/s Benchmark____GWs_Opt_1kx10x0-16 28558740 125.6 ns/op 8277.22 MB/s Benchmark____GWs_Opt_1kx10x0-16 31137709 113.9 ns/op 9130.64 MB/s Benchmark____GWs_Opt_1kx10x0-16 28805583 114.4 ns/op 9092.40 MB/s Benchmark____GWs_Opt_1kx10x0-16 31349936 109.5 ns/op 9500.55 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23755519 147.3 ns/op 14009.14 MB/s Benchmark____GWs_Opt_2kx10x0-16 24780548 140.9 ns/op 14649.47 MB/s Benchmark____GWs_Opt_2kx10x0-16 23803334 146.5 ns/op 14087.21 MB/s Benchmark____GWs_Opt_2kx10x0-16 24861399 149.0 ns/op 13852.38 MB/s Benchmark____GWs_Opt_2kx10x0-16 24833739 143.6 ns/op 14376.29 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 13078536 354.0 ns/op 11614.19 MB/s Benchmark____GWs_Opt_4kx10x0-16 12518175 343.3 ns/op 11978.53 MB/s Benchmark____GWs_Opt_4kx10x0-16 12458936 286.9 ns/op 14332.48 MB/s Benchmark____GWs_Opt_4kx10x0-16 12463873 319.5 ns/op 12868.55 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:43620->127.0.0.1:34787: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:38332->127.0.0.1:33961: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6385886 552.1 ns/op 5660.53 MB/s Benchmark____GWs_Opt_1kx01x1-16 6670718 550.2 ns/op 5679.90 MB/s Benchmark____GWs_Opt_1kx01x1-16 6405685 549.4 ns/op 5688.07 MB/s Benchmark____GWs_Opt_1kx01x1-16 6456285 550.0 ns/op 5682.06 MB/s Benchmark____GWs_Opt_1kx01x1-16 6586682 547.5 ns/op 5707.29 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4820654 757.5 ns/op 8180.52 MB/s Benchmark____GWs_Opt_2kx01x1-16 4724354 759.2 ns/op 8162.84 MB/s Benchmark____GWs_Opt_2kx01x1-16 4810452 753.4 ns/op 8225.39 MB/s Benchmark____GWs_Opt_2kx01x1-16 4831272 752.8 ns/op 8232.23 MB/s Benchmark____GWs_Opt_2kx01x1-16 4734970 752.1 ns/op 8239.08 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2642404 1440 ns/op 8568.21 MB/s Benchmark____GWs_Opt_4kx01x1-16 2644519 1361 ns/op 9070.73 MB/s Benchmark____GWs_Opt_4kx01x1-16 2641886 1369 ns/op 9014.11 MB/s Benchmark____GWs_Opt_4kx01x1-16 2682154 1345 ns/op 9177.05 MB/s Benchmark____GWs_Opt_4kx01x1-16 2604925 1385 ns/op 8913.58 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6510837 546.3 ns/op 5720.23 MB/s Benchmark____GWs_Opt_1kx10x1-16 6506913 544.2 ns/op 5742.27 MB/s Benchmark____GWs_Opt_1kx10x1-16 6293400 550.2 ns/op 5679.60 MB/s Benchmark____GWs_Opt_1kx10x1-16 6523084 548.1 ns/op 5701.39 MB/s Benchmark____GWs_Opt_1kx10x1-16 6210796 536.3 ns/op 5826.92 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4778558 829.0 ns/op 7475.57 MB/s Benchmark____GWs_Opt_2kx10x1-16 4272079 779.0 ns/op 7954.88 MB/s Benchmark____GWs_Opt_2kx10x1-16 4353519 748.6 ns/op 8278.61 MB/s Benchmark____GWs_Opt_2kx10x1-16 4183942 841.6 ns/op 7363.26 MB/s Benchmark____GWs_Opt_2kx10x1-16 4169557 826.4 ns/op 7498.51 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2436759 1484 ns/op 8313.34 MB/s Benchmark____GWs_Opt_4kx10x1-16 2401138 1502 ns/op 8214.64 MB/s Benchmark____GWs_Opt_4kx10x1-16 2331457 1482 ns/op 8326.43 MB/s Benchmark____GWs_Opt_4kx10x1-16 2363468 1499 ns/op 8232.57 MB/s Benchmark____GWs_Opt_4kx10x1-16 2404051 1505 ns/op 8202.35 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12323890 290.3 ns/op 3582.88 MB/s Benchmark____GWs_Int_1kx01x0-16 11677804 288.9 ns/op 3600.21 MB/s Benchmark____GWs_Int_1kx01x0-16 12740257 285.5 ns/op 3643.20 MB/s Benchmark____GWs_Int_1kx01x0-16 12620688 285.9 ns/op 3638.20 MB/s Benchmark____GWs_Int_1kx01x0-16 11633641 285.9 ns/op 3637.80 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10529476 358.1 ns/op 5764.11 MB/s Benchmark____GWs_Int_2kx01x0-16 10079056 354.8 ns/op 5817.59 MB/s Benchmark____GWs_Int_2kx01x0-16 8625214 360.4 ns/op 5726.58 MB/s Benchmark____GWs_Int_2kx01x0-16 9239866 368.7 ns/op 5597.83 MB/s Benchmark____GWs_Int_2kx01x0-16 9627176 357.7 ns/op 5769.97 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5688747 632.6 ns/op 6500.37 MB/s Benchmark____GWs_Int_4kx01x0-16 5600731 633.7 ns/op 6489.08 MB/s Benchmark____GWs_Int_4kx01x0-16 5702468 614.0 ns/op 6696.67 MB/s Benchmark____GWs_Int_4kx01x0-16 5690558 632.1 ns/op 6504.97 MB/s Benchmark____GWs_Int_4kx01x0-16 5705620 642.4 ns/op 6401.37 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30860052 118.2 ns/op 8801.15 MB/s Benchmark____GWs_Int_1kx10x0-16 30876268 113.5 ns/op 9166.55 MB/s Benchmark____GWs_Int_1kx10x0-16 30078752 113.5 ns/op 9163.03 MB/s Benchmark____GWs_Int_1kx10x0-16 27036534 112.8 ns/op 9223.63 MB/s Benchmark____GWs_Int_1kx10x0-16 32113792 112.1 ns/op 9277.24 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 23480272 142.2 ns/op 14511.02 MB/s Benchmark____GWs_Int_2kx10x0-16 25588588 155.6 ns/op 13268.67 MB/s Benchmark____GWs_Int_2kx10x0-16 25570435 157.3 ns/op 13122.42 MB/s Benchmark____GWs_Int_2kx10x0-16 23376626 139.6 ns/op 14785.74 MB/s Benchmark____GWs_Int_2kx10x0-16 25340374 135.5 ns/op 15235.15 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12670035 295.8 ns/op 13902.53 MB/s Benchmark____GWs_Int_4kx10x0-16 10258908 341.3 ns/op 12047.65 MB/s Benchmark____GWs_Int_4kx10x0-16 8568597 362.6 ns/op 11339.58 MB/s Benchmark____GWs_Int_4kx10x0-16 13025529 296.1 ns/op 13886.99 MB/s Benchmark____GWs_Int_4kx10x0-16 13153629 331.9 ns/op 12388.69 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6546544 561.7 ns/op 5563.85 MB/s Benchmark____GWs_Int_1kx01x1-16 6333553 548.8 ns/op 5694.62 MB/s Benchmark____GWs_Int_1kx01x1-16 6394070 559.6 ns/op 5584.54 MB/s Benchmark____GWs_Int_1kx01x1-16 6738226 557.8 ns/op 5602.05 MB/s Benchmark____GWs_Int_1kx01x1-16 6449852 552.0 ns/op 5661.31 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4651988 1113 ns/op 5567.26 MB/s Benchmark____GWs_Int_2kx01x1-16 4622546 760.6 ns/op 8147.28 MB/s Benchmark____GWs_Int_2kx01x1-16 4959402 756.8 ns/op 8188.57 MB/s Benchmark____GWs_Int_2kx01x1-16 4812634 764.4 ns/op 8106.69 MB/s Benchmark____GWs_Int_2kx01x1-16 4701464 754.4 ns/op 8214.60 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2042479 2022 ns/op 6103.09 MB/s Benchmark____GWs_Int_4kx01x1-16 2542567 1364 ns/op 9050.04 MB/s Benchmark____GWs_Int_4kx01x1-16 2481799 1570 ns/op 7862.67 MB/s Benchmark____GWs_Int_4kx01x1-16 2610793 1563 ns/op 7897.54 MB/s Benchmark____GWs_Int_4kx01x1-16 2698240 1358 ns/op 9087.75 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6549604 548.6 ns/op 5695.97 MB/s Benchmark____GWs_Int_1kx10x1-16 6632846 548.0 ns/op 5702.17 MB/s Benchmark____GWs_Int_1kx10x1-16 6423482 545.6 ns/op 5728.05 MB/s Benchmark____GWs_Int_1kx10x1-16 6609566 611.2 ns/op 5112.67 MB/s Benchmark____GWs_Int_1kx10x1-16 6584361 584.5 ns/op 5346.12 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4166091 838.7 ns/op 7388.70 MB/s Benchmark____GWs_Int_2kx10x1-16 4299813 832.9 ns/op 7440.55 MB/s Benchmark____GWs_Int_2kx10x1-16 4270770 836.1 ns/op 7411.54 MB/s Benchmark____GWs_Int_2kx10x1-16 4394691 833.8 ns/op 7432.19 MB/s Benchmark____GWs_Int_2kx10x1-16 3924591 815.5 ns/op 7599.00 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2281695 1459 ns/op 8456.46 MB/s Benchmark____GWs_Int_4kx10x1-16 2451982 1492 ns/op 8269.53 MB/s Benchmark____GWs_Int_4kx10x1-16 2196589 1416 ns/op 8716.03 MB/s Benchmark____GWs_Int_4kx10x1-16 2400626 1533 ns/op 8047.82 MB/s Benchmark____GWs_Int_4kx10x1-16 2389408 1476 ns/op 8358.59 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8280492 452.4 ns/op 225.45 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8364336 431.0 ns/op 236.64 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8366108 430.4 ns/op 237.01 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8354808 441.3 ns/op 231.14 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8244042 429.7 ns/op 237.38 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 711573 5060 ns/op 34.98 MB/s Benchmark__GWs_Reqs_1SubEach-16 761205 5383 ns/op 32.88 MB/s Benchmark__GWs_Reqs_1SubEach-16 801757 5279 ns/op 33.53 MB/s Benchmark__GWs_Reqs_1SubEach-16 744633 5213 ns/op 33.95 MB/s Benchmark__GWs_Reqs_1SubEach-16 765036 5229 ns/op 33.85 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2100.567s