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 49372772 72.01 ns/op 152.77 MB/s Benchmark______Pub0b_Payload-16 47597262 72.47 ns/op 151.80 MB/s Benchmark______Pub0b_Payload-16 49954389 72.28 ns/op 152.18 MB/s Benchmark______Pub0b_Payload-16 47007842 72.05 ns/op 152.67 MB/s Benchmark______Pub0b_Payload-16 47402646 71.94 ns/op 152.90 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46584070 75.78 ns/op 250.74 MB/s Benchmark______Pub8b_Payload-16 46733542 72.88 ns/op 260.71 MB/s Benchmark______Pub8b_Payload-16 46557052 73.61 ns/op 258.10 MB/s Benchmark______Pub8b_Payload-16 46742860 72.57 ns/op 261.83 MB/s Benchmark______Pub8b_Payload-16 46279953 72.69 ns/op 261.37 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 41190783 76.83 ns/op 572.69 MB/s Benchmark_____Pub32b_Payload-16 44575753 77.38 ns/op 568.64 MB/s Benchmark_____Pub32b_Payload-16 44472814 76.76 ns/op 573.22 MB/s Benchmark_____Pub32b_Payload-16 44970852 77.74 ns/op 565.98 MB/s Benchmark_____Pub32b_Payload-16 46886922 76.67 ns/op 573.90 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39612796 87.19 ns/op 1617.25 MB/s Benchmark____Pub128B_Payload-16 41978901 85.58 ns/op 1647.55 MB/s Benchmark____Pub128B_Payload-16 38842857 85.47 ns/op 1649.62 MB/s Benchmark____Pub128B_Payload-16 39269422 87.61 ns/op 1609.46 MB/s Benchmark____Pub128B_Payload-16 39924376 85.29 ns/op 1653.22 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35777517 94.97 ns/op 2832.36 MB/s Benchmark____Pub256B_Payload-16 35462872 94.21 ns/op 2855.33 MB/s Benchmark____Pub256B_Payload-16 36739579 94.20 ns/op 2855.56 MB/s Benchmark____Pub256B_Payload-16 31337931 97.15 ns/op 2768.97 MB/s Benchmark____Pub256B_Payload-16 36694638 97.36 ns/op 2763.04 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23511295 145.8 ns/op 7121.53 MB/s Benchmark______Pub1K_Payload-16 25398187 150.0 ns/op 6921.47 MB/s Benchmark______Pub1K_Payload-16 26520362 138.8 ns/op 7479.27 MB/s Benchmark______Pub1K_Payload-16 25758740 143.0 ns/op 7256.40 MB/s Benchmark______Pub1K_Payload-16 26029837 150.3 ns/op 6904.87 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5785123 618.6 ns/op 6644.23 MB/s Benchmark______Pub4K_Payload-16 5317333 641.0 ns/op 6411.76 MB/s Benchmark______Pub4K_Payload-16 5539446 619.6 ns/op 6633.50 MB/s Benchmark______Pub4K_Payload-16 5300644 675.1 ns/op 6087.70 MB/s Benchmark______Pub4K_Payload-16 5147640 622.7 ns/op 6599.91 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2806514 1275 ns/op 6434.03 MB/s Benchmark______Pub8K_Payload-16 2790682 1280 ns/op 6413.16 MB/s Benchmark______Pub8K_Payload-16 2703048 1291 ns/op 6356.84 MB/s Benchmark______Pub8K_Payload-16 2801181 1286 ns/op 6381.08 MB/s Benchmark______Pub8K_Payload-16 2796211 1273 ns/op 6448.68 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 643008 5391 ns/op 6081.11 MB/s Benchmark_____Pub32K_Payload-16 660991 5538 ns/op 5919.37 MB/s Benchmark_____Pub32K_Payload-16 647562 6544 ns/op 5009.87 MB/s Benchmark_____Pub32K_Payload-16 658878 5321 ns/op 6161.63 MB/s Benchmark_____Pub32K_Payload-16 676978 6798 ns/op 4822.50 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32594055 92.81 ns/op 118.52 MB/s Benchmark__AuthPub0b_Payload-16 33113779 92.53 ns/op 118.87 MB/s Benchmark__AuthPub0b_Payload-16 36914744 92.80 ns/op 118.54 MB/s Benchmark__AuthPub0b_Payload-16 36663722 92.48 ns/op 118.94 MB/s Benchmark__AuthPub0b_Payload-16 36866040 92.49 ns/op 118.93 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15842528 225.7 ns/op Benchmark_____________PubSub-16 15480528 226.3 ns/op Benchmark_____________PubSub-16 15612856 225.8 ns/op Benchmark_____________PubSub-16 15768303 226.2 ns/op Benchmark_____________PubSub-16 15765553 227.2 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15658486 224.2 ns/op Benchmark_____PubSubTwoConns-16 15799166 225.2 ns/op Benchmark_____PubSubTwoConns-16 15716635 223.9 ns/op Benchmark_____PubSubTwoConns-16 15880370 228.6 ns/op Benchmark_____PubSubTwoConns-16 15793206 224.8 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51614->127.0.0.1:42061: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45374->127.0.0.1:39029: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46600->127.0.0.1:37615: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57454->127.0.0.1:41233: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41084->127.0.0.1:42717: 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 14476467 242.9 ns/op Benchmark_____PubTwoQueueSub-16 14549394 243.0 ns/op Benchmark_____PubTwoQueueSub-16 14642226 243.0 ns/op Benchmark_____PubTwoQueueSub-16 14602909 243.4 ns/op Benchmark_____PubTwoQueueSub-16 14433986 243.3 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14552184 243.7 ns/op Benchmark____PubFourQueueSub-16 14568932 243.8 ns/op Benchmark____PubFourQueueSub-16 14697048 242.6 ns/op Benchmark____PubFourQueueSub-16 14578905 242.8 ns/op Benchmark____PubFourQueueSub-16 14567581 242.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14275232 242.4 ns/op Benchmark___PubEightQueueSub-16 14693376 243.7 ns/op Benchmark___PubEightQueueSub-16 14642674 243.2 ns/op Benchmark___PubEightQueueSub-16 14533066 243.6 ns/op Benchmark___PubEightQueueSub-16 14586548 243.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23322 155443 ns/op Benchmark_PubSub512kTwoConns-16 23257 154000 ns/op Benchmark_PubSub512kTwoConns-16 23166 154951 ns/op Benchmark_PubSub512kTwoConns-16 23044 155490 ns/op Benchmark_PubSub512kTwoConns-16 23046 155437 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15415798 228.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15296582 228.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15386058 228.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15387338 227.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15156370 227.6 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15257116 229.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15290268 228.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15268561 228.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15297684 228.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 15283492 229.2 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11172404 314.8 ns/op Benchmark____RoutedPubSub_0b-16 11702325 312.4 ns/op Benchmark____RoutedPubSub_0b-16 11180020 314.1 ns/op Benchmark____RoutedPubSub_0b-16 11051808 312.0 ns/op Benchmark____RoutedPubSub_0b-16 11008666 308.2 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6518888 543.4 ns/op Benchmark____RoutedPubSub_1K-16 6388624 541.9 ns/op Benchmark____RoutedPubSub_1K-16 6562824 533.4 ns/op Benchmark____RoutedPubSub_1K-16 6598719 536.9 ns/op Benchmark____RoutedPubSub_1K-16 6477192 533.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85255 44967 ns/op Benchmark__RoutedPubSub_100K-16 74947 49222 ns/op Benchmark__RoutedPubSub_100K-16 75423 49240 ns/op Benchmark__RoutedPubSub_100K-16 72728 47782 ns/op Benchmark__RoutedPubSub_100K-16 72124 48922 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9708829 315.6 ns/op Benchmark____Routed2QueueSub-16 9778867 322.8 ns/op Benchmark____Routed2QueueSub-16 9871006 315.0 ns/op Benchmark____Routed2QueueSub-16 9616959 318.4 ns/op Benchmark____Routed2QueueSub-16 9833492 312.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9502056 323.3 ns/op Benchmark____Routed4QueueSub-16 11362992 311.2 ns/op Benchmark____Routed4QueueSub-16 9663468 320.3 ns/op Benchmark____Routed4QueueSub-16 9973749 320.9 ns/op Benchmark____Routed4QueueSub-16 9576871 324.1 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9331089 331.0 ns/op Benchmark____Routed8QueueSub-16 11070992 328.1 ns/op Benchmark____Routed8QueueSub-16 11184236 335.6 ns/op Benchmark____Routed8QueueSub-16 9638434 329.8 ns/op Benchmark____Routed8QueueSub-16 11168500 329.8 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8848624 343.1 ns/op Benchmark___Routed16QueueSub-16 8858782 342.2 ns/op Benchmark___Routed16QueueSub-16 8851932 342.9 ns/op Benchmark___Routed16QueueSub-16 10426348 349.4 ns/op Benchmark___Routed16QueueSub-16 8887854 338.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6505646 547.4 ns/op Benchmark____________RouteCompressOff-16 6450326 553.6 ns/op Benchmark____________RouteCompressOff-16 6323133 549.5 ns/op Benchmark____________RouteCompressOff-16 6458342 550.2 ns/op Benchmark____________RouteCompressOff-16 6501757 554.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6509624 553.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6635088 554.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6397062 553.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6336637 540.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6457093 543.1 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6421176 553.8 ns/op Benchmark_________RouteCompressS2Fast-16 6680948 548.3 ns/op Benchmark_________RouteCompressS2Fast-16 6411248 554.6 ns/op Benchmark_________RouteCompressS2Fast-16 6207289 551.3 ns/op Benchmark_________RouteCompressS2Fast-16 6426261 543.9 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6468026 549.5 ns/op Benchmark_______RouteCompressS2Better-16 6572217 550.2 ns/op Benchmark_______RouteCompressS2Better-16 6439994 540.7 ns/op Benchmark_______RouteCompressS2Better-16 6470222 553.9 ns/op Benchmark_______RouteCompressS2Better-16 6645452 547.8 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6398007 553.2 ns/op Benchmark_________RouteCompressS2Best-16 6532663 557.0 ns/op Benchmark_________RouteCompressS2Best-16 6533887 550.8 ns/op Benchmark_________RouteCompressS2Best-16 6398386 543.8 ns/op Benchmark_________RouteCompressS2Best-16 6396150 548.7 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4596782 770.7 ns/op 323.08 MB/s Benchmark______FanOut_8x1x10-16 4607632 770.2 ns/op 323.28 MB/s Benchmark______FanOut_8x1x10-16 4596562 775.1 ns/op 321.25 MB/s Benchmark______FanOut_8x1x10-16 4640361 773.9 ns/op 321.75 MB/s Benchmark______FanOut_8x1x10-16 4599392 775.4 ns/op 321.14 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 534697 6167 ns/op 376.01 MB/s Benchmark_____FanOut_8x1x100-16 533800 6156 ns/op 376.69 MB/s Benchmark_____FanOut_8x1x100-16 549486 6130 ns/op 378.29 MB/s Benchmark_____FanOut_8x1x100-16 535584 6138 ns/op 377.79 MB/s Benchmark_____FanOut_8x1x100-16 555476 6107 ns/op 379.75 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47810 75754 ns/op 303.87 MB/s Benchmark____FanOut_8x10x100-16 47871 74948 ns/op 307.13 MB/s Benchmark____FanOut_8x10x100-16 48002 75037 ns/op 306.77 MB/s Benchmark____FanOut_8x10x100-16 47404 75176 ns/op 306.20 MB/s Benchmark____FanOut_8x10x100-16 47450 74823 ns/op 307.65 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5740 604230 ns/op 397.23 MB/s Benchmark___FanOut_8x10x1000-16 5876 602481 ns/op 398.38 MB/s Benchmark___FanOut_8x10x1000-16 5604 617778 ns/op 388.52 MB/s Benchmark___FanOut_8x10x1000-16 5752 605587 ns/op 396.34 MB/s Benchmark___FanOut_8x10x1000-16 5948 602107 ns/op 398.63 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4948 711091 ns/op 323.47 MB/s Benchmark___FanOut_8x100x100-16 5000 712304 ns/op 322.92 MB/s Benchmark___FanOut_8x100x100-16 4878 713527 ns/op 322.37 MB/s Benchmark___FanOut_8x100x100-16 4978 711454 ns/op 323.31 MB/s Benchmark___FanOut_8x100x100-16 5079 710039 ns/op 323.95 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 582 6208270 ns/op 386.58 MB/s Benchmark__FanOut_8x100x1000-16 582 6263266 ns/op 383.19 MB/s Benchmark__FanOut_8x100x1000-16 570 6252082 ns/op 383.88 MB/s Benchmark__FanOut_8x100x1000-16 570 6171814 ns/op 388.87 MB/s Benchmark__FanOut_8x100x1000-16 570 6189784 ns/op 387.74 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 512 6831612 ns/op 365.95 MB/s Benchmark__FanOut_8x10x10000-16 534 6692515 ns/op 373.55 MB/s Benchmark__FanOut_8x10x10000-16 517 6812810 ns/op 366.96 MB/s Benchmark__FanOut_8x10x10000-16 519 6794910 ns/op 367.93 MB/s Benchmark__FanOut_8x10x10000-16 519 6808249 ns/op 367.20 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 945 3770098 ns/op 305.04 MB/s Benchmark___FanOut_8x500x100-16 952 3795024 ns/op 303.03 MB/s Benchmark___FanOut_8x500x100-16 937 3779761 ns/op 304.26 MB/s Benchmark___FanOut_8x500x100-16 940 3789740 ns/op 303.46 MB/s Benchmark___FanOut_8x500x100-16 942 3770875 ns/op 304.97 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 349927 9554 ns/op 1532.39 MB/s Benchmark___FanOut_128x1x100-16 348781 9558 ns/op 1531.74 MB/s Benchmark___FanOut_128x1x100-16 359845 9593 ns/op 1526.23 MB/s Benchmark___FanOut_128x1x100-16 357696 9601 ns/op 1524.90 MB/s Benchmark___FanOut_128x1x100-16 355041 9569 ns/op 1530.04 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32305 112652 ns/op 1288.40 MB/s Benchmark__FanOut_128x10x100-16 31976 112964 ns/op 1284.85 MB/s Benchmark__FanOut_128x10x100-16 31942 111514 ns/op 1301.55 MB/s Benchmark__FanOut_128x10x100-16 32364 111398 ns/op 1302.91 MB/s Benchmark__FanOut_128x10x100-16 32388 111143 ns/op 1305.90 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4141 890118 ns/op 1640.39 MB/s Benchmark_FanOut_128x10x1000-16 4081 880784 ns/op 1657.77 MB/s Benchmark_FanOut_128x10x1000-16 4064 882988 ns/op 1653.64 MB/s Benchmark_FanOut_128x10x1000-16 3960 887110 ns/op 1645.95 MB/s Benchmark_FanOut_128x10x1000-16 3969 875446 ns/op 1667.88 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3420 1016920 ns/op 1426.01 MB/s Benchmark_FanOut_128x100x100-16 3476 1017439 ns/op 1425.29 MB/s Benchmark_FanOut_128x100x100-16 3445 1021771 ns/op 1419.24 MB/s Benchmark_FanOut_128x100x100-16 3487 1020424 ns/op 1421.12 MB/s Benchmark_FanOut_128x100x100-16 3453 1017745 ns/op 1424.86 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 375 9356852 ns/op 1560.37 MB/s BenchmarkFanOut_128x100x1000-16 388 9508715 ns/op 1535.45 MB/s BenchmarkFanOut_128x100x1000-16 385 9384989 ns/op 1555.69 MB/s BenchmarkFanOut_128x100x1000-16 376 9346809 ns/op 1562.05 MB/s BenchmarkFanOut_128x100x1000-16 385 9351448 ns/op 1561.27 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 368 9758103 ns/op 1506.45 MB/s BenchmarkFanOut_128x10x10000-16 372 9640614 ns/op 1524.81 MB/s BenchmarkFanOut_128x10x10000-16 370 9729008 ns/op 1510.96 MB/s BenchmarkFanOut_128x10x10000-16 373 9715085 ns/op 1513.13 MB/s BenchmarkFanOut_128x10x10000-16 369 9709490 ns/op 1514.00 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 668 5324653 ns/op 1361.62 MB/s BenchmarkFanOut__128x500x100-16 667 5318342 ns/op 1363.23 MB/s BenchmarkFanOut__128x500x100-16 674 5288931 ns/op 1370.81 MB/s BenchmarkFanOut__128x500x100-16 672 5309760 ns/op 1365.44 MB/s BenchmarkFanOut__128x500x100-16 675 5286951 ns/op 1371.33 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1923 1855930 ns/op 2850.61 MB/s Benchmark_FanOut_512x100x100-16 1948 1859086 ns/op 2845.77 MB/s Benchmark_FanOut_512x100x100-16 1920 1842203 ns/op 2871.85 MB/s Benchmark_FanOut_512x100x100-16 1908 1864992 ns/op 2836.75 MB/s Benchmark_FanOut_512x100x100-16 1953 1849758 ns/op 2860.12 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16712031 ns/op 3171.40 MB/s Benchmark__FanOut_512x100x1k-16 212 16889129 ns/op 3138.14 MB/s Benchmark__FanOut_512x100x1k-16 214 16839356 ns/op 3147.42 MB/s Benchmark__FanOut_512x100x1k-16 214 16993591 ns/op 3118.85 MB/s Benchmark__FanOut_512x100x1k-16 214 16911375 ns/op 3134.02 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3151 1142590 ns/op 9129.29 MB/s Benchmark____FanOut_1kx10x1k-16 3044 1169702 ns/op 8917.69 MB/s Benchmark____FanOut_1kx10x1k-16 3184 1155072 ns/op 9030.64 MB/s Benchmark____FanOut_1kx10x1k-16 3051 1180559 ns/op 8835.68 MB/s Benchmark____FanOut_1kx10x1k-16 3210 1163100 ns/op 8968.31 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2757 1261872 ns/op 8258.40 MB/s Benchmark__FanOut_1kx100x100-16 2744 1258955 ns/op 8277.53 MB/s Benchmark__FanOut_1kx100x100-16 2730 1257978 ns/op 8283.96 MB/s Benchmark__FanOut_1kx100x100-16 2695 1264048 ns/op 8244.18 MB/s Benchmark__FanOut_1kx100x100-16 2808 1265012 ns/op 8237.90 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4526499 804.4 ns/op 309.53 MB/s Benchmark_____RFanOut_8x1x10-16 4333467 798.6 ns/op 311.81 MB/s Benchmark_____RFanOut_8x1x10-16 4434284 807.1 ns/op 308.52 MB/s Benchmark_____RFanOut_8x1x10-16 4476734 783.1 ns/op 317.96 MB/s Benchmark_____RFanOut_8x1x10-16 4430484 795.3 ns/op 313.08 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 527160 6428 ns/op 360.77 MB/s Benchmark____RFanOut_8x1x100-16 521500 6428 ns/op 360.78 MB/s Benchmark____RFanOut_8x1x100-16 521143 6191 ns/op 374.56 MB/s Benchmark____RFanOut_8x1x100-16 557259 6385 ns/op 363.18 MB/s Benchmark____RFanOut_8x1x100-16 532630 6150 ns/op 377.09 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47356 75781 ns/op 303.75 MB/s Benchmark___RFanOut_8x10x100-16 47443 75635 ns/op 304.34 MB/s Benchmark___RFanOut_8x10x100-16 47632 75670 ns/op 304.20 MB/s Benchmark___RFanOut_8x10x100-16 46846 76432 ns/op 301.17 MB/s Benchmark___RFanOut_8x10x100-16 47734 76925 ns/op 299.24 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5709 606016 ns/op 396.06 MB/s Benchmark__RFanOut_8x10x1000-16 5848 607640 ns/op 395.00 MB/s Benchmark__RFanOut_8x10x1000-16 5620 605107 ns/op 396.66 MB/s Benchmark__RFanOut_8x10x1000-16 5845 604053 ns/op 397.35 MB/s Benchmark__RFanOut_8x10x1000-16 5608 607916 ns/op 394.82 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4935 717812 ns/op 320.44 MB/s Benchmark__RFanOut_8x100x100-16 4904 737258 ns/op 311.99 MB/s Benchmark__RFanOut_8x100x100-16 4856 716296 ns/op 321.12 MB/s Benchmark__RFanOut_8x100x100-16 4869 715660 ns/op 321.41 MB/s Benchmark__RFanOut_8x100x100-16 4939 712496 ns/op 322.84 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 555 6263177 ns/op 383.20 MB/s Benchmark_RFanOut_8x100x1000-16 564 6387960 ns/op 375.71 MB/s Benchmark_RFanOut_8x100x1000-16 574 6283072 ns/op 381.98 MB/s Benchmark_RFanOut_8x100x1000-16 562 6310427 ns/op 380.33 MB/s Benchmark_RFanOut_8x100x1000-16 558 6269040 ns/op 382.84 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 528 6808801 ns/op 367.17 MB/s Benchmark_RFanOut_8x10x10000-16 520 6807552 ns/op 367.24 MB/s Benchmark_RFanOut_8x10x10000-16 526 6804176 ns/op 367.42 MB/s Benchmark_RFanOut_8x10x10000-16 524 6820851 ns/op 366.53 MB/s Benchmark_RFanOut_8x10x10000-16 522 6856409 ns/op 364.63 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2944 1149065 ns/op 9077.85 MB/s Benchmark_RFanOut_1kx10x1000-16 2836 1143632 ns/op 9120.97 MB/s Benchmark_RFanOut_1kx10x1000-16 3181 1149291 ns/op 9076.06 MB/s Benchmark_RFanOut_1kx10x1000-16 3147 1162420 ns/op 8973.56 MB/s Benchmark_RFanOut_1kx10x1000-16 3025 1172488 ns/op 8896.50 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6959194 504.4 ns/op 4119.39 MB/s Benchmark_____FanIn_1kx100x1-16 6946286 506.3 ns/op 4104.31 MB/s Benchmark_____FanIn_1kx100x1-16 6995919 504.1 ns/op 4122.56 MB/s Benchmark_____FanIn_1kx100x1-16 6888894 504.2 ns/op 4121.67 MB/s Benchmark_____FanIn_1kx100x1-16 6978627 504.4 ns/op 4120.13 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2615612 1362 ns/op 6034.93 MB/s Benchmark_____FanIn_4kx100x1-16 2683053 1374 ns/op 5983.74 MB/s Benchmark_____FanIn_4kx100x1-16 2649770 1357 ns/op 6057.55 MB/s Benchmark_____FanIn_4kx100x1-16 2599353 1343 ns/op 6121.13 MB/s Benchmark_____FanIn_4kx100x1-16 2559543 1363 ns/op 6031.73 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1701247 2108 ns/op 7785.70 MB/s Benchmark_____FanIn_8kx100x1-16 1691053 2111 ns/op 7774.25 MB/s Benchmark_____FanIn_8kx100x1-16 1697808 2112 ns/op 7771.98 MB/s Benchmark_____FanIn_8kx100x1-16 1683188 2117 ns/op 7751.67 MB/s Benchmark_____FanIn_8kx100x1-16 1706665 2089 ns/op 7855.64 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 867338 4157 ns/op 7890.50 MB/s Benchmark____FanIn_16kx100x1-16 876493 4112 ns/op 7975.73 MB/s Benchmark____FanIn_16kx100x1-16 851703 4138 ns/op 7926.03 MB/s Benchmark____FanIn_16kx100x1-16 876061 4103 ns/op 7994.83 MB/s Benchmark____FanIn_16kx100x1-16 863389 4171 ns/op 7863.03 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 169160 20078 ns/op 6529.64 MB/s Benchmark____FanIn_64kx100x1-16 163831 19928 ns/op 6578.95 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 8256793668 vs 11091567600 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36856->127.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:36850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36288->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36534->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36770->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36320->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7543183710 vs 11052235800 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:39002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39226->127.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:39300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39018->127.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:38858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39166->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39056->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38996->127.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:39630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39082->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39436->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39652->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39196->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39254->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39284->127.0.0.1:5222: write: broken pipe --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38830->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 169390 19736 ns/op 6643.03 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 680226010 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54850->127.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:54124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54340->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54498->127.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:54148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:53994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54296->127.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:54008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54508->127.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:54074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54548->127.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:54492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54236->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 318024340 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55882->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: 252086070 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57750->127.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:57736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58284->127.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:58378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57652->127.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:58094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57952->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57702->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57584->127.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:58328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57710->127.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:57666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58076->127.0.0.1:5222: write: connection reset by peer 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:57768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57682->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58154->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: 342144900 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60192->127.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:59452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59320->127.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:60030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59706->127.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:60140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59610->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: 761895080 vs 11496593000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34370->127.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: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:34258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34002->127.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:34024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:33830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34386->127.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:34112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34540->127.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: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:34470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33900->127.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:34224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34150->127.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:34104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:34346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34090->127.0.0.1:5222: write: connection reset by peer 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: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:34560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34064->127.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:33860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34288->127.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:34078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34492->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:34462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33786->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34450->127.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:34402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34368->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5498269 646.8 ns/op 439.08 MB/s Benchmark___BumpPubCount_1x3-16 5502434 643.6 ns/op 441.26 MB/s Benchmark___BumpPubCount_1x3-16 5522071 641.9 ns/op 442.44 MB/s Benchmark___BumpPubCount_1x3-16 5565348 643.3 ns/op 441.45 MB/s Benchmark___BumpPubCount_1x3-16 5554214 645.6 ns/op 439.93 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5286814 675.3 ns/op 420.55 MB/s Benchmark___BumpPubCount_2x3-16 5192403 676.1 ns/op 420.03 MB/s Benchmark___BumpPubCount_2x3-16 5231600 677.0 ns/op 419.48 MB/s Benchmark___BumpPubCount_2x3-16 5358140 674.9 ns/op 420.83 MB/s Benchmark___BumpPubCount_2x3-16 5270938 677.5 ns/op 419.20 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5472474 648.8 ns/op 437.76 MB/s Benchmark___BumpPubCount_5x3-16 5564547 646.6 ns/op 439.19 MB/s Benchmark___BumpPubCount_5x3-16 5536747 643.4 ns/op 441.40 MB/s Benchmark___BumpPubCount_5x3-16 5553256 646.8 ns/op 439.06 MB/s Benchmark___BumpPubCount_5x3-16 5551198 646.0 ns/op 439.61 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5554492 650.6 ns/op 436.55 MB/s Benchmark__BumpPubCount_10x3-16 5539863 647.3 ns/op 438.77 MB/s Benchmark__BumpPubCount_10x3-16 5555398 647.2 ns/op 438.81 MB/s Benchmark__BumpPubCount_10x3-16 5537144 646.7 ns/op 439.15 MB/s Benchmark__BumpPubCount_10x3-16 5572518 647.3 ns/op 438.77 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12355806 268.8 ns/op 3869.06 MB/s Benchmark____GWs_Opt_1kx01x0-16 13321534 275.2 ns/op 3779.59 MB/s Benchmark____GWs_Opt_1kx01x0-16 13038532 287.8 ns/op 3613.93 MB/s Benchmark____GWs_Opt_1kx01x0-16 12817275 270.9 ns/op 3838.94 MB/s Benchmark____GWs_Opt_1kx01x0-16 12514746 275.7 ns/op 3772.34 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9757405 333.3 ns/op 6191.82 MB/s Benchmark____GWs_Opt_2kx01x0-16 10317170 349.8 ns/op 5899.73 MB/s Benchmark____GWs_Opt_2kx01x0-16 10731412 341.9 ns/op 6036.94 MB/s Benchmark____GWs_Opt_2kx01x0-16 10171948 339.1 ns/op 6087.38 MB/s Benchmark____GWs_Opt_2kx01x0-16 10301154 350.5 ns/op 5888.84 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5488112 662.8 ns/op 6203.68 MB/s Benchmark____GWs_Opt_4kx01x0-16 5525624 641.6 ns/op 6408.85 MB/s Benchmark____GWs_Opt_4kx01x0-16 5511955 785.9 ns/op 5232.39 MB/s Benchmark____GWs_Opt_4kx01x0-16 5797501 622.8 ns/op 6602.28 MB/s Benchmark____GWs_Opt_4kx01x0-16 5521125 617.5 ns/op 6659.40 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28158814 111.1 ns/op 9356.93 MB/s Benchmark____GWs_Opt_1kx10x0-16 30538131 113.5 ns/op 9166.69 MB/s Benchmark____GWs_Opt_1kx10x0-16 31589626 115.3 ns/op 9020.82 MB/s Benchmark____GWs_Opt_1kx10x0-16 29123112 114.8 ns/op 9061.58 MB/s Benchmark____GWs_Opt_1kx10x0-16 30327468 113.1 ns/op 9196.16 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24639700 143.2 ns/op 14411.12 MB/s Benchmark____GWs_Opt_2kx10x0-16 25272938 170.0 ns/op 12140.71 MB/s Benchmark____GWs_Opt_2kx10x0-16 24620786 153.4 ns/op 13451.01 MB/s Benchmark____GWs_Opt_2kx10x0-16 18941563 162.9 ns/op 12671.37 MB/s Benchmark____GWs_Opt_2kx10x0-16 25315252 151.6 ns/op 13610.89 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 13309806 300.5 ns/op 13682.66 MB/s Benchmark____GWs_Opt_4kx10x0-16 11575828 301.4 ns/op 13643.00 MB/s Benchmark____GWs_Opt_4kx10x0-16 12522678 375.7 ns/op 10945.09 MB/s Benchmark____GWs_Opt_4kx10x0-16 13472643 285.1 ns/op 14425.02 MB/s Benchmark____GWs_Opt_4kx10x0-16 11827183 295.8 ns/op 13903.12 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6355836 549.9 ns/op 5683.32 MB/s Benchmark____GWs_Opt_1kx01x1-16 6504654 546.0 ns/op 5723.44 MB/s Benchmark____GWs_Opt_1kx01x1-16 6564745 549.5 ns/op 5686.93 MB/s Benchmark____GWs_Opt_1kx01x1-16 6510890 544.7 ns/op 5737.15 MB/s Benchmark____GWs_Opt_1kx01x1-16 6383714 546.2 ns/op 5721.05 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4582918 767.3 ns/op 8076.35 MB/s Benchmark____GWs_Opt_2kx01x1-16 4555586 763.7 ns/op 8114.83 MB/s Benchmark____GWs_Opt_2kx01x1-16 4704384 752.7 ns/op 8232.95 MB/s Benchmark____GWs_Opt_2kx01x1-16 4871098 769.2 ns/op 8056.11 MB/s Benchmark____GWs_Opt_2kx01x1-16 4700856 767.3 ns/op 8075.93 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2311466 1359 ns/op 9082.00 MB/s Benchmark____GWs_Opt_4kx01x1-16 2612743 1368 ns/op 9022.96 MB/s Benchmark____GWs_Opt_4kx01x1-16 2644326 1494 ns/op 8258.77 MB/s Benchmark____GWs_Opt_4kx01x1-16 2570826 1385 ns/op 8912.91 MB/s Benchmark____GWs_Opt_4kx01x1-16 2583129 1373 ns/op 8986.95 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6207488 540.1 ns/op 5786.18 MB/s Benchmark____GWs_Opt_1kx10x1-16 6550790 549.7 ns/op 5684.67 MB/s Benchmark____GWs_Opt_1kx10x1-16 6369092 541.8 ns/op 5768.06 MB/s Benchmark____GWs_Opt_1kx10x1-16 6628315 553.2 ns/op 5649.22 MB/s Benchmark____GWs_Opt_1kx10x1-16 6169809 553.5 ns/op 5645.95 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4198486 842.6 ns/op 7354.38 MB/s Benchmark____GWs_Opt_2kx10x1-16 4257943 829.0 ns/op 7474.89 MB/s Benchmark____GWs_Opt_2kx10x1-16 4442172 857.3 ns/op 7228.13 MB/s Benchmark____GWs_Opt_2kx10x1-16 4203919 838.1 ns/op 7393.88 MB/s Benchmark____GWs_Opt_2kx10x1-16 4205925 826.8 ns/op 7495.14 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2152779 1498 ns/op 8236.59 MB/s Benchmark____GWs_Opt_4kx10x1-16 2288977 1582 ns/op 7800.61 MB/s Benchmark____GWs_Opt_4kx10x1-16 2475855 1470 ns/op 8397.30 MB/s Benchmark____GWs_Opt_4kx10x1-16 2265084 1535 ns/op 8040.42 MB/s Benchmark____GWs_Opt_4kx10x1-16 2309142 1479 ns/op 8344.68 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12554089 284.4 ns/op 3656.18 MB/s Benchmark____GWs_Int_1kx01x0-16 12824521 276.0 ns/op 3768.13 MB/s Benchmark____GWs_Int_1kx01x0-16 12652326 283.7 ns/op 3665.69 MB/s Benchmark____GWs_Int_1kx01x0-16 12769316 279.4 ns/op 3722.00 MB/s Benchmark____GWs_Int_1kx01x0-16 12728974 288.0 ns/op 3611.57 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10056444 347.0 ns/op 5947.49 MB/s Benchmark____GWs_Int_2kx01x0-16 9469196 346.6 ns/op 5955.02 MB/s Benchmark____GWs_Int_2kx01x0-16 10190468 351.5 ns/op 5871.46 MB/s Benchmark____GWs_Int_2kx01x0-16 10271907 354.3 ns/op 5825.61 MB/s Benchmark____GWs_Int_2kx01x0-16 10491520 332.8 ns/op 6202.49 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5468978 649.1 ns/op 6335.11 MB/s Benchmark____GWs_Int_4kx01x0-16 5762872 629.8 ns/op 6528.94 MB/s Benchmark____GWs_Int_4kx01x0-16 5637673 691.6 ns/op 5945.45 MB/s Benchmark____GWs_Int_4kx01x0-16 5675240 652.7 ns/op 6300.46 MB/s Benchmark____GWs_Int_4kx01x0-16 5541720 646.4 ns/op 6361.86 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31913416 113.1 ns/op 9196.27 MB/s Benchmark____GWs_Int_1kx10x0-16 31175282 115.1 ns/op 9039.47 MB/s Benchmark____GWs_Int_1kx10x0-16 32261967 109.6 ns/op 9487.40 MB/s Benchmark____GWs_Int_1kx10x0-16 30240608 106.6 ns/op 9755.20 MB/s Benchmark____GWs_Int_1kx10x0-16 32464168 110.4 ns/op 9420.73 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24463116 143.5 ns/op 14379.61 MB/s Benchmark____GWs_Int_2kx10x0-16 26495288 151.3 ns/op 13641.90 MB/s Benchmark____GWs_Int_2kx10x0-16 25806052 144.7 ns/op 14259.60 MB/s Benchmark____GWs_Int_2kx10x0-16 25884734 147.2 ns/op 14017.46 MB/s Benchmark____GWs_Int_2kx10x0-16 25677248 140.3 ns/op 14715.18 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12844818 353.1 ns/op 11644.41 MB/s Benchmark____GWs_Int_4kx10x0-16 13284697 292.4 ns/op 14060.81 MB/s Benchmark____GWs_Int_4kx10x0-16 11273876 300.7 ns/op 13674.85 MB/s Benchmark____GWs_Int_4kx10x0-16 13301239 307.2 ns/op 13383.97 MB/s Benchmark____GWs_Int_4kx10x0-16 9600153 360.8 ns/op 11397.23 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6299942 556.9 ns/op 5611.41 MB/s Benchmark____GWs_Int_1kx01x1-16 6438256 548.9 ns/op 5693.72 MB/s Benchmark____GWs_Int_1kx01x1-16 6415962 560.6 ns/op 5573.89 MB/s Benchmark____GWs_Int_1kx01x1-16 6484516 564.5 ns/op 5536.07 MB/s Benchmark____GWs_Int_1kx01x1-16 6441987 558.7 ns/op 5593.00 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4775884 769.5 ns/op 8053.28 MB/s Benchmark____GWs_Int_2kx01x1-16 4612540 761.2 ns/op 8141.38 MB/s Benchmark____GWs_Int_2kx01x1-16 4530220 760.9 ns/op 8144.22 MB/s Benchmark____GWs_Int_2kx01x1-16 4655138 767.3 ns/op 8076.35 MB/s Benchmark____GWs_Int_2kx01x1-16 4895383 783.4 ns/op 7910.18 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2636934 1399 ns/op 8819.58 MB/s Benchmark____GWs_Int_4kx01x1-16 2591322 1588 ns/op 7769.46 MB/s Benchmark____GWs_Int_4kx01x1-16 2591467 1383 ns/op 8923.22 MB/s Benchmark____GWs_Int_4kx01x1-16 2294038 1383 ns/op 8922.29 MB/s Benchmark____GWs_Int_4kx01x1-16 2628278 1371 ns/op 8998.74 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6575113 547.7 ns/op 5705.62 MB/s Benchmark____GWs_Int_1kx10x1-16 6570705 565.5 ns/op 5526.43 MB/s Benchmark____GWs_Int_1kx10x1-16 6573439 545.0 ns/op 5734.00 MB/s Benchmark____GWs_Int_1kx10x1-16 6492055 557.2 ns/op 5608.18 MB/s Benchmark____GWs_Int_1kx10x1-16 6529611 548.4 ns/op 5698.80 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4155783 878.1 ns/op 7057.11 MB/s Benchmark____GWs_Int_2kx10x1-16 4159623 833.5 ns/op 7434.82 MB/s Benchmark____GWs_Int_2kx10x1-16 4211272 833.0 ns/op 7439.31 MB/s Benchmark____GWs_Int_2kx10x1-16 4448098 840.7 ns/op 7371.49 MB/s Benchmark____GWs_Int_2kx10x1-16 4201318 827.9 ns/op 7485.17 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2446009 1513 ns/op 8154.38 MB/s Benchmark____GWs_Int_4kx10x1-16 2443940 1701 ns/op 7255.95 MB/s Benchmark____GWs_Int_4kx10x1-16 2356903 1560 ns/op 7912.68 MB/s Benchmark____GWs_Int_4kx10x1-16 2151392 1481 ns/op 8334.12 MB/s Benchmark____GWs_Int_4kx10x1-16 2375803 1487 ns/op 8298.65 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8254548 431.8 ns/op 236.24 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8447956 431.0 ns/op 236.67 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7705262 432.9 ns/op 235.61 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8351350 432.3 ns/op 235.97 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8113270 456.5 ns/op 223.44 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 614505 5028 ns/op 35.20 MB/s Benchmark__GWs_Reqs_1SubEach-16 788689 5220 ns/op 33.91 MB/s Benchmark__GWs_Reqs_1SubEach-16 734553 5166 ns/op 34.26 MB/s Benchmark__GWs_Reqs_1SubEach-16 753798 5224 ns/op 33.89 MB/s Benchmark__GWs_Reqs_1SubEach-16 787464 5315 ns/op 33.30 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2106.841s