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 55945996 64.68 ns/op 170.08 MB/s Benchmark______Pub0b_Payload-16 52750657 63.97 ns/op 171.97 MB/s Benchmark______Pub0b_Payload-16 52642563 65.42 ns/op 168.14 MB/s Benchmark______Pub0b_Payload-16 51170264 64.68 ns/op 170.07 MB/s Benchmark______Pub0b_Payload-16 52963040 64.83 ns/op 169.66 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 52371934 65.04 ns/op 292.14 MB/s Benchmark______Pub8b_Payload-16 51138106 64.78 ns/op 293.32 MB/s Benchmark______Pub8b_Payload-16 48673855 64.74 ns/op 293.47 MB/s Benchmark______Pub8b_Payload-16 50078624 64.93 ns/op 292.64 MB/s Benchmark______Pub8b_Payload-16 52256864 64.82 ns/op 293.11 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 49109200 69.43 ns/op 633.77 MB/s Benchmark_____Pub32b_Payload-16 48970920 69.44 ns/op 633.61 MB/s Benchmark_____Pub32b_Payload-16 51724874 69.38 ns/op 634.23 MB/s Benchmark_____Pub32b_Payload-16 48962089 69.26 ns/op 635.32 MB/s Benchmark_____Pub32b_Payload-16 46176820 69.60 ns/op 632.19 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39959628 78.91 ns/op 1786.82 MB/s Benchmark____Pub128B_Payload-16 38655968 79.13 ns/op 1781.98 MB/s Benchmark____Pub128B_Payload-16 43678141 79.20 ns/op 1780.39 MB/s Benchmark____Pub128B_Payload-16 39031102 79.54 ns/op 1772.66 MB/s Benchmark____Pub128B_Payload-16 43057689 80.74 ns/op 1746.28 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 40915252 90.79 ns/op 2963.00 MB/s Benchmark____Pub256B_Payload-16 41080843 86.73 ns/op 3101.72 MB/s Benchmark____Pub256B_Payload-16 39719301 88.51 ns/op 3039.35 MB/s Benchmark____Pub256B_Payload-16 38423029 86.95 ns/op 3093.69 MB/s Benchmark____Pub256B_Payload-16 38539734 89.38 ns/op 3009.57 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24310074 142.4 ns/op 7287.31 MB/s Benchmark______Pub1K_Payload-16 21707018 141.4 ns/op 7338.96 MB/s Benchmark______Pub1K_Payload-16 22554490 135.2 ns/op 7678.81 MB/s Benchmark______Pub1K_Payload-16 23147772 142.0 ns/op 7309.55 MB/s Benchmark______Pub1K_Payload-16 24043147 146.9 ns/op 7067.01 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5249565 631.8 ns/op 6504.76 MB/s Benchmark______Pub4K_Payload-16 5601486 627.1 ns/op 6554.23 MB/s Benchmark______Pub4K_Payload-16 5577794 634.0 ns/op 6482.34 MB/s Benchmark______Pub4K_Payload-16 5293843 628.6 ns/op 6537.84 MB/s Benchmark______Pub4K_Payload-16 5357136 624.8 ns/op 6578.09 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2754842 1286 ns/op 6380.51 MB/s Benchmark______Pub8K_Payload-16 2755915 1272 ns/op 6448.81 MB/s Benchmark______Pub8K_Payload-16 2791551 1292 ns/op 6351.60 MB/s Benchmark______Pub8K_Payload-16 2745076 1278 ns/op 6421.23 MB/s Benchmark______Pub8K_Payload-16 2741823 1280 ns/op 6412.81 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 673018 5277 ns/op 6212.55 MB/s Benchmark_____Pub32K_Payload-16 668145 5766 ns/op 5685.31 MB/s Benchmark_____Pub32K_Payload-16 658464 5474 ns/op 5988.77 MB/s Benchmark_____Pub32K_Payload-16 653896 5327 ns/op 6154.48 MB/s Benchmark_____Pub32K_Payload-16 666884 5536 ns/op 5922.29 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 34075608 88.40 ns/op 124.44 MB/s Benchmark__AuthPub0b_Payload-16 38523298 87.94 ns/op 125.08 MB/s Benchmark__AuthPub0b_Payload-16 38488834 88.07 ns/op 124.90 MB/s Benchmark__AuthPub0b_Payload-16 34235006 88.18 ns/op 124.74 MB/s Benchmark__AuthPub0b_Payload-16 38381518 89.35 ns/op 123.11 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 17025034 211.1 ns/op Benchmark_____________PubSub-16 16819480 210.1 ns/op Benchmark_____________PubSub-16 16915459 209.8 ns/op Benchmark_____________PubSub-16 16836842 211.0 ns/op Benchmark_____________PubSub-16 16737242 211.1 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 16919851 209.3 ns/op Benchmark_____PubSubTwoConns-16 16926200 209.6 ns/op Benchmark_____PubSubTwoConns-16 16991434 208.2 ns/op Benchmark_____PubSubTwoConns-16 16861947 209.5 ns/op Benchmark_____PubSubTwoConns-16 16907547 209.6 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:44180->127.0.0.1:43689: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40148->127.0.0.1:34851: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:36544->127.0.0.1:40631: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:39692->127.0.0.1:43921: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50170->127.0.0.1:43359: 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 15593452 228.8 ns/op Benchmark_____PubTwoQueueSub-16 15473953 227.4 ns/op Benchmark_____PubTwoQueueSub-16 15455380 228.3 ns/op Benchmark_____PubTwoQueueSub-16 15502677 229.2 ns/op Benchmark_____PubTwoQueueSub-16 15473799 228.6 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15484521 228.3 ns/op Benchmark____PubFourQueueSub-16 15403592 229.0 ns/op Benchmark____PubFourQueueSub-16 15195615 229.1 ns/op Benchmark____PubFourQueueSub-16 15490338 228.9 ns/op Benchmark____PubFourQueueSub-16 15491740 228.4 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15437390 226.4 ns/op Benchmark___PubEightQueueSub-16 15693975 229.0 ns/op Benchmark___PubEightQueueSub-16 15496532 230.0 ns/op Benchmark___PubEightQueueSub-16 15412582 229.2 ns/op Benchmark___PubEightQueueSub-16 15487473 229.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23355 155183 ns/op Benchmark_PubSub512kTwoConns-16 21686 165289 ns/op Benchmark_PubSub512kTwoConns-16 23074 153914 ns/op Benchmark_PubSub512kTwoConns-16 23287 153620 ns/op Benchmark_PubSub512kTwoConns-16 23278 157003 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16377960 212.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 16210274 213.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 16369507 213.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 16588993 213.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 16616437 213.0 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16176985 212.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 16179736 212.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 16270717 214.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 16533265 212.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 16571328 212.4 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12027069 296.3 ns/op Benchmark____RoutedPubSub_0b-16 12305332 295.6 ns/op Benchmark____RoutedPubSub_0b-16 11569370 295.5 ns/op Benchmark____RoutedPubSub_0b-16 11565948 299.1 ns/op Benchmark____RoutedPubSub_0b-16 11798943 295.1 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6841833 517.5 ns/op Benchmark____RoutedPubSub_1K-16 6600618 519.9 ns/op Benchmark____RoutedPubSub_1K-16 6834051 515.0 ns/op Benchmark____RoutedPubSub_1K-16 7108130 707.3 ns/op Benchmark____RoutedPubSub_1K-16 7087502 523.7 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84655 42015 ns/op Benchmark__RoutedPubSub_100K-16 87325 47301 ns/op Benchmark__RoutedPubSub_100K-16 74941 48798 ns/op Benchmark__RoutedPubSub_100K-16 77100 48774 ns/op Benchmark__RoutedPubSub_100K-16 73910 49350 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9812880 309.8 ns/op Benchmark____Routed2QueueSub-16 10034772 301.1 ns/op Benchmark____Routed2QueueSub-16 10253624 302.0 ns/op Benchmark____Routed2QueueSub-16 11895765 296.0 ns/op Benchmark____Routed2QueueSub-16 11987119 305.2 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 11759241 307.9 ns/op Benchmark____Routed4QueueSub-16 9918961 308.7 ns/op Benchmark____Routed4QueueSub-16 11894347 303.8 ns/op Benchmark____Routed4QueueSub-16 9791894 308.4 ns/op Benchmark____Routed4QueueSub-16 9886467 307.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 11531830 314.2 ns/op Benchmark____Routed8QueueSub-16 9531696 317.5 ns/op Benchmark____Routed8QueueSub-16 9597453 317.1 ns/op Benchmark____Routed8QueueSub-16 9484347 321.9 ns/op Benchmark____Routed8QueueSub-16 9607927 316.5 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9361995 340.5 ns/op Benchmark___Routed16QueueSub-16 9148448 329.3 ns/op Benchmark___Routed16QueueSub-16 9267452 334.7 ns/op Benchmark___Routed16QueueSub-16 9128892 336.7 ns/op Benchmark___Routed16QueueSub-16 9062456 338.1 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6605490 532.9 ns/op Benchmark____________RouteCompressOff-16 6637995 535.7 ns/op Benchmark____________RouteCompressOff-16 6743288 530.6 ns/op Benchmark____________RouteCompressOff-16 6774110 533.4 ns/op Benchmark____________RouteCompressOff-16 6769108 531.9 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 8190219 537.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6545148 533.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6640366 535.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6573966 496.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6652932 526.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6709903 527.6 ns/op Benchmark_________RouteCompressS2Fast-16 6895814 531.1 ns/op Benchmark_________RouteCompressS2Fast-16 6709561 530.2 ns/op Benchmark_________RouteCompressS2Fast-16 6521958 474.1 ns/op Benchmark_________RouteCompressS2Fast-16 6575710 530.0 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6725324 529.3 ns/op Benchmark_______RouteCompressS2Better-16 6640374 566.1 ns/op Benchmark_______RouteCompressS2Better-16 6659552 530.8 ns/op Benchmark_______RouteCompressS2Better-16 6708932 526.3 ns/op Benchmark_______RouteCompressS2Better-16 6657261 529.3 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6729194 523.5 ns/op Benchmark_________RouteCompressS2Best-16 6679024 534.9 ns/op Benchmark_________RouteCompressS2Best-16 6640525 525.0 ns/op Benchmark_________RouteCompressS2Best-16 6806388 523.6 ns/op Benchmark_________RouteCompressS2Best-16 6704380 531.1 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5134614 688.4 ns/op 361.71 MB/s Benchmark______FanOut_8x1x10-16 5180452 689.1 ns/op 361.36 MB/s Benchmark______FanOut_8x1x10-16 5141929 688.2 ns/op 361.84 MB/s Benchmark______FanOut_8x1x10-16 5158291 688.0 ns/op 361.90 MB/s Benchmark______FanOut_8x1x10-16 5126764 691.7 ns/op 359.99 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 633462 5357 ns/op 432.93 MB/s Benchmark_____FanOut_8x1x100-16 632422 5322 ns/op 435.74 MB/s Benchmark_____FanOut_8x1x100-16 590401 5273 ns/op 439.82 MB/s Benchmark_____FanOut_8x1x100-16 619814 5360 ns/op 432.67 MB/s Benchmark_____FanOut_8x1x100-16 664623 5336 ns/op 434.60 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52734 68257 ns/op 337.24 MB/s Benchmark____FanOut_8x10x100-16 52810 67796 ns/op 339.53 MB/s Benchmark____FanOut_8x10x100-16 53115 67889 ns/op 339.07 MB/s Benchmark____FanOut_8x10x100-16 53058 67934 ns/op 338.84 MB/s Benchmark____FanOut_8x10x100-16 52556 67978 ns/op 338.62 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6631 529757 ns/op 453.07 MB/s Benchmark___FanOut_8x10x1000-16 6577 541263 ns/op 443.44 MB/s Benchmark___FanOut_8x10x1000-16 6423 533895 ns/op 449.56 MB/s Benchmark___FanOut_8x10x1000-16 6504 541321 ns/op 443.39 MB/s Benchmark___FanOut_8x10x1000-16 6422 539324 ns/op 445.04 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5571 635374 ns/op 362.02 MB/s Benchmark___FanOut_8x100x100-16 5544 636214 ns/op 361.54 MB/s Benchmark___FanOut_8x100x100-16 5578 636469 ns/op 361.40 MB/s Benchmark___FanOut_8x100x100-16 5449 635656 ns/op 361.86 MB/s Benchmark___FanOut_8x100x100-16 5535 635692 ns/op 361.84 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 646 5437890 ns/op 441.35 MB/s Benchmark__FanOut_8x100x1000-16 632 5518597 ns/op 434.90 MB/s Benchmark__FanOut_8x100x1000-16 656 5541389 ns/op 433.11 MB/s Benchmark__FanOut_8x100x1000-16 626 5599009 ns/op 428.65 MB/s Benchmark__FanOut_8x100x1000-16 640 5490072 ns/op 437.16 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 597 5892057 ns/op 424.30 MB/s Benchmark__FanOut_8x10x10000-16 603 5957308 ns/op 419.66 MB/s Benchmark__FanOut_8x10x10000-16 603 6008032 ns/op 416.11 MB/s Benchmark__FanOut_8x10x10000-16 609 5931681 ns/op 421.47 MB/s Benchmark__FanOut_8x10x10000-16 591 5988246 ns/op 417.49 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1042 3402625 ns/op 337.98 MB/s Benchmark___FanOut_8x500x100-16 1047 3398963 ns/op 338.34 MB/s Benchmark___FanOut_8x500x100-16 1046 3398738 ns/op 338.37 MB/s Benchmark___FanOut_8x500x100-16 1047 3410602 ns/op 337.19 MB/s Benchmark___FanOut_8x500x100-16 1045 3406810 ns/op 337.56 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 393043 8821 ns/op 1659.86 MB/s Benchmark___FanOut_128x1x100-16 388392 8880 ns/op 1648.71 MB/s Benchmark___FanOut_128x1x100-16 381315 8875 ns/op 1649.70 MB/s Benchmark___FanOut_128x1x100-16 379274 8877 ns/op 1649.30 MB/s Benchmark___FanOut_128x1x100-16 390482 8902 ns/op 1644.76 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 34936 102966 ns/op 1409.61 MB/s Benchmark__FanOut_128x10x100-16 34945 102670 ns/op 1413.67 MB/s Benchmark__FanOut_128x10x100-16 34929 102338 ns/op 1418.25 MB/s Benchmark__FanOut_128x10x100-16 35148 102698 ns/op 1413.28 MB/s Benchmark__FanOut_128x10x100-16 35043 102810 ns/op 1411.74 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4302 810818 ns/op 1800.82 MB/s Benchmark_FanOut_128x10x1000-16 4245 804120 ns/op 1815.82 MB/s Benchmark_FanOut_128x10x1000-16 4348 807416 ns/op 1808.41 MB/s Benchmark_FanOut_128x10x1000-16 4429 799979 ns/op 1825.22 MB/s Benchmark_FanOut_128x10x1000-16 4528 799920 ns/op 1825.36 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3736 949142 ns/op 1527.84 MB/s Benchmark_FanOut_128x100x100-16 3790 947935 ns/op 1529.79 MB/s Benchmark_FanOut_128x100x100-16 3703 948118 ns/op 1529.49 MB/s Benchmark_FanOut_128x100x100-16 3645 948724 ns/op 1528.52 MB/s Benchmark_FanOut_128x100x100-16 3733 948158 ns/op 1529.43 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 417 8500352 ns/op 1717.59 MB/s BenchmarkFanOut_128x100x1000-16 416 8531016 ns/op 1711.42 MB/s BenchmarkFanOut_128x100x1000-16 417 8587222 ns/op 1700.22 MB/s BenchmarkFanOut_128x100x1000-16 415 8490205 ns/op 1719.65 MB/s BenchmarkFanOut_128x100x1000-16 421 8544088 ns/op 1708.80 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 406 8871457 ns/op 1657.02 MB/s BenchmarkFanOut_128x10x10000-16 406 8936145 ns/op 1645.02 MB/s BenchmarkFanOut_128x10x10000-16 408 8919462 ns/op 1648.10 MB/s BenchmarkFanOut_128x10x10000-16 398 8834223 ns/op 1664.00 MB/s BenchmarkFanOut_128x10x10000-16 399 8871777 ns/op 1656.96 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 711 5018688 ns/op 1444.63 MB/s BenchmarkFanOut__128x500x100-16 715 4993618 ns/op 1451.88 MB/s BenchmarkFanOut__128x500x100-16 712 4992172 ns/op 1452.30 MB/s BenchmarkFanOut__128x500x100-16 715 5011164 ns/op 1446.80 MB/s BenchmarkFanOut__128x500x100-16 705 4973533 ns/op 1457.74 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2055 1774575 ns/op 2981.29 MB/s Benchmark_FanOut_512x100x100-16 2032 1753004 ns/op 3017.98 MB/s Benchmark_FanOut_512x100x100-16 1998 1773160 ns/op 2983.67 MB/s Benchmark_FanOut_512x100x100-16 2022 1756283 ns/op 3012.34 MB/s Benchmark_FanOut_512x100x100-16 2011 1770971 ns/op 2987.36 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 225 16062871 ns/op 3299.57 MB/s Benchmark__FanOut_512x100x1k-16 223 16136962 ns/op 3284.42 MB/s Benchmark__FanOut_512x100x1k-16 222 16257231 ns/op 3260.12 MB/s Benchmark__FanOut_512x100x1k-16 224 16156605 ns/op 3280.42 MB/s Benchmark__FanOut_512x100x1k-16 220 15997526 ns/op 3313.05 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2972 1116757 ns/op 9340.47 MB/s Benchmark____FanOut_1kx10x1k-16 3298 1115181 ns/op 9353.67 MB/s Benchmark____FanOut_1kx10x1k-16 3008 1090560 ns/op 9564.84 MB/s Benchmark____FanOut_1kx10x1k-16 3129 1094975 ns/op 9526.28 MB/s Benchmark____FanOut_1kx10x1k-16 3375 1105206 ns/op 9438.09 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2910 1201889 ns/op 8670.55 MB/s Benchmark__FanOut_1kx100x100-16 2971 1189797 ns/op 8758.67 MB/s Benchmark__FanOut_1kx100x100-16 2886 1197735 ns/op 8700.62 MB/s Benchmark__FanOut_1kx100x100-16 2886 1195588 ns/op 8716.25 MB/s Benchmark__FanOut_1kx100x100-16 2976 1193095 ns/op 8734.46 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4965841 702.0 ns/op 354.70 MB/s Benchmark_____RFanOut_8x1x10-16 4817368 714.2 ns/op 348.62 MB/s Benchmark_____RFanOut_8x1x10-16 4784520 699.5 ns/op 355.95 MB/s Benchmark_____RFanOut_8x1x10-16 4860981 713.1 ns/op 349.19 MB/s Benchmark_____RFanOut_8x1x10-16 4977321 708.0 ns/op 351.69 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 629668 5274 ns/op 439.72 MB/s Benchmark____RFanOut_8x1x100-16 609979 5278 ns/op 439.39 MB/s Benchmark____RFanOut_8x1x100-16 602614 5378 ns/op 431.18 MB/s Benchmark____RFanOut_8x1x100-16 597026 5340 ns/op 434.29 MB/s Benchmark____RFanOut_8x1x100-16 612976 5401 ns/op 429.33 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 52724 67566 ns/op 340.69 MB/s Benchmark___RFanOut_8x10x100-16 52518 68235 ns/op 337.35 MB/s Benchmark___RFanOut_8x10x100-16 52680 67689 ns/op 340.07 MB/s Benchmark___RFanOut_8x10x100-16 52942 67775 ns/op 339.64 MB/s Benchmark___RFanOut_8x10x100-16 52987 68115 ns/op 337.94 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6556 539381 ns/op 444.99 MB/s Benchmark__RFanOut_8x10x1000-16 6362 538271 ns/op 445.91 MB/s Benchmark__RFanOut_8x10x1000-16 6640 538769 ns/op 445.50 MB/s Benchmark__RFanOut_8x10x1000-16 6331 542765 ns/op 442.22 MB/s Benchmark__RFanOut_8x10x1000-16 6213 536633 ns/op 447.27 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5524 634540 ns/op 362.50 MB/s Benchmark__RFanOut_8x100x100-16 5490 635364 ns/op 362.03 MB/s Benchmark__RFanOut_8x100x100-16 5569 635079 ns/op 362.19 MB/s Benchmark__RFanOut_8x100x100-16 5598 639089 ns/op 359.92 MB/s Benchmark__RFanOut_8x100x100-16 5520 636888 ns/op 361.16 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 642 5609227 ns/op 427.87 MB/s Benchmark_RFanOut_8x100x1000-16 633 5593291 ns/op 429.09 MB/s Benchmark_RFanOut_8x100x1000-16 638 5580170 ns/op 430.10 MB/s Benchmark_RFanOut_8x100x1000-16 639 5660801 ns/op 423.97 MB/s Benchmark_RFanOut_8x100x1000-16 637 5585938 ns/op 429.65 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 612 5945871 ns/op 420.46 MB/s Benchmark_RFanOut_8x10x10000-16 606 5999907 ns/op 416.68 MB/s Benchmark_RFanOut_8x10x10000-16 601 5910374 ns/op 422.99 MB/s Benchmark_RFanOut_8x10x10000-16 589 5929024 ns/op 421.66 MB/s Benchmark_RFanOut_8x10x10000-16 601 5904657 ns/op 423.40 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3178 1093990 ns/op 9534.86 MB/s Benchmark_RFanOut_1kx10x1000-16 2868 1137739 ns/op 9168.22 MB/s Benchmark_RFanOut_1kx10x1000-16 3019 1119249 ns/op 9319.68 MB/s Benchmark_RFanOut_1kx10x1000-16 3219 1127276 ns/op 9253.32 MB/s Benchmark_RFanOut_1kx10x1000-16 2991 1123288 ns/op 9286.17 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7216176 487.4 ns/op 4263.42 MB/s Benchmark_____FanIn_1kx100x1-16 7247594 487.1 ns/op 4266.32 MB/s Benchmark_____FanIn_1kx100x1-16 7419265 487.5 ns/op 4262.29 MB/s Benchmark_____FanIn_1kx100x1-16 7124582 490.1 ns/op 4240.37 MB/s Benchmark_____FanIn_1kx100x1-16 7068190 485.1 ns/op 4283.33 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2710042 1342 ns/op 6127.57 MB/s Benchmark_____FanIn_4kx100x1-16 2627690 1332 ns/op 6174.06 MB/s Benchmark_____FanIn_4kx100x1-16 2663600 1334 ns/op 6165.70 MB/s Benchmark_____FanIn_4kx100x1-16 2684710 1332 ns/op 6173.62 MB/s Benchmark_____FanIn_4kx100x1-16 2616920 1329 ns/op 6185.66 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1708797 2121 ns/op 7737.78 MB/s Benchmark_____FanIn_8kx100x1-16 1731888 2086 ns/op 7869.34 MB/s Benchmark_____FanIn_8kx100x1-16 1713806 2066 ns/op 7944.95 MB/s Benchmark_____FanIn_8kx100x1-16 1726633 2100 ns/op 7814.98 MB/s Benchmark_____FanIn_8kx100x1-16 1734058 2082 ns/op 7882.89 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 876176 4109 ns/op 7981.99 MB/s Benchmark____FanIn_16kx100x1-16 875395 4102 ns/op 7995.62 MB/s Benchmark____FanIn_16kx100x1-16 870932 4140 ns/op 7922.41 MB/s Benchmark____FanIn_16kx100x1-16 857056 4105 ns/op 7989.56 MB/s Benchmark____FanIn_16kx100x1-16 869738 4129 ns/op 7944.26 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 171991 19855 ns/op 6603.16 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7863213456 vs 11314447800 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43796->127.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:43926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44058->127.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:43928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43502->127.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:43976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43924->127.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:43342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43206->127.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:43584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43370->127.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:43734->127.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:43758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43340->127.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:43240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43842->127.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:44030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43576->127.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:43880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44020->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 169202 20036 ns/op 6543.56 MB/s Benchmark____FanIn_64kx100x1-16 163963 19828 ns/op 6612.07 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 8890363413 vs 10868687400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33152->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32776->127.0.0.1:5222: write: connection reset by peer Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 82717790 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34776->127.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:34726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35016->127.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:34294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34136->127.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: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:34600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34196->127.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:34962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35032->127.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:34716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34646->127.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:34396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:34574->127.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:34470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34376->127.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:34128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34950->127.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:34116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35006->127.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:34502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34126->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: 477167600 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36468->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:36110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36242->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: 236879630 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38316->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: 399037960 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39528->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: 488572430 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41336->127.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:41488->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41546->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42066->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42186->127.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:41386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41556->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41692->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41848->127.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:41322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:41492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41790->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5912652 602.5 ns/op 471.38 MB/s Benchmark___BumpPubCount_1x3-16 5980171 602.5 ns/op 471.40 MB/s Benchmark___BumpPubCount_1x3-16 5906388 603.0 ns/op 470.96 MB/s Benchmark___BumpPubCount_1x3-16 5947360 600.5 ns/op 472.95 MB/s Benchmark___BumpPubCount_1x3-16 5946397 600.2 ns/op 473.20 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5640002 631.6 ns/op 449.67 MB/s Benchmark___BumpPubCount_2x3-16 5613865 635.8 ns/op 446.69 MB/s Benchmark___BumpPubCount_2x3-16 5511048 635.9 ns/op 446.58 MB/s Benchmark___BumpPubCount_2x3-16 5588947 634.3 ns/op 447.72 MB/s Benchmark___BumpPubCount_2x3-16 5464705 637.2 ns/op 445.67 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5851539 607.7 ns/op 467.36 MB/s Benchmark___BumpPubCount_5x3-16 5839288 609.5 ns/op 465.96 MB/s Benchmark___BumpPubCount_5x3-16 5860082 613.0 ns/op 463.27 MB/s Benchmark___BumpPubCount_5x3-16 5742162 611.6 ns/op 464.37 MB/s Benchmark___BumpPubCount_5x3-16 5161618 613.6 ns/op 462.85 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5890174 607.5 ns/op 467.48 MB/s Benchmark__BumpPubCount_10x3-16 5884740 617.1 ns/op 460.22 MB/s Benchmark__BumpPubCount_10x3-16 5882247 607.7 ns/op 467.33 MB/s Benchmark__BumpPubCount_10x3-16 5033739 607.9 ns/op 467.19 MB/s Benchmark__BumpPubCount_10x3-16 5905891 608.2 ns/op 466.92 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11260276 271.2 ns/op 3835.04 MB/s Benchmark____GWs_Opt_1kx01x0-16 12706964 278.7 ns/op 3731.35 MB/s Benchmark____GWs_Opt_1kx01x0-16 13143442 273.7 ns/op 3799.26 MB/s Benchmark____GWs_Opt_1kx01x0-16 12494784 268.7 ns/op 3870.39 MB/s Benchmark____GWs_Opt_1kx01x0-16 13379098 269.7 ns/op 3856.49 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10577914 324.9 ns/op 6352.65 MB/s Benchmark____GWs_Opt_2kx01x0-16 10587247 332.0 ns/op 6217.12 MB/s Benchmark____GWs_Opt_2kx01x0-16 9976029 338.2 ns/op 6103.72 MB/s Benchmark____GWs_Opt_2kx01x0-16 10388886 344.0 ns/op 5999.44 MB/s Benchmark____GWs_Opt_2kx01x0-16 10577055 331.3 ns/op 6230.08 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5860747 615.7 ns/op 6678.31 MB/s Benchmark____GWs_Opt_4kx01x0-16 5521804 617.5 ns/op 6659.21 MB/s Benchmark____GWs_Opt_4kx01x0-16 5825277 603.2 ns/op 6817.01 MB/s Benchmark____GWs_Opt_4kx01x0-16 5730858 627.1 ns/op 6557.20 MB/s Benchmark____GWs_Opt_4kx01x0-16 5688988 619.8 ns/op 6634.05 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29751975 117.0 ns/op 8886.72 MB/s Benchmark____GWs_Opt_1kx10x0-16 29110484 119.4 ns/op 8710.17 MB/s Benchmark____GWs_Opt_1kx10x0-16 30908622 109.8 ns/op 9472.95 MB/s Benchmark____GWs_Opt_1kx10x0-16 30867033 112.2 ns/op 9266.51 MB/s Benchmark____GWs_Opt_1kx10x0-16 31835212 109.3 ns/op 9517.91 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23624188 143.4 ns/op 14389.32 MB/s Benchmark____GWs_Opt_2kx10x0-16 23821437 145.9 ns/op 14145.00 MB/s Benchmark____GWs_Opt_2kx10x0-16 21241778 143.0 ns/op 14433.96 MB/s Benchmark____GWs_Opt_2kx10x0-16 24455383 152.9 ns/op 13498.80 MB/s Benchmark____GWs_Opt_2kx10x0-16 19634275 162.6 ns/op 12696.07 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11707987 294.3 ns/op 13971.71 MB/s Benchmark____GWs_Opt_4kx10x0-16 12347721 313.8 ns/op 13101.84 MB/s Benchmark____GWs_Opt_4kx10x0-16 12922656 288.1 ns/op 14272.84 MB/s Benchmark____GWs_Opt_4kx10x0-16 12750955 322.1 ns/op 12768.14 MB/s Benchmark____GWs_Opt_4kx10x0-16 11661117 294.7 ns/op 13952.52 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6594135 530.8 ns/op 5887.76 MB/s Benchmark____GWs_Opt_1kx01x1-16 6585272 531.1 ns/op 5884.41 MB/s Benchmark____GWs_Opt_1kx01x1-16 6529706 535.6 ns/op 5834.38 MB/s Benchmark____GWs_Opt_1kx01x1-16 6492807 539.4 ns/op 5793.40 MB/s Benchmark____GWs_Opt_1kx01x1-16 6960004 541.7 ns/op 5768.38 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4820055 738.4 ns/op 8392.71 MB/s Benchmark____GWs_Opt_2kx01x1-16 4732600 748.1 ns/op 8283.34 MB/s Benchmark____GWs_Opt_2kx01x1-16 4750003 746.9 ns/op 8296.54 MB/s Benchmark____GWs_Opt_2kx01x1-16 4852048 852.8 ns/op 7266.51 MB/s Benchmark____GWs_Opt_2kx01x1-16 4759617 740.0 ns/op 8374.34 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2657986 1358 ns/op 9087.83 MB/s Benchmark____GWs_Opt_4kx01x1-16 2645101 1337 ns/op 9227.94 MB/s Benchmark____GWs_Opt_4kx01x1-16 2703680 1356 ns/op 9098.99 MB/s Benchmark____GWs_Opt_4kx01x1-16 2642406 1348 ns/op 9153.56 MB/s Benchmark____GWs_Opt_4kx01x1-16 2688936 1346 ns/op 9171.76 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6576561 536.9 ns/op 5820.60 MB/s Benchmark____GWs_Opt_1kx10x1-16 6835567 541.1 ns/op 5775.29 MB/s Benchmark____GWs_Opt_1kx10x1-16 6723277 542.8 ns/op 5756.80 MB/s Benchmark____GWs_Opt_1kx10x1-16 6649383 542.0 ns/op 5766.19 MB/s Benchmark____GWs_Opt_1kx10x1-16 6942129 537.8 ns/op 5810.96 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4282484 838.5 ns/op 7390.73 MB/s Benchmark____GWs_Opt_2kx10x1-16 4114323 822.9 ns/op 7530.38 MB/s Benchmark____GWs_Opt_2kx10x1-16 4354292 793.6 ns/op 7809.21 MB/s Benchmark____GWs_Opt_2kx10x1-16 4265919 825.7 ns/op 7504.91 MB/s Benchmark____GWs_Opt_2kx10x1-16 4081898 819.7 ns/op 7560.01 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2428278 1585 ns/op 7788.08 MB/s Benchmark____GWs_Opt_4kx10x1-16 2431033 1505 ns/op 8202.62 MB/s Benchmark____GWs_Opt_4kx10x1-16 2442296 1548 ns/op 7969.89 MB/s Benchmark____GWs_Opt_4kx10x1-16 2384421 1503 ns/op 8213.51 MB/s Benchmark____GWs_Opt_4kx10x1-16 2375204 1526 ns/op 8086.56 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12673206 276.0 ns/op 3767.61 MB/s Benchmark____GWs_Int_1kx01x0-16 12081961 281.7 ns/op 3691.63 MB/s Benchmark____GWs_Int_1kx01x0-16 12023102 285.1 ns/op 3647.72 MB/s Benchmark____GWs_Int_1kx01x0-16 12728665 283.0 ns/op 3675.25 MB/s Benchmark____GWs_Int_1kx01x0-16 12800253 283.3 ns/op 3670.53 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9838082 349.5 ns/op 5904.87 MB/s Benchmark____GWs_Int_2kx01x0-16 10835338 360.2 ns/op 5730.17 MB/s Benchmark____GWs_Int_2kx01x0-16 9131886 353.3 ns/op 5841.79 MB/s Benchmark____GWs_Int_2kx01x0-16 9171283 372.2 ns/op 5545.63 MB/s Benchmark____GWs_Int_2kx01x0-16 10762303 365.7 ns/op 5643.44 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 3810391 872.0 ns/op 4715.43 MB/s Benchmark____GWs_Int_4kx01x0-16 5425392 629.5 ns/op 6532.00 MB/s Benchmark____GWs_Int_4kx01x0-16 5626600 616.1 ns/op 6674.27 MB/s Benchmark____GWs_Int_4kx01x0-16 5563690 628.1 ns/op 6546.24 MB/s Benchmark____GWs_Int_4kx01x0-16 5670802 621.6 ns/op 6615.09 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32457912 125.0 ns/op 8318.66 MB/s Benchmark____GWs_Int_1kx10x0-16 31609669 108.8 ns/op 9561.95 MB/s Benchmark____GWs_Int_1kx10x0-16 32157451 109.7 ns/op 9482.98 MB/s Benchmark____GWs_Int_1kx10x0-16 32397153 109.5 ns/op 9500.77 MB/s Benchmark____GWs_Int_1kx10x0-16 31687489 111.8 ns/op 9305.27 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25323721 139.4 ns/op 14807.49 MB/s Benchmark____GWs_Int_2kx10x0-16 25720648 140.2 ns/op 14717.34 MB/s Benchmark____GWs_Int_2kx10x0-16 26077531 145.4 ns/op 14195.24 MB/s Benchmark____GWs_Int_2kx10x0-16 25746273 145.2 ns/op 14214.32 MB/s Benchmark____GWs_Int_2kx10x0-16 23139346 140.0 ns/op 14739.80 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:41398->127.0.0.1:33657: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:48002->127.0.0.1:40077: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 10687538 319.2 ns/op 12881.42 MB/s Benchmark____GWs_Int_4kx10x0-16 11125953 320.1 ns/op 12844.85 MB/s Benchmark____GWs_Int_4kx10x0-16 11327524 318.3 ns/op 12917.14 MB/s Benchmark____GWs_Int_4kx10x0-16 11729738 281.9 ns/op 14588.00 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6391986 538.8 ns/op 5800.19 MB/s Benchmark____GWs_Int_1kx01x1-16 6720616 543.5 ns/op 5749.86 MB/s Benchmark____GWs_Int_1kx01x1-16 6593254 544.8 ns/op 5735.88 MB/s Benchmark____GWs_Int_1kx01x1-16 6655651 537.8 ns/op 5810.36 MB/s Benchmark____GWs_Int_1kx01x1-16 6542306 537.3 ns/op 5816.19 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4772088 744.7 ns/op 8321.56 MB/s Benchmark____GWs_Int_2kx01x1-16 4775158 760.1 ns/op 8152.47 MB/s Benchmark____GWs_Int_2kx01x1-16 4883768 766.5 ns/op 8085.11 MB/s Benchmark____GWs_Int_2kx01x1-16 4902366 747.7 ns/op 8287.88 MB/s Benchmark____GWs_Int_2kx01x1-16 4412134 751.4 ns/op 8246.94 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2699991 1542 ns/op 8003.73 MB/s Benchmark____GWs_Int_4kx01x1-16 2286915 1352 ns/op 9125.31 MB/s Benchmark____GWs_Int_4kx01x1-16 2697189 1559 ns/op 7914.18 MB/s Benchmark____GWs_Int_4kx01x1-16 2690518 1359 ns/op 9079.79 MB/s Benchmark____GWs_Int_4kx01x1-16 2687466 3003 ns/op 4109.13 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6606975 536.2 ns/op 5828.25 MB/s Benchmark____GWs_Int_1kx10x1-16 6527594 554.1 ns/op 5639.78 MB/s Benchmark____GWs_Int_1kx10x1-16 6712393 542.2 ns/op 5763.07 MB/s Benchmark____GWs_Int_1kx10x1-16 6783580 532.1 ns/op 5873.44 MB/s Benchmark____GWs_Int_1kx10x1-16 6476128 541.4 ns/op 5772.20 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4211564 825.8 ns/op 7503.82 MB/s Benchmark____GWs_Int_2kx10x1-16 4217204 835.3 ns/op 7419.00 MB/s Benchmark____GWs_Int_2kx10x1-16 4164199 820.8 ns/op 7549.87 MB/s Benchmark____GWs_Int_2kx10x1-16 4282749 830.7 ns/op 7460.22 MB/s Benchmark____GWs_Int_2kx10x1-16 4360920 837.2 ns/op 7402.27 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2439957 1564 ns/op 7892.28 MB/s Benchmark____GWs_Int_4kx10x1-16 2345120 1475 ns/op 8365.72 MB/s Benchmark____GWs_Int_4kx10x1-16 2341246 1540 ns/op 8014.43 MB/s Benchmark____GWs_Int_4kx10x1-16 2335874 1642 ns/op 7516.35 MB/s Benchmark____GWs_Int_4kx10x1-16 2408396 1504 ns/op 8203.11 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8391662 426.6 ns/op 239.10 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8523837 432.0 ns/op 236.10 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8583774 425.5 ns/op 239.72 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8551717 418.1 ns/op 243.94 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8567602 423.0 ns/op 241.13 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 762286 4831 ns/op 36.64 MB/s Benchmark__GWs_Reqs_1SubEach-16 756339 4951 ns/op 35.75 MB/s Benchmark__GWs_Reqs_1SubEach-16 809391 4942 ns/op 35.82 MB/s Benchmark__GWs_Reqs_1SubEach-16 828636 4977 ns/op 35.57 MB/s Benchmark__GWs_Reqs_1SubEach-16 748458 4910 ns/op 36.05 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2112.112s