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 48430490 73.87 ns/op 148.91 MB/s Benchmark______Pub0b_Payload-16 45413917 73.92 ns/op 148.80 MB/s Benchmark______Pub0b_Payload-16 46079924 73.96 ns/op 148.73 MB/s Benchmark______Pub0b_Payload-16 43307708 74.04 ns/op 148.57 MB/s Benchmark______Pub0b_Payload-16 45555512 73.80 ns/op 149.06 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 45502288 74.80 ns/op 254.00 MB/s Benchmark______Pub8b_Payload-16 48124330 74.71 ns/op 254.31 MB/s Benchmark______Pub8b_Payload-16 41887714 76.08 ns/op 249.75 MB/s Benchmark______Pub8b_Payload-16 45699304 74.77 ns/op 254.12 MB/s Benchmark______Pub8b_Payload-16 48513216 74.60 ns/op 254.70 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43581440 78.76 ns/op 558.63 MB/s Benchmark_____Pub32b_Payload-16 42540709 79.17 ns/op 555.79 MB/s Benchmark_____Pub32b_Payload-16 43424692 79.34 ns/op 554.61 MB/s Benchmark_____Pub32b_Payload-16 43238228 80.97 ns/op 543.41 MB/s Benchmark_____Pub32b_Payload-16 37869796 80.55 ns/op 546.22 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 35317729 89.74 ns/op 1571.20 MB/s Benchmark____Pub128B_Payload-16 38353956 89.04 ns/op 1583.50 MB/s Benchmark____Pub128B_Payload-16 33853011 91.86 ns/op 1534.93 MB/s Benchmark____Pub128B_Payload-16 38961012 88.84 ns/op 1587.07 MB/s Benchmark____Pub128B_Payload-16 38488261 89.35 ns/op 1578.11 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36934740 96.45 ns/op 2788.93 MB/s Benchmark____Pub256B_Payload-16 37307046 101.7 ns/op 2645.55 MB/s Benchmark____Pub256B_Payload-16 36020128 98.11 ns/op 2741.91 MB/s Benchmark____Pub256B_Payload-16 35399594 97.84 ns/op 2749.48 MB/s Benchmark____Pub256B_Payload-16 35560544 98.57 ns/op 2728.92 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22249167 145.7 ns/op 7122.25 MB/s Benchmark______Pub1K_Payload-16 23902611 139.8 ns/op 7423.25 MB/s Benchmark______Pub1K_Payload-16 20156532 151.5 ns/op 6849.94 MB/s Benchmark______Pub1K_Payload-16 21989180 145.0 ns/op 7156.45 MB/s Benchmark______Pub1K_Payload-16 25673436 142.0 ns/op 7311.26 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5712897 626.9 ns/op 6556.17 MB/s Benchmark______Pub4K_Payload-16 5744996 625.0 ns/op 6576.28 MB/s Benchmark______Pub4K_Payload-16 5513262 623.6 ns/op 6590.96 MB/s Benchmark______Pub4K_Payload-16 5319727 617.8 ns/op 6652.90 MB/s Benchmark______Pub4K_Payload-16 5098628 619.7 ns/op 6632.03 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2795634 1278 ns/op 6420.03 MB/s Benchmark______Pub8K_Payload-16 2710372 1278 ns/op 6419.51 MB/s Benchmark______Pub8K_Payload-16 2687083 1275 ns/op 6433.79 MB/s Benchmark______Pub8K_Payload-16 2818239 1277 ns/op 6425.80 MB/s Benchmark______Pub8K_Payload-16 2751096 1278 ns/op 6420.91 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 574396 7441 ns/op 4405.45 MB/s Benchmark_____Pub32K_Payload-16 664392 5503 ns/op 5957.14 MB/s Benchmark_____Pub32K_Payload-16 549800 5519 ns/op 5940.30 MB/s Benchmark_____Pub32K_Payload-16 565770 5577 ns/op 5877.88 MB/s Benchmark_____Pub32K_Payload-16 567129 5407 ns/op 6063.42 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31614208 96.68 ns/op 113.78 MB/s Benchmark__AuthPub0b_Payload-16 31710820 101.1 ns/op 108.80 MB/s Benchmark__AuthPub0b_Payload-16 32104803 95.67 ns/op 114.98 MB/s Benchmark__AuthPub0b_Payload-16 35340764 96.00 ns/op 114.59 MB/s Benchmark__AuthPub0b_Payload-16 35803218 96.23 ns/op 114.31 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15446772 229.7 ns/op Benchmark_____________PubSub-16 15319878 229.3 ns/op Benchmark_____________PubSub-16 15330741 229.3 ns/op Benchmark_____________PubSub-16 15306712 229.9 ns/op Benchmark_____________PubSub-16 15266182 229.6 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15470072 227.9 ns/op Benchmark_____PubSubTwoConns-16 15303740 226.8 ns/op Benchmark_____PubSubTwoConns-16 15656122 227.4 ns/op Benchmark_____PubSubTwoConns-16 15594946 227.2 ns/op Benchmark_____PubSubTwoConns-16 15551871 227.2 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40078->127.0.0.1:43517: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46518->127.0.0.1:40491: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51834->127.0.0.1:41497: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51918->127.0.0.1:42359: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51460->127.0.0.1:32827: 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 14379520 246.4 ns/op Benchmark_____PubTwoQueueSub-16 14171574 245.8 ns/op Benchmark_____PubTwoQueueSub-16 14480104 246.0 ns/op Benchmark_____PubTwoQueueSub-16 14321023 246.0 ns/op Benchmark_____PubTwoQueueSub-16 14186053 247.1 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14351522 246.1 ns/op Benchmark____PubFourQueueSub-16 14252186 246.7 ns/op Benchmark____PubFourQueueSub-16 14386294 246.3 ns/op Benchmark____PubFourQueueSub-16 14507413 246.3 ns/op Benchmark____PubFourQueueSub-16 14334200 246.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14524352 246.2 ns/op Benchmark___PubEightQueueSub-16 14401269 246.2 ns/op Benchmark___PubEightQueueSub-16 14286675 246.9 ns/op Benchmark___PubEightQueueSub-16 14469051 246.7 ns/op Benchmark___PubEightQueueSub-16 14225995 246.1 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23139 156508 ns/op Benchmark_PubSub512kTwoConns-16 23050 155456 ns/op Benchmark_PubSub512kTwoConns-16 23143 154481 ns/op Benchmark_PubSub512kTwoConns-16 23172 155526 ns/op Benchmark_PubSub512kTwoConns-16 23019 156031 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 14853766 229.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15059097 231.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 14994123 231.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15154604 231.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 14960983 231.8 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 14967836 230.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 14940876 231.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15049776 231.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15101316 231.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15114958 231.8 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11629720 310.5 ns/op Benchmark____RoutedPubSub_0b-16 11664252 313.9 ns/op Benchmark____RoutedPubSub_0b-16 11627556 314.3 ns/op Benchmark____RoutedPubSub_0b-16 11184100 317.8 ns/op Benchmark____RoutedPubSub_0b-16 11171985 312.8 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6343374 533.8 ns/op Benchmark____RoutedPubSub_1K-16 6771589 1152 ns/op Benchmark____RoutedPubSub_1K-16 6660588 536.1 ns/op Benchmark____RoutedPubSub_1K-16 6580887 530.3 ns/op Benchmark____RoutedPubSub_1K-16 6754670 534.1 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84159 42725 ns/op Benchmark__RoutedPubSub_100K-16 82605 44185 ns/op Benchmark__RoutedPubSub_100K-16 78097 45439 ns/op Benchmark__RoutedPubSub_100K-16 78130 46639 ns/op Benchmark__RoutedPubSub_100K-16 74948 44549 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9847197 316.0 ns/op Benchmark____Routed2QueueSub-16 9719766 316.1 ns/op Benchmark____Routed2QueueSub-16 9804975 344.9 ns/op Benchmark____Routed2QueueSub-16 9661161 321.4 ns/op Benchmark____Routed2QueueSub-16 9589858 323.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9685155 327.2 ns/op Benchmark____Routed4QueueSub-16 9661629 316.3 ns/op Benchmark____Routed4QueueSub-16 9510860 324.0 ns/op Benchmark____Routed4QueueSub-16 11007856 317.9 ns/op Benchmark____Routed4QueueSub-16 11369338 322.9 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9383634 326.9 ns/op Benchmark____Routed8QueueSub-16 10848222 329.4 ns/op Benchmark____Routed8QueueSub-16 9426426 323.3 ns/op Benchmark____Routed8QueueSub-16 9525882 331.0 ns/op Benchmark____Routed8QueueSub-16 9170376 332.9 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8900778 342.0 ns/op Benchmark___Routed16QueueSub-16 8852532 351.5 ns/op Benchmark___Routed16QueueSub-16 8866674 344.6 ns/op Benchmark___Routed16QueueSub-16 9092736 349.2 ns/op Benchmark___Routed16QueueSub-16 8805639 347.7 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6337693 549.7 ns/op Benchmark____________RouteCompressOff-16 6580432 547.8 ns/op Benchmark____________RouteCompressOff-16 6475316 548.8 ns/op Benchmark____________RouteCompressOff-16 6524325 539.2 ns/op Benchmark____________RouteCompressOff-16 6208743 551.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6408650 555.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6468057 548.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6452696 543.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6529369 548.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6354198 552.4 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6550654 554.4 ns/op Benchmark_________RouteCompressS2Fast-16 6581698 546.7 ns/op Benchmark_________RouteCompressS2Fast-16 6288129 547.3 ns/op Benchmark_________RouteCompressS2Fast-16 6473139 551.3 ns/op Benchmark_________RouteCompressS2Fast-16 6482220 549.9 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6373671 548.3 ns/op Benchmark_______RouteCompressS2Better-16 6422113 550.2 ns/op Benchmark_______RouteCompressS2Better-16 6533452 549.9 ns/op Benchmark_______RouteCompressS2Better-16 6428986 543.0 ns/op Benchmark_______RouteCompressS2Better-16 6449269 547.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6439035 553.8 ns/op Benchmark_________RouteCompressS2Best-16 6511899 538.5 ns/op Benchmark_________RouteCompressS2Best-16 6554967 550.6 ns/op Benchmark_________RouteCompressS2Best-16 6472146 545.2 ns/op Benchmark_________RouteCompressS2Best-16 6517021 544.2 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4705850 766.1 ns/op 325.03 MB/s Benchmark______FanOut_8x1x10-16 4694338 763.5 ns/op 326.13 MB/s Benchmark______FanOut_8x1x10-16 4703451 761.5 ns/op 326.97 MB/s Benchmark______FanOut_8x1x10-16 4697418 769.1 ns/op 323.76 MB/s Benchmark______FanOut_8x1x10-16 4689510 761.5 ns/op 326.98 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 564650 6035 ns/op 384.28 MB/s Benchmark_____FanOut_8x1x100-16 553678 6199 ns/op 374.12 MB/s Benchmark_____FanOut_8x1x100-16 558757 6099 ns/op 380.23 MB/s Benchmark_____FanOut_8x1x100-16 567607 6051 ns/op 383.24 MB/s Benchmark_____FanOut_8x1x100-16 552578 6044 ns/op 383.66 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48205 74264 ns/op 309.96 MB/s Benchmark____FanOut_8x10x100-16 46489 74542 ns/op 308.80 MB/s Benchmark____FanOut_8x10x100-16 48240 74039 ns/op 310.90 MB/s Benchmark____FanOut_8x10x100-16 47990 74112 ns/op 310.60 MB/s Benchmark____FanOut_8x10x100-16 48765 73818 ns/op 311.83 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5820 603156 ns/op 397.94 MB/s Benchmark___FanOut_8x10x1000-16 5808 594878 ns/op 403.48 MB/s Benchmark___FanOut_8x10x1000-16 6092 593498 ns/op 404.41 MB/s Benchmark___FanOut_8x10x1000-16 5644 597920 ns/op 401.42 MB/s Benchmark___FanOut_8x10x1000-16 6010 589116 ns/op 407.42 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5001 698266 ns/op 329.41 MB/s Benchmark___FanOut_8x100x100-16 4912 700246 ns/op 328.48 MB/s Benchmark___FanOut_8x100x100-16 4960 701148 ns/op 328.06 MB/s Benchmark___FanOut_8x100x100-16 5029 703658 ns/op 326.89 MB/s Benchmark___FanOut_8x100x100-16 5029 699382 ns/op 328.89 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 577 6123171 ns/op 391.96 MB/s Benchmark__FanOut_8x100x1000-16 580 6057786 ns/op 396.19 MB/s Benchmark__FanOut_8x100x1000-16 565 6087123 ns/op 394.28 MB/s Benchmark__FanOut_8x100x1000-16 580 6046284 ns/op 396.94 MB/s Benchmark__FanOut_8x100x1000-16 584 6065201 ns/op 395.70 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 536 6614284 ns/op 377.97 MB/s Benchmark__FanOut_8x10x10000-16 525 6664147 ns/op 375.14 MB/s Benchmark__FanOut_8x10x10000-16 528 6556027 ns/op 381.33 MB/s Benchmark__FanOut_8x10x10000-16 518 6707431 ns/op 372.72 MB/s Benchmark__FanOut_8x10x10000-16 519 6667541 ns/op 374.95 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 940 3710518 ns/op 309.93 MB/s Benchmark___FanOut_8x500x100-16 948 3719832 ns/op 309.16 MB/s Benchmark___FanOut_8x500x100-16 954 3724721 ns/op 308.75 MB/s Benchmark___FanOut_8x500x100-16 962 3701049 ns/op 310.73 MB/s Benchmark___FanOut_8x500x100-16 957 3712467 ns/op 309.77 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 359871 9397 ns/op 1558.07 MB/s Benchmark___FanOut_128x1x100-16 362010 9433 ns/op 1552.13 MB/s Benchmark___FanOut_128x1x100-16 363261 9489 ns/op 1542.92 MB/s Benchmark___FanOut_128x1x100-16 339678 9362 ns/op 1563.92 MB/s Benchmark___FanOut_128x1x100-16 360614 9420 ns/op 1554.20 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32670 109486 ns/op 1325.66 MB/s Benchmark__FanOut_128x10x100-16 32720 109097 ns/op 1330.39 MB/s Benchmark__FanOut_128x10x100-16 32815 109236 ns/op 1328.69 MB/s Benchmark__FanOut_128x10x100-16 32943 109414 ns/op 1326.53 MB/s Benchmark__FanOut_128x10x100-16 32883 109137 ns/op 1329.90 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4105 864667 ns/op 1688.67 MB/s Benchmark_FanOut_128x10x1000-16 3996 858507 ns/op 1700.79 MB/s Benchmark_FanOut_128x10x1000-16 4292 851691 ns/op 1714.40 MB/s Benchmark_FanOut_128x10x1000-16 4002 859074 ns/op 1699.67 MB/s Benchmark_FanOut_128x10x1000-16 4222 863324 ns/op 1691.30 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3604 999924 ns/op 1450.25 MB/s Benchmark_FanOut_128x100x100-16 3519 1001450 ns/op 1448.04 MB/s Benchmark_FanOut_128x100x100-16 3552 1001576 ns/op 1447.86 MB/s Benchmark_FanOut_128x100x100-16 3492 1005626 ns/op 1442.03 MB/s Benchmark_FanOut_128x100x100-16 3588 1002623 ns/op 1446.35 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 390 9182730 ns/op 1589.96 MB/s BenchmarkFanOut_128x100x1000-16 394 9184072 ns/op 1589.72 MB/s BenchmarkFanOut_128x100x1000-16 384 9104622 ns/op 1603.60 MB/s BenchmarkFanOut_128x100x1000-16 388 9202472 ns/op 1586.55 MB/s BenchmarkFanOut_128x100x1000-16 386 9276353 ns/op 1573.91 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 375 9481734 ns/op 1550.36 MB/s BenchmarkFanOut_128x10x10000-16 370 9514431 ns/op 1545.04 MB/s BenchmarkFanOut_128x10x10000-16 376 9609810 ns/op 1529.70 MB/s BenchmarkFanOut_128x10x10000-16 380 9620504 ns/op 1528.00 MB/s BenchmarkFanOut_128x10x10000-16 374 9556046 ns/op 1538.31 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 684 5206820 ns/op 1392.43 MB/s BenchmarkFanOut__128x500x100-16 682 5233824 ns/op 1385.25 MB/s BenchmarkFanOut__128x500x100-16 678 5232286 ns/op 1385.65 MB/s BenchmarkFanOut__128x500x100-16 681 5209465 ns/op 1391.72 MB/s BenchmarkFanOut__128x500x100-16 681 5225185 ns/op 1387.54 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1971 1827788 ns/op 2894.50 MB/s Benchmark_FanOut_512x100x100-16 1952 1830297 ns/op 2890.53 MB/s Benchmark_FanOut_512x100x100-16 1982 1823650 ns/op 2901.06 MB/s Benchmark_FanOut_512x100x100-16 1965 1833610 ns/op 2885.31 MB/s Benchmark_FanOut_512x100x100-16 1922 1833986 ns/op 2884.71 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16714911 ns/op 3170.85 MB/s Benchmark__FanOut_512x100x1k-16 216 16527711 ns/op 3206.77 MB/s Benchmark__FanOut_512x100x1k-16 216 16612403 ns/op 3190.42 MB/s Benchmark__FanOut_512x100x1k-16 216 16591180 ns/op 3194.50 MB/s Benchmark__FanOut_512x100x1k-16 214 16752365 ns/op 3163.76 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2874 1146359 ns/op 9099.28 MB/s Benchmark____FanOut_1kx10x1k-16 3220 1141171 ns/op 9140.65 MB/s Benchmark____FanOut_1kx10x1k-16 3376 1119750 ns/op 9315.50 MB/s Benchmark____FanOut_1kx10x1k-16 3040 1159955 ns/op 8992.62 MB/s Benchmark____FanOut_1kx10x1k-16 3124 1163505 ns/op 8965.19 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2775 1247198 ns/op 8355.56 MB/s Benchmark__FanOut_1kx100x100-16 2835 1248065 ns/op 8349.76 MB/s Benchmark__FanOut_1kx100x100-16 2785 1250837 ns/op 8331.25 MB/s Benchmark__FanOut_1kx100x100-16 2828 1253229 ns/op 8315.35 MB/s Benchmark__FanOut_1kx100x100-16 2737 1246969 ns/op 8357.09 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4525824 780.9 ns/op 318.85 MB/s Benchmark_____RFanOut_8x1x10-16 4652168 786.7 ns/op 316.50 MB/s Benchmark_____RFanOut_8x1x10-16 4548534 796.7 ns/op 312.52 MB/s Benchmark_____RFanOut_8x1x10-16 4514029 788.4 ns/op 315.82 MB/s Benchmark_____RFanOut_8x1x10-16 4498606 797.8 ns/op 312.10 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 546372 6324 ns/op 366.70 MB/s Benchmark____RFanOut_8x1x100-16 529843 6455 ns/op 359.27 MB/s Benchmark____RFanOut_8x1x100-16 543156 6270 ns/op 369.87 MB/s Benchmark____RFanOut_8x1x100-16 545953 6449 ns/op 359.59 MB/s Benchmark____RFanOut_8x1x100-16 535756 6337 ns/op 365.96 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47896 74114 ns/op 310.59 MB/s Benchmark___RFanOut_8x10x100-16 48358 73783 ns/op 311.98 MB/s Benchmark___RFanOut_8x10x100-16 47899 74277 ns/op 309.91 MB/s Benchmark___RFanOut_8x10x100-16 48514 74131 ns/op 310.52 MB/s Benchmark___RFanOut_8x10x100-16 48346 73872 ns/op 311.61 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5724 595259 ns/op 403.22 MB/s Benchmark__RFanOut_8x10x1000-16 5949 592002 ns/op 405.44 MB/s Benchmark__RFanOut_8x10x1000-16 5971 591505 ns/op 405.78 MB/s Benchmark__RFanOut_8x10x1000-16 5996 594916 ns/op 403.45 MB/s Benchmark__RFanOut_8x10x1000-16 5830 593141 ns/op 404.66 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5130 706466 ns/op 325.59 MB/s Benchmark__RFanOut_8x100x100-16 5037 702998 ns/op 327.20 MB/s Benchmark__RFanOut_8x100x100-16 5002 703323 ns/op 327.05 MB/s Benchmark__RFanOut_8x100x100-16 5036 704728 ns/op 326.39 MB/s Benchmark__RFanOut_8x100x100-16 5024 706083 ns/op 325.77 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 588 6240506 ns/op 384.59 MB/s Benchmark_RFanOut_8x100x1000-16 585 6114753 ns/op 392.50 MB/s Benchmark_RFanOut_8x100x1000-16 586 6142503 ns/op 390.72 MB/s Benchmark_RFanOut_8x100x1000-16 585 6112574 ns/op 392.64 MB/s Benchmark_RFanOut_8x100x1000-16 580 6161323 ns/op 389.53 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 530 6773778 ns/op 369.07 MB/s Benchmark_RFanOut_8x10x10000-16 525 6606848 ns/op 378.40 MB/s Benchmark_RFanOut_8x10x10000-16 530 6730646 ns/op 371.44 MB/s Benchmark_RFanOut_8x10x10000-16 546 6619174 ns/op 377.69 MB/s Benchmark_RFanOut_8x10x10000-16 519 6775689 ns/op 368.97 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3000 1169848 ns/op 8916.58 MB/s Benchmark_RFanOut_1kx10x1000-16 2677 1127172 ns/op 9254.17 MB/s Benchmark_RFanOut_1kx10x1000-16 2749 1153672 ns/op 9041.60 MB/s Benchmark_RFanOut_1kx10x1000-16 3187 1143031 ns/op 9125.77 MB/s Benchmark_RFanOut_1kx10x1000-16 3042 1159361 ns/op 8997.23 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6946568 503.1 ns/op 4130.79 MB/s Benchmark_____FanIn_1kx100x1-16 6864932 501.9 ns/op 4140.43 MB/s Benchmark_____FanIn_1kx100x1-16 6977320 504.2 ns/op 4121.60 MB/s Benchmark_____FanIn_1kx100x1-16 6990040 505.5 ns/op 4110.92 MB/s Benchmark_____FanIn_1kx100x1-16 6966620 502.4 ns/op 4136.50 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2645328 1358 ns/op 6055.64 MB/s Benchmark_____FanIn_4kx100x1-16 2661049 1367 ns/op 6012.54 MB/s Benchmark_____FanIn_4kx100x1-16 2644382 1375 ns/op 5980.70 MB/s Benchmark_____FanIn_4kx100x1-16 2596891 1344 ns/op 6118.89 MB/s Benchmark_____FanIn_4kx100x1-16 2670897 1368 ns/op 6008.42 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1711308 2145 ns/op 7652.14 MB/s Benchmark_____FanIn_8kx100x1-16 1668999 2092 ns/op 7846.13 MB/s Benchmark_____FanIn_8kx100x1-16 1694034 2101 ns/op 7813.72 MB/s Benchmark_____FanIn_8kx100x1-16 1720879 2114 ns/op 7762.80 MB/s Benchmark_____FanIn_8kx100x1-16 1705240 2110 ns/op 7779.37 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 864253 4162 ns/op 7881.28 MB/s Benchmark____FanIn_16kx100x1-16 869277 4125 ns/op 7952.48 MB/s Benchmark____FanIn_16kx100x1-16 844760 4181 ns/op 7845.40 MB/s Benchmark____FanIn_16kx100x1-16 874360 4118 ns/op 7965.48 MB/s Benchmark____FanIn_16kx100x1-16 868665 4099 ns/op 8001.24 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5393373075 vs 11327558400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47296->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47592->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 157724 20038 ns/op 6542.87 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1580089512 vs 6496302300 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33740->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 165808 19989 ns/op 6558.92 MB/s Benchmark____FanIn_64kx100x1-16 167122 19878 ns/op 6595.44 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 824162830 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41810->127.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: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:41696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41188->127.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:41508->127.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:41514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41400->127.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:41878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41488->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: 266637060 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43218->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: 273453740 vs 11496593000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45596->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:46186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46428->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: 146558620 vs 1310900000 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:44522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45180->127.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:44670->127.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:44424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44726->127.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: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:44496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44800->127.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:44536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45000->127.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:44634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45094->127.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:44476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45150->127.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: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:44988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44898->127.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:44390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44508->127.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:44934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44696->127.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:44984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45032->127.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:44904->127.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: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:45260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45130->127.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:44664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44640->127.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:44362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44868->127.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:44456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44760->127.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:44652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44680->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: 726762960 vs 11562138000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47876->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:47424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47384->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5579126 644.1 ns/op 440.90 MB/s Benchmark___BumpPubCount_1x3-16 5561997 642.2 ns/op 442.22 MB/s Benchmark___BumpPubCount_1x3-16 5600425 635.5 ns/op 446.87 MB/s Benchmark___BumpPubCount_1x3-16 5606960 639.8 ns/op 443.90 MB/s Benchmark___BumpPubCount_1x3-16 5580249 640.6 ns/op 443.34 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5338915 670.6 ns/op 423.47 MB/s Benchmark___BumpPubCount_2x3-16 5334261 668.7 ns/op 424.73 MB/s Benchmark___BumpPubCount_2x3-16 5281568 666.2 ns/op 426.27 MB/s Benchmark___BumpPubCount_2x3-16 5321310 668.2 ns/op 425.03 MB/s Benchmark___BumpPubCount_2x3-16 5336518 668.0 ns/op 425.17 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5555658 638.3 ns/op 444.94 MB/s Benchmark___BumpPubCount_5x3-16 5297043 639.7 ns/op 443.96 MB/s Benchmark___BumpPubCount_5x3-16 5610165 638.0 ns/op 445.14 MB/s Benchmark___BumpPubCount_5x3-16 5581328 639.8 ns/op 443.88 MB/s Benchmark___BumpPubCount_5x3-16 5356148 643.1 ns/op 441.60 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5600355 641.3 ns/op 442.86 MB/s Benchmark__BumpPubCount_10x3-16 5563908 639.6 ns/op 444.01 MB/s Benchmark__BumpPubCount_10x3-16 5644184 642.2 ns/op 442.20 MB/s Benchmark__BumpPubCount_10x3-16 4775138 640.3 ns/op 443.57 MB/s Benchmark__BumpPubCount_10x3-16 5593443 640.5 ns/op 443.37 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12645903 277.8 ns/op 3743.53 MB/s Benchmark____GWs_Opt_1kx01x0-16 11585877 281.3 ns/op 3697.29 MB/s Benchmark____GWs_Opt_1kx01x0-16 12446528 285.9 ns/op 3638.03 MB/s Benchmark____GWs_Opt_1kx01x0-16 12898843 275.5 ns/op 3775.31 MB/s Benchmark____GWs_Opt_1kx01x0-16 12856915 278.4 ns/op 3736.30 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10479573 358.2 ns/op 5762.74 MB/s Benchmark____GWs_Opt_2kx01x0-16 9518437 355.5 ns/op 5806.06 MB/s Benchmark____GWs_Opt_2kx01x0-16 10748301 350.2 ns/op 5893.54 MB/s Benchmark____GWs_Opt_2kx01x0-16 10794464 338.9 ns/op 6089.84 MB/s Benchmark____GWs_Opt_2kx01x0-16 10121970 345.4 ns/op 5975.80 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5885278 605.9 ns/op 6787.01 MB/s Benchmark____GWs_Opt_4kx01x0-16 5676595 673.7 ns/op 6103.51 MB/s Benchmark____GWs_Opt_4kx01x0-16 6028099 608.3 ns/op 6759.78 MB/s Benchmark____GWs_Opt_4kx01x0-16 5869426 652.2 ns/op 6305.27 MB/s Benchmark____GWs_Opt_4kx01x0-16 5705216 630.8 ns/op 6519.05 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28135953 112.0 ns/op 9282.39 MB/s Benchmark____GWs_Opt_1kx10x0-16 32673412 110.3 ns/op 9426.38 MB/s Benchmark____GWs_Opt_1kx10x0-16 28754524 113.3 ns/op 9181.54 MB/s Benchmark____GWs_Opt_1kx10x0-16 32154871 111.1 ns/op 9357.49 MB/s Benchmark____GWs_Opt_1kx10x0-16 31237486 120.7 ns/op 8616.33 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25181160 147.0 ns/op 14039.02 MB/s Benchmark____GWs_Opt_2kx10x0-16 22383628 160.9 ns/op 12831.47 MB/s Benchmark____GWs_Opt_2kx10x0-16 24892684 152.4 ns/op 13547.13 MB/s Benchmark____GWs_Opt_2kx10x0-16 24548636 164.0 ns/op 12587.31 MB/s Benchmark____GWs_Opt_2kx10x0-16 24030148 142.9 ns/op 14448.09 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 13087116 300.0 ns/op 13704.41 MB/s Benchmark____GWs_Opt_4kx10x0-16 11813778 293.4 ns/op 14013.85 MB/s Benchmark____GWs_Opt_4kx10x0-16 12222576 337.4 ns/op 12186.02 MB/s Benchmark____GWs_Opt_4kx10x0-16 12448285 685.0 ns/op 6002.62 MB/s Benchmark____GWs_Opt_4kx10x0-16 9954638 312.5 ns/op 13159.75 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6369775 543.7 ns/op 5747.36 MB/s Benchmark____GWs_Opt_1kx01x1-16 6225434 545.1 ns/op 5732.51 MB/s Benchmark____GWs_Opt_1kx01x1-16 6475212 554.2 ns/op 5638.86 MB/s Benchmark____GWs_Opt_1kx01x1-16 6622356 552.6 ns/op 5655.51 MB/s Benchmark____GWs_Opt_1kx01x1-16 6356270 557.1 ns/op 5609.61 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4687039 751.2 ns/op 8249.65 MB/s Benchmark____GWs_Opt_2kx01x1-16 4353254 763.7 ns/op 8114.05 MB/s Benchmark____GWs_Opt_2kx01x1-16 4784496 750.2 ns/op 8260.33 MB/s Benchmark____GWs_Opt_2kx01x1-16 4357218 748.7 ns/op 8277.37 MB/s Benchmark____GWs_Opt_2kx01x1-16 4680842 791.2 ns/op 7832.30 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2661910 1369 ns/op 9012.81 MB/s Benchmark____GWs_Opt_4kx01x1-16 2624120 1360 ns/op 9076.44 MB/s Benchmark____GWs_Opt_4kx01x1-16 2665974 1352 ns/op 9130.11 MB/s Benchmark____GWs_Opt_4kx01x1-16 2613838 1359 ns/op 9080.84 MB/s Benchmark____GWs_Opt_4kx01x1-16 2622526 1357 ns/op 9096.87 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6615660 555.2 ns/op 5628.49 MB/s Benchmark____GWs_Opt_1kx10x1-16 6623252 563.2 ns/op 5549.10 MB/s Benchmark____GWs_Opt_1kx10x1-16 6557736 549.8 ns/op 5684.29 MB/s Benchmark____GWs_Opt_1kx10x1-16 6374498 552.4 ns/op 5656.67 MB/s Benchmark____GWs_Opt_1kx10x1-16 6490124 556.6 ns/op 5614.19 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4187278 837.7 ns/op 7397.99 MB/s Benchmark____GWs_Opt_2kx10x1-16 4248733 834.4 ns/op 7426.50 MB/s Benchmark____GWs_Opt_2kx10x1-16 4133200 846.2 ns/op 7323.00 MB/s Benchmark____GWs_Opt_2kx10x1-16 4245159 852.0 ns/op 7273.88 MB/s Benchmark____GWs_Opt_2kx10x1-16 4232316 830.4 ns/op 7462.46 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2419411 1572 ns/op 7851.74 MB/s Benchmark____GWs_Opt_4kx10x1-16 2306120 1504 ns/op 8203.51 MB/s Benchmark____GWs_Opt_4kx10x1-16 2457211 1497 ns/op 8245.83 MB/s Benchmark____GWs_Opt_4kx10x1-16 2557218 1466 ns/op 8419.89 MB/s Benchmark____GWs_Opt_4kx10x1-16 2354451 1475 ns/op 8366.22 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12374444 292.0 ns/op 3561.06 MB/s Benchmark____GWs_Int_1kx01x0-16 12231214 280.6 ns/op 3705.92 MB/s Benchmark____GWs_Int_1kx01x0-16 12368575 287.2 ns/op 3621.11 MB/s Benchmark____GWs_Int_1kx01x0-16 12551560 283.4 ns/op 3670.30 MB/s Benchmark____GWs_Int_1kx01x0-16 12471006 286.5 ns/op 3630.13 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10187611 352.1 ns/op 5862.13 MB/s Benchmark____GWs_Int_2kx01x0-16 9963522 362.5 ns/op 5693.15 MB/s Benchmark____GWs_Int_2kx01x0-16 10359280 360.6 ns/op 5724.58 MB/s Benchmark____GWs_Int_2kx01x0-16 9886309 359.6 ns/op 5738.96 MB/s Benchmark____GWs_Int_2kx01x0-16 9724921 368.8 ns/op 5595.79 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5585512 633.2 ns/op 6493.88 MB/s Benchmark____GWs_Int_4kx01x0-16 5534478 662.5 ns/op 6206.71 MB/s Benchmark____GWs_Int_4kx01x0-16 5497610 628.7 ns/op 6541.00 MB/s Benchmark____GWs_Int_4kx01x0-16 5842154 642.4 ns/op 6401.41 MB/s Benchmark____GWs_Int_4kx01x0-16 5785039 629.8 ns/op 6529.13 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31328004 111.7 ns/op 9308.01 MB/s Benchmark____GWs_Int_1kx10x0-16 29992160 115.7 ns/op 8990.96 MB/s Benchmark____GWs_Int_1kx10x0-16 30804435 111.7 ns/op 9308.01 MB/s Benchmark____GWs_Int_1kx10x0-16 31363978 113.9 ns/op 9130.16 MB/s Benchmark____GWs_Int_1kx10x0-16 32115516 109.7 ns/op 9477.98 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 23047921 140.6 ns/op 14681.57 MB/s Benchmark____GWs_Int_2kx10x0-16 26056124 142.7 ns/op 14467.97 MB/s Benchmark____GWs_Int_2kx10x0-16 25905205 152.1 ns/op 13566.96 MB/s Benchmark____GWs_Int_2kx10x0-16 23382250 153.0 ns/op 13488.13 MB/s Benchmark____GWs_Int_2kx10x0-16 24756572 167.5 ns/op 12321.29 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11867900 295.4 ns/op 13920.18 MB/s Benchmark____GWs_Int_4kx10x0-16 12324240 278.7 ns/op 14752.72 MB/s Benchmark____GWs_Int_4kx10x0-16 11866801 295.9 ns/op 13896.11 MB/s Benchmark____GWs_Int_4kx10x0-16 11325819 332.5 ns/op 12365.06 MB/s Benchmark____GWs_Int_4kx10x0-16 12798433 283.4 ns/op 14510.27 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6425076 700.8 ns/op 4459.48 MB/s Benchmark____GWs_Int_1kx01x1-16 6336784 559.6 ns/op 5583.96 MB/s Benchmark____GWs_Int_1kx01x1-16 6363292 562.4 ns/op 5556.81 MB/s Benchmark____GWs_Int_1kx01x1-16 6680319 556.2 ns/op 5618.15 MB/s Benchmark____GWs_Int_1kx01x1-16 6474585 556.3 ns/op 5617.61 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4691127 770.6 ns/op 8041.67 MB/s Benchmark____GWs_Int_2kx01x1-16 4571260 760.2 ns/op 8151.91 MB/s Benchmark____GWs_Int_2kx01x1-16 4941784 753.5 ns/op 8223.75 MB/s Benchmark____GWs_Int_2kx01x1-16 4713550 767.3 ns/op 8076.34 MB/s Benchmark____GWs_Int_2kx01x1-16 4798945 759.2 ns/op 8162.33 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2618028 1562 ns/op 7899.50 MB/s Benchmark____GWs_Int_4kx01x1-16 2617358 1355 ns/op 9105.05 MB/s Benchmark____GWs_Int_4kx01x1-16 2694153 1364 ns/op 9050.83 MB/s Benchmark____GWs_Int_4kx01x1-16 2382259 1339 ns/op 9217.39 MB/s Benchmark____GWs_Int_4kx01x1-16 2679411 1368 ns/op 9022.49 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6573987 658.6 ns/op 4744.69 MB/s Benchmark____GWs_Int_1kx10x1-16 6063170 550.4 ns/op 5677.82 MB/s Benchmark____GWs_Int_1kx10x1-16 6645064 552.6 ns/op 5654.62 MB/s Benchmark____GWs_Int_1kx10x1-16 6662757 550.3 ns/op 5679.16 MB/s Benchmark____GWs_Int_1kx10x1-16 6413326 548.4 ns/op 5698.63 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4299528 841.0 ns/op 7368.33 MB/s Benchmark____GWs_Int_2kx10x1-16 4277526 831.2 ns/op 7455.85 MB/s Benchmark____GWs_Int_2kx10x1-16 4176697 829.3 ns/op 7472.61 MB/s Benchmark____GWs_Int_2kx10x1-16 4070600 831.9 ns/op 7449.15 MB/s Benchmark____GWs_Int_2kx10x1-16 4147402 821.0 ns/op 7548.39 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2387049 1468 ns/op 8406.21 MB/s Benchmark____GWs_Int_4kx10x1-16 2433564 1483 ns/op 8323.45 MB/s Benchmark____GWs_Int_4kx10x1-16 2152429 1515 ns/op 8143.35 MB/s Benchmark____GWs_Int_4kx10x1-16 2489066 1538 ns/op 8024.17 MB/s Benchmark____GWs_Int_4kx10x1-16 2199855 1515 ns/op 8143.21 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8095267 438.8 ns/op 232.44 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7932976 439.9 ns/op 231.89 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8321787 437.1 ns/op 233.34 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7764704 441.5 ns/op 231.02 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7937468 436.7 ns/op 233.58 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 621458 5054 ns/op 35.02 MB/s Benchmark__GWs_Reqs_1SubEach-16 770690 5171 ns/op 34.23 MB/s Benchmark__GWs_Reqs_1SubEach-16 786062 5321 ns/op 33.27 MB/s Benchmark__GWs_Reqs_1SubEach-16 706975 5171 ns/op 34.23 MB/s Benchmark__GWs_Reqs_1SubEach-16 738037 5243 ns/op 33.76 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2069.933s