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 50120233 72.83 ns/op 151.03 MB/s Benchmark______Pub0b_Payload-16 47340436 71.75 ns/op 153.31 MB/s Benchmark______Pub0b_Payload-16 50223237 72.15 ns/op 152.46 MB/s Benchmark______Pub0b_Payload-16 44136292 71.64 ns/op 153.54 MB/s Benchmark______Pub0b_Payload-16 47188600 71.71 ns/op 153.39 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46895979 72.37 ns/op 262.55 MB/s Benchmark______Pub8b_Payload-16 49691942 72.57 ns/op 261.83 MB/s Benchmark______Pub8b_Payload-16 46516940 72.33 ns/op 262.68 MB/s Benchmark______Pub8b_Payload-16 46752123 72.34 ns/op 262.65 MB/s Benchmark______Pub8b_Payload-16 46977747 72.43 ns/op 262.31 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 42830827 76.58 ns/op 574.57 MB/s Benchmark_____Pub32b_Payload-16 42640915 82.37 ns/op 534.16 MB/s Benchmark_____Pub32b_Payload-16 47018983 76.32 ns/op 576.53 MB/s Benchmark_____Pub32b_Payload-16 46979382 79.25 ns/op 555.23 MB/s Benchmark_____Pub32b_Payload-16 43994202 76.50 ns/op 575.17 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 37487290 85.44 ns/op 1650.33 MB/s Benchmark____Pub128B_Payload-16 35564986 99.25 ns/op 1420.67 MB/s Benchmark____Pub128B_Payload-16 42166809 87.36 ns/op 1614.06 MB/s Benchmark____Pub128B_Payload-16 40264665 89.88 ns/op 1568.77 MB/s Benchmark____Pub128B_Payload-16 42135710 85.47 ns/op 1649.77 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36483265 97.29 ns/op 2765.05 MB/s Benchmark____Pub256B_Payload-16 37890039 98.05 ns/op 2743.43 MB/s Benchmark____Pub256B_Payload-16 36194884 93.30 ns/op 2883.14 MB/s Benchmark____Pub256B_Payload-16 38100710 94.49 ns/op 2846.87 MB/s Benchmark____Pub256B_Payload-16 32363547 95.81 ns/op 2807.70 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23957896 138.7 ns/op 7483.24 MB/s Benchmark______Pub1K_Payload-16 25685356 141.7 ns/op 7326.00 MB/s Benchmark______Pub1K_Payload-16 26020479 141.1 ns/op 7354.34 MB/s Benchmark______Pub1K_Payload-16 23160664 141.8 ns/op 7319.40 MB/s Benchmark______Pub1K_Payload-16 23342114 143.7 ns/op 7225.27 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5794904 617.1 ns/op 6660.71 MB/s Benchmark______Pub4K_Payload-16 5188188 623.6 ns/op 6590.74 MB/s Benchmark______Pub4K_Payload-16 5308807 620.4 ns/op 6624.39 MB/s Benchmark______Pub4K_Payload-16 5546190 619.0 ns/op 6639.57 MB/s Benchmark______Pub4K_Payload-16 5396110 621.5 ns/op 6612.88 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2821106 1284 ns/op 6388.75 MB/s Benchmark______Pub8K_Payload-16 2820667 1276 ns/op 6430.02 MB/s Benchmark______Pub8K_Payload-16 2690764 1268 ns/op 6473.44 MB/s Benchmark______Pub8K_Payload-16 2791332 1274 ns/op 6441.09 MB/s Benchmark______Pub8K_Payload-16 2782000 1281 ns/op 6405.78 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 654765 5432 ns/op 6034.83 MB/s Benchmark_____Pub32K_Payload-16 664206 5325 ns/op 6156.29 MB/s Benchmark_____Pub32K_Payload-16 592486 5568 ns/op 5888.12 MB/s Benchmark_____Pub32K_Payload-16 655534 5404 ns/op 6066.42 MB/s Benchmark_____Pub32K_Payload-16 643177 6007 ns/op 5457.42 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32230578 93.91 ns/op 117.13 MB/s Benchmark__AuthPub0b_Payload-16 36354804 94.15 ns/op 116.84 MB/s Benchmark__AuthPub0b_Payload-16 36425730 94.26 ns/op 116.70 MB/s Benchmark__AuthPub0b_Payload-16 35882395 94.44 ns/op 116.47 MB/s Benchmark__AuthPub0b_Payload-16 35961940 95.47 ns/op 115.22 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15479611 227.8 ns/op Benchmark_____________PubSub-16 15419949 227.3 ns/op Benchmark_____________PubSub-16 15424305 227.8 ns/op Benchmark_____________PubSub-16 15270522 228.6 ns/op Benchmark_____________PubSub-16 15489765 228.0 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15363780 226.6 ns/op Benchmark_____PubSubTwoConns-16 15619916 225.7 ns/op Benchmark_____PubSubTwoConns-16 15688748 226.8 ns/op Benchmark_____PubSubTwoConns-16 15744397 225.8 ns/op Benchmark_____PubSubTwoConns-16 15454458 226.3 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49670->127.0.0.1:39837: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:36232->127.0.0.1:33681: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:32786->127.0.0.1:38031: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57500->127.0.0.1:44059: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:53596->127.0.0.1:40193: 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 14413836 247.4 ns/op Benchmark_____PubTwoQueueSub-16 14148178 248.0 ns/op Benchmark_____PubTwoQueueSub-16 14385721 248.0 ns/op Benchmark_____PubTwoQueueSub-16 14224737 247.9 ns/op Benchmark_____PubTwoQueueSub-16 14408739 248.9 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14391073 247.7 ns/op Benchmark____PubFourQueueSub-16 14289550 249.5 ns/op Benchmark____PubFourQueueSub-16 13945129 248.4 ns/op Benchmark____PubFourQueueSub-16 14340127 247.5 ns/op Benchmark____PubFourQueueSub-16 14217596 247.9 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14286674 247.4 ns/op Benchmark___PubEightQueueSub-16 14248105 247.0 ns/op Benchmark___PubEightQueueSub-16 14357152 248.1 ns/op Benchmark___PubEightQueueSub-16 14400093 247.5 ns/op Benchmark___PubEightQueueSub-16 14148295 248.9 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23277 154508 ns/op Benchmark_PubSub512kTwoConns-16 23276 154827 ns/op Benchmark_PubSub512kTwoConns-16 23016 154566 ns/op Benchmark_PubSub512kTwoConns-16 23200 155167 ns/op Benchmark_PubSub512kTwoConns-16 23368 156283 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15184789 229.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15097868 230.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 14992638 230.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15037623 231.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15172512 230.2 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15377534 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15112647 230.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15204964 229.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15407658 230.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15136368 231.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11145530 314.2 ns/op Benchmark____RoutedPubSub_0b-16 11198209 319.9 ns/op Benchmark____RoutedPubSub_0b-16 10900123 316.3 ns/op Benchmark____RoutedPubSub_0b-16 11211942 315.9 ns/op Benchmark____RoutedPubSub_0b-16 11157780 320.2 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6591529 541.9 ns/op Benchmark____RoutedPubSub_1K-16 6744728 547.0 ns/op Benchmark____RoutedPubSub_1K-16 6547081 540.9 ns/op Benchmark____RoutedPubSub_1K-16 6578034 534.7 ns/op Benchmark____RoutedPubSub_1K-16 6729174 541.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 82693 41271 ns/op Benchmark__RoutedPubSub_100K-16 87458 43098 ns/op Benchmark__RoutedPubSub_100K-16 85924 42449 ns/op Benchmark__RoutedPubSub_100K-16 84542 42231 ns/op Benchmark__RoutedPubSub_100K-16 86059 41542 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9807307 336.9 ns/op Benchmark____Routed2QueueSub-16 9470011 328.8 ns/op Benchmark____Routed2QueueSub-16 9507687 325.2 ns/op Benchmark____Routed2QueueSub-16 9766329 320.7 ns/op Benchmark____Routed2QueueSub-16 9853672 328.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 11122927 320.3 ns/op Benchmark____Routed4QueueSub-16 9341311 323.2 ns/op Benchmark____Routed4QueueSub-16 9355094 322.8 ns/op Benchmark____Routed4QueueSub-16 9549798 329.5 ns/op Benchmark____Routed4QueueSub-16 9422415 328.1 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 8938225 336.6 ns/op Benchmark____Routed8QueueSub-16 10866469 334.3 ns/op Benchmark____Routed8QueueSub-16 8937046 337.2 ns/op Benchmark____Routed8QueueSub-16 9142812 332.7 ns/op Benchmark____Routed8QueueSub-16 10638201 327.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8825510 346.1 ns/op Benchmark___Routed16QueueSub-16 8680036 350.2 ns/op Benchmark___Routed16QueueSub-16 8981888 352.0 ns/op Benchmark___Routed16QueueSub-16 8578273 350.9 ns/op Benchmark___Routed16QueueSub-16 8728597 349.8 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6380222 555.1 ns/op Benchmark____________RouteCompressOff-16 6466334 554.0 ns/op Benchmark____________RouteCompressOff-16 6486193 554.2 ns/op Benchmark____________RouteCompressOff-16 6411876 557.2 ns/op Benchmark____________RouteCompressOff-16 6365638 549.4 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6313615 540.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6443526 553.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6467690 557.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6516697 551.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6300955 548.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6317077 553.9 ns/op Benchmark_________RouteCompressS2Fast-16 6473587 504.5 ns/op Benchmark_________RouteCompressS2Fast-16 6342314 558.5 ns/op Benchmark_________RouteCompressS2Fast-16 6394146 558.8 ns/op Benchmark_________RouteCompressS2Fast-16 6291164 560.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6206679 558.2 ns/op Benchmark_______RouteCompressS2Better-16 6260574 559.6 ns/op Benchmark_______RouteCompressS2Better-16 6454605 559.9 ns/op Benchmark_______RouteCompressS2Better-16 6487269 556.8 ns/op Benchmark_______RouteCompressS2Better-16 6486142 500.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6368016 555.0 ns/op Benchmark_________RouteCompressS2Best-16 6534097 554.6 ns/op Benchmark_________RouteCompressS2Best-16 6373506 551.8 ns/op Benchmark_________RouteCompressS2Best-16 6386826 551.4 ns/op Benchmark_________RouteCompressS2Best-16 6404588 530.4 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4640212 775.7 ns/op 321.00 MB/s Benchmark______FanOut_8x1x10-16 4614943 780.2 ns/op 319.16 MB/s Benchmark______FanOut_8x1x10-16 4614316 774.3 ns/op 321.58 MB/s Benchmark______FanOut_8x1x10-16 4616380 781.4 ns/op 318.67 MB/s Benchmark______FanOut_8x1x10-16 4568319 771.7 ns/op 322.65 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 530992 6135 ns/op 378.00 MB/s Benchmark_____FanOut_8x1x100-16 557952 6261 ns/op 370.37 MB/s Benchmark_____FanOut_8x1x100-16 526994 6284 ns/op 369.00 MB/s Benchmark_____FanOut_8x1x100-16 562125 6155 ns/op 376.78 MB/s Benchmark_____FanOut_8x1x100-16 551301 6299 ns/op 368.14 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47347 76048 ns/op 302.69 MB/s Benchmark____FanOut_8x10x100-16 47322 76433 ns/op 301.17 MB/s Benchmark____FanOut_8x10x100-16 47462 75798 ns/op 303.69 MB/s Benchmark____FanOut_8x10x100-16 46951 76510 ns/op 300.86 MB/s Benchmark____FanOut_8x10x100-16 46887 76097 ns/op 302.49 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5548 610109 ns/op 393.40 MB/s Benchmark___FanOut_8x10x1000-16 5907 611540 ns/op 392.48 MB/s Benchmark___FanOut_8x10x1000-16 5424 613971 ns/op 390.93 MB/s Benchmark___FanOut_8x10x1000-16 5838 609650 ns/op 393.70 MB/s Benchmark___FanOut_8x10x1000-16 5952 615015 ns/op 390.27 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4855 728249 ns/op 315.85 MB/s Benchmark___FanOut_8x100x100-16 4929 723935 ns/op 317.73 MB/s Benchmark___FanOut_8x100x100-16 4893 726281 ns/op 316.71 MB/s Benchmark___FanOut_8x100x100-16 4902 723294 ns/op 318.02 MB/s Benchmark___FanOut_8x100x100-16 4911 738410 ns/op 311.51 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 568 6303305 ns/op 380.76 MB/s Benchmark__FanOut_8x100x1000-16 552 6399725 ns/op 375.02 MB/s Benchmark__FanOut_8x100x1000-16 556 6372570 ns/op 376.62 MB/s Benchmark__FanOut_8x100x1000-16 570 6329775 ns/op 379.16 MB/s Benchmark__FanOut_8x100x1000-16 552 6382912 ns/op 376.01 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 516 6953681 ns/op 359.52 MB/s Benchmark__FanOut_8x10x10000-16 526 6895937 ns/op 362.54 MB/s Benchmark__FanOut_8x10x10000-16 523 6841625 ns/op 365.41 MB/s Benchmark__FanOut_8x10x10000-16 524 6919442 ns/op 361.30 MB/s Benchmark__FanOut_8x10x10000-16 507 6809140 ns/op 367.16 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 921 3801637 ns/op 302.51 MB/s Benchmark___FanOut_8x500x100-16 933 3812927 ns/op 301.61 MB/s Benchmark___FanOut_8x500x100-16 936 3825206 ns/op 300.64 MB/s Benchmark___FanOut_8x500x100-16 931 3831532 ns/op 300.15 MB/s Benchmark___FanOut_8x500x100-16 925 3839740 ns/op 299.50 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 341383 9573 ns/op 1529.39 MB/s Benchmark___FanOut_128x1x100-16 363181 9623 ns/op 1521.41 MB/s Benchmark___FanOut_128x1x100-16 354840 9672 ns/op 1513.70 MB/s Benchmark___FanOut_128x1x100-16 351548 9647 ns/op 1517.70 MB/s Benchmark___FanOut_128x1x100-16 353365 9631 ns/op 1520.24 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31885 113268 ns/op 1281.39 MB/s Benchmark__FanOut_128x10x100-16 31893 113097 ns/op 1283.34 MB/s Benchmark__FanOut_128x10x100-16 31732 112641 ns/op 1288.53 MB/s Benchmark__FanOut_128x10x100-16 31887 112618 ns/op 1288.79 MB/s Benchmark__FanOut_128x10x100-16 31962 112489 ns/op 1290.27 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4035 891358 ns/op 1638.11 MB/s Benchmark_FanOut_128x10x1000-16 4033 906248 ns/op 1611.19 MB/s Benchmark_FanOut_128x10x1000-16 3962 894108 ns/op 1633.07 MB/s Benchmark_FanOut_128x10x1000-16 3961 892965 ns/op 1635.16 MB/s Benchmark_FanOut_128x10x1000-16 4111 896933 ns/op 1627.93 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3468 1027557 ns/op 1411.25 MB/s Benchmark_FanOut_128x100x100-16 3438 1028757 ns/op 1409.61 MB/s Benchmark_FanOut_128x100x100-16 3463 1027480 ns/op 1411.36 MB/s Benchmark_FanOut_128x100x100-16 3439 1025864 ns/op 1413.58 MB/s Benchmark_FanOut_128x100x100-16 3435 1030923 ns/op 1406.64 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 376 9472864 ns/op 1541.26 MB/s BenchmarkFanOut_128x100x1000-16 376 9516828 ns/op 1534.14 MB/s BenchmarkFanOut_128x100x1000-16 378 9417486 ns/op 1550.32 MB/s BenchmarkFanOut_128x100x1000-16 379 9481267 ns/op 1539.89 MB/s BenchmarkFanOut_128x100x1000-16 376 9518147 ns/op 1533.93 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 366 9848762 ns/op 1492.59 MB/s BenchmarkFanOut_128x10x10000-16 362 9807453 ns/op 1498.87 MB/s BenchmarkFanOut_128x10x10000-16 364 9898646 ns/op 1485.07 MB/s BenchmarkFanOut_128x10x10000-16 367 9811045 ns/op 1498.33 MB/s BenchmarkFanOut_128x10x10000-16 364 9822553 ns/op 1496.57 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 656 5339518 ns/op 1357.83 MB/s BenchmarkFanOut__128x500x100-16 657 5354569 ns/op 1354.01 MB/s BenchmarkFanOut__128x500x100-16 663 5304608 ns/op 1366.76 MB/s BenchmarkFanOut__128x500x100-16 664 5331171 ns/op 1359.95 MB/s BenchmarkFanOut__128x500x100-16 669 5334083 ns/op 1359.21 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1944 1846501 ns/op 2865.16 MB/s Benchmark_FanOut_512x100x100-16 1929 1864167 ns/op 2838.01 MB/s Benchmark_FanOut_512x100x100-16 1953 1853958 ns/op 2853.64 MB/s Benchmark_FanOut_512x100x100-16 1885 1872381 ns/op 2825.56 MB/s Benchmark_FanOut_512x100x100-16 1908 1857597 ns/op 2848.05 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16739249 ns/op 3166.24 MB/s Benchmark__FanOut_512x100x1k-16 213 16823822 ns/op 3150.33 MB/s Benchmark__FanOut_512x100x1k-16 211 16792943 ns/op 3156.12 MB/s Benchmark__FanOut_512x100x1k-16 216 16749991 ns/op 3164.21 MB/s Benchmark__FanOut_512x100x1k-16 212 16903700 ns/op 3135.44 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2930 1174175 ns/op 8883.72 MB/s Benchmark____FanOut_1kx10x1k-16 3231 1146785 ns/op 9095.90 MB/s Benchmark____FanOut_1kx10x1k-16 2926 1166088 ns/op 8945.32 MB/s Benchmark____FanOut_1kx10x1k-16 3198 1153089 ns/op 9046.17 MB/s Benchmark____FanOut_1kx10x1k-16 2862 1154899 ns/op 9031.99 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2722 1284236 ns/op 8114.58 MB/s Benchmark__FanOut_1kx100x100-16 2768 1285736 ns/op 8105.12 MB/s Benchmark__FanOut_1kx100x100-16 2733 1276070 ns/op 8166.51 MB/s Benchmark__FanOut_1kx100x100-16 2738 1275005 ns/op 8173.33 MB/s Benchmark__FanOut_1kx100x100-16 2750 1274407 ns/op 8177.17 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4494919 789.6 ns/op 315.33 MB/s Benchmark_____RFanOut_8x1x10-16 4471635 786.3 ns/op 316.68 MB/s Benchmark_____RFanOut_8x1x10-16 4375837 780.6 ns/op 318.97 MB/s Benchmark_____RFanOut_8x1x10-16 4447726 776.3 ns/op 320.73 MB/s Benchmark_____RFanOut_8x1x10-16 4477057 798.4 ns/op 311.87 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 519873 6137 ns/op 377.90 MB/s Benchmark____RFanOut_8x1x100-16 528184 6264 ns/op 370.23 MB/s Benchmark____RFanOut_8x1x100-16 537612 6189 ns/op 374.67 MB/s Benchmark____RFanOut_8x1x100-16 519884 6194 ns/op 374.42 MB/s Benchmark____RFanOut_8x1x100-16 539722 6238 ns/op 371.76 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47244 75994 ns/op 302.91 MB/s Benchmark___RFanOut_8x10x100-16 47396 77045 ns/op 298.77 MB/s Benchmark___RFanOut_8x10x100-16 47755 76380 ns/op 301.38 MB/s Benchmark___RFanOut_8x10x100-16 46790 76410 ns/op 301.26 MB/s Benchmark___RFanOut_8x10x100-16 47335 76318 ns/op 301.62 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5558 617111 ns/op 388.94 MB/s Benchmark__RFanOut_8x10x1000-16 5635 606509 ns/op 395.74 MB/s Benchmark__RFanOut_8x10x1000-16 5626 610786 ns/op 392.97 MB/s Benchmark__RFanOut_8x10x1000-16 5809 618588 ns/op 388.01 MB/s Benchmark__RFanOut_8x10x1000-16 5763 611755 ns/op 392.35 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4987 717580 ns/op 320.55 MB/s Benchmark__RFanOut_8x100x100-16 4934 717549 ns/op 320.56 MB/s Benchmark__RFanOut_8x100x100-16 4863 722912 ns/op 318.18 MB/s Benchmark__RFanOut_8x100x100-16 4803 715067 ns/op 321.67 MB/s Benchmark__RFanOut_8x100x100-16 4938 730188 ns/op 315.01 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 567 6347836 ns/op 378.08 MB/s Benchmark_RFanOut_8x100x1000-16 561 6448758 ns/op 372.17 MB/s Benchmark_RFanOut_8x100x1000-16 555 6440495 ns/op 372.65 MB/s Benchmark_RFanOut_8x100x1000-16 558 6465965 ns/op 371.18 MB/s Benchmark_RFanOut_8x100x1000-16 546 6512982 ns/op 368.50 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 525 6890411 ns/op 362.83 MB/s Benchmark_RFanOut_8x10x10000-16 528 6888235 ns/op 362.94 MB/s Benchmark_RFanOut_8x10x10000-16 523 7046834 ns/op 354.77 MB/s Benchmark_RFanOut_8x10x10000-16 523 6851570 ns/op 364.88 MB/s Benchmark_RFanOut_8x10x10000-16 507 6802591 ns/op 367.51 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2938 1170411 ns/op 8912.29 MB/s Benchmark_RFanOut_1kx10x1000-16 3237 1149958 ns/op 9070.80 MB/s Benchmark_RFanOut_1kx10x1000-16 3075 1154255 ns/op 9037.03 MB/s Benchmark_RFanOut_1kx10x1000-16 2988 1171814 ns/op 8901.61 MB/s Benchmark_RFanOut_1kx10x1000-16 3231 1154358 ns/op 9036.22 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6898335 504.1 ns/op 4121.96 MB/s Benchmark_____FanIn_1kx100x1-16 6887905 507.0 ns/op 4098.81 MB/s Benchmark_____FanIn_1kx100x1-16 6912812 505.6 ns/op 4110.27 MB/s Benchmark_____FanIn_1kx100x1-16 6990532 504.6 ns/op 4118.15 MB/s Benchmark_____FanIn_1kx100x1-16 7002967 506.0 ns/op 4106.84 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2611833 1383 ns/op 5943.38 MB/s Benchmark_____FanIn_4kx100x1-16 2618296 1376 ns/op 5977.43 MB/s Benchmark_____FanIn_4kx100x1-16 2608120 1366 ns/op 6018.49 MB/s Benchmark_____FanIn_4kx100x1-16 2609650 1387 ns/op 5928.74 MB/s Benchmark_____FanIn_4kx100x1-16 2606574 1369 ns/op 6005.03 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1693332 2125 ns/op 7722.98 MB/s Benchmark_____FanIn_8kx100x1-16 1673455 2104 ns/op 7801.37 MB/s Benchmark_____FanIn_8kx100x1-16 1688083 2119 ns/op 7744.59 MB/s Benchmark_____FanIn_8kx100x1-16 1707818 2104 ns/op 7802.32 MB/s Benchmark_____FanIn_8kx100x1-16 1701243 2129 ns/op 7711.09 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 873304 4181 ns/op 7844.30 MB/s Benchmark____FanIn_16kx100x1-16 864739 4152 ns/op 7900.54 MB/s Benchmark____FanIn_16kx100x1-16 880966 4161 ns/op 7882.45 MB/s Benchmark____FanIn_16kx100x1-16 853666 4165 ns/op 7874.48 MB/s Benchmark____FanIn_16kx100x1-16 864025 4265 ns/op 7690.06 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 172510 19888 ns/op 6592.05 MB/s Benchmark____FanIn_64kx100x1-16 165882 19751 ns/op 6637.81 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 334516959 vs 655530000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48122->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 161970 20085 ns/op 6527.60 MB/s Benchmark____FanIn_64kx100x1-16 165295 19962 ns/op 6567.81 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 410967150 vs 11745664000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46372->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46422->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46538->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46632->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 161765060 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48360->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 292855060 vs 11693228000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:51220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51188->127.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: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:51146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:51786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51308->127.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: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:50992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51412->127.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:51348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51052->127.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:51238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51452->127.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:51698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51120->127.0.0.1:5222: write: connection reset by peer 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:51016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51748->127.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:51670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:51498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51546->127.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:51196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51210->127.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:51158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:51380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51794->127.0.0.1:5222: write: connection reset by peer 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:50956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51756->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: 125977490 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53058->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: 319204150 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54686->127.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:55278->127.0.0.1:5222: write: connection reset by peer 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:54922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:55302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54914->127.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: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:54704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55166->127.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:55012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55058->127.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:55004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54608->127.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:54878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54822->127.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:54946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54900->127.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:55050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54674->127.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:54616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54998->127.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:55014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55348->127.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: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: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:55152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54696->127.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:54680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55362->127.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: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:54832->127.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:54774->127.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:54982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54938->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5511393 648.6 ns/op 437.84 MB/s Benchmark___BumpPubCount_1x3-16 5551920 641.9 ns/op 442.45 MB/s Benchmark___BumpPubCount_1x3-16 5548005 643.1 ns/op 441.61 MB/s Benchmark___BumpPubCount_1x3-16 5524039 643.0 ns/op 441.67 MB/s Benchmark___BumpPubCount_1x3-16 5541783 640.7 ns/op 443.28 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5278593 672.7 ns/op 422.18 MB/s Benchmark___BumpPubCount_2x3-16 5289537 678.8 ns/op 418.37 MB/s Benchmark___BumpPubCount_2x3-16 5307657 674.7 ns/op 420.90 MB/s Benchmark___BumpPubCount_2x3-16 5289423 672.1 ns/op 422.55 MB/s Benchmark___BumpPubCount_2x3-16 5275522 676.9 ns/op 419.53 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5400606 646.0 ns/op 439.65 MB/s Benchmark___BumpPubCount_5x3-16 5448396 647.3 ns/op 438.78 MB/s Benchmark___BumpPubCount_5x3-16 5562709 647.4 ns/op 438.71 MB/s Benchmark___BumpPubCount_5x3-16 5573737 646.3 ns/op 439.44 MB/s Benchmark___BumpPubCount_5x3-16 5544349 647.4 ns/op 438.70 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5580681 644.6 ns/op 440.59 MB/s Benchmark__BumpPubCount_10x3-16 5534941 646.7 ns/op 439.13 MB/s Benchmark__BumpPubCount_10x3-16 5559590 646.5 ns/op 439.30 MB/s Benchmark__BumpPubCount_10x3-16 5555587 643.6 ns/op 441.27 MB/s Benchmark__BumpPubCount_10x3-16 5572230 643.0 ns/op 441.66 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11629555 275.3 ns/op 3777.46 MB/s Benchmark____GWs_Opt_1kx01x0-16 12814650 269.9 ns/op 3853.96 MB/s Benchmark____GWs_Opt_1kx01x0-16 12793713 271.1 ns/op 3836.20 MB/s Benchmark____GWs_Opt_1kx01x0-16 12450574 269.5 ns/op 3858.91 MB/s Benchmark____GWs_Opt_1kx01x0-16 12641108 270.7 ns/op 3841.75 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10422991 342.4 ns/op 6028.17 MB/s Benchmark____GWs_Opt_2kx01x0-16 10417700 337.1 ns/op 6123.25 MB/s Benchmark____GWs_Opt_2kx01x0-16 9289188 346.2 ns/op 5962.08 MB/s Benchmark____GWs_Opt_2kx01x0-16 9952555 345.8 ns/op 5969.19 MB/s Benchmark____GWs_Opt_2kx01x0-16 10586007 339.9 ns/op 6072.56 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5740485 703.9 ns/op 5841.38 MB/s Benchmark____GWs_Opt_4kx01x0-16 5793759 612.1 ns/op 6718.12 MB/s Benchmark____GWs_Opt_4kx01x0-16 5671236 612.3 ns/op 6716.12 MB/s Benchmark____GWs_Opt_4kx01x0-16 5659480 605.2 ns/op 6794.05 MB/s Benchmark____GWs_Opt_4kx01x0-16 5712307 607.7 ns/op 6766.43 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28729732 114.5 ns/op 9080.07 MB/s Benchmark____GWs_Opt_1kx10x0-16 33615955 112.7 ns/op 9230.23 MB/s Benchmark____GWs_Opt_1kx10x0-16 31794312 112.0 ns/op 9286.08 MB/s Benchmark____GWs_Opt_1kx10x0-16 31674908 109.1 ns/op 9531.34 MB/s Benchmark____GWs_Opt_1kx10x0-16 28270209 110.6 ns/op 9400.16 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25070389 172.7 ns/op 11950.28 MB/s Benchmark____GWs_Opt_2kx10x0-16 25659123 154.0 ns/op 13403.89 MB/s Benchmark____GWs_Opt_2kx10x0-16 23972737 153.7 ns/op 13430.41 MB/s Benchmark____GWs_Opt_2kx10x0-16 25372438 141.6 ns/op 14572.39 MB/s Benchmark____GWs_Opt_2kx10x0-16 24974674 168.8 ns/op 12227.42 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11869362 320.1 ns/op 12847.91 MB/s Benchmark____GWs_Opt_4kx10x0-16 11285818 284.3 ns/op 14461.10 MB/s Benchmark____GWs_Opt_4kx10x0-16 12039075 304.8 ns/op 13490.69 MB/s Benchmark____GWs_Opt_4kx10x0-16 12459979 286.1 ns/op 14371.64 MB/s Benchmark____GWs_Opt_4kx10x0-16 11032062 291.0 ns/op 14128.19 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6474639 558.8 ns/op 5592.72 MB/s Benchmark____GWs_Opt_1kx01x1-16 6575524 986.0 ns/op 3169.30 MB/s Benchmark____GWs_Opt_1kx01x1-16 6296635 556.2 ns/op 5618.08 MB/s Benchmark____GWs_Opt_1kx01x1-16 6465926 557.6 ns/op 5604.03 MB/s Benchmark____GWs_Opt_1kx01x1-16 6472816 547.0 ns/op 5713.49 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4443232 758.7 ns/op 8168.40 MB/s Benchmark____GWs_Opt_2kx01x1-16 4475608 807.2 ns/op 7677.34 MB/s Benchmark____GWs_Opt_2kx01x1-16 4663959 755.1 ns/op 8206.69 MB/s Benchmark____GWs_Opt_2kx01x1-16 4561560 802.1 ns/op 7726.07 MB/s Benchmark____GWs_Opt_2kx01x1-16 4461012 770.1 ns/op 8046.50 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2578750 1472 ns/op 8381.60 MB/s Benchmark____GWs_Opt_4kx01x1-16 2604175 1351 ns/op 9136.52 MB/s Benchmark____GWs_Opt_4kx01x1-16 2656196 1366 ns/op 9034.72 MB/s Benchmark____GWs_Opt_4kx01x1-16 2610553 1400 ns/op 8817.58 MB/s Benchmark____GWs_Opt_4kx01x1-16 2527425 1561 ns/op 7907.92 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 5990518 567.2 ns/op 5509.60 MB/s Benchmark____GWs_Opt_1kx10x1-16 6116877 562.3 ns/op 5557.74 MB/s Benchmark____GWs_Opt_1kx10x1-16 6645337 569.6 ns/op 5486.41 MB/s Benchmark____GWs_Opt_1kx10x1-16 6039739 557.7 ns/op 5603.55 MB/s Benchmark____GWs_Opt_1kx10x1-16 6281224 566.9 ns/op 5512.03 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4113590 835.7 ns/op 7415.27 MB/s Benchmark____GWs_Opt_2kx10x1-16 4172047 848.8 ns/op 7301.14 MB/s Benchmark____GWs_Opt_2kx10x1-16 4177503 878.5 ns/op 7054.17 MB/s Benchmark____GWs_Opt_2kx10x1-16 4069467 861.5 ns/op 7193.65 MB/s Benchmark____GWs_Opt_2kx10x1-16 4038199 846.5 ns/op 7320.49 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2382760 1527 ns/op 8080.53 MB/s Benchmark____GWs_Opt_4kx10x1-16 2325889 1537 ns/op 8028.70 MB/s Benchmark____GWs_Opt_4kx10x1-16 2383604 1520 ns/op 8121.18 MB/s Benchmark____GWs_Opt_4kx10x1-16 2304092 1541 ns/op 8008.00 MB/s Benchmark____GWs_Opt_4kx10x1-16 2324070 1543 ns/op 8000.40 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12245383 294.2 ns/op 3534.52 MB/s Benchmark____GWs_Int_1kx01x0-16 12636367 287.8 ns/op 3614.10 MB/s Benchmark____GWs_Int_1kx01x0-16 13036240 288.2 ns/op 3608.20 MB/s Benchmark____GWs_Int_1kx01x0-16 12112882 278.9 ns/op 3729.40 MB/s Benchmark____GWs_Int_1kx01x0-16 12221965 288.7 ns/op 3602.25 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10680097 354.8 ns/op 5817.38 MB/s Benchmark____GWs_Int_2kx01x0-16 9292539 393.4 ns/op 5246.06 MB/s Benchmark____GWs_Int_2kx01x0-16 10494080 351.7 ns/op 5868.45 MB/s Benchmark____GWs_Int_2kx01x0-16 9608388 357.5 ns/op 5773.08 MB/s Benchmark____GWs_Int_2kx01x0-16 10220007 364.1 ns/op 5668.14 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5849224 689.9 ns/op 5959.88 MB/s Benchmark____GWs_Int_4kx01x0-16 6048170 627.9 ns/op 6548.79 MB/s Benchmark____GWs_Int_4kx01x0-16 5743598 628.0 ns/op 6547.31 MB/s Benchmark____GWs_Int_4kx01x0-16 5765509 600.1 ns/op 6852.20 MB/s Benchmark____GWs_Int_4kx01x0-16 5860938 637.8 ns/op 6447.01 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31864611 113.0 ns/op 9207.27 MB/s Benchmark____GWs_Int_1kx10x0-16 30893162 123.5 ns/op 8421.88 MB/s Benchmark____GWs_Int_1kx10x0-16 30667362 111.4 ns/op 9334.91 MB/s Benchmark____GWs_Int_1kx10x0-16 32468367 110.4 ns/op 9421.02 MB/s Benchmark____GWs_Int_1kx10x0-16 30685876 110.1 ns/op 9446.33 MB/s Benchmark____GWs_Int_2kx10x0 bench_test.go:55: Failed read: read tcp 127.0.0.1:36768->127.0.0.1:39553: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 25474713 142.9 ns/op 14442.24 MB/s Benchmark____GWs_Int_2kx10x0-16 25639984 159.3 ns/op 12956.58 MB/s Benchmark____GWs_Int_2kx10x0-16 26196735 144.6 ns/op 14271.92 MB/s Benchmark____GWs_Int_2kx10x0-16 25124432 146.6 ns/op 14081.00 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12197281 295.7 ns/op 13905.47 MB/s Benchmark____GWs_Int_4kx10x0-16 10608782 294.5 ns/op 13963.01 MB/s Benchmark____GWs_Int_4kx10x0-16 13189974 369.2 ns/op 11138.11 MB/s Benchmark____GWs_Int_4kx10x0-16 13132161 322.1 ns/op 12764.70 MB/s Benchmark____GWs_Int_4kx10x0-16 13331250 296.5 ns/op 13869.32 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6339658 559.1 ns/op 5588.86 MB/s Benchmark____GWs_Int_1kx01x1-16 6438736 557.8 ns/op 5601.87 MB/s Benchmark____GWs_Int_1kx01x1-16 6197592 572.1 ns/op 5462.31 MB/s Benchmark____GWs_Int_1kx01x1-16 6413107 561.4 ns/op 5566.72 MB/s Benchmark____GWs_Int_1kx01x1-16 6380210 568.6 ns/op 5496.28 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4113343 773.4 ns/op 8013.18 MB/s Benchmark____GWs_Int_2kx01x1-16 4347387 780.6 ns/op 7938.85 MB/s Benchmark____GWs_Int_2kx01x1-16 4517936 758.0 ns/op 8175.98 MB/s Benchmark____GWs_Int_2kx01x1-16 4753483 780.5 ns/op 7940.20 MB/s Benchmark____GWs_Int_2kx01x1-16 4625318 766.2 ns/op 8088.44 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2561977 1686 ns/op 7320.82 MB/s Benchmark____GWs_Int_4kx01x1-16 2606061 1373 ns/op 8989.26 MB/s Benchmark____GWs_Int_4kx01x1-16 2599869 1379 ns/op 8948.60 MB/s Benchmark____GWs_Int_4kx01x1-16 2434336 1373 ns/op 8991.16 MB/s Benchmark____GWs_Int_4kx01x1-16 2609498 1453 ns/op 8491.55 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6319435 564.4 ns/op 5536.56 MB/s Benchmark____GWs_Int_1kx10x1-16 6264985 563.3 ns/op 5547.31 MB/s Benchmark____GWs_Int_1kx10x1-16 6049923 588.0 ns/op 5315.06 MB/s Benchmark____GWs_Int_1kx10x1-16 6695086 563.4 ns/op 5546.72 MB/s Benchmark____GWs_Int_1kx10x1-16 5972925 564.7 ns/op 5534.25 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4132843 848.4 ns/op 7304.05 MB/s Benchmark____GWs_Int_2kx10x1-16 4205986 839.9 ns/op 7378.11 MB/s Benchmark____GWs_Int_2kx10x1-16 4038919 859.9 ns/op 7206.39 MB/s Benchmark____GWs_Int_2kx10x1-16 4260922 860.4 ns/op 7202.05 MB/s Benchmark____GWs_Int_2kx10x1-16 4029720 846.9 ns/op 7317.69 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2265830 1516 ns/op 8140.10 MB/s Benchmark____GWs_Int_4kx10x1-16 2258872 1547 ns/op 7979.34 MB/s Benchmark____GWs_Int_4kx10x1-16 2274892 1533 ns/op 8049.87 MB/s Benchmark____GWs_Int_4kx10x1-16 2249890 1457 ns/op 8471.81 MB/s Benchmark____GWs_Int_4kx10x1-16 2220585 1539 ns/op 8020.30 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8177728 430.6 ns/op 236.88 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8376844 435.6 ns/op 234.17 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8251718 442.3 ns/op 230.63 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8009047 442.2 ns/op 230.66 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8485159 434.7 ns/op 234.63 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 635401 5080 ns/op 34.84 MB/s Benchmark__GWs_Reqs_1SubEach-16 715974 5164 ns/op 34.27 MB/s Benchmark__GWs_Reqs_1SubEach-16 771584 5303 ns/op 33.38 MB/s Benchmark__GWs_Reqs_1SubEach-16 728653 5234 ns/op 33.82 MB/s Benchmark__GWs_Reqs_1SubEach-16 726463 5269 ns/op 33.60 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2089.863s