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 50317167 71.41 ns/op 154.03 MB/s Benchmark______Pub0b_Payload-16 47549076 71.77 ns/op 153.26 MB/s Benchmark______Pub0b_Payload-16 48042988 71.43 ns/op 154.00 MB/s Benchmark______Pub0b_Payload-16 47663701 71.40 ns/op 154.05 MB/s Benchmark______Pub0b_Payload-16 47795163 72.85 ns/op 151.01 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 47404128 73.05 ns/op 260.11 MB/s Benchmark______Pub8b_Payload-16 47282089 72.26 ns/op 262.95 MB/s Benchmark______Pub8b_Payload-16 46902792 73.95 ns/op 256.94 MB/s Benchmark______Pub8b_Payload-16 43245399 75.22 ns/op 252.60 MB/s Benchmark______Pub8b_Payload-16 47161725 72.45 ns/op 262.25 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44454266 76.81 ns/op 572.83 MB/s Benchmark_____Pub32b_Payload-16 46849672 76.67 ns/op 573.90 MB/s Benchmark_____Pub32b_Payload-16 44779491 77.01 ns/op 571.37 MB/s Benchmark_____Pub32b_Payload-16 41223250 77.35 ns/op 568.85 MB/s Benchmark_____Pub32b_Payload-16 46821810 76.42 ns/op 575.74 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39656875 89.26 ns/op 1579.72 MB/s Benchmark____Pub128B_Payload-16 39594468 86.93 ns/op 1621.98 MB/s Benchmark____Pub128B_Payload-16 39475692 86.13 ns/op 1637.01 MB/s Benchmark____Pub128B_Payload-16 35009846 87.36 ns/op 1614.07 MB/s Benchmark____Pub128B_Payload-16 41972775 86.40 ns/op 1632.02 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36639145 96.54 ns/op 2786.29 MB/s Benchmark____Pub256B_Payload-16 35691717 96.12 ns/op 2798.58 MB/s Benchmark____Pub256B_Payload-16 31704372 96.07 ns/op 2800.08 MB/s Benchmark____Pub256B_Payload-16 31426420 96.17 ns/op 2797.27 MB/s Benchmark____Pub256B_Payload-16 35818261 98.40 ns/op 2733.62 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22633717 145.0 ns/op 7158.17 MB/s Benchmark______Pub1K_Payload-16 23884288 139.1 ns/op 7462.84 MB/s Benchmark______Pub1K_Payload-16 25839483 138.3 ns/op 7503.49 MB/s Benchmark______Pub1K_Payload-16 25314616 141.3 ns/op 7343.91 MB/s Benchmark______Pub1K_Payload-16 22191661 141.8 ns/op 7319.15 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5874003 622.8 ns/op 6599.20 MB/s Benchmark______Pub4K_Payload-16 5166934 623.3 ns/op 6594.11 MB/s Benchmark______Pub4K_Payload-16 5496452 619.7 ns/op 6632.26 MB/s Benchmark______Pub4K_Payload-16 5561704 628.5 ns/op 6539.10 MB/s Benchmark______Pub4K_Payload-16 5614125 622.4 ns/op 6603.58 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2775548 1287 ns/op 6375.97 MB/s Benchmark______Pub8K_Payload-16 2789042 1347 ns/op 6090.69 MB/s Benchmark______Pub8K_Payload-16 2692159 1284 ns/op 6389.98 MB/s Benchmark______Pub8K_Payload-16 2744553 1294 ns/op 6342.23 MB/s Benchmark______Pub8K_Payload-16 2745780 1276 ns/op 6432.71 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 654142 5385 ns/op 6087.85 MB/s Benchmark_____Pub32K_Payload-16 646560 5540 ns/op 5917.41 MB/s Benchmark_____Pub32K_Payload-16 554727 5417 ns/op 6051.81 MB/s Benchmark_____Pub32K_Payload-16 663553 5490 ns/op 5971.19 MB/s Benchmark_____Pub32K_Payload-16 649480 5507 ns/op 5952.52 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31432312 96.16 ns/op 114.40 MB/s Benchmark__AuthPub0b_Payload-16 32371792 94.06 ns/op 116.95 MB/s Benchmark__AuthPub0b_Payload-16 36284850 96.56 ns/op 113.92 MB/s Benchmark__AuthPub0b_Payload-16 34682277 94.89 ns/op 115.92 MB/s Benchmark__AuthPub0b_Payload-16 36385612 93.88 ns/op 117.17 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15749149 225.5 ns/op Benchmark_____________PubSub-16 15738124 225.5 ns/op Benchmark_____________PubSub-16 15634824 226.3 ns/op Benchmark_____________PubSub-16 15613500 225.4 ns/op Benchmark_____________PubSub-16 15803571 226.4 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15819103 224.8 ns/op Benchmark_____PubSubTwoConns-16 15838713 224.9 ns/op Benchmark_____PubSubTwoConns-16 15878965 223.9 ns/op Benchmark_____PubSubTwoConns-16 15822288 224.5 ns/op Benchmark_____PubSubTwoConns-16 15829626 225.5 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40556->127.0.0.1:33493: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43716->127.0.0.1:42445: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57980->127.0.0.1:32931: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:39850->127.0.0.1:40013: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:44862->127.0.0.1:35603: 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 14509747 246.1 ns/op Benchmark_____PubTwoQueueSub-16 14316266 246.0 ns/op Benchmark_____PubTwoQueueSub-16 14417376 246.0 ns/op Benchmark_____PubTwoQueueSub-16 14585364 246.9 ns/op Benchmark_____PubTwoQueueSub-16 14083455 247.1 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14217751 247.2 ns/op Benchmark____PubFourQueueSub-16 14332636 246.5 ns/op Benchmark____PubFourQueueSub-16 14479755 247.5 ns/op Benchmark____PubFourQueueSub-16 14519978 246.8 ns/op Benchmark____PubFourQueueSub-16 14459629 247.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14241118 248.8 ns/op Benchmark___PubEightQueueSub-16 14329419 248.4 ns/op Benchmark___PubEightQueueSub-16 14356401 246.7 ns/op Benchmark___PubEightQueueSub-16 14476250 247.4 ns/op Benchmark___PubEightQueueSub-16 14360676 247.8 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23096 157633 ns/op Benchmark_PubSub512kTwoConns-16 23150 156802 ns/op Benchmark_PubSub512kTwoConns-16 22772 155302 ns/op Benchmark_PubSub512kTwoConns-16 23041 156430 ns/op Benchmark_PubSub512kTwoConns-16 23002 155876 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15428978 228.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15362908 228.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15351795 229.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15226185 228.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15269364 226.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15197528 228.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15440892 228.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15364088 228.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15398320 228.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15185042 228.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11598408 306.8 ns/op Benchmark____RoutedPubSub_0b-16 11561852 313.9 ns/op Benchmark____RoutedPubSub_0b-16 11331697 305.5 ns/op Benchmark____RoutedPubSub_0b-16 11157608 311.9 ns/op Benchmark____RoutedPubSub_0b-16 10983669 308.4 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6609220 530.4 ns/op Benchmark____RoutedPubSub_1K-16 6536911 536.8 ns/op Benchmark____RoutedPubSub_1K-16 6689676 532.7 ns/op Benchmark____RoutedPubSub_1K-16 6681584 536.8 ns/op Benchmark____RoutedPubSub_1K-16 6756670 538.4 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84446 43113 ns/op Benchmark__RoutedPubSub_100K-16 84151 42049 ns/op Benchmark__RoutedPubSub_100K-16 84711 44497 ns/op Benchmark__RoutedPubSub_100K-16 70100 46338 ns/op Benchmark__RoutedPubSub_100K-16 81015 45965 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9811557 332.3 ns/op Benchmark____Routed2QueueSub-16 9637818 325.6 ns/op Benchmark____Routed2QueueSub-16 9367056 324.0 ns/op Benchmark____Routed2QueueSub-16 11271454 322.2 ns/op Benchmark____Routed2QueueSub-16 9472976 326.2 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9415014 323.3 ns/op Benchmark____Routed4QueueSub-16 9218810 332.0 ns/op Benchmark____Routed4QueueSub-16 11111776 326.0 ns/op Benchmark____Routed4QueueSub-16 9491509 323.3 ns/op Benchmark____Routed4QueueSub-16 9568719 321.5 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9405555 335.0 ns/op Benchmark____Routed8QueueSub-16 9274364 339.5 ns/op Benchmark____Routed8QueueSub-16 10832002 329.8 ns/op Benchmark____Routed8QueueSub-16 9263946 327.3 ns/op Benchmark____Routed8QueueSub-16 9004719 333.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8728308 351.1 ns/op Benchmark___Routed16QueueSub-16 8776117 355.7 ns/op Benchmark___Routed16QueueSub-16 10274834 354.2 ns/op Benchmark___Routed16QueueSub-16 8599671 357.6 ns/op Benchmark___Routed16QueueSub-16 10338710 353.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6437234 542.1 ns/op Benchmark____________RouteCompressOff-16 6554168 550.4 ns/op Benchmark____________RouteCompressOff-16 6283770 520.0 ns/op Benchmark____________RouteCompressOff-16 6302192 547.7 ns/op Benchmark____________RouteCompressOff-16 6535740 548.4 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6310321 548.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6322280 551.9 ns/op Benchmark_RouteCompressS2Uncompressed-16 6449200 546.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6501066 557.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6589500 547.9 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6494448 549.3 ns/op Benchmark_________RouteCompressS2Fast-16 6443044 550.7 ns/op Benchmark_________RouteCompressS2Fast-16 6494874 540.9 ns/op Benchmark_________RouteCompressS2Fast-16 6437282 546.8 ns/op Benchmark_________RouteCompressS2Fast-16 6557314 546.3 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6486987 541.7 ns/op Benchmark_______RouteCompressS2Better-16 6400572 546.4 ns/op Benchmark_______RouteCompressS2Better-16 6485354 543.4 ns/op Benchmark_______RouteCompressS2Better-16 6455010 549.8 ns/op Benchmark_______RouteCompressS2Better-16 6485899 542.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6350881 550.6 ns/op Benchmark_________RouteCompressS2Best-16 6567885 551.4 ns/op Benchmark_________RouteCompressS2Best-16 6475334 550.3 ns/op Benchmark_________RouteCompressS2Best-16 6523849 550.1 ns/op Benchmark_________RouteCompressS2Best-16 6494300 545.6 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4616781 766.8 ns/op 324.71 MB/s Benchmark______FanOut_8x1x10-16 4650366 765.6 ns/op 325.24 MB/s Benchmark______FanOut_8x1x10-16 4690170 769.6 ns/op 323.56 MB/s Benchmark______FanOut_8x1x10-16 4666723 794.6 ns/op 313.36 MB/s Benchmark______FanOut_8x1x10-16 4561176 769.9 ns/op 323.40 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 561619 6113 ns/op 379.37 MB/s Benchmark_____FanOut_8x1x100-16 536532 6124 ns/op 378.67 MB/s Benchmark_____FanOut_8x1x100-16 570042 6247 ns/op 371.19 MB/s Benchmark_____FanOut_8x1x100-16 566502 6158 ns/op 376.56 MB/s Benchmark_____FanOut_8x1x100-16 531148 6097 ns/op 380.34 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47642 75631 ns/op 304.36 MB/s Benchmark____FanOut_8x10x100-16 47604 75499 ns/op 304.89 MB/s Benchmark____FanOut_8x10x100-16 47673 75566 ns/op 304.62 MB/s Benchmark____FanOut_8x10x100-16 47175 75815 ns/op 303.62 MB/s Benchmark____FanOut_8x10x100-16 47392 75865 ns/op 303.42 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5878 607205 ns/op 395.28 MB/s Benchmark___FanOut_8x10x1000-16 5840 608559 ns/op 394.41 MB/s Benchmark___FanOut_8x10x1000-16 5558 609508 ns/op 393.79 MB/s Benchmark___FanOut_8x10x1000-16 5634 611638 ns/op 392.42 MB/s Benchmark___FanOut_8x10x1000-16 5625 611290 ns/op 392.64 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4922 720459 ns/op 319.27 MB/s Benchmark___FanOut_8x100x100-16 4908 720147 ns/op 319.41 MB/s Benchmark___FanOut_8x100x100-16 4975 723527 ns/op 317.91 MB/s Benchmark___FanOut_8x100x100-16 4858 720613 ns/op 319.20 MB/s Benchmark___FanOut_8x100x100-16 4863 724967 ns/op 317.28 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 554 6328022 ns/op 379.27 MB/s Benchmark__FanOut_8x100x1000-16 547 6323012 ns/op 379.57 MB/s Benchmark__FanOut_8x100x1000-16 558 6317405 ns/op 379.91 MB/s Benchmark__FanOut_8x100x1000-16 562 6312556 ns/op 380.20 MB/s Benchmark__FanOut_8x100x1000-16 561 6315237 ns/op 380.04 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 530 6798879 ns/op 367.71 MB/s Benchmark__FanOut_8x10x10000-16 519 6867373 ns/op 364.04 MB/s Benchmark__FanOut_8x10x10000-16 519 6855942 ns/op 364.65 MB/s Benchmark__FanOut_8x10x10000-16 519 6844003 ns/op 365.29 MB/s Benchmark__FanOut_8x10x10000-16 526 6853617 ns/op 364.77 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 926 3823424 ns/op 300.78 MB/s Benchmark___FanOut_8x500x100-16 924 3829457 ns/op 300.31 MB/s Benchmark___FanOut_8x500x100-16 926 3835511 ns/op 299.83 MB/s Benchmark___FanOut_8x500x100-16 927 3830475 ns/op 300.23 MB/s Benchmark___FanOut_8x500x100-16 930 3830625 ns/op 300.22 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 356636 9548 ns/op 1533.40 MB/s Benchmark___FanOut_128x1x100-16 355107 9678 ns/op 1512.77 MB/s Benchmark___FanOut_128x1x100-16 357589 9579 ns/op 1528.44 MB/s Benchmark___FanOut_128x1x100-16 350804 9595 ns/op 1525.91 MB/s Benchmark___FanOut_128x1x100-16 362026 9656 ns/op 1516.24 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32242 111734 ns/op 1298.98 MB/s Benchmark__FanOut_128x10x100-16 31941 112249 ns/op 1293.03 MB/s Benchmark__FanOut_128x10x100-16 31868 112677 ns/op 1288.12 MB/s Benchmark__FanOut_128x10x100-16 32042 112450 ns/op 1290.71 MB/s Benchmark__FanOut_128x10x100-16 31908 112231 ns/op 1293.23 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3912 889471 ns/op 1641.58 MB/s Benchmark_FanOut_128x10x1000-16 4096 883277 ns/op 1653.10 MB/s Benchmark_FanOut_128x10x1000-16 3919 907261 ns/op 1609.39 MB/s Benchmark_FanOut_128x10x1000-16 3696 907293 ns/op 1609.34 MB/s Benchmark_FanOut_128x10x1000-16 3912 895991 ns/op 1629.64 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3490 1022861 ns/op 1417.73 MB/s Benchmark_FanOut_128x100x100-16 3457 1022880 ns/op 1417.70 MB/s Benchmark_FanOut_128x100x100-16 3469 1026104 ns/op 1413.25 MB/s Benchmark_FanOut_128x100x100-16 3439 1023088 ns/op 1417.42 MB/s Benchmark_FanOut_128x100x100-16 3451 1023485 ns/op 1416.87 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 376 9383453 ns/op 1555.95 MB/s BenchmarkFanOut_128x100x1000-16 374 9554882 ns/op 1528.03 MB/s BenchmarkFanOut_128x100x1000-16 379 9539106 ns/op 1530.56 MB/s BenchmarkFanOut_128x100x1000-16 368 9504524 ns/op 1536.13 MB/s BenchmarkFanOut_128x100x1000-16 379 9437225 ns/op 1547.08 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 370 9754615 ns/op 1506.99 MB/s BenchmarkFanOut_128x10x10000-16 361 9690348 ns/op 1516.99 MB/s BenchmarkFanOut_128x10x10000-16 368 9789296 ns/op 1501.65 MB/s BenchmarkFanOut_128x10x10000-16 370 9756431 ns/op 1506.71 MB/s BenchmarkFanOut_128x10x10000-16 369 9891259 ns/op 1486.17 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 664 5371488 ns/op 1349.75 MB/s BenchmarkFanOut__128x500x100-16 661 5319766 ns/op 1362.87 MB/s BenchmarkFanOut__128x500x100-16 654 5376561 ns/op 1348.47 MB/s BenchmarkFanOut__128x500x100-16 672 5347106 ns/op 1355.90 MB/s BenchmarkFanOut__128x500x100-16 663 5382467 ns/op 1346.99 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1911 1860755 ns/op 2843.21 MB/s Benchmark_FanOut_512x100x100-16 1946 1857259 ns/op 2848.57 MB/s Benchmark_FanOut_512x100x100-16 1912 1861528 ns/op 2842.03 MB/s Benchmark_FanOut_512x100x100-16 1963 1852352 ns/op 2856.11 MB/s Benchmark_FanOut_512x100x100-16 1922 1869583 ns/op 2829.79 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16701479 ns/op 3173.40 MB/s Benchmark__FanOut_512x100x1k-16 217 16856025 ns/op 3144.31 MB/s Benchmark__FanOut_512x100x1k-16 211 16875853 ns/op 3140.61 MB/s Benchmark__FanOut_512x100x1k-16 216 16920486 ns/op 3132.33 MB/s Benchmark__FanOut_512x100x1k-16 211 16930611 ns/op 3130.46 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3237 1134554 ns/op 9193.96 MB/s Benchmark____FanOut_1kx10x1k-16 3232 1144111 ns/op 9117.15 MB/s Benchmark____FanOut_1kx10x1k-16 3032 1160822 ns/op 8985.90 MB/s Benchmark____FanOut_1kx10x1k-16 2956 1145461 ns/op 9106.41 MB/s Benchmark____FanOut_1kx10x1k-16 3309 1160447 ns/op 8988.81 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2784 1269244 ns/op 8210.43 MB/s Benchmark__FanOut_1kx100x100-16 2772 1269151 ns/op 8211.03 MB/s Benchmark__FanOut_1kx100x100-16 2782 1269668 ns/op 8207.69 MB/s Benchmark__FanOut_1kx100x100-16 2791 1286395 ns/op 8100.96 MB/s Benchmark__FanOut_1kx100x100-16 2696 1272002 ns/op 8192.63 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4544379 770.5 ns/op 323.16 MB/s Benchmark_____RFanOut_8x1x10-16 4548844 776.4 ns/op 320.70 MB/s Benchmark_____RFanOut_8x1x10-16 4459502 782.2 ns/op 318.33 MB/s Benchmark_____RFanOut_8x1x10-16 4450312 784.7 ns/op 317.30 MB/s Benchmark_____RFanOut_8x1x10-16 4455321 776.2 ns/op 320.81 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 501634 6260 ns/op 370.42 MB/s Benchmark____RFanOut_8x1x100-16 521288 6249 ns/op 371.11 MB/s Benchmark____RFanOut_8x1x100-16 536264 6237 ns/op 371.83 MB/s Benchmark____RFanOut_8x1x100-16 546846 6237 ns/op 371.79 MB/s Benchmark____RFanOut_8x1x100-16 541858 6331 ns/op 366.28 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47398 76501 ns/op 300.90 MB/s Benchmark___RFanOut_8x10x100-16 47505 77668 ns/op 296.38 MB/s Benchmark___RFanOut_8x10x100-16 47408 75330 ns/op 305.57 MB/s Benchmark___RFanOut_8x10x100-16 47217 75628 ns/op 304.37 MB/s Benchmark___RFanOut_8x10x100-16 47341 77192 ns/op 298.21 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5701 613521 ns/op 391.22 MB/s Benchmark__RFanOut_8x10x1000-16 5598 614924 ns/op 390.32 MB/s Benchmark__RFanOut_8x10x1000-16 5420 615420 ns/op 390.01 MB/s Benchmark__RFanOut_8x10x1000-16 5826 610554 ns/op 393.12 MB/s Benchmark__RFanOut_8x10x1000-16 5569 615567 ns/op 389.92 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4770 716929 ns/op 320.84 MB/s Benchmark__RFanOut_8x100x100-16 4840 718735 ns/op 320.03 MB/s Benchmark__RFanOut_8x100x100-16 4934 720789 ns/op 319.12 MB/s Benchmark__RFanOut_8x100x100-16 4882 715506 ns/op 321.48 MB/s Benchmark__RFanOut_8x100x100-16 4975 712708 ns/op 322.74 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 550 6420033 ns/op 373.83 MB/s Benchmark_RFanOut_8x100x1000-16 558 6275784 ns/op 382.43 MB/s Benchmark_RFanOut_8x100x1000-16 564 6299562 ns/op 380.98 MB/s Benchmark_RFanOut_8x100x1000-16 552 6449769 ns/op 372.11 MB/s Benchmark_RFanOut_8x100x1000-16 562 6322286 ns/op 379.61 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 523 7011272 ns/op 356.57 MB/s Benchmark_RFanOut_8x10x10000-16 525 6810753 ns/op 367.07 MB/s Benchmark_RFanOut_8x10x10000-16 525 7074243 ns/op 353.40 MB/s Benchmark_RFanOut_8x10x10000-16 516 6844387 ns/op 365.27 MB/s Benchmark_RFanOut_8x10x10000-16 519 6941715 ns/op 360.14 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3085 1165644 ns/op 8948.73 MB/s Benchmark_RFanOut_1kx10x1000-16 2856 1169729 ns/op 8917.48 MB/s Benchmark_RFanOut_1kx10x1000-16 3193 1174617 ns/op 8880.37 MB/s Benchmark_RFanOut_1kx10x1000-16 3057 1179852 ns/op 8840.97 MB/s Benchmark_RFanOut_1kx10x1000-16 3162 1171748 ns/op 8902.12 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7042603 507.4 ns/op 4095.55 MB/s Benchmark_____FanIn_1kx100x1-16 6902445 503.8 ns/op 4124.93 MB/s Benchmark_____FanIn_1kx100x1-16 6920252 504.4 ns/op 4120.05 MB/s Benchmark_____FanIn_1kx100x1-16 6976508 505.2 ns/op 4113.00 MB/s Benchmark_____FanIn_1kx100x1-16 6919489 506.0 ns/op 4106.72 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2648178 1371 ns/op 5995.63 MB/s Benchmark_____FanIn_4kx100x1-16 2629340 1352 ns/op 6080.84 MB/s Benchmark_____FanIn_4kx100x1-16 2626856 1356 ns/op 6065.60 MB/s Benchmark_____FanIn_4kx100x1-16 2619686 1361 ns/op 6042.60 MB/s Benchmark_____FanIn_4kx100x1-16 2584327 1371 ns/op 5995.50 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1719279 2117 ns/op 7754.72 MB/s Benchmark_____FanIn_8kx100x1-16 1702911 2122 ns/op 7735.45 MB/s Benchmark_____FanIn_8kx100x1-16 1697091 2142 ns/op 7664.55 MB/s Benchmark_____FanIn_8kx100x1-16 1689099 2103 ns/op 7806.09 MB/s Benchmark_____FanIn_8kx100x1-16 1677280 2115 ns/op 7760.94 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 869122 4195 ns/op 7818.13 MB/s Benchmark____FanIn_16kx100x1-16 865785 4200 ns/op 7808.92 MB/s Benchmark____FanIn_16kx100x1-16 870754 4199 ns/op 7812.04 MB/s Benchmark____FanIn_16kx100x1-16 869518 4129 ns/op 7944.61 MB/s Benchmark____FanIn_16kx100x1-16 869272 4189 ns/op 7829.84 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3624163158 vs 11058791100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45696->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45876->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45274->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 174094 20004 ns/op 6553.90 MB/s Benchmark____FanIn_64kx100x1-16 167517 19940 ns/op 6574.88 MB/s Benchmark____FanIn_64kx100x1-16 169615 19874 ns/op 6596.83 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 9860613366 vs 11524217400 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33526->127.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:33680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33468->127.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:33118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33806->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark___FanIn_128kx100x1 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33358->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: 429057570 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35142->127.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:35264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34998->127.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:35494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35322->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:35164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35814->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: 1043869670 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37228->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: 247235740 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39150->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: 1027483420 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40690->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: 638670480 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42608->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42866->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5586445 637.5 ns/op 445.52 MB/s Benchmark___BumpPubCount_1x3-16 5530801 643.0 ns/op 441.71 MB/s Benchmark___BumpPubCount_1x3-16 5566503 638.4 ns/op 444.84 MB/s Benchmark___BumpPubCount_1x3-16 5571370 644.9 ns/op 440.39 MB/s Benchmark___BumpPubCount_1x3-16 5519844 641.0 ns/op 443.03 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5288455 678.5 ns/op 418.59 MB/s Benchmark___BumpPubCount_2x3-16 5226632 685.2 ns/op 414.46 MB/s Benchmark___BumpPubCount_2x3-16 5297325 681.9 ns/op 416.46 MB/s Benchmark___BumpPubCount_2x3-16 5298618 680.5 ns/op 417.37 MB/s Benchmark___BumpPubCount_2x3-16 5302413 676.4 ns/op 419.88 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5514129 651.9 ns/op 435.65 MB/s Benchmark___BumpPubCount_5x3-16 5238723 647.6 ns/op 438.52 MB/s Benchmark___BumpPubCount_5x3-16 5487470 651.1 ns/op 436.18 MB/s Benchmark___BumpPubCount_5x3-16 5524068 654.2 ns/op 434.13 MB/s Benchmark___BumpPubCount_5x3-16 5470172 649.0 ns/op 437.62 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5491269 653.2 ns/op 434.81 MB/s Benchmark__BumpPubCount_10x3-16 5533794 651.0 ns/op 436.27 MB/s Benchmark__BumpPubCount_10x3-16 5512968 651.4 ns/op 436.00 MB/s Benchmark__BumpPubCount_10x3-16 5516715 651.2 ns/op 436.11 MB/s Benchmark__BumpPubCount_10x3-16 5519004 651.8 ns/op 435.70 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12710446 278.6 ns/op 3732.91 MB/s Benchmark____GWs_Opt_1kx01x0-16 12469756 262.8 ns/op 3956.88 MB/s Benchmark____GWs_Opt_1kx01x0-16 12980290 267.6 ns/op 3886.26 MB/s Benchmark____GWs_Opt_1kx01x0-16 13048120 271.1 ns/op 3835.77 MB/s Benchmark____GWs_Opt_1kx01x0-16 12265086 277.1 ns/op 3752.66 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10809572 345.1 ns/op 5981.12 MB/s Benchmark____GWs_Opt_2kx01x0-16 10725517 347.8 ns/op 5935.01 MB/s Benchmark____GWs_Opt_2kx01x0-16 9896564 341.2 ns/op 6048.99 MB/s Benchmark____GWs_Opt_2kx01x0-16 10906538 341.3 ns/op 6048.15 MB/s Benchmark____GWs_Opt_2kx01x0-16 10693594 332.6 ns/op 6205.82 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5825346 625.9 ns/op 6569.78 MB/s Benchmark____GWs_Opt_4kx01x0-16 5360128 636.7 ns/op 6458.33 MB/s Benchmark____GWs_Opt_4kx01x0-16 4874166 628.5 ns/op 6542.76 MB/s Benchmark____GWs_Opt_4kx01x0-16 5716322 637.8 ns/op 6447.06 MB/s Benchmark____GWs_Opt_4kx01x0-16 5717536 635.6 ns/op 6469.63 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27952803 109.3 ns/op 9513.93 MB/s Benchmark____GWs_Opt_1kx10x0-16 32355600 108.5 ns/op 9588.74 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:37222->127.0.0.1:42187: use of closed network connection --- FAIL: Benchmark____GWs_Opt_1kx10x0-16 Benchmark____GWs_Opt_1kx10x0-16 23692857 136.8 ns/op 7604.36 MB/s Benchmark____GWs_Opt_1kx10x0-16 31201100 110.3 ns/op 9425.94 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 22958973 155.0 ns/op 13317.31 MB/s Benchmark____GWs_Opt_2kx10x0-16 25427593 141.2 ns/op 14621.81 MB/s Benchmark____GWs_Opt_2kx10x0-16 19058533 178.6 ns/op 11554.58 MB/s Benchmark____GWs_Opt_2kx10x0-16 24038138 146.7 ns/op 14071.58 MB/s Benchmark____GWs_Opt_2kx10x0-16 26357179 150.8 ns/op 13691.04 MB/s Benchmark____GWs_Opt_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:41928->127.0.0.1:44433: 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:35274->127.0.0.1:40483: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12785180 304.4 ns/op 13506.86 MB/s Benchmark____GWs_Opt_4kx10x0-16 13285598 305.2 ns/op 13475.19 MB/s Benchmark____GWs_Opt_4kx10x0-16 11871076 350.0 ns/op 11749.59 MB/s Benchmark____GWs_Opt_4kx10x0-16 12886687 310.3 ns/op 13249.98 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6382856 557.4 ns/op 5606.73 MB/s Benchmark____GWs_Opt_1kx01x1-16 6753706 556.4 ns/op 5616.62 MB/s Benchmark____GWs_Opt_1kx01x1-16 6322755 555.5 ns/op 5625.07 MB/s Benchmark____GWs_Opt_1kx01x1-16 6216999 555.1 ns/op 5629.69 MB/s Benchmark____GWs_Opt_1kx01x1-16 6286671 553.4 ns/op 5646.51 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4559332 771.6 ns/op 8030.96 MB/s Benchmark____GWs_Opt_2kx01x1-16 4565446 763.2 ns/op 8120.20 MB/s Benchmark____GWs_Opt_2kx01x1-16 4557259 760.8 ns/op 8145.83 MB/s Benchmark____GWs_Opt_2kx01x1-16 4464822 760.8 ns/op 8145.23 MB/s Benchmark____GWs_Opt_2kx01x1-16 4615102 760.9 ns/op 8144.81 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2293723 1530 ns/op 8064.68 MB/s Benchmark____GWs_Opt_4kx01x1-16 2623383 1826 ns/op 6757.04 MB/s Benchmark____GWs_Opt_4kx01x1-16 2588683 1370 ns/op 9009.56 MB/s Benchmark____GWs_Opt_4kx01x1-16 2616277 1385 ns/op 8911.55 MB/s Benchmark____GWs_Opt_4kx01x1-16 2679284 1383 ns/op 8924.21 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6143894 563.0 ns/op 5550.43 MB/s Benchmark____GWs_Opt_1kx10x1-16 6208018 557.1 ns/op 5608.91 MB/s Benchmark____GWs_Opt_1kx10x1-16 6155408 562.6 ns/op 5554.75 MB/s Benchmark____GWs_Opt_1kx10x1-16 6632209 554.4 ns/op 5637.08 MB/s Benchmark____GWs_Opt_1kx10x1-16 6143808 554.8 ns/op 5632.99 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4714551 854.5 ns/op 7251.87 MB/s Benchmark____GWs_Opt_2kx10x1-16 4009668 831.4 ns/op 7453.52 MB/s Benchmark____GWs_Opt_2kx10x1-16 4066120 843.4 ns/op 7347.66 MB/s Benchmark____GWs_Opt_2kx10x1-16 4143216 852.2 ns/op 7271.88 MB/s Benchmark____GWs_Opt_2kx10x1-16 4119090 850.5 ns/op 7286.20 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2425006 1542 ns/op 8002.73 MB/s Benchmark____GWs_Opt_4kx10x1-16 2414276 1655 ns/op 7456.77 MB/s Benchmark____GWs_Opt_4kx10x1-16 2315570 1527 ns/op 8082.46 MB/s Benchmark____GWs_Opt_4kx10x1-16 2348953 1528 ns/op 8079.11 MB/s Benchmark____GWs_Opt_4kx10x1-16 2338299 1600 ns/op 7712.12 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12295790 285.0 ns/op 3649.11 MB/s Benchmark____GWs_Int_1kx01x0-16 12700262 295.2 ns/op 3522.81 MB/s Benchmark____GWs_Int_1kx01x0-16 11345852 282.0 ns/op 3687.54 MB/s Benchmark____GWs_Int_1kx01x0-16 12986072 278.7 ns/op 3731.25 MB/s Benchmark____GWs_Int_1kx01x0-16 12514130 281.9 ns/op 3689.01 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10316278 369.2 ns/op 5591.19 MB/s Benchmark____GWs_Int_2kx01x0-16 10109386 354.0 ns/op 5831.18 MB/s Benchmark____GWs_Int_2kx01x0-16 9950365 365.7 ns/op 5643.23 MB/s Benchmark____GWs_Int_2kx01x0-16 10710595 337.4 ns/op 6116.90 MB/s Benchmark____GWs_Int_2kx01x0-16 10889926 350.6 ns/op 5886.99 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5794670 651.0 ns/op 6316.74 MB/s Benchmark____GWs_Int_4kx01x0-16 5737371 644.1 ns/op 6384.52 MB/s Benchmark____GWs_Int_4kx01x0-16 5838578 641.7 ns/op 6408.43 MB/s Benchmark____GWs_Int_4kx01x0-16 5521626 644.3 ns/op 6382.08 MB/s Benchmark____GWs_Int_4kx01x0-16 5742504 626.7 ns/op 6560.89 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31781880 114.8 ns/op 9057.89 MB/s Benchmark____GWs_Int_1kx10x0-16 31553498 116.2 ns/op 8947.36 MB/s Benchmark____GWs_Int_1kx10x0-16 31139182 115.1 ns/op 9033.64 MB/s Benchmark____GWs_Int_1kx10x0-16 32683695 116.2 ns/op 8946.32 MB/s Benchmark____GWs_Int_1kx10x0-16 31603546 114.7 ns/op 9066.01 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24664215 154.9 ns/op 13328.08 MB/s Benchmark____GWs_Int_2kx10x0-16 24991626 150.3 ns/op 13734.10 MB/s Benchmark____GWs_Int_2kx10x0-16 21812618 145.1 ns/op 14219.79 MB/s Benchmark____GWs_Int_2kx10x0-16 24933964 139.6 ns/op 14784.63 MB/s Benchmark____GWs_Int_2kx10x0-16 24821732 138.9 ns/op 14860.43 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13133571 293.8 ns/op 13995.20 MB/s Benchmark____GWs_Int_4kx10x0-16 12250406 323.1 ns/op 12726.77 MB/s Benchmark____GWs_Int_4kx10x0-16 11906854 319.0 ns/op 12889.61 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:57520->127.0.0.1:40239: 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:57102->127.0.0.1:34165: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12834670 352.1 ns/op 11679.90 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6418590 561.2 ns/op 5568.38 MB/s Benchmark____GWs_Int_1kx01x1-16 6518493 566.6 ns/op 5514.89 MB/s Benchmark____GWs_Int_1kx01x1-16 6125628 555.9 ns/op 5621.36 MB/s Benchmark____GWs_Int_1kx01x1-16 6289059 555.8 ns/op 5622.46 MB/s Benchmark____GWs_Int_1kx01x1-16 6108936 557.0 ns/op 5610.39 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4791000 852.2 ns/op 7271.84 MB/s Benchmark____GWs_Int_2kx01x1-16 4641684 781.5 ns/op 7930.12 MB/s Benchmark____GWs_Int_2kx01x1-16 4655011 770.5 ns/op 8043.04 MB/s Benchmark____GWs_Int_2kx01x1-16 4660875 780.8 ns/op 7936.43 MB/s Benchmark____GWs_Int_2kx01x1-16 4605332 773.2 ns/op 8014.71 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2620358 1369 ns/op 9015.69 MB/s Benchmark____GWs_Int_4kx01x1-16 2628093 1510 ns/op 8173.07 MB/s Benchmark____GWs_Int_4kx01x1-16 2274716 1585 ns/op 7786.90 MB/s Benchmark____GWs_Int_4kx01x1-16 2544862 1377 ns/op 8959.88 MB/s Benchmark____GWs_Int_4kx01x1-16 2606226 1371 ns/op 8998.50 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6696518 553.1 ns/op 5650.37 MB/s Benchmark____GWs_Int_1kx10x1-16 6263862 555.3 ns/op 5627.46 MB/s Benchmark____GWs_Int_1kx10x1-16 6244040 566.5 ns/op 5516.80 MB/s Benchmark____GWs_Int_1kx10x1-16 6169400 564.1 ns/op 5539.71 MB/s Benchmark____GWs_Int_1kx10x1-16 6547723 562.0 ns/op 5560.01 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4043137 851.8 ns/op 7275.10 MB/s Benchmark____GWs_Int_2kx10x1-16 3858050 839.4 ns/op 7382.45 MB/s Benchmark____GWs_Int_2kx10x1-16 4238350 866.0 ns/op 7155.94 MB/s Benchmark____GWs_Int_2kx10x1-16 4084652 851.5 ns/op 7278.03 MB/s Benchmark____GWs_Int_2kx10x1-16 4137810 909.2 ns/op 6815.90 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2362878 1518 ns/op 8128.19 MB/s Benchmark____GWs_Int_4kx10x1-16 2209774 1526 ns/op 8086.84 MB/s Benchmark____GWs_Int_4kx10x1-16 2351746 1961 ns/op 6294.51 MB/s Benchmark____GWs_Int_4kx10x1-16 2346534 1499 ns/op 8231.06 MB/s Benchmark____GWs_Int_4kx10x1-16 2315281 1528 ns/op 8076.80 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8253410 444.7 ns/op 229.36 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8129545 436.6 ns/op 233.60 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7865110 436.0 ns/op 233.94 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8449842 433.3 ns/op 235.40 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7975642 431.6 ns/op 236.33 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 624446 5048 ns/op 35.06 MB/s Benchmark__GWs_Reqs_1SubEach-16 783714 5266 ns/op 33.61 MB/s Benchmark__GWs_Reqs_1SubEach-16 737610 5267 ns/op 33.61 MB/s Benchmark__GWs_Reqs_1SubEach-16 764815 5352 ns/op 33.07 MB/s Benchmark__GWs_Reqs_1SubEach-16 718626 5238 ns/op 33.79 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2145.005s