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 49682835 72.19 ns/op 152.37 MB/s Benchmark______Pub0b_Payload-16 44999845 72.36 ns/op 152.02 MB/s Benchmark______Pub0b_Payload-16 47284774 72.97 ns/op 150.74 MB/s Benchmark______Pub0b_Payload-16 47366758 72.02 ns/op 152.73 MB/s Benchmark______Pub0b_Payload-16 47585088 76.12 ns/op 144.51 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 49661844 72.66 ns/op 261.49 MB/s Benchmark______Pub8b_Payload-16 45815254 76.72 ns/op 247.65 MB/s Benchmark______Pub8b_Payload-16 49585155 72.76 ns/op 261.13 MB/s Benchmark______Pub8b_Payload-16 46316868 72.68 ns/op 261.43 MB/s Benchmark______Pub8b_Payload-16 46434296 72.72 ns/op 261.28 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44423125 76.70 ns/op 573.67 MB/s Benchmark_____Pub32b_Payload-16 44331729 77.02 ns/op 571.28 MB/s Benchmark_____Pub32b_Payload-16 44199234 76.69 ns/op 573.71 MB/s Benchmark_____Pub32b_Payload-16 44625663 76.69 ns/op 573.75 MB/s Benchmark_____Pub32b_Payload-16 46713360 77.28 ns/op 569.33 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39436288 85.71 ns/op 1645.14 MB/s Benchmark____Pub128B_Payload-16 39810216 91.15 ns/op 1546.92 MB/s Benchmark____Pub128B_Payload-16 35063552 89.65 ns/op 1572.77 MB/s Benchmark____Pub128B_Payload-16 41972061 85.52 ns/op 1648.72 MB/s Benchmark____Pub128B_Payload-16 39209529 86.08 ns/op 1637.99 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 32317022 93.39 ns/op 2880.34 MB/s Benchmark____Pub256B_Payload-16 32410912 94.24 ns/op 2854.27 MB/s Benchmark____Pub256B_Payload-16 35867786 95.42 ns/op 2819.24 MB/s Benchmark____Pub256B_Payload-16 36107181 96.53 ns/op 2786.83 MB/s Benchmark____Pub256B_Payload-16 36145700 94.20 ns/op 2855.74 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25715541 139.2 ns/op 7455.84 MB/s Benchmark______Pub1K_Payload-16 23834497 140.7 ns/op 7377.77 MB/s Benchmark______Pub1K_Payload-16 22601119 139.0 ns/op 7465.63 MB/s Benchmark______Pub1K_Payload-16 24994062 140.9 ns/op 7364.77 MB/s Benchmark______Pub1K_Payload-16 24343864 135.9 ns/op 7637.38 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5394291 617.4 ns/op 6656.87 MB/s Benchmark______Pub4K_Payload-16 5644992 618.7 ns/op 6643.14 MB/s Benchmark______Pub4K_Payload-16 5239658 617.2 ns/op 6658.60 MB/s Benchmark______Pub4K_Payload-16 5470515 634.4 ns/op 6478.92 MB/s Benchmark______Pub4K_Payload-16 5782587 630.4 ns/op 6519.92 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2848033 1283 ns/op 6397.67 MB/s Benchmark______Pub8K_Payload-16 2765995 1291 ns/op 6356.50 MB/s Benchmark______Pub8K_Payload-16 2796432 1270 ns/op 6463.11 MB/s Benchmark______Pub8K_Payload-16 2767316 1288 ns/op 6373.28 MB/s Benchmark______Pub8K_Payload-16 2744788 1283 ns/op 6397.51 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 645912 5582 ns/op 5873.28 MB/s Benchmark_____Pub32K_Payload-16 658869 5471 ns/op 5991.90 MB/s Benchmark_____Pub32K_Payload-16 653061 5437 ns/op 6029.50 MB/s Benchmark_____Pub32K_Payload-16 656133 6937 ns/op 4725.87 MB/s Benchmark_____Pub32K_Payload-16 644413 5489 ns/op 5972.65 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32555532 93.83 ns/op 117.24 MB/s Benchmark__AuthPub0b_Payload-16 37180934 92.80 ns/op 118.54 MB/s Benchmark__AuthPub0b_Payload-16 32603960 92.63 ns/op 118.75 MB/s Benchmark__AuthPub0b_Payload-16 37089838 92.85 ns/op 118.48 MB/s Benchmark__AuthPub0b_Payload-16 36913305 92.60 ns/op 118.79 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15662870 226.3 ns/op Benchmark_____________PubSub-16 15712429 226.1 ns/op Benchmark_____________PubSub-16 15725134 226.5 ns/op Benchmark_____________PubSub-16 15626486 225.9 ns/op Benchmark_____________PubSub-16 15609907 226.8 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15600538 224.3 ns/op Benchmark_____PubSubTwoConns-16 15686554 224.4 ns/op Benchmark_____PubSubTwoConns-16 15740028 225.4 ns/op Benchmark_____PubSubTwoConns-16 15755454 225.1 ns/op Benchmark_____PubSubTwoConns-16 15692665 225.3 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54290->127.0.0.1:33893: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:41060->127.0.0.1:33133: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:37646->127.0.0.1:34523: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43874->127.0.0.1:36927: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:44630->127.0.0.1:34669: 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 14600529 243.5 ns/op Benchmark_____PubTwoQueueSub-16 14428202 244.0 ns/op Benchmark_____PubTwoQueueSub-16 14525727 243.4 ns/op Benchmark_____PubTwoQueueSub-16 14370291 244.1 ns/op Benchmark_____PubTwoQueueSub-16 14555480 243.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14482136 244.0 ns/op Benchmark____PubFourQueueSub-16 14420437 243.0 ns/op Benchmark____PubFourQueueSub-16 14457951 243.6 ns/op Benchmark____PubFourQueueSub-16 14741125 244.5 ns/op Benchmark____PubFourQueueSub-16 14629705 243.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14360899 244.8 ns/op Benchmark___PubEightQueueSub-16 14562133 244.0 ns/op Benchmark___PubEightQueueSub-16 14591181 243.5 ns/op Benchmark___PubEightQueueSub-16 14549548 244.5 ns/op Benchmark___PubEightQueueSub-16 14402797 243.3 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23298 161020 ns/op Benchmark_PubSub512kTwoConns-16 23038 155518 ns/op Benchmark_PubSub512kTwoConns-16 23197 155691 ns/op Benchmark_PubSub512kTwoConns-16 23268 155073 ns/op Benchmark_PubSub512kTwoConns-16 23133 154512 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15224862 228.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15240879 228.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15214258 228.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15222874 228.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15385220 229.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15254209 228.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 15242335 228.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15373842 229.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15421657 229.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15254136 228.8 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11563532 313.0 ns/op Benchmark____RoutedPubSub_0b-16 11626567 311.1 ns/op Benchmark____RoutedPubSub_0b-16 11761051 313.3 ns/op Benchmark____RoutedPubSub_0b-16 11441182 313.8 ns/op Benchmark____RoutedPubSub_0b-16 11287467 315.5 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6315156 540.4 ns/op Benchmark____RoutedPubSub_1K-16 6753225 538.2 ns/op Benchmark____RoutedPubSub_1K-16 6709394 540.8 ns/op Benchmark____RoutedPubSub_1K-16 6695067 539.1 ns/op Benchmark____RoutedPubSub_1K-16 6628056 532.7 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85108 45545 ns/op Benchmark__RoutedPubSub_100K-16 76920 49024 ns/op Benchmark__RoutedPubSub_100K-16 73369 42598 ns/op Benchmark__RoutedPubSub_100K-16 83944 42187 ns/op Benchmark__RoutedPubSub_100K-16 83935 41720 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9653774 314.6 ns/op Benchmark____Routed2QueueSub-16 9910699 320.1 ns/op Benchmark____Routed2QueueSub-16 9844705 312.7 ns/op Benchmark____Routed2QueueSub-16 9549004 316.7 ns/op Benchmark____Routed2QueueSub-16 9816232 313.6 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9719528 316.4 ns/op Benchmark____Routed4QueueSub-16 9695804 320.0 ns/op Benchmark____Routed4QueueSub-16 9622473 322.0 ns/op Benchmark____Routed4QueueSub-16 9788268 321.7 ns/op Benchmark____Routed4QueueSub-16 9677374 324.3 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9538458 326.7 ns/op Benchmark____Routed8QueueSub-16 9289915 328.7 ns/op Benchmark____Routed8QueueSub-16 9232816 327.7 ns/op Benchmark____Routed8QueueSub-16 10946575 328.9 ns/op Benchmark____Routed8QueueSub-16 9460891 328.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8818639 344.8 ns/op Benchmark___Routed16QueueSub-16 8913032 340.7 ns/op Benchmark___Routed16QueueSub-16 8989250 346.6 ns/op Benchmark___Routed16QueueSub-16 8881700 344.1 ns/op Benchmark___Routed16QueueSub-16 8889158 344.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6439810 548.7 ns/op Benchmark____________RouteCompressOff-16 6396064 551.0 ns/op Benchmark____________RouteCompressOff-16 6328707 556.5 ns/op Benchmark____________RouteCompressOff-16 6530316 554.5 ns/op Benchmark____________RouteCompressOff-16 6209421 551.9 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6201448 553.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6479420 549.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6401763 550.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6603787 546.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6510052 551.2 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6435694 548.8 ns/op Benchmark_________RouteCompressS2Fast-16 6422970 547.6 ns/op Benchmark_________RouteCompressS2Fast-16 6545671 551.9 ns/op Benchmark_________RouteCompressS2Fast-16 6353024 553.8 ns/op Benchmark_________RouteCompressS2Fast-16 6612568 552.9 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6442814 549.5 ns/op Benchmark_______RouteCompressS2Better-16 6523561 550.0 ns/op Benchmark_______RouteCompressS2Better-16 6511632 547.0 ns/op Benchmark_______RouteCompressS2Better-16 6525937 548.4 ns/op Benchmark_______RouteCompressS2Better-16 6460502 546.5 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6388588 542.1 ns/op Benchmark_________RouteCompressS2Best-16 6498596 549.1 ns/op Benchmark_________RouteCompressS2Best-16 6516202 550.5 ns/op Benchmark_________RouteCompressS2Best-16 6467151 546.1 ns/op Benchmark_________RouteCompressS2Best-16 6469149 545.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4615647 775.8 ns/op 320.97 MB/s Benchmark______FanOut_8x1x10-16 4624857 778.9 ns/op 319.68 MB/s Benchmark______FanOut_8x1x10-16 4627084 777.5 ns/op 320.25 MB/s Benchmark______FanOut_8x1x10-16 4639197 783.3 ns/op 317.90 MB/s Benchmark______FanOut_8x1x10-16 4644172 779.3 ns/op 319.50 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 540188 6155 ns/op 376.77 MB/s Benchmark_____FanOut_8x1x100-16 533773 6134 ns/op 378.03 MB/s Benchmark_____FanOut_8x1x100-16 554840 6150 ns/op 377.05 MB/s Benchmark_____FanOut_8x1x100-16 519961 6216 ns/op 373.06 MB/s Benchmark_____FanOut_8x1x100-16 523558 6164 ns/op 376.20 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46848 74854 ns/op 307.52 MB/s Benchmark____FanOut_8x10x100-16 47373 74990 ns/op 306.96 MB/s Benchmark____FanOut_8x10x100-16 47776 75127 ns/op 306.40 MB/s Benchmark____FanOut_8x10x100-16 47460 75601 ns/op 304.48 MB/s Benchmark____FanOut_8x10x100-16 47942 74711 ns/op 308.11 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5959 600120 ns/op 399.95 MB/s Benchmark___FanOut_8x10x1000-16 5536 600451 ns/op 399.73 MB/s Benchmark___FanOut_8x10x1000-16 5984 600894 ns/op 399.44 MB/s Benchmark___FanOut_8x10x1000-16 5787 630391 ns/op 380.75 MB/s Benchmark___FanOut_8x10x1000-16 5712 598207 ns/op 401.23 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5028 710533 ns/op 323.73 MB/s Benchmark___FanOut_8x100x100-16 4994 721345 ns/op 318.88 MB/s Benchmark___FanOut_8x100x100-16 4969 710785 ns/op 323.61 MB/s Benchmark___FanOut_8x100x100-16 5008 712068 ns/op 323.03 MB/s Benchmark___FanOut_8x100x100-16 4872 722288 ns/op 318.46 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 578 6280863 ns/op 382.12 MB/s Benchmark__FanOut_8x100x1000-16 564 6292982 ns/op 381.38 MB/s Benchmark__FanOut_8x100x1000-16 578 6165601 ns/op 389.26 MB/s Benchmark__FanOut_8x100x1000-16 568 6349579 ns/op 377.98 MB/s Benchmark__FanOut_8x100x1000-16 570 6238239 ns/op 384.73 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 520 6729787 ns/op 371.49 MB/s Benchmark__FanOut_8x10x10000-16 519 6830492 ns/op 366.01 MB/s Benchmark__FanOut_8x10x10000-16 531 6775960 ns/op 368.95 MB/s Benchmark__FanOut_8x10x10000-16 522 6857189 ns/op 364.58 MB/s Benchmark__FanOut_8x10x10000-16 530 6861513 ns/op 364.35 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 928 3782698 ns/op 304.02 MB/s Benchmark___FanOut_8x500x100-16 934 3779023 ns/op 304.32 MB/s Benchmark___FanOut_8x500x100-16 943 3773435 ns/op 304.77 MB/s Benchmark___FanOut_8x500x100-16 934 3772100 ns/op 304.88 MB/s Benchmark___FanOut_8x500x100-16 943 3771322 ns/op 304.94 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 356953 9539 ns/op 1534.81 MB/s Benchmark___FanOut_128x1x100-16 354253 9612 ns/op 1523.22 MB/s Benchmark___FanOut_128x1x100-16 360243 9575 ns/op 1529.07 MB/s Benchmark___FanOut_128x1x100-16 356191 9582 ns/op 1527.98 MB/s Benchmark___FanOut_128x1x100-16 360310 9624 ns/op 1521.33 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32212 112171 ns/op 1293.92 MB/s Benchmark__FanOut_128x10x100-16 32118 111460 ns/op 1302.18 MB/s Benchmark__FanOut_128x10x100-16 32394 111370 ns/op 1303.23 MB/s Benchmark__FanOut_128x10x100-16 32036 111548 ns/op 1301.15 MB/s Benchmark__FanOut_128x10x100-16 32372 111740 ns/op 1298.92 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4116 877699 ns/op 1663.60 MB/s Benchmark_FanOut_128x10x1000-16 3970 879548 ns/op 1660.10 MB/s Benchmark_FanOut_128x10x1000-16 3956 891003 ns/op 1638.76 MB/s Benchmark_FanOut_128x10x1000-16 3996 878871 ns/op 1661.38 MB/s Benchmark_FanOut_128x10x1000-16 3975 878263 ns/op 1662.53 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3472 1019042 ns/op 1423.04 MB/s Benchmark_FanOut_128x100x100-16 3463 1017467 ns/op 1425.25 MB/s Benchmark_FanOut_128x100x100-16 3562 1017909 ns/op 1424.63 MB/s Benchmark_FanOut_128x100x100-16 3439 1021564 ns/op 1419.53 MB/s Benchmark_FanOut_128x100x100-16 3436 1016176 ns/op 1427.06 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 379 9447109 ns/op 1545.46 MB/s BenchmarkFanOut_128x100x1000-16 376 9358171 ns/op 1560.15 MB/s BenchmarkFanOut_128x100x1000-16 374 9404129 ns/op 1552.52 MB/s BenchmarkFanOut_128x100x1000-16 385 9334137 ns/op 1564.17 MB/s BenchmarkFanOut_128x100x1000-16 374 9331704 ns/op 1564.57 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 367 9658044 ns/op 1522.06 MB/s BenchmarkFanOut_128x10x10000-16 370 9634263 ns/op 1525.82 MB/s BenchmarkFanOut_128x10x10000-16 367 9652686 ns/op 1522.91 MB/s BenchmarkFanOut_128x10x10000-16 372 9700806 ns/op 1515.35 MB/s BenchmarkFanOut_128x10x10000-16 370 9784087 ns/op 1502.45 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 678 5289662 ns/op 1370.62 MB/s BenchmarkFanOut__128x500x100-16 668 5316149 ns/op 1363.80 MB/s BenchmarkFanOut__128x500x100-16 667 5294990 ns/op 1369.25 MB/s BenchmarkFanOut__128x500x100-16 667 5305845 ns/op 1366.44 MB/s BenchmarkFanOut__128x500x100-16 674 5303623 ns/op 1367.02 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1928 1865610 ns/op 2835.82 MB/s Benchmark_FanOut_512x100x100-16 1956 1855433 ns/op 2851.37 MB/s Benchmark_FanOut_512x100x100-16 1900 1862236 ns/op 2840.95 MB/s Benchmark_FanOut_512x100x100-16 1912 1862491 ns/op 2840.56 MB/s Benchmark_FanOut_512x100x100-16 1947 1843440 ns/op 2869.92 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16875770 ns/op 3140.63 MB/s Benchmark__FanOut_512x100x1k-16 213 16868638 ns/op 3141.96 MB/s Benchmark__FanOut_512x100x1k-16 211 16878298 ns/op 3140.16 MB/s Benchmark__FanOut_512x100x1k-16 213 16729290 ns/op 3168.13 MB/s Benchmark__FanOut_512x100x1k-16 211 16776375 ns/op 3159.24 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2986 1136946 ns/op 9174.61 MB/s Benchmark____FanOut_1kx10x1k-16 2811 1141299 ns/op 9139.62 MB/s Benchmark____FanOut_1kx10x1k-16 3133 1168056 ns/op 8930.26 MB/s Benchmark____FanOut_1kx10x1k-16 3270 1158681 ns/op 9002.51 MB/s Benchmark____FanOut_1kx10x1k-16 2892 1149316 ns/op 9075.87 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2812 1261809 ns/op 8258.81 MB/s Benchmark__FanOut_1kx100x100-16 2745 1266775 ns/op 8226.43 MB/s Benchmark__FanOut_1kx100x100-16 2772 1265729 ns/op 8233.23 MB/s Benchmark__FanOut_1kx100x100-16 2744 1267077 ns/op 8224.47 MB/s Benchmark__FanOut_1kx100x100-16 2754 1267080 ns/op 8224.45 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4338556 806.2 ns/op 308.86 MB/s Benchmark_____RFanOut_8x1x10-16 4390794 793.4 ns/op 313.84 MB/s Benchmark_____RFanOut_8x1x10-16 4391508 788.8 ns/op 315.67 MB/s Benchmark_____RFanOut_8x1x10-16 4310858 791.3 ns/op 314.69 MB/s Benchmark_____RFanOut_8x1x10-16 4456140 782.7 ns/op 318.12 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 514488 6097 ns/op 380.37 MB/s Benchmark____RFanOut_8x1x100-16 589503 6360 ns/op 364.63 MB/s Benchmark____RFanOut_8x1x100-16 514419 6165 ns/op 376.13 MB/s Benchmark____RFanOut_8x1x100-16 504930 6367 ns/op 364.24 MB/s Benchmark____RFanOut_8x1x100-16 529129 6445 ns/op 359.80 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47750 78290 ns/op 294.02 MB/s Benchmark___RFanOut_8x10x100-16 47503 75404 ns/op 305.28 MB/s Benchmark___RFanOut_8x10x100-16 47793 75150 ns/op 306.31 MB/s Benchmark___RFanOut_8x10x100-16 47407 75117 ns/op 306.44 MB/s Benchmark___RFanOut_8x10x100-16 47770 75257 ns/op 305.87 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5745 612954 ns/op 391.58 MB/s Benchmark__RFanOut_8x10x1000-16 5911 603757 ns/op 397.54 MB/s Benchmark__RFanOut_8x10x1000-16 5708 605840 ns/op 396.18 MB/s Benchmark__RFanOut_8x10x1000-16 5808 606136 ns/op 395.98 MB/s Benchmark__RFanOut_8x10x1000-16 5674 607645 ns/op 395.00 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4878 715035 ns/op 321.69 MB/s Benchmark__RFanOut_8x100x100-16 4932 715494 ns/op 321.48 MB/s Benchmark__RFanOut_8x100x100-16 4868 714609 ns/op 321.88 MB/s Benchmark__RFanOut_8x100x100-16 4958 716496 ns/op 321.03 MB/s Benchmark__RFanOut_8x100x100-16 4952 714604 ns/op 321.88 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 565 6360070 ns/op 377.36 MB/s Benchmark_RFanOut_8x100x1000-16 562 6310755 ns/op 380.31 MB/s Benchmark_RFanOut_8x100x1000-16 558 6294382 ns/op 381.30 MB/s Benchmark_RFanOut_8x100x1000-16 566 6227442 ns/op 385.39 MB/s Benchmark_RFanOut_8x100x1000-16 564 6306015 ns/op 380.59 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 523 6865865 ns/op 364.12 MB/s Benchmark_RFanOut_8x10x10000-16 532 6880510 ns/op 363.35 MB/s Benchmark_RFanOut_8x10x10000-16 520 6891290 ns/op 362.78 MB/s Benchmark_RFanOut_8x10x10000-16 514 6803601 ns/op 367.46 MB/s Benchmark_RFanOut_8x10x10000-16 510 6878005 ns/op 363.48 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2875 1147900 ns/op 9087.06 MB/s Benchmark_RFanOut_1kx10x1000-16 3193 1156562 ns/op 9019.01 MB/s Benchmark_RFanOut_1kx10x1000-16 3232 1136828 ns/op 9175.57 MB/s Benchmark_RFanOut_1kx10x1000-16 2966 1157987 ns/op 9007.91 MB/s Benchmark_RFanOut_1kx10x1000-16 3038 1136371 ns/op 9179.25 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7028774 504.7 ns/op 4117.31 MB/s Benchmark_____FanIn_1kx100x1-16 7011009 506.2 ns/op 4105.26 MB/s Benchmark_____FanIn_1kx100x1-16 6941476 524.2 ns/op 3964.48 MB/s Benchmark_____FanIn_1kx100x1-16 6969368 506.3 ns/op 4104.57 MB/s Benchmark_____FanIn_1kx100x1-16 7004353 503.2 ns/op 4129.56 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2584938 1367 ns/op 6016.16 MB/s Benchmark_____FanIn_4kx100x1-16 2607495 1372 ns/op 5993.29 MB/s Benchmark_____FanIn_4kx100x1-16 2630570 1369 ns/op 6006.19 MB/s Benchmark_____FanIn_4kx100x1-16 2643550 1376 ns/op 5976.66 MB/s Benchmark_____FanIn_4kx100x1-16 2611334 1369 ns/op 6006.23 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1698955 2101 ns/op 7813.97 MB/s Benchmark_____FanIn_8kx100x1-16 1707621 2127 ns/op 7716.72 MB/s Benchmark_____FanIn_8kx100x1-16 1703902 2102 ns/op 7808.27 MB/s Benchmark_____FanIn_8kx100x1-16 1701909 2109 ns/op 7784.02 MB/s Benchmark_____FanIn_8kx100x1-16 1707164 2100 ns/op 7817.31 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 878031 4103 ns/op 7994.05 MB/s Benchmark____FanIn_16kx100x1-16 861968 4117 ns/op 7966.52 MB/s Benchmark____FanIn_16kx100x1-16 845108 4112 ns/op 7976.08 MB/s Benchmark____FanIn_16kx100x1-16 871149 4160 ns/op 7884.28 MB/s Benchmark____FanIn_16kx100x1-16 867547 4137 ns/op 7928.65 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 166298 19957 ns/op 6569.30 MB/s Benchmark____FanIn_64kx100x1-16 168763 19867 ns/op 6599.11 MB/s Benchmark____FanIn_64kx100x1-16 165694 19823 ns/op 6613.74 MB/s Benchmark____FanIn_64kx100x1-16 151914 20166 ns/op 6501.29 MB/s Benchmark____FanIn_64kx100x1-16 165730 19803 ns/op 6620.34 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 172121170 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36144->127.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: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: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:35882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36448->127.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:36508->127.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:36308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36530->127.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:36570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35890->127.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:36000->127.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:36124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36396->127.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:36016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36484->127.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: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:36368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36804->127.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:36134->127.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:35922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35938->127.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:36328->127.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:35954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36132->127.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:36048->127.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:36384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36642->127.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:35970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36718->127.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:36326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36214->127.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:36086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36582->127.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:36654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36078->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 215380870 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38220->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38108->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: 346470870 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40074->127.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:40602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40046->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:40170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39718->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: 152588760 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41794->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: 1249680970 vs 11667010000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44926->127.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:44276->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44684->127.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: broken pipe 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:44818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44762->127.0.0.1:5222: write: connection reset by peer 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:44644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44592->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44254->127.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:44628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44574->127.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:45142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44300->127.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:44598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45078->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44474->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5540326 647.9 ns/op 438.35 MB/s Benchmark___BumpPubCount_1x3-16 5510976 642.5 ns/op 442.00 MB/s Benchmark___BumpPubCount_1x3-16 5581257 644.2 ns/op 440.89 MB/s Benchmark___BumpPubCount_1x3-16 5583651 644.8 ns/op 440.45 MB/s Benchmark___BumpPubCount_1x3-16 5522914 648.9 ns/op 437.67 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5275651 677.0 ns/op 419.49 MB/s Benchmark___BumpPubCount_2x3-16 5294922 672.2 ns/op 422.50 MB/s Benchmark___BumpPubCount_2x3-16 5242278 680.5 ns/op 417.33 MB/s Benchmark___BumpPubCount_2x3-16 5265278 676.8 ns/op 419.62 MB/s Benchmark___BumpPubCount_2x3-16 5258796 677.1 ns/op 419.43 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5408478 642.8 ns/op 441.80 MB/s Benchmark___BumpPubCount_5x3-16 5324714 645.8 ns/op 439.74 MB/s Benchmark___BumpPubCount_5x3-16 5136964 647.2 ns/op 438.81 MB/s Benchmark___BumpPubCount_5x3-16 5480726 646.2 ns/op 439.52 MB/s Benchmark___BumpPubCount_5x3-16 5157530 643.9 ns/op 441.05 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5555740 645.3 ns/op 440.13 MB/s Benchmark__BumpPubCount_10x3-16 5552246 647.1 ns/op 438.90 MB/s Benchmark__BumpPubCount_10x3-16 5578065 645.4 ns/op 440.04 MB/s Benchmark__BumpPubCount_10x3-16 5604045 647.7 ns/op 438.47 MB/s Benchmark__BumpPubCount_10x3-16 5563848 651.9 ns/op 435.66 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12314282 269.3 ns/op 3861.83 MB/s Benchmark____GWs_Opt_1kx01x0-16 12692881 274.0 ns/op 3796.13 MB/s Benchmark____GWs_Opt_1kx01x0-16 12404646 274.3 ns/op 3791.49 MB/s Benchmark____GWs_Opt_1kx01x0-16 12727372 268.2 ns/op 3877.14 MB/s Benchmark____GWs_Opt_1kx01x0-16 11855076 268.1 ns/op 3878.54 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9481479 334.7 ns/op 6166.33 MB/s Benchmark____GWs_Opt_2kx01x0-16 10207839 334.9 ns/op 6162.59 MB/s Benchmark____GWs_Opt_2kx01x0-16 10314967 332.2 ns/op 6212.62 MB/s Benchmark____GWs_Opt_2kx01x0-16 10284398 335.7 ns/op 6149.03 MB/s Benchmark____GWs_Opt_2kx01x0-16 10273308 351.0 ns/op 5879.96 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5549658 648.7 ns/op 6338.46 MB/s Benchmark____GWs_Opt_4kx01x0-16 5435526 621.8 ns/op 6613.58 MB/s Benchmark____GWs_Opt_4kx01x0-16 5805480 631.7 ns/op 6509.45 MB/s Benchmark____GWs_Opt_4kx01x0-16 5576779 635.9 ns/op 6466.73 MB/s Benchmark____GWs_Opt_4kx01x0-16 5637595 629.8 ns/op 6528.81 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 32131839 119.3 ns/op 8719.21 MB/s Benchmark____GWs_Opt_1kx10x0-16 28248039 107.0 ns/op 9720.74 MB/s Benchmark____GWs_Opt_1kx10x0-16 32420760 134.1 ns/op 7754.40 MB/s Benchmark____GWs_Opt_1kx10x0-16 30601868 113.9 ns/op 9131.14 MB/s Benchmark____GWs_Opt_1kx10x0-16 31798881 111.9 ns/op 9291.98 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 22325746 164.2 ns/op 12573.49 MB/s Benchmark____GWs_Opt_2kx10x0-16 18566534 163.8 ns/op 12600.57 MB/s Benchmark____GWs_Opt_2kx10x0-16 25241958 142.2 ns/op 14513.68 MB/s Benchmark____GWs_Opt_2kx10x0-16 24949899 152.9 ns/op 13499.83 MB/s Benchmark____GWs_Opt_2kx10x0-16 24521146 155.4 ns/op 13280.12 MB/s Benchmark____GWs_Opt_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:54848->127.0.0.1:39093: 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:51858->127.0.0.1:43505: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 13349800 305.5 ns/op 13458.21 MB/s Benchmark____GWs_Opt_4kx10x0-16 12694651 300.7 ns/op 13673.21 MB/s Benchmark____GWs_Opt_4kx10x0-16 12491582 316.1 ns/op 13009.18 MB/s Benchmark____GWs_Opt_4kx10x0-16 11531047 286.7 ns/op 14341.50 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6433320 541.2 ns/op 5774.58 MB/s Benchmark____GWs_Opt_1kx01x1-16 6550269 541.9 ns/op 5767.27 MB/s Benchmark____GWs_Opt_1kx01x1-16 6716149 546.6 ns/op 5716.73 MB/s Benchmark____GWs_Opt_1kx01x1-16 6598717 549.7 ns/op 5684.54 MB/s Benchmark____GWs_Opt_1kx01x1-16 6523636 546.7 ns/op 5716.30 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4682912 754.4 ns/op 8214.26 MB/s Benchmark____GWs_Opt_2kx01x1-16 4595178 746.6 ns/op 8300.48 MB/s Benchmark____GWs_Opt_2kx01x1-16 4624867 757.0 ns/op 8185.94 MB/s Benchmark____GWs_Opt_2kx01x1-16 4659024 752.3 ns/op 8237.49 MB/s Benchmark____GWs_Opt_2kx01x1-16 4868808 768.4 ns/op 8065.32 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2616343 1365 ns/op 9038.94 MB/s Benchmark____GWs_Opt_4kx01x1-16 2623689 1369 ns/op 9014.09 MB/s Benchmark____GWs_Opt_4kx01x1-16 2685156 1382 ns/op 8926.82 MB/s Benchmark____GWs_Opt_4kx01x1-16 2605371 1375 ns/op 8973.39 MB/s Benchmark____GWs_Opt_4kx01x1-16 1000000 3332 ns/op 3703.53 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6467223 660.0 ns/op 4734.68 MB/s Benchmark____GWs_Opt_1kx10x1-16 6153397 551.6 ns/op 5665.48 MB/s Benchmark____GWs_Opt_1kx10x1-16 6232494 552.4 ns/op 5657.45 MB/s Benchmark____GWs_Opt_1kx10x1-16 6224848 546.5 ns/op 5718.54 MB/s Benchmark____GWs_Opt_1kx10x1-16 6672769 539.9 ns/op 5788.12 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4323206 850.6 ns/op 7285.28 MB/s Benchmark____GWs_Opt_2kx10x1-16 4128246 829.4 ns/op 7471.98 MB/s Benchmark____GWs_Opt_2kx10x1-16 4258730 865.3 ns/op 7161.82 MB/s Benchmark____GWs_Opt_2kx10x1-16 4244881 792.2 ns/op 7822.16 MB/s Benchmark____GWs_Opt_2kx10x1-16 4304990 795.7 ns/op 7788.35 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2386033 1569 ns/op 7867.91 MB/s Benchmark____GWs_Opt_4kx10x1-16 2476857 1486 ns/op 8304.95 MB/s Benchmark____GWs_Opt_4kx10x1-16 2346284 1516 ns/op 8137.84 MB/s Benchmark____GWs_Opt_4kx10x1-16 2381253 1580 ns/op 7810.43 MB/s Benchmark____GWs_Opt_4kx10x1-16 2422806 1530 ns/op 8065.49 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12033214 281.4 ns/op 3696.36 MB/s Benchmark____GWs_Int_1kx01x0-16 12723526 289.6 ns/op 3591.02 MB/s Benchmark____GWs_Int_1kx01x0-16 12267757 284.5 ns/op 3655.70 MB/s Benchmark____GWs_Int_1kx01x0-16 12677823 293.7 ns/op 3541.57 MB/s Benchmark____GWs_Int_1kx01x0-16 12071472 285.3 ns/op 3645.58 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10308742 372.8 ns/op 5536.80 MB/s Benchmark____GWs_Int_2kx01x0-16 10370498 373.7 ns/op 5523.26 MB/s Benchmark____GWs_Int_2kx01x0-16 9008516 352.1 ns/op 5861.61 MB/s Benchmark____GWs_Int_2kx01x0-16 9981517 352.9 ns/op 5848.20 MB/s Benchmark____GWs_Int_2kx01x0-16 10246141 324.0 ns/op 6370.47 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5650993 636.6 ns/op 6459.73 MB/s Benchmark____GWs_Int_4kx01x0-16 5566720 643.5 ns/op 6390.47 MB/s Benchmark____GWs_Int_4kx01x0-16 5621691 656.7 ns/op 6262.00 MB/s Benchmark____GWs_Int_4kx01x0-16 5615444 642.4 ns/op 6400.51 MB/s Benchmark____GWs_Int_4kx01x0-16 5681750 650.0 ns/op 6326.37 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31390656 112.0 ns/op 9283.31 MB/s Benchmark____GWs_Int_1kx10x0-16 29667810 111.3 ns/op 9343.36 MB/s Benchmark____GWs_Int_1kx10x0-16 28995418 109.6 ns/op 9488.05 MB/s Benchmark____GWs_Int_1kx10x0-16 31342756 112.5 ns/op 9244.06 MB/s Benchmark____GWs_Int_1kx10x0-16 31484860 113.5 ns/op 9163.12 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 19222197 157.7 ns/op 13090.26 MB/s Benchmark____GWs_Int_2kx10x0-16 25077925 139.1 ns/op 14833.49 MB/s Benchmark____GWs_Int_2kx10x0-16 26091238 143.3 ns/op 14406.81 MB/s Benchmark____GWs_Int_2kx10x0-16 25044888 140.7 ns/op 14670.36 MB/s Benchmark____GWs_Int_2kx10x0-16 25507509 137.0 ns/op 15067.32 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11762810 284.4 ns/op 14456.00 MB/s Benchmark____GWs_Int_4kx10x0-16 10448715 360.0 ns/op 11423.62 MB/s Benchmark____GWs_Int_4kx10x0-16 13305708 337.9 ns/op 12170.40 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:48074->127.0.0.1:38131: 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:50760->127.0.0.1:42363: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12014800 301.5 ns/op 13638.85 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6417859 546.6 ns/op 5717.23 MB/s Benchmark____GWs_Int_1kx01x1-16 6132492 556.6 ns/op 5614.16 MB/s Benchmark____GWs_Int_1kx01x1-16 6426283 558.3 ns/op 5597.05 MB/s Benchmark____GWs_Int_1kx01x1-16 6437476 558.6 ns/op 5594.08 MB/s Benchmark____GWs_Int_1kx01x1-16 6477787 641.8 ns/op 4869.46 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4722564 772.5 ns/op 8022.25 MB/s Benchmark____GWs_Int_2kx01x1-16 1000000 3900 ns/op 1588.91 MB/s Benchmark____GWs_Int_2kx01x1-16 4680301 884.4 ns/op 7007.32 MB/s Benchmark____GWs_Int_2kx01x1-16 4701441 764.1 ns/op 8110.41 MB/s Benchmark____GWs_Int_2kx01x1-16 4725819 770.1 ns/op 8046.71 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2646494 1373 ns/op 8985.61 MB/s Benchmark____GWs_Int_4kx01x1-16 2040688 1582 ns/op 7801.59 MB/s Benchmark____GWs_Int_4kx01x1-16 2632046 1531 ns/op 8060.33 MB/s Benchmark____GWs_Int_4kx01x1-16 2614422 1363 ns/op 9052.66 MB/s Benchmark____GWs_Int_4kx01x1-16 2615288 1363 ns/op 9051.71 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6627088 555.4 ns/op 5626.79 MB/s Benchmark____GWs_Int_1kx10x1-16 6566650 557.9 ns/op 5600.86 MB/s Benchmark____GWs_Int_1kx10x1-16 6512366 548.1 ns/op 5701.53 MB/s Benchmark____GWs_Int_1kx10x1-16 6585872 546.8 ns/op 5715.28 MB/s Benchmark____GWs_Int_1kx10x1-16 6267870 543.8 ns/op 5746.76 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4048453 869.8 ns/op 7124.99 MB/s Benchmark____GWs_Int_2kx10x1-16 4143180 843.0 ns/op 7350.89 MB/s Benchmark____GWs_Int_2kx10x1-16 4604208 837.1 ns/op 7403.34 MB/s Benchmark____GWs_Int_2kx10x1-16 4223782 837.7 ns/op 7397.88 MB/s Benchmark____GWs_Int_2kx10x1-16 3806773 822.4 ns/op 7535.63 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2318245 1492 ns/op 8271.81 MB/s Benchmark____GWs_Int_4kx10x1-16 2467939 1578 ns/op 7820.69 MB/s Benchmark____GWs_Int_4kx10x1-16 2303677 1529 ns/op 8072.38 MB/s Benchmark____GWs_Int_4kx10x1-16 2153258 1479 ns/op 8341.58 MB/s Benchmark____GWs_Int_4kx10x1-16 2279086 1508 ns/op 8183.31 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8760925 426.5 ns/op 239.17 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8008194 430.9 ns/op 236.74 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8376888 428.1 ns/op 238.24 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8187906 429.0 ns/op 237.75 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8170562 434.8 ns/op 234.60 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 718030 5017 ns/op 35.28 MB/s Benchmark__GWs_Reqs_1SubEach-16 737431 5258 ns/op 33.66 MB/s Benchmark__GWs_Reqs_1SubEach-16 776040 5277 ns/op 33.54 MB/s Benchmark__GWs_Reqs_1SubEach-16 796620 5202 ns/op 34.03 MB/s Benchmark__GWs_Reqs_1SubEach-16 779534 5251 ns/op 33.71 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2113.437s