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 49723777 72.10 ns/op 152.57 MB/s Benchmark______Pub0b_Payload-16 49961034 73.07 ns/op 150.55 MB/s Benchmark______Pub0b_Payload-16 43410948 72.56 ns/op 151.60 MB/s Benchmark______Pub0b_Payload-16 43000923 72.31 ns/op 152.12 MB/s Benchmark______Pub0b_Payload-16 46875254 72.03 ns/op 152.71 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46614384 73.56 ns/op 258.28 MB/s Benchmark______Pub8b_Payload-16 46833256 72.97 ns/op 260.37 MB/s Benchmark______Pub8b_Payload-16 49597628 73.48 ns/op 258.57 MB/s Benchmark______Pub8b_Payload-16 46490866 72.76 ns/op 261.13 MB/s Benchmark______Pub8b_Payload-16 49477129 73.36 ns/op 259.00 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44065708 77.17 ns/op 570.15 MB/s Benchmark_____Pub32b_Payload-16 44201506 76.88 ns/op 572.33 MB/s Benchmark_____Pub32b_Payload-16 44686850 76.68 ns/op 573.80 MB/s Benchmark_____Pub32b_Payload-16 46836908 76.68 ns/op 573.80 MB/s Benchmark_____Pub32b_Payload-16 44349457 76.80 ns/op 572.94 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39545110 86.65 ns/op 1627.24 MB/s Benchmark____Pub128B_Payload-16 34862578 87.10 ns/op 1618.91 MB/s Benchmark____Pub128B_Payload-16 34270348 89.76 ns/op 1570.93 MB/s Benchmark____Pub128B_Payload-16 39547395 87.75 ns/op 1606.81 MB/s Benchmark____Pub128B_Payload-16 41575604 85.43 ns/op 1650.44 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35575537 95.40 ns/op 2819.60 MB/s Benchmark____Pub256B_Payload-16 37860843 98.18 ns/op 2739.90 MB/s Benchmark____Pub256B_Payload-16 32145170 94.58 ns/op 2844.26 MB/s Benchmark____Pub256B_Payload-16 35583288 101.6 ns/op 2647.77 MB/s Benchmark____Pub256B_Payload-16 38232613 94.21 ns/op 2855.42 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 20924371 146.1 ns/op 7103.19 MB/s Benchmark______Pub1K_Payload-16 24809827 142.9 ns/op 7261.79 MB/s Benchmark______Pub1K_Payload-16 24912474 140.9 ns/op 7369.28 MB/s Benchmark______Pub1K_Payload-16 24028216 134.3 ns/op 7726.62 MB/s Benchmark______Pub1K_Payload-16 22524232 160.4 ns/op 6472.10 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5686705 626.6 ns/op 6559.56 MB/s Benchmark______Pub4K_Payload-16 5612642 627.7 ns/op 6548.17 MB/s Benchmark______Pub4K_Payload-16 5292339 630.6 ns/op 6517.58 MB/s Benchmark______Pub4K_Payload-16 5789834 615.7 ns/op 6675.63 MB/s Benchmark______Pub4K_Payload-16 5743899 627.0 ns/op 6555.10 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2788411 1296 ns/op 6331.40 MB/s Benchmark______Pub8K_Payload-16 2767370 1279 ns/op 6415.94 MB/s Benchmark______Pub8K_Payload-16 2744097 1277 ns/op 6425.28 MB/s Benchmark______Pub8K_Payload-16 2622412 1283 ns/op 6394.89 MB/s Benchmark______Pub8K_Payload-16 2790649 1270 ns/op 6460.00 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 635544 5591 ns/op 5863.67 MB/s Benchmark_____Pub32K_Payload-16 661477 5470 ns/op 5993.31 MB/s Benchmark_____Pub32K_Payload-16 664020 5482 ns/op 5979.81 MB/s Benchmark_____Pub32K_Payload-16 648980 5382 ns/op 6091.43 MB/s Benchmark_____Pub32K_Payload-16 563510 5424 ns/op 6044.62 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32651427 92.84 ns/op 118.49 MB/s Benchmark__AuthPub0b_Payload-16 36838054 93.80 ns/op 117.27 MB/s Benchmark__AuthPub0b_Payload-16 34434805 92.76 ns/op 118.59 MB/s Benchmark__AuthPub0b_Payload-16 32535730 93.61 ns/op 117.51 MB/s Benchmark__AuthPub0b_Payload-16 37082962 92.79 ns/op 118.55 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15700096 226.0 ns/op Benchmark_____________PubSub-16 15551547 227.8 ns/op Benchmark_____________PubSub-16 15746395 226.6 ns/op Benchmark_____________PubSub-16 15604992 226.3 ns/op Benchmark_____________PubSub-16 15536542 226.3 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15797103 225.3 ns/op Benchmark_____PubSubTwoConns-16 15485973 225.1 ns/op Benchmark_____PubSubTwoConns-16 15839091 223.7 ns/op Benchmark_____PubSubTwoConns-16 15692110 224.6 ns/op Benchmark_____PubSubTwoConns-16 15767229 224.8 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33380->127.0.0.1:36315: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:35598->127.0.0.1:38839: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34230->127.0.0.1:37273: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50862->127.0.0.1:45993: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:38516->127.0.0.1:32835: 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 14447388 243.9 ns/op Benchmark_____PubTwoQueueSub-16 14354802 244.0 ns/op Benchmark_____PubTwoQueueSub-16 14646123 243.3 ns/op Benchmark_____PubTwoQueueSub-16 14569176 243.6 ns/op Benchmark_____PubTwoQueueSub-16 14588194 244.0 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14569899 243.7 ns/op Benchmark____PubFourQueueSub-16 14422364 242.7 ns/op Benchmark____PubFourQueueSub-16 14572774 243.7 ns/op Benchmark____PubFourQueueSub-16 14615088 243.9 ns/op Benchmark____PubFourQueueSub-16 14539058 243.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14630838 243.6 ns/op Benchmark___PubEightQueueSub-16 14633461 243.2 ns/op Benchmark___PubEightQueueSub-16 14648518 244.2 ns/op Benchmark___PubEightQueueSub-16 14761866 241.9 ns/op Benchmark___PubEightQueueSub-16 14697222 243.9 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23271 155459 ns/op Benchmark_PubSub512kTwoConns-16 22966 155580 ns/op Benchmark_PubSub512kTwoConns-16 23272 156207 ns/op Benchmark_PubSub512kTwoConns-16 23050 154655 ns/op Benchmark_PubSub512kTwoConns-16 23176 155991 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15443775 228.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15444699 228.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15264638 228.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15316196 228.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15235424 227.8 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15315256 227.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15289624 226.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15147006 228.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15331960 228.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15324918 228.8 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11286297 312.4 ns/op Benchmark____RoutedPubSub_0b-16 11317477 317.9 ns/op Benchmark____RoutedPubSub_0b-16 11793960 312.6 ns/op Benchmark____RoutedPubSub_0b-16 11189499 312.9 ns/op Benchmark____RoutedPubSub_0b-16 11306763 308.0 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6568308 540.1 ns/op Benchmark____RoutedPubSub_1K-16 6558547 541.2 ns/op Benchmark____RoutedPubSub_1K-16 6716460 538.8 ns/op Benchmark____RoutedPubSub_1K-16 6636003 538.9 ns/op Benchmark____RoutedPubSub_1K-16 6664740 537.3 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85092 39829 ns/op Benchmark__RoutedPubSub_100K-16 79446 47967 ns/op Benchmark__RoutedPubSub_100K-16 75082 45797 ns/op Benchmark__RoutedPubSub_100K-16 75748 46742 ns/op Benchmark__RoutedPubSub_100K-16 81865 45952 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9729573 312.2 ns/op Benchmark____Routed2QueueSub-16 9840055 318.2 ns/op Benchmark____Routed2QueueSub-16 9840825 319.7 ns/op Benchmark____Routed2QueueSub-16 9626122 319.6 ns/op Benchmark____Routed2QueueSub-16 9820596 319.5 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9777219 322.6 ns/op Benchmark____Routed4QueueSub-16 9434971 323.4 ns/op Benchmark____Routed4QueueSub-16 9715498 317.6 ns/op Benchmark____Routed4QueueSub-16 9808150 320.9 ns/op Benchmark____Routed4QueueSub-16 9729309 321.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 11080574 329.1 ns/op Benchmark____Routed8QueueSub-16 9542954 328.1 ns/op Benchmark____Routed8QueueSub-16 9255704 327.1 ns/op Benchmark____Routed8QueueSub-16 9359902 325.7 ns/op Benchmark____Routed8QueueSub-16 9295873 328.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8932502 349.5 ns/op Benchmark___Routed16QueueSub-16 8938801 344.9 ns/op Benchmark___Routed16QueueSub-16 8752089 352.6 ns/op Benchmark___Routed16QueueSub-16 9040275 346.0 ns/op Benchmark___Routed16QueueSub-16 8882976 344.3 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6345294 553.8 ns/op Benchmark____________RouteCompressOff-16 6556353 559.1 ns/op Benchmark____________RouteCompressOff-16 6446906 547.3 ns/op Benchmark____________RouteCompressOff-16 6426506 551.1 ns/op Benchmark____________RouteCompressOff-16 6412196 545.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6319213 559.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6484641 550.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6385539 552.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6416937 549.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6304623 521.2 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6397981 551.0 ns/op Benchmark_________RouteCompressS2Fast-16 6357094 552.7 ns/op Benchmark_________RouteCompressS2Fast-16 6471778 553.0 ns/op Benchmark_________RouteCompressS2Fast-16 6452017 553.1 ns/op Benchmark_________RouteCompressS2Fast-16 6361512 549.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6489241 554.2 ns/op Benchmark_______RouteCompressS2Better-16 6521787 554.9 ns/op Benchmark_______RouteCompressS2Better-16 6431974 551.6 ns/op Benchmark_______RouteCompressS2Better-16 6281942 553.1 ns/op Benchmark_______RouteCompressS2Better-16 6336478 543.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6493813 540.8 ns/op Benchmark_________RouteCompressS2Best-16 6312056 552.3 ns/op Benchmark_________RouteCompressS2Best-16 6403982 546.8 ns/op Benchmark_________RouteCompressS2Best-16 6570156 550.7 ns/op Benchmark_________RouteCompressS2Best-16 6455468 549.3 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4683710 777.9 ns/op 320.11 MB/s Benchmark______FanOut_8x1x10-16 4636124 773.1 ns/op 322.06 MB/s Benchmark______FanOut_8x1x10-16 4653447 785.2 ns/op 317.10 MB/s Benchmark______FanOut_8x1x10-16 4614024 777.5 ns/op 320.25 MB/s Benchmark______FanOut_8x1x10-16 4613988 774.3 ns/op 321.58 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 560647 6159 ns/op 376.50 MB/s Benchmark_____FanOut_8x1x100-16 534249 6277 ns/op 369.42 MB/s Benchmark_____FanOut_8x1x100-16 558650 6388 ns/op 363.05 MB/s Benchmark_____FanOut_8x1x100-16 562458 6162 ns/op 376.34 MB/s Benchmark_____FanOut_8x1x100-16 535576 6166 ns/op 376.10 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47827 75593 ns/op 304.51 MB/s Benchmark____FanOut_8x10x100-16 47784 75064 ns/op 306.66 MB/s Benchmark____FanOut_8x10x100-16 47556 75949 ns/op 303.09 MB/s Benchmark____FanOut_8x10x100-16 46740 75061 ns/op 306.67 MB/s Benchmark____FanOut_8x10x100-16 47934 75096 ns/op 306.53 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5820 597260 ns/op 401.87 MB/s Benchmark___FanOut_8x10x1000-16 5629 604007 ns/op 397.38 MB/s Benchmark___FanOut_8x10x1000-16 5666 600595 ns/op 399.64 MB/s Benchmark___FanOut_8x10x1000-16 6027 614664 ns/op 390.49 MB/s Benchmark___FanOut_8x10x1000-16 5821 606319 ns/op 395.86 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4978 719646 ns/op 319.63 MB/s Benchmark___FanOut_8x100x100-16 4862 720795 ns/op 319.12 MB/s Benchmark___FanOut_8x100x100-16 4905 713500 ns/op 322.38 MB/s Benchmark___FanOut_8x100x100-16 4929 716092 ns/op 321.21 MB/s Benchmark___FanOut_8x100x100-16 5018 711556 ns/op 323.26 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 549 6402718 ns/op 374.84 MB/s Benchmark__FanOut_8x100x1000-16 571 6182635 ns/op 388.19 MB/s Benchmark__FanOut_8x100x1000-16 567 6201562 ns/op 387.00 MB/s Benchmark__FanOut_8x100x1000-16 555 6329382 ns/op 379.19 MB/s Benchmark__FanOut_8x100x1000-16 547 6213476 ns/op 386.26 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 505 6775596 ns/op 368.97 MB/s Benchmark__FanOut_8x10x10000-16 530 6939674 ns/op 360.25 MB/s Benchmark__FanOut_8x10x10000-16 519 6903248 ns/op 362.15 MB/s Benchmark__FanOut_8x10x10000-16 530 6837952 ns/op 365.61 MB/s Benchmark__FanOut_8x10x10000-16 501 6810620 ns/op 367.08 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 931 3785764 ns/op 303.77 MB/s Benchmark___FanOut_8x500x100-16 930 3797745 ns/op 302.82 MB/s Benchmark___FanOut_8x500x100-16 932 3799257 ns/op 302.70 MB/s Benchmark___FanOut_8x500x100-16 930 3781658 ns/op 304.10 MB/s Benchmark___FanOut_8x500x100-16 933 3798996 ns/op 302.72 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 354442 9597 ns/op 1525.62 MB/s Benchmark___FanOut_128x1x100-16 357332 9581 ns/op 1528.14 MB/s Benchmark___FanOut_128x1x100-16 350617 9598 ns/op 1525.42 MB/s Benchmark___FanOut_128x1x100-16 356815 9672 ns/op 1513.69 MB/s Benchmark___FanOut_128x1x100-16 358749 9616 ns/op 1522.61 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31984 111231 ns/op 1304.86 MB/s Benchmark__FanOut_128x10x100-16 32466 112523 ns/op 1289.88 MB/s Benchmark__FanOut_128x10x100-16 32050 113849 ns/op 1274.85 MB/s Benchmark__FanOut_128x10x100-16 32227 111589 ns/op 1300.67 MB/s Benchmark__FanOut_128x10x100-16 32245 111649 ns/op 1299.98 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4036 881511 ns/op 1656.41 MB/s Benchmark_FanOut_128x10x1000-16 4065 880860 ns/op 1657.63 MB/s Benchmark_FanOut_128x10x1000-16 4060 887397 ns/op 1645.42 MB/s Benchmark_FanOut_128x10x1000-16 3985 878489 ns/op 1662.10 MB/s Benchmark_FanOut_128x10x1000-16 3956 899250 ns/op 1623.73 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3525 1013100 ns/op 1431.39 MB/s Benchmark_FanOut_128x100x100-16 3464 1019459 ns/op 1422.46 MB/s Benchmark_FanOut_128x100x100-16 3500 1016443 ns/op 1426.68 MB/s Benchmark_FanOut_128x100x100-16 3499 1017199 ns/op 1425.62 MB/s Benchmark_FanOut_128x100x100-16 3514 1019179 ns/op 1422.85 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 381 9427881 ns/op 1548.61 MB/s BenchmarkFanOut_128x100x1000-16 380 9235267 ns/op 1580.91 MB/s BenchmarkFanOut_128x100x1000-16 351 9395467 ns/op 1553.96 MB/s BenchmarkFanOut_128x100x1000-16 381 9371336 ns/op 1557.96 MB/s BenchmarkFanOut_128x100x1000-16 386 9439456 ns/op 1546.71 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 368 9613270 ns/op 1529.15 MB/s BenchmarkFanOut_128x10x10000-16 367 9680929 ns/op 1518.46 MB/s BenchmarkFanOut_128x10x10000-16 369 9683909 ns/op 1518.00 MB/s BenchmarkFanOut_128x10x10000-16 373 9719114 ns/op 1512.50 MB/s BenchmarkFanOut_128x10x10000-16 373 9737534 ns/op 1509.64 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 662 5291693 ns/op 1370.10 MB/s BenchmarkFanOut__128x500x100-16 663 5307175 ns/op 1366.10 MB/s BenchmarkFanOut__128x500x100-16 669 5280010 ns/op 1373.13 MB/s BenchmarkFanOut__128x500x100-16 666 5353615 ns/op 1354.25 MB/s BenchmarkFanOut__128x500x100-16 674 5317245 ns/op 1363.51 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1903 1854584 ns/op 2852.68 MB/s Benchmark_FanOut_512x100x100-16 1905 1860604 ns/op 2843.45 MB/s Benchmark_FanOut_512x100x100-16 1932 1852333 ns/op 2856.14 MB/s Benchmark_FanOut_512x100x100-16 1915 1862219 ns/op 2840.98 MB/s Benchmark_FanOut_512x100x100-16 1878 1864743 ns/op 2837.13 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16820450 ns/op 3150.96 MB/s Benchmark__FanOut_512x100x1k-16 213 17006024 ns/op 3116.57 MB/s Benchmark__FanOut_512x100x1k-16 216 16876896 ns/op 3140.42 MB/s Benchmark__FanOut_512x100x1k-16 214 16839054 ns/op 3147.48 MB/s Benchmark__FanOut_512x100x1k-16 211 16784803 ns/op 3157.65 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3108 1141670 ns/op 9136.65 MB/s Benchmark____FanOut_1kx10x1k-16 3009 1135141 ns/op 9189.20 MB/s Benchmark____FanOut_1kx10x1k-16 3192 1161627 ns/op 8979.68 MB/s Benchmark____FanOut_1kx10x1k-16 2930 1150744 ns/op 9064.61 MB/s Benchmark____FanOut_1kx10x1k-16 2817 1133379 ns/op 9203.49 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2738 1264529 ns/op 8241.04 MB/s Benchmark__FanOut_1kx100x100-16 2767 1273853 ns/op 8180.73 MB/s Benchmark__FanOut_1kx100x100-16 2803 1261184 ns/op 8262.90 MB/s Benchmark__FanOut_1kx100x100-16 2752 1265682 ns/op 8233.53 MB/s Benchmark__FanOut_1kx100x100-16 2839 1267737 ns/op 8220.19 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4518636 790.2 ns/op 315.13 MB/s Benchmark_____RFanOut_8x1x10-16 4461302 782.6 ns/op 318.18 MB/s Benchmark_____RFanOut_8x1x10-16 4560410 781.7 ns/op 318.53 MB/s Benchmark_____RFanOut_8x1x10-16 4541340 794.4 ns/op 313.46 MB/s Benchmark_____RFanOut_8x1x10-16 4383686 796.0 ns/op 312.81 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 518793 6162 ns/op 376.36 MB/s Benchmark____RFanOut_8x1x100-16 562882 6108 ns/op 379.69 MB/s Benchmark____RFanOut_8x1x100-16 543093 6160 ns/op 376.45 MB/s Benchmark____RFanOut_8x1x100-16 525327 6078 ns/op 381.55 MB/s Benchmark____RFanOut_8x1x100-16 541460 6104 ns/op 379.90 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46863 75536 ns/op 304.74 MB/s Benchmark___RFanOut_8x10x100-16 46992 77401 ns/op 297.40 MB/s Benchmark___RFanOut_8x10x100-16 47080 76365 ns/op 301.43 MB/s Benchmark___RFanOut_8x10x100-16 46656 75798 ns/op 303.69 MB/s Benchmark___RFanOut_8x10x100-16 47364 75451 ns/op 305.08 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5786 605593 ns/op 396.34 MB/s Benchmark__RFanOut_8x10x1000-16 5378 608893 ns/op 394.19 MB/s Benchmark__RFanOut_8x10x1000-16 5690 609438 ns/op 393.84 MB/s Benchmark__RFanOut_8x10x1000-16 5065 605570 ns/op 396.35 MB/s Benchmark__RFanOut_8x10x1000-16 5824 621832 ns/op 385.99 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4969 717991 ns/op 320.36 MB/s Benchmark__RFanOut_8x100x100-16 4909 718816 ns/op 320.00 MB/s Benchmark__RFanOut_8x100x100-16 4975 716901 ns/op 320.85 MB/s Benchmark__RFanOut_8x100x100-16 4930 732897 ns/op 313.85 MB/s Benchmark__RFanOut_8x100x100-16 4828 716384 ns/op 321.08 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 566 6493972 ns/op 369.58 MB/s Benchmark_RFanOut_8x100x1000-16 567 6326141 ns/op 379.38 MB/s Benchmark_RFanOut_8x100x1000-16 564 6274933 ns/op 382.48 MB/s Benchmark_RFanOut_8x100x1000-16 564 6303036 ns/op 380.77 MB/s Benchmark_RFanOut_8x100x1000-16 564 6324861 ns/op 379.46 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 517 6934280 ns/op 360.53 MB/s Benchmark_RFanOut_8x10x10000-16 529 6775606 ns/op 368.97 MB/s Benchmark_RFanOut_8x10x10000-16 516 6884680 ns/op 363.13 MB/s Benchmark_RFanOut_8x10x10000-16 519 6823884 ns/op 366.36 MB/s Benchmark_RFanOut_8x10x10000-16 520 6778049 ns/op 368.84 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3084 1168994 ns/op 8923.09 MB/s Benchmark_RFanOut_1kx10x1000-16 3135 1139525 ns/op 9153.84 MB/s Benchmark_RFanOut_1kx10x1000-16 3033 1160487 ns/op 8988.50 MB/s Benchmark_RFanOut_1kx10x1000-16 3198 1149870 ns/op 9071.50 MB/s Benchmark_RFanOut_1kx10x1000-16 2950 1157511 ns/op 9011.61 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6929678 506.7 ns/op 4101.20 MB/s Benchmark_____FanIn_1kx100x1-16 6935874 505.2 ns/op 4113.31 MB/s Benchmark_____FanIn_1kx100x1-16 6989836 506.3 ns/op 4104.41 MB/s Benchmark_____FanIn_1kx100x1-16 7008280 507.4 ns/op 4095.18 MB/s Benchmark_____FanIn_1kx100x1-16 7027011 504.4 ns/op 4119.77 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2622082 1389 ns/op 5920.98 MB/s Benchmark_____FanIn_4kx100x1-16 2607716 1361 ns/op 6041.20 MB/s Benchmark_____FanIn_4kx100x1-16 2651637 1365 ns/op 6022.97 MB/s Benchmark_____FanIn_4kx100x1-16 2613031 1374 ns/op 5983.23 MB/s Benchmark_____FanIn_4kx100x1-16 2669816 1362 ns/op 6035.14 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1699190 2137 ns/op 7682.47 MB/s Benchmark_____FanIn_8kx100x1-16 1683900 2123 ns/op 7730.44 MB/s Benchmark_____FanIn_8kx100x1-16 1731789 2128 ns/op 7712.07 MB/s Benchmark_____FanIn_8kx100x1-16 1709589 2198 ns/op 7467.73 MB/s Benchmark_____FanIn_8kx100x1-16 1700521 2126 ns/op 7722.40 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 873324 4138 ns/op 7927.44 MB/s Benchmark____FanIn_16kx100x1-16 872011 4155 ns/op 7893.34 MB/s Benchmark____FanIn_16kx100x1-16 867784 4156 ns/op 7891.76 MB/s Benchmark____FanIn_16kx100x1-16 866756 4108 ns/op 7983.71 MB/s Benchmark____FanIn_16kx100x1-16 866109 4184 ns/op 7839.48 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 180478 20079 ns/op 6529.40 MB/s Benchmark____FanIn_64kx100x1-16 166018 19805 ns/op 6619.73 MB/s Benchmark____FanIn_64kx100x1-16 168070 20058 ns/op 6536.27 MB/s Benchmark____FanIn_64kx100x1-16 170344 19935 ns/op 6576.47 MB/s Benchmark____FanIn_64kx100x1-16 168627 20004 ns/op 6553.85 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 544416770 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45584->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45616->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45788->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:45012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45416->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 133056350 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47678->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46866->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47300->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47432->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46894->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: 462747700 vs 11129541000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50082->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49348->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: 3230581960 vs 11640792000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52842->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 243303040 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54424->127.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:53954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54070->127.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:54198->127.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:54060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54136->127.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:53964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54536->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54246->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:54592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54638->127.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:54446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54730->127.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:54080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:54046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54486->127.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:54108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54720->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5558452 647.5 ns/op 438.62 MB/s Benchmark___BumpPubCount_1x3-16 5561049 647.7 ns/op 438.45 MB/s Benchmark___BumpPubCount_1x3-16 5492809 643.7 ns/op 441.19 MB/s Benchmark___BumpPubCount_1x3-16 5514016 649.9 ns/op 436.97 MB/s Benchmark___BumpPubCount_1x3-16 5571829 646.1 ns/op 439.54 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5310301 672.8 ns/op 422.13 MB/s Benchmark___BumpPubCount_2x3-16 5277390 677.4 ns/op 419.23 MB/s Benchmark___BumpPubCount_2x3-16 5319194 673.5 ns/op 421.67 MB/s Benchmark___BumpPubCount_2x3-16 5328805 671.5 ns/op 422.96 MB/s Benchmark___BumpPubCount_2x3-16 5285421 669.2 ns/op 424.39 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5633019 639.8 ns/op 443.86 MB/s Benchmark___BumpPubCount_5x3-16 5548900 642.5 ns/op 442.00 MB/s Benchmark___BumpPubCount_5x3-16 5371762 642.8 ns/op 441.82 MB/s Benchmark___BumpPubCount_5x3-16 5602520 644.3 ns/op 440.78 MB/s Benchmark___BumpPubCount_5x3-16 5493216 638.2 ns/op 445.01 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5575869 644.2 ns/op 440.84 MB/s Benchmark__BumpPubCount_10x3-16 5592058 640.8 ns/op 443.17 MB/s Benchmark__BumpPubCount_10x3-16 5593371 640.9 ns/op 443.11 MB/s Benchmark__BumpPubCount_10x3-16 5615642 642.4 ns/op 442.11 MB/s Benchmark__BumpPubCount_10x3-16 5601907 641.5 ns/op 442.71 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 13694720 270.1 ns/op 3851.13 MB/s Benchmark____GWs_Opt_1kx01x0-16 12950899 265.5 ns/op 3917.63 MB/s Benchmark____GWs_Opt_1kx01x0-16 12826008 273.0 ns/op 3809.24 MB/s Benchmark____GWs_Opt_1kx01x0-16 13263313 266.6 ns/op 3900.45 MB/s Benchmark____GWs_Opt_1kx01x0-16 12758078 278.6 ns/op 3733.49 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10460194 351.7 ns/op 5868.73 MB/s Benchmark____GWs_Opt_2kx01x0-16 10860208 322.7 ns/op 6396.32 MB/s Benchmark____GWs_Opt_2kx01x0-16 10280872 340.3 ns/op 6064.79 MB/s Benchmark____GWs_Opt_2kx01x0-16 10398379 317.4 ns/op 6502.72 MB/s Benchmark____GWs_Opt_2kx01x0-16 10379607 339.9 ns/op 6071.48 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5674495 601.6 ns/op 6835.27 MB/s Benchmark____GWs_Opt_4kx01x0-16 5779485 680.7 ns/op 6040.98 MB/s Benchmark____GWs_Opt_4kx01x0-16 6170335 610.2 ns/op 6738.99 MB/s Benchmark____GWs_Opt_4kx01x0-16 5975084 618.5 ns/op 6648.51 MB/s Benchmark____GWs_Opt_4kx01x0-16 5920995 618.4 ns/op 6649.84 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27743924 115.8 ns/op 8981.78 MB/s Benchmark____GWs_Opt_1kx10x0-16 28498154 117.4 ns/op 8860.90 MB/s Benchmark____GWs_Opt_1kx10x0-16 30658579 113.0 ns/op 9201.25 MB/s Benchmark____GWs_Opt_1kx10x0-16 33017024 112.5 ns/op 9244.59 MB/s Benchmark____GWs_Opt_1kx10x0-16 31283145 112.2 ns/op 9270.11 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 22138686 146.4 ns/op 14098.01 MB/s Benchmark____GWs_Opt_2kx10x0-16 23786941 141.0 ns/op 14642.40 MB/s Benchmark____GWs_Opt_2kx10x0-16 24811824 154.0 ns/op 13405.23 MB/s Benchmark____GWs_Opt_2kx10x0-16 24534817 163.5 ns/op 12624.06 MB/s Benchmark____GWs_Opt_2kx10x0-16 20603587 146.2 ns/op 14118.85 MB/s Benchmark____GWs_Opt_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:40086->127.0.0.1:41353: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:48098->127.0.0.1:42931: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 10553430 336.4 ns/op 12222.84 MB/s Benchmark____GWs_Opt_4kx10x0-16 12989042 370.5 ns/op 11097.84 MB/s Benchmark____GWs_Opt_4kx10x0-16 12110712 303.6 ns/op 13544.69 MB/s Benchmark____GWs_Opt_4kx10x0-16 10237297 311.3 ns/op 13210.19 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6494805 548.3 ns/op 5699.89 MB/s Benchmark____GWs_Opt_1kx01x1-16 6642429 551.4 ns/op 5667.28 MB/s Benchmark____GWs_Opt_1kx01x1-16 6878583 542.0 ns/op 5765.50 MB/s Benchmark____GWs_Opt_1kx01x1-16 6499452 545.8 ns/op 5725.56 MB/s Benchmark____GWs_Opt_1kx01x1-16 6564090 551.2 ns/op 5669.77 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4806931 749.8 ns/op 8264.37 MB/s Benchmark____GWs_Opt_2kx01x1-16 4765195 754.4 ns/op 8214.23 MB/s Benchmark____GWs_Opt_2kx01x1-16 4691103 752.6 ns/op 8234.64 MB/s Benchmark____GWs_Opt_2kx01x1-16 4847443 915.3 ns/op 6770.63 MB/s Benchmark____GWs_Opt_2kx01x1-16 4728753 752.9 ns/op 8230.51 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2611935 1361 ns/op 9066.73 MB/s Benchmark____GWs_Opt_4kx01x1-16 2666773 1353 ns/op 9122.60 MB/s Benchmark____GWs_Opt_4kx01x1-16 2595792 1658 ns/op 7442.57 MB/s Benchmark____GWs_Opt_4kx01x1-16 2618204 1482 ns/op 8327.76 MB/s Benchmark____GWs_Opt_4kx01x1-16 2686418 1365 ns/op 9042.66 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6643650 552.7 ns/op 5654.34 MB/s Benchmark____GWs_Opt_1kx10x1-16 6197995 556.3 ns/op 5617.46 MB/s Benchmark____GWs_Opt_1kx10x1-16 6635656 579.0 ns/op 5397.56 MB/s Benchmark____GWs_Opt_1kx10x1-16 6659402 552.2 ns/op 5658.68 MB/s Benchmark____GWs_Opt_1kx10x1-16 6376690 540.5 ns/op 5781.47 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4093953 837.8 ns/op 7396.68 MB/s Benchmark____GWs_Opt_2kx10x1-16 4220570 824.4 ns/op 7517.08 MB/s Benchmark____GWs_Opt_2kx10x1-16 3952630 836.7 ns/op 7406.24 MB/s Benchmark____GWs_Opt_2kx10x1-16 4304514 829.7 ns/op 7469.07 MB/s Benchmark____GWs_Opt_2kx10x1-16 4574829 822.4 ns/op 7535.23 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2421832 1584 ns/op 7790.16 MB/s Benchmark____GWs_Opt_4kx10x1-16 2366426 1518 ns/op 8129.70 MB/s Benchmark____GWs_Opt_4kx10x1-16 2353521 1511 ns/op 8166.71 MB/s Benchmark____GWs_Opt_4kx10x1-16 2283307 1506 ns/op 8192.13 MB/s Benchmark____GWs_Opt_4kx10x1-16 2375743 1410 ns/op 8753.28 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12618937 292.7 ns/op 3553.49 MB/s Benchmark____GWs_Int_1kx01x0-16 11115555 291.2 ns/op 3571.17 MB/s Benchmark____GWs_Int_1kx01x0-16 11852970 287.1 ns/op 3622.89 MB/s Benchmark____GWs_Int_1kx01x0-16 11939371 275.3 ns/op 3777.54 MB/s Benchmark____GWs_Int_1kx01x0-16 11226552 277.5 ns/op 3748.19 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10103362 351.5 ns/op 5871.30 MB/s Benchmark____GWs_Int_2kx01x0-16 10866009 357.4 ns/op 5774.87 MB/s Benchmark____GWs_Int_2kx01x0-16 10978971 348.7 ns/op 5919.13 MB/s Benchmark____GWs_Int_2kx01x0-16 10280427 358.7 ns/op 5753.34 MB/s Benchmark____GWs_Int_2kx01x0-16 9839298 341.8 ns/op 6038.22 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5876619 625.3 ns/op 6575.76 MB/s Benchmark____GWs_Int_4kx01x0-16 5874706 630.1 ns/op 6525.63 MB/s Benchmark____GWs_Int_4kx01x0-16 5642047 611.2 ns/op 6728.20 MB/s Benchmark____GWs_Int_4kx01x0-16 5708618 627.9 ns/op 6548.85 MB/s Benchmark____GWs_Int_4kx01x0-16 5953519 613.7 ns/op 6700.50 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31084204 109.9 ns/op 9461.65 MB/s Benchmark____GWs_Int_1kx10x0-16 32604207 114.1 ns/op 9111.45 MB/s Benchmark____GWs_Int_1kx10x0-16 27478496 111.6 ns/op 9321.18 MB/s Benchmark____GWs_Int_1kx10x0-16 31897916 117.0 ns/op 8885.52 MB/s Benchmark____GWs_Int_1kx10x0-16 31502605 111.2 ns/op 9350.34 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 21286179 152.0 ns/op 13575.57 MB/s Benchmark____GWs_Int_2kx10x0-16 24817206 153.9 ns/op 13414.82 MB/s Benchmark____GWs_Int_2kx10x0-16 25463052 157.0 ns/op 13146.93 MB/s Benchmark____GWs_Int_2kx10x0-16 25729860 147.2 ns/op 14017.46 MB/s Benchmark____GWs_Int_2kx10x0-16 21652024 156.1 ns/op 13223.25 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12517484 278.3 ns/op 14773.44 MB/s Benchmark____GWs_Int_4kx10x0-16 13537910 284.8 ns/op 14436.98 MB/s Benchmark____GWs_Int_4kx10x0-16 7956878 414.8 ns/op 9912.47 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:49004->127.0.0.1:45933: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 bench_test.go:158: Error on read: read tcp 127.0.0.1:34850->127.0.0.1:34851: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:49394->127.0.0.1:45197: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6472236 546.8 ns/op 5715.15 MB/s Benchmark____GWs_Int_1kx01x1-16 6535454 550.7 ns/op 5674.46 MB/s Benchmark____GWs_Int_1kx01x1-16 6543686 550.4 ns/op 5677.57 MB/s Benchmark____GWs_Int_1kx01x1-16 6436504 555.5 ns/op 5625.09 MB/s Benchmark____GWs_Int_1kx01x1-16 6425316 555.7 ns/op 5623.26 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4767676 761.3 ns/op 8140.01 MB/s Benchmark____GWs_Int_2kx01x1-16 4684114 758.6 ns/op 8169.15 MB/s Benchmark____GWs_Int_2kx01x1-16 4840671 760.9 ns/op 8144.81 MB/s Benchmark____GWs_Int_2kx01x1-16 4690056 773.2 ns/op 8014.51 MB/s Benchmark____GWs_Int_2kx01x1-16 4782109 765.4 ns/op 8096.10 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2674315 1347 ns/op 9163.11 MB/s Benchmark____GWs_Int_4kx01x1-16 2690044 1354 ns/op 9112.44 MB/s Benchmark____GWs_Int_4kx01x1-16 2682759 1369 ns/op 9017.84 MB/s Benchmark____GWs_Int_4kx01x1-16 2622835 1356 ns/op 9103.10 MB/s Benchmark____GWs_Int_4kx01x1-16 2613435 1341 ns/op 9205.55 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6582832 547.5 ns/op 5707.88 MB/s Benchmark____GWs_Int_1kx10x1-16 6615038 543.2 ns/op 5752.90 MB/s Benchmark____GWs_Int_1kx10x1-16 6650488 549.5 ns/op 5687.12 MB/s Benchmark____GWs_Int_1kx10x1-16 6538525 550.4 ns/op 5677.75 MB/s Benchmark____GWs_Int_1kx10x1-16 6614196 541.3 ns/op 5773.29 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3893517 833.6 ns/op 7434.27 MB/s Benchmark____GWs_Int_2kx10x1-16 4467696 825.6 ns/op 7505.66 MB/s Benchmark____GWs_Int_2kx10x1-16 4276632 829.7 ns/op 7468.86 MB/s Benchmark____GWs_Int_2kx10x1-16 4229924 825.1 ns/op 7510.24 MB/s Benchmark____GWs_Int_2kx10x1-16 4334176 846.0 ns/op 7325.39 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2320794 1683 ns/op 7332.17 MB/s Benchmark____GWs_Int_4kx10x1-16 2377398 1649 ns/op 7485.70 MB/s Benchmark____GWs_Int_4kx10x1-16 2384182 1575 ns/op 7835.21 MB/s Benchmark____GWs_Int_4kx10x1-16 2402056 1489 ns/op 8286.03 MB/s Benchmark____GWs_Int_4kx10x1-16 2503489 1516 ns/op 8141.53 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8104291 433.2 ns/op 235.43 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8581646 435.3 ns/op 234.33 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8368711 438.3 ns/op 232.71 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8440249 439.5 ns/op 232.06 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7768656 429.5 ns/op 237.47 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 618069 4947 ns/op 35.78 MB/s Benchmark__GWs_Reqs_1SubEach-16 796756 5176 ns/op 34.20 MB/s Benchmark__GWs_Reqs_1SubEach-16 733633 5189 ns/op 34.11 MB/s Benchmark__GWs_Reqs_1SubEach-16 726724 5292 ns/op 33.45 MB/s Benchmark__GWs_Reqs_1SubEach-16 765693 5225 ns/op 33.88 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2143.329s