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 49302451 77.90 ns/op 141.21 MB/s Benchmark______Pub0b_Payload-16 43798576 71.99 ns/op 152.80 MB/s Benchmark______Pub0b_Payload-16 47368126 75.20 ns/op 146.29 MB/s Benchmark______Pub0b_Payload-16 47645956 71.85 ns/op 153.10 MB/s Benchmark______Pub0b_Payload-16 46959289 71.97 ns/op 152.84 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46743002 72.64 ns/op 261.57 MB/s Benchmark______Pub8b_Payload-16 46664052 73.22 ns/op 259.48 MB/s Benchmark______Pub8b_Payload-16 46482577 72.74 ns/op 261.19 MB/s Benchmark______Pub8b_Payload-16 45375025 72.81 ns/op 260.94 MB/s Benchmark______Pub8b_Payload-16 48532738 75.32 ns/op 252.25 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44416635 76.39 ns/op 575.99 MB/s Benchmark_____Pub32b_Payload-16 45006639 76.38 ns/op 576.04 MB/s Benchmark_____Pub32b_Payload-16 47120457 76.70 ns/op 573.66 MB/s Benchmark_____Pub32b_Payload-16 44835945 77.95 ns/op 564.48 MB/s Benchmark_____Pub32b_Payload-16 44702611 77.63 ns/op 566.82 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38848882 87.17 ns/op 1617.57 MB/s Benchmark____Pub128B_Payload-16 39293888 85.99 ns/op 1639.70 MB/s Benchmark____Pub128B_Payload-16 37784401 87.35 ns/op 1614.12 MB/s Benchmark____Pub128B_Payload-16 39795850 86.10 ns/op 1637.58 MB/s Benchmark____Pub128B_Payload-16 39474925 91.60 ns/op 1539.23 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 32317717 98.16 ns/op 2740.30 MB/s Benchmark____Pub256B_Payload-16 31695525 94.85 ns/op 2836.03 MB/s Benchmark____Pub256B_Payload-16 36741730 98.39 ns/op 2733.90 MB/s Benchmark____Pub256B_Payload-16 35581891 97.37 ns/op 2762.54 MB/s Benchmark____Pub256B_Payload-16 37619310 102.6 ns/op 2621.50 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22618290 136.1 ns/op 7624.39 MB/s Benchmark______Pub1K_Payload-16 24509479 135.7 ns/op 7651.73 MB/s Benchmark______Pub1K_Payload-16 23779552 142.5 ns/op 7283.97 MB/s Benchmark______Pub1K_Payload-16 22694794 153.2 ns/op 6777.32 MB/s Benchmark______Pub1K_Payload-16 23708190 140.6 ns/op 7381.65 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5577260 617.7 ns/op 6654.11 MB/s Benchmark______Pub4K_Payload-16 5387812 632.2 ns/op 6500.81 MB/s Benchmark______Pub4K_Payload-16 5659245 609.4 ns/op 6744.48 MB/s Benchmark______Pub4K_Payload-16 5515687 628.6 ns/op 6538.76 MB/s Benchmark______Pub4K_Payload-16 5349913 622.0 ns/op 6608.18 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2790781 1281 ns/op 6405.35 MB/s Benchmark______Pub8K_Payload-16 2660226 1282 ns/op 6400.58 MB/s Benchmark______Pub8K_Payload-16 2788712 1291 ns/op 6354.61 MB/s Benchmark______Pub8K_Payload-16 2781421 1277 ns/op 6424.25 MB/s Benchmark______Pub8K_Payload-16 2733994 1287 ns/op 6378.16 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 413720 8936 ns/op 3668.73 MB/s Benchmark_____Pub32K_Payload-16 669145 5486 ns/op 5975.87 MB/s Benchmark_____Pub32K_Payload-16 673594 5381 ns/op 6092.79 MB/s Benchmark_____Pub32K_Payload-16 567240 5479 ns/op 5983.19 MB/s Benchmark_____Pub32K_Payload-16 545037 5571 ns/op 5885.02 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32525854 95.47 ns/op 115.22 MB/s Benchmark__AuthPub0b_Payload-16 34329736 92.74 ns/op 118.61 MB/s Benchmark__AuthPub0b_Payload-16 36000314 93.39 ns/op 117.79 MB/s Benchmark__AuthPub0b_Payload-16 36633994 93.19 ns/op 118.03 MB/s Benchmark__AuthPub0b_Payload-16 36702136 95.40 ns/op 115.30 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15430384 228.5 ns/op Benchmark_____________PubSub-16 15550006 229.8 ns/op Benchmark_____________PubSub-16 15742627 229.9 ns/op Benchmark_____________PubSub-16 15434150 228.3 ns/op Benchmark_____________PubSub-16 15385754 228.4 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15412854 226.5 ns/op Benchmark_____PubSubTwoConns-16 15425835 226.3 ns/op Benchmark_____PubSubTwoConns-16 15331034 226.8 ns/op Benchmark_____PubSubTwoConns-16 15645304 226.4 ns/op Benchmark_____PubSubTwoConns-16 15805743 226.8 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42712->127.0.0.1:42463: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52364->127.0.0.1:43813: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59196->127.0.0.1:41997: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33248->127.0.0.1:37833: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41204->127.0.0.1:46097: 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 14260326 248.9 ns/op Benchmark_____PubTwoQueueSub-16 14298492 247.2 ns/op Benchmark_____PubTwoQueueSub-16 14369245 248.2 ns/op Benchmark_____PubTwoQueueSub-16 14275929 247.2 ns/op Benchmark_____PubTwoQueueSub-16 14080014 247.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14185192 247.6 ns/op Benchmark____PubFourQueueSub-16 14309481 248.7 ns/op Benchmark____PubFourQueueSub-16 14232208 247.1 ns/op Benchmark____PubFourQueueSub-16 14578810 247.8 ns/op Benchmark____PubFourQueueSub-16 14423593 247.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14204395 248.8 ns/op Benchmark___PubEightQueueSub-16 14451139 248.6 ns/op Benchmark___PubEightQueueSub-16 14301314 247.5 ns/op Benchmark___PubEightQueueSub-16 14378803 247.4 ns/op Benchmark___PubEightQueueSub-16 14402776 248.0 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22839 156147 ns/op Benchmark_PubSub512kTwoConns-16 23214 154829 ns/op Benchmark_PubSub512kTwoConns-16 23059 156780 ns/op Benchmark_PubSub512kTwoConns-16 23007 156671 ns/op Benchmark_PubSub512kTwoConns-16 22914 157166 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15009316 230.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 14960694 230.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15112692 230.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15092929 230.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 14999276 231.0 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15136108 230.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15224919 229.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15240652 228.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15231692 230.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15250280 230.5 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11678284 312.1 ns/op Benchmark____RoutedPubSub_0b-16 11202796 312.3 ns/op Benchmark____RoutedPubSub_0b-16 11185118 314.3 ns/op Benchmark____RoutedPubSub_0b-16 11401102 316.9 ns/op Benchmark____RoutedPubSub_0b-16 11292835 318.8 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6571720 542.0 ns/op Benchmark____RoutedPubSub_1K-16 6631880 542.1 ns/op Benchmark____RoutedPubSub_1K-16 6484272 542.1 ns/op Benchmark____RoutedPubSub_1K-16 6700446 550.1 ns/op Benchmark____RoutedPubSub_1K-16 6641343 1249 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84367 42486 ns/op Benchmark__RoutedPubSub_100K-16 83938 42641 ns/op Benchmark__RoutedPubSub_100K-16 83053 44173 ns/op Benchmark__RoutedPubSub_100K-16 71601 49108 ns/op Benchmark__RoutedPubSub_100K-16 71304 49728 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9503455 326.5 ns/op Benchmark____Routed2QueueSub-16 9697180 319.8 ns/op Benchmark____Routed2QueueSub-16 9667432 322.7 ns/op Benchmark____Routed2QueueSub-16 9544221 325.0 ns/op Benchmark____Routed2QueueSub-16 9564518 320.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9432007 329.6 ns/op Benchmark____Routed4QueueSub-16 9360332 331.1 ns/op Benchmark____Routed4QueueSub-16 9649594 325.2 ns/op Benchmark____Routed4QueueSub-16 10997104 325.0 ns/op Benchmark____Routed4QueueSub-16 11082272 326.7 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9090133 341.7 ns/op Benchmark____Routed8QueueSub-16 10944636 332.1 ns/op Benchmark____Routed8QueueSub-16 9080892 332.3 ns/op Benchmark____Routed8QueueSub-16 9506074 333.1 ns/op Benchmark____Routed8QueueSub-16 9220976 330.3 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8979547 352.4 ns/op Benchmark___Routed16QueueSub-16 8826775 360.7 ns/op Benchmark___Routed16QueueSub-16 8841722 360.5 ns/op Benchmark___Routed16QueueSub-16 8673945 361.7 ns/op Benchmark___Routed16QueueSub-16 8558559 354.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6306709 555.5 ns/op Benchmark____________RouteCompressOff-16 6439863 552.2 ns/op Benchmark____________RouteCompressOff-16 6313084 551.6 ns/op Benchmark____________RouteCompressOff-16 6417660 550.9 ns/op Benchmark____________RouteCompressOff-16 6461400 555.1 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6290324 559.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6325435 556.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6241453 557.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6473976 551.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6463392 560.5 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6367951 551.7 ns/op Benchmark_________RouteCompressS2Fast-16 6268144 553.3 ns/op Benchmark_________RouteCompressS2Fast-16 6237196 516.0 ns/op Benchmark_________RouteCompressS2Fast-16 6408684 554.5 ns/op Benchmark_________RouteCompressS2Fast-16 6492054 554.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6415821 554.9 ns/op Benchmark_______RouteCompressS2Better-16 6399556 501.8 ns/op Benchmark_______RouteCompressS2Better-16 6328233 550.5 ns/op Benchmark_______RouteCompressS2Better-16 6426296 549.6 ns/op Benchmark_______RouteCompressS2Better-16 6291327 554.8 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6629298 555.8 ns/op Benchmark_________RouteCompressS2Best-16 6472732 554.1 ns/op Benchmark_________RouteCompressS2Best-16 6234878 550.5 ns/op Benchmark_________RouteCompressS2Best-16 6423309 553.2 ns/op Benchmark_________RouteCompressS2Best-16 6511830 550.6 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4617238 772.2 ns/op 322.44 MB/s Benchmark______FanOut_8x1x10-16 4633404 776.6 ns/op 320.61 MB/s Benchmark______FanOut_8x1x10-16 4586242 774.9 ns/op 321.33 MB/s Benchmark______FanOut_8x1x10-16 4604151 778.0 ns/op 320.04 MB/s Benchmark______FanOut_8x1x10-16 4594484 780.9 ns/op 318.87 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 540589 6163 ns/op 376.29 MB/s Benchmark_____FanOut_8x1x100-16 523088 6222 ns/op 372.70 MB/s Benchmark_____FanOut_8x1x100-16 556017 6179 ns/op 375.28 MB/s Benchmark_____FanOut_8x1x100-16 516622 6189 ns/op 374.67 MB/s Benchmark_____FanOut_8x1x100-16 524336 6191 ns/op 374.57 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46678 76930 ns/op 299.22 MB/s Benchmark____FanOut_8x10x100-16 46566 77578 ns/op 296.72 MB/s Benchmark____FanOut_8x10x100-16 46695 76925 ns/op 299.24 MB/s Benchmark____FanOut_8x10x100-16 46293 76978 ns/op 299.03 MB/s Benchmark____FanOut_8x10x100-16 46430 78365 ns/op 293.74 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5409 619997 ns/op 387.13 MB/s Benchmark___FanOut_8x10x1000-16 5686 617601 ns/op 388.63 MB/s Benchmark___FanOut_8x10x1000-16 5317 641917 ns/op 373.91 MB/s Benchmark___FanOut_8x10x1000-16 5710 623697 ns/op 384.83 MB/s Benchmark___FanOut_8x10x1000-16 5503 621520 ns/op 386.18 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4840 732480 ns/op 314.03 MB/s Benchmark___FanOut_8x100x100-16 4798 738175 ns/op 311.61 MB/s Benchmark___FanOut_8x100x100-16 4896 733147 ns/op 313.74 MB/s Benchmark___FanOut_8x100x100-16 4618 734984 ns/op 312.96 MB/s Benchmark___FanOut_8x100x100-16 4872 733421 ns/op 313.62 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 549 6523045 ns/op 367.93 MB/s Benchmark__FanOut_8x100x1000-16 548 6483498 ns/op 370.17 MB/s Benchmark__FanOut_8x100x1000-16 549 6450284 ns/op 372.08 MB/s Benchmark__FanOut_8x100x1000-16 548 6488267 ns/op 369.90 MB/s Benchmark__FanOut_8x100x1000-16 553 6527115 ns/op 367.70 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 513 7020635 ns/op 356.10 MB/s Benchmark__FanOut_8x10x10000-16 517 7072410 ns/op 353.49 MB/s Benchmark__FanOut_8x10x10000-16 504 6884938 ns/op 363.11 MB/s Benchmark__FanOut_8x10x10000-16 514 7012187 ns/op 356.52 MB/s Benchmark__FanOut_8x10x10000-16 501 7080846 ns/op 353.07 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 918 3893814 ns/op 295.35 MB/s Benchmark___FanOut_8x500x100-16 921 3951700 ns/op 291.02 MB/s Benchmark___FanOut_8x500x100-16 925 3870612 ns/op 297.12 MB/s Benchmark___FanOut_8x500x100-16 928 3877131 ns/op 296.62 MB/s Benchmark___FanOut_8x500x100-16 930 3855684 ns/op 298.27 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 355568 9608 ns/op 1523.84 MB/s Benchmark___FanOut_128x1x100-16 350442 9656 ns/op 1516.32 MB/s Benchmark___FanOut_128x1x100-16 369138 9652 ns/op 1516.87 MB/s Benchmark___FanOut_128x1x100-16 336676 9647 ns/op 1517.67 MB/s Benchmark___FanOut_128x1x100-16 363836 9620 ns/op 1521.97 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31850 112237 ns/op 1293.16 MB/s Benchmark__FanOut_128x10x100-16 31957 113034 ns/op 1284.05 MB/s Benchmark__FanOut_128x10x100-16 31744 112917 ns/op 1285.38 MB/s Benchmark__FanOut_128x10x100-16 32002 111985 ns/op 1296.08 MB/s Benchmark__FanOut_128x10x100-16 32035 112499 ns/op 1290.16 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3937 913921 ns/op 1597.67 MB/s Benchmark_FanOut_128x10x1000-16 3664 906138 ns/op 1611.39 MB/s Benchmark_FanOut_128x10x1000-16 3890 906489 ns/op 1610.77 MB/s Benchmark_FanOut_128x10x1000-16 3848 914445 ns/op 1596.75 MB/s Benchmark_FanOut_128x10x1000-16 3998 909552 ns/op 1605.34 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3454 1036688 ns/op 1398.82 MB/s Benchmark_FanOut_128x100x100-16 3420 1033836 ns/op 1402.68 MB/s Benchmark_FanOut_128x100x100-16 3404 1032928 ns/op 1403.91 MB/s Benchmark_FanOut_128x100x100-16 3448 1033738 ns/op 1402.81 MB/s Benchmark_FanOut_128x100x100-16 3420 1030642 ns/op 1407.03 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 370 9673802 ns/op 1509.25 MB/s BenchmarkFanOut_128x100x1000-16 368 9656859 ns/op 1511.89 MB/s BenchmarkFanOut_128x100x1000-16 364 9580166 ns/op 1524.00 MB/s BenchmarkFanOut_128x100x1000-16 367 9538851 ns/op 1530.60 MB/s BenchmarkFanOut_128x100x1000-16 366 9628825 ns/op 1516.30 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 363 10004069 ns/op 1469.42 MB/s BenchmarkFanOut_128x10x10000-16 366 9891748 ns/op 1486.10 MB/s BenchmarkFanOut_128x10x10000-16 364 9830735 ns/op 1495.32 MB/s BenchmarkFanOut_128x10x10000-16 366 9807427 ns/op 1498.88 MB/s BenchmarkFanOut_128x10x10000-16 367 9940008 ns/op 1478.89 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 657 5405604 ns/op 1341.23 MB/s BenchmarkFanOut__128x500x100-16 654 5422605 ns/op 1337.02 MB/s BenchmarkFanOut__128x500x100-16 658 5381546 ns/op 1347.22 MB/s BenchmarkFanOut__128x500x100-16 652 5437640 ns/op 1333.32 MB/s BenchmarkFanOut__128x500x100-16 654 5383718 ns/op 1346.68 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1918 1859554 ns/op 2845.05 MB/s Benchmark_FanOut_512x100x100-16 1939 1853250 ns/op 2854.73 MB/s Benchmark_FanOut_512x100x100-16 1911 1886446 ns/op 2804.49 MB/s Benchmark_FanOut_512x100x100-16 1906 1874502 ns/op 2822.36 MB/s Benchmark_FanOut_512x100x100-16 1908 1858353 ns/op 2846.89 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 211 17127271 ns/op 3094.51 MB/s Benchmark__FanOut_512x100x1k-16 212 17060153 ns/op 3106.69 MB/s Benchmark__FanOut_512x100x1k-16 211 17140028 ns/op 3092.21 MB/s Benchmark__FanOut_512x100x1k-16 213 16867206 ns/op 3142.22 MB/s Benchmark__FanOut_512x100x1k-16 213 16847103 ns/op 3145.97 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2860 1171346 ns/op 8905.18 MB/s Benchmark____FanOut_1kx10x1k-16 3168 1169232 ns/op 8921.27 MB/s Benchmark____FanOut_1kx10x1k-16 3181 1170757 ns/op 8909.65 MB/s Benchmark____FanOut_1kx10x1k-16 2941 1152130 ns/op 9053.70 MB/s Benchmark____FanOut_1kx10x1k-16 3187 1154101 ns/op 9038.24 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2694 1275420 ns/op 8170.67 MB/s Benchmark__FanOut_1kx100x100-16 2696 1286047 ns/op 8103.16 MB/s Benchmark__FanOut_1kx100x100-16 2709 1275528 ns/op 8169.98 MB/s Benchmark__FanOut_1kx100x100-16 2708 1287290 ns/op 8095.33 MB/s Benchmark__FanOut_1kx100x100-16 2792 1276255 ns/op 8165.33 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4406060 800.6 ns/op 311.00 MB/s Benchmark_____RFanOut_8x1x10-16 4437452 803.1 ns/op 310.03 MB/s Benchmark_____RFanOut_8x1x10-16 4409352 805.6 ns/op 309.08 MB/s Benchmark_____RFanOut_8x1x10-16 4394395 796.5 ns/op 312.62 MB/s Benchmark_____RFanOut_8x1x10-16 4408222 795.3 ns/op 313.08 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 542830 6372 ns/op 363.93 MB/s Benchmark____RFanOut_8x1x100-16 537996 6283 ns/op 369.07 MB/s Benchmark____RFanOut_8x1x100-16 520480 6309 ns/op 367.58 MB/s Benchmark____RFanOut_8x1x100-16 523969 6429 ns/op 360.74 MB/s Benchmark____RFanOut_8x1x100-16 501181 6432 ns/op 360.54 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46792 77180 ns/op 298.25 MB/s Benchmark___RFanOut_8x10x100-16 46621 76694 ns/op 300.14 MB/s Benchmark___RFanOut_8x10x100-16 46356 78962 ns/op 291.52 MB/s Benchmark___RFanOut_8x10x100-16 45770 77477 ns/op 297.11 MB/s Benchmark___RFanOut_8x10x100-16 46659 77715 ns/op 296.20 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5626 626441 ns/op 383.15 MB/s Benchmark__RFanOut_8x10x1000-16 5503 621803 ns/op 386.00 MB/s Benchmark__RFanOut_8x10x1000-16 5511 622623 ns/op 385.50 MB/s Benchmark__RFanOut_8x10x1000-16 5422 623672 ns/op 384.85 MB/s Benchmark__RFanOut_8x10x1000-16 5650 628301 ns/op 382.01 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4762 732046 ns/op 314.21 MB/s Benchmark__RFanOut_8x100x100-16 4825 729549 ns/op 315.29 MB/s Benchmark__RFanOut_8x100x100-16 4916 729938 ns/op 315.12 MB/s Benchmark__RFanOut_8x100x100-16 4818 725059 ns/op 317.24 MB/s Benchmark__RFanOut_8x100x100-16 4866 722591 ns/op 318.33 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 553 6469361 ns/op 370.98 MB/s Benchmark_RFanOut_8x100x1000-16 546 6610993 ns/op 363.03 MB/s Benchmark_RFanOut_8x100x1000-16 556 6588070 ns/op 364.30 MB/s Benchmark_RFanOut_8x100x1000-16 555 6445208 ns/op 372.37 MB/s Benchmark_RFanOut_8x100x1000-16 524 6503944 ns/op 369.01 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 512 7069703 ns/op 353.62 MB/s Benchmark_RFanOut_8x10x10000-16 501 6937583 ns/op 360.36 MB/s Benchmark_RFanOut_8x10x10000-16 508 6901664 ns/op 362.23 MB/s Benchmark_RFanOut_8x10x10000-16 506 6934950 ns/op 360.50 MB/s Benchmark_RFanOut_8x10x10000-16 508 7047746 ns/op 354.73 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3139 1161392 ns/op 8981.49 MB/s Benchmark_RFanOut_1kx10x1000-16 3068 1144378 ns/op 9115.03 MB/s Benchmark_RFanOut_1kx10x1000-16 3130 1181075 ns/op 8831.81 MB/s Benchmark_RFanOut_1kx10x1000-16 3061 1168625 ns/op 8925.91 MB/s Benchmark_RFanOut_1kx10x1000-16 2919 1187353 ns/op 8785.12 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6978650 506.2 ns/op 4105.47 MB/s Benchmark_____FanIn_1kx100x1-16 6891094 508.2 ns/op 4088.81 MB/s Benchmark_____FanIn_1kx100x1-16 6972852 506.7 ns/op 4100.65 MB/s Benchmark_____FanIn_1kx100x1-16 6977223 506.0 ns/op 4106.51 MB/s Benchmark_____FanIn_1kx100x1-16 6899035 508.0 ns/op 4090.34 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2573329 1398 ns/op 5880.04 MB/s Benchmark_____FanIn_4kx100x1-16 2648610 1358 ns/op 6052.60 MB/s Benchmark_____FanIn_4kx100x1-16 2561346 1374 ns/op 5985.59 MB/s Benchmark_____FanIn_4kx100x1-16 2630168 1365 ns/op 6021.96 MB/s Benchmark_____FanIn_4kx100x1-16 2562205 1352 ns/op 6080.86 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1688690 2126 ns/op 7719.06 MB/s Benchmark_____FanIn_8kx100x1-16 1697756 2120 ns/op 7743.93 MB/s Benchmark_____FanIn_8kx100x1-16 1697314 2121 ns/op 7738.55 MB/s Benchmark_____FanIn_8kx100x1-16 1696690 2130 ns/op 7705.41 MB/s Benchmark_____FanIn_8kx100x1-16 1677954 2131 ns/op 7703.84 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 852651 4201 ns/op 7808.11 MB/s Benchmark____FanIn_16kx100x1-16 865636 4182 ns/op 7842.89 MB/s Benchmark____FanIn_16kx100x1-16 885475 4203 ns/op 7804.35 MB/s Benchmark____FanIn_16kx100x1-16 873186 4171 ns/op 7863.61 MB/s Benchmark____FanIn_16kx100x1-16 845876 4115 ns/op 7971.44 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 167911 19949 ns/op 6572.03 MB/s Benchmark____FanIn_64kx100x1-16 171918 20136 ns/op 6510.81 MB/s Benchmark____FanIn_64kx100x1-16 165972 19784 ns/op 6626.76 MB/s Benchmark____FanIn_64kx100x1-16 180396 20005 ns/op 6553.70 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 210162918 vs 655530000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58698->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58840->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: 759797640 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60362->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: 149704780 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33880->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:34070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33396->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33630->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33596->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: 1038232800 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35516->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: 603669450 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37172->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: 105920720 vs 11352394000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40016->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5446922 646.6 ns/op 439.21 MB/s Benchmark___BumpPubCount_1x3-16 5486646 643.7 ns/op 441.22 MB/s Benchmark___BumpPubCount_1x3-16 5505002 649.1 ns/op 437.55 MB/s Benchmark___BumpPubCount_1x3-16 5535322 651.2 ns/op 436.12 MB/s Benchmark___BumpPubCount_1x3-16 5502506 652.9 ns/op 434.97 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5195754 684.9 ns/op 414.66 MB/s Benchmark___BumpPubCount_2x3-16 5223860 682.8 ns/op 415.96 MB/s Benchmark___BumpPubCount_2x3-16 5230154 683.2 ns/op 415.68 MB/s Benchmark___BumpPubCount_2x3-16 5170663 684.2 ns/op 415.08 MB/s Benchmark___BumpPubCount_2x3-16 5170736 683.9 ns/op 415.25 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5495155 649.9 ns/op 436.98 MB/s Benchmark___BumpPubCount_5x3-16 5478643 659.2 ns/op 430.85 MB/s Benchmark___BumpPubCount_5x3-16 5463043 654.7 ns/op 433.79 MB/s Benchmark___BumpPubCount_5x3-16 5491448 650.2 ns/op 436.77 MB/s Benchmark___BumpPubCount_5x3-16 5291199 655.5 ns/op 433.28 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5534029 649.7 ns/op 437.15 MB/s Benchmark__BumpPubCount_10x3-16 5547344 649.2 ns/op 437.48 MB/s Benchmark__BumpPubCount_10x3-16 4757220 650.2 ns/op 436.76 MB/s Benchmark__BumpPubCount_10x3-16 5512366 648.5 ns/op 437.95 MB/s Benchmark__BumpPubCount_10x3-16 5500033 651.0 ns/op 436.28 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11768665 276.4 ns/op 3762.19 MB/s Benchmark____GWs_Opt_1kx01x0-16 12184191 271.6 ns/op 3828.52 MB/s Benchmark____GWs_Opt_1kx01x0-16 13059882 281.4 ns/op 3695.93 MB/s Benchmark____GWs_Opt_1kx01x0-16 12825831 274.8 ns/op 3783.91 MB/s Benchmark____GWs_Opt_1kx01x0-16 12748602 279.4 ns/op 3722.56 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9913675 344.7 ns/op 5987.77 MB/s Benchmark____GWs_Opt_2kx01x0-16 9466570 331.0 ns/op 6235.60 MB/s Benchmark____GWs_Opt_2kx01x0-16 10817620 345.6 ns/op 5972.96 MB/s Benchmark____GWs_Opt_2kx01x0-16 9892432 332.9 ns/op 6200.00 MB/s Benchmark____GWs_Opt_2kx01x0-16 10416373 354.4 ns/op 5824.15 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5959951 628.7 ns/op 6540.06 MB/s Benchmark____GWs_Opt_4kx01x0-16 5350690 636.8 ns/op 6456.91 MB/s Benchmark____GWs_Opt_4kx01x0-16 5884839 676.7 ns/op 6076.66 MB/s Benchmark____GWs_Opt_4kx01x0-16 5677411 612.2 ns/op 6716.89 MB/s Benchmark____GWs_Opt_4kx01x0-16 5844397 622.5 ns/op 6605.96 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28121017 120.6 ns/op 8623.51 MB/s Benchmark____GWs_Opt_1kx10x0-16 28936645 112.4 ns/op 9252.45 MB/s Benchmark____GWs_Opt_1kx10x0-16 32104669 109.4 ns/op 9510.13 MB/s Benchmark____GWs_Opt_1kx10x0-16 28013712 111.0 ns/op 9372.17 MB/s Benchmark____GWs_Opt_1kx10x0-16 20390516 150.0 ns/op 6932.25 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23895804 158.6 ns/op 13010.83 MB/s Benchmark____GWs_Opt_2kx10x0-16 25181061 146.3 ns/op 14112.28 MB/s Benchmark____GWs_Opt_2kx10x0-16 25374048 140.9 ns/op 14650.07 MB/s Benchmark____GWs_Opt_2kx10x0-16 24195656 161.2 ns/op 12800.13 MB/s Benchmark____GWs_Opt_2kx10x0-16 25126706 162.9 ns/op 12667.87 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12682334 302.6 ns/op 13589.43 MB/s Benchmark____GWs_Opt_4kx10x0-16 12718177 378.6 ns/op 10861.59 MB/s Benchmark____GWs_Opt_4kx10x0-16 12500521 294.9 ns/op 13942.73 MB/s Benchmark____GWs_Opt_4kx10x0-16 11884441 303.6 ns/op 13545.55 MB/s Benchmark____GWs_Opt_4kx10x0-16 12848917 299.6 ns/op 13727.21 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6543958 548.6 ns/op 5696.46 MB/s Benchmark____GWs_Opt_1kx01x1-16 6488460 546.5 ns/op 5718.19 MB/s Benchmark____GWs_Opt_1kx01x1-16 6517603 546.0 ns/op 5723.41 MB/s Benchmark____GWs_Opt_1kx01x1-16 6420385 554.3 ns/op 5638.05 MB/s Benchmark____GWs_Opt_1kx01x1-16 6468172 553.3 ns/op 5648.44 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4571626 782.2 ns/op 7922.21 MB/s Benchmark____GWs_Opt_2kx01x1-16 4621081 783.3 ns/op 7911.58 MB/s Benchmark____GWs_Opt_2kx01x1-16 4161132 862.0 ns/op 7188.86 MB/s Benchmark____GWs_Opt_2kx01x1-16 4704216 777.4 ns/op 7971.47 MB/s Benchmark____GWs_Opt_2kx01x1-16 4600815 765.2 ns/op 8098.10 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 1000000 3407 ns/op 3622.22 MB/s Benchmark____GWs_Opt_4kx01x1-16 2611194 1379 ns/op 8946.42 MB/s Benchmark____GWs_Opt_4kx01x1-16 2649774 1401 ns/op 8805.89 MB/s Benchmark____GWs_Opt_4kx01x1-16 2519888 1372 ns/op 8994.58 MB/s Benchmark____GWs_Opt_4kx01x1-16 2558470 1384 ns/op 8916.26 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6561103 558.3 ns/op 5597.04 MB/s Benchmark____GWs_Opt_1kx10x1-16 6094190 565.2 ns/op 5528.93 MB/s Benchmark____GWs_Opt_1kx10x1-16 6143554 568.6 ns/op 5496.24 MB/s Benchmark____GWs_Opt_1kx10x1-16 6170990 553.8 ns/op 5642.59 MB/s Benchmark____GWs_Opt_1kx10x1-16 5784884 562.8 ns/op 5553.08 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 3993139 856.5 ns/op 7235.23 MB/s Benchmark____GWs_Opt_2kx10x1-16 4033390 850.8 ns/op 7283.67 MB/s Benchmark____GWs_Opt_2kx10x1-16 4065950 942.7 ns/op 6573.50 MB/s Benchmark____GWs_Opt_2kx10x1-16 4194532 831.8 ns/op 7449.77 MB/s Benchmark____GWs_Opt_2kx10x1-16 4136625 843.9 ns/op 7342.95 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2356370 1561 ns/op 7906.52 MB/s Benchmark____GWs_Opt_4kx10x1-16 2274324 1502 ns/op 8213.80 MB/s Benchmark____GWs_Opt_4kx10x1-16 2169870 1556 ns/op 7930.94 MB/s Benchmark____GWs_Opt_4kx10x1-16 2300376 1536 ns/op 8036.94 MB/s Benchmark____GWs_Opt_4kx10x1-16 2301224 1544 ns/op 7994.69 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 13077640 289.6 ns/op 3591.51 MB/s Benchmark____GWs_Int_1kx01x0-16 12306489 306.6 ns/op 3392.13 MB/s Benchmark____GWs_Int_1kx01x0-16 11929726 286.8 ns/op 3626.69 MB/s Benchmark____GWs_Int_1kx01x0-16 12062872 292.4 ns/op 3556.77 MB/s Benchmark____GWs_Int_1kx01x0-16 11345656 282.7 ns/op 3679.40 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9512341 358.2 ns/op 5762.69 MB/s Benchmark____GWs_Int_2kx01x0-16 9097057 365.5 ns/op 5646.32 MB/s Benchmark____GWs_Int_2kx01x0-16 9950935 362.4 ns/op 5696.04 MB/s Benchmark____GWs_Int_2kx01x0-16 10089703 360.6 ns/op 5724.44 MB/s Benchmark____GWs_Int_2kx01x0-16 9255926 354.1 ns/op 5828.13 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5729290 642.7 ns/op 6398.42 MB/s Benchmark____GWs_Int_4kx01x0-16 5874399 635.9 ns/op 6466.25 MB/s Benchmark____GWs_Int_4kx01x0-16 5698886 647.9 ns/op 6346.33 MB/s Benchmark____GWs_Int_4kx01x0-16 5912318 631.0 ns/op 6516.53 MB/s Benchmark____GWs_Int_4kx01x0-16 5617447 631.7 ns/op 6509.37 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31141627 112.3 ns/op 9262.20 MB/s Benchmark____GWs_Int_1kx10x0-16 32601908 107.7 ns/op 9660.31 MB/s Benchmark____GWs_Int_1kx10x0-16 32502567 105.9 ns/op 9818.43 MB/s Benchmark____GWs_Int_1kx10x0-16 25853007 119.8 ns/op 8681.01 MB/s Benchmark____GWs_Int_1kx10x0-16 30452346 109.8 ns/op 9469.52 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24703226 154.2 ns/op 13387.55 MB/s Benchmark____GWs_Int_2kx10x0-16 25847536 145.5 ns/op 14183.16 MB/s Benchmark____GWs_Int_2kx10x0-16 25749937 151.2 ns/op 13654.54 MB/s Benchmark____GWs_Int_2kx10x0-16 25997818 144.8 ns/op 14254.93 MB/s Benchmark____GWs_Int_2kx10x0-16 22986027 162.2 ns/op 12728.64 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12764175 301.1 ns/op 13658.70 MB/s Benchmark____GWs_Int_4kx10x0-16 12854763 277.1 ns/op 14837.14 MB/s Benchmark____GWs_Int_4kx10x0-16 12700344 325.2 ns/op 12643.02 MB/s Benchmark____GWs_Int_4kx10x0-16 11339235 303.3 ns/op 13558.68 MB/s Benchmark____GWs_Int_4kx10x0-16 11964092 324.1 ns/op 12687.05 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6365880 563.4 ns/op 5546.86 MB/s Benchmark____GWs_Int_1kx01x1-16 6304039 558.9 ns/op 5591.75 MB/s Benchmark____GWs_Int_1kx01x1-16 6481590 561.0 ns/op 5570.78 MB/s Benchmark____GWs_Int_1kx01x1-16 6397770 560.6 ns/op 5574.66 MB/s Benchmark____GWs_Int_1kx01x1-16 6599714 554.0 ns/op 5641.06 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4670133 768.4 ns/op 8064.85 MB/s Benchmark____GWs_Int_2kx01x1-16 4644884 965.1 ns/op 6421.12 MB/s Benchmark____GWs_Int_2kx01x1-16 4633875 781.9 ns/op 7925.81 MB/s Benchmark____GWs_Int_2kx01x1-16 4298858 776.6 ns/op 7979.46 MB/s Benchmark____GWs_Int_2kx01x1-16 4516452 784.4 ns/op 7900.40 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2610720 1566 ns/op 7881.63 MB/s Benchmark____GWs_Int_4kx01x1-16 2634800 1383 ns/op 8921.44 MB/s Benchmark____GWs_Int_4kx01x1-16 2248978 1392 ns/op 8868.73 MB/s Benchmark____GWs_Int_4kx01x1-16 2619373 1374 ns/op 8979.98 MB/s Benchmark____GWs_Int_4kx01x1-16 2574207 1376 ns/op 8967.96 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6164964 564.1 ns/op 5540.06 MB/s Benchmark____GWs_Int_1kx10x1-16 6153633 557.2 ns/op 5607.91 MB/s Benchmark____GWs_Int_1kx10x1-16 6102409 557.1 ns/op 5609.63 MB/s Benchmark____GWs_Int_1kx10x1-16 6105447 564.8 ns/op 5533.07 MB/s Benchmark____GWs_Int_1kx10x1-16 5970034 558.6 ns/op 5594.18 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3999795 855.1 ns/op 7246.77 MB/s Benchmark____GWs_Int_2kx10x1-16 4111130 855.9 ns/op 7240.40 MB/s Benchmark____GWs_Int_2kx10x1-16 4116828 868.7 ns/op 7133.46 MB/s Benchmark____GWs_Int_2kx10x1-16 4000188 883.4 ns/op 7015.23 MB/s Benchmark____GWs_Int_2kx10x1-16 4046548 859.8 ns/op 7207.47 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2306424 1546 ns/op 7984.95 MB/s Benchmark____GWs_Int_4kx10x1-16 2428282 1691 ns/op 7296.73 MB/s Benchmark____GWs_Int_4kx10x1-16 2341272 1545 ns/op 7987.89 MB/s Benchmark____GWs_Int_4kx10x1-16 2322428 1651 ns/op 7475.64 MB/s Benchmark____GWs_Int_4kx10x1-16 2328188 1533 ns/op 8051.86 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8001990 435.2 ns/op 234.38 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8069587 438.4 ns/op 232.67 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8176178 444.6 ns/op 229.44 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8186001 443.5 ns/op 229.97 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8042778 439.2 ns/op 232.24 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 609805 5057 ns/op 35.00 MB/s Benchmark__GWs_Reqs_1SubEach-16 778288 5257 ns/op 33.67 MB/s Benchmark__GWs_Reqs_1SubEach-16 729352 5202 ns/op 34.03 MB/s Benchmark__GWs_Reqs_1SubEach-16 723477 5365 ns/op 32.99 MB/s Benchmark__GWs_Reqs_1SubEach-16 778189 5306 ns/op 33.36 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2070.241s