[C#] Added more string read/write methods to the DirectBuffer #729 (#845

) * [C#] Add more string reading/writing methods to DirectBuffer More, hopefully efficient, mechanisms to read and write strings to and from the DirectBuffer. * [C#] Reverted to .net45 * [C#] Reverted to .net45 * [C#] Updated Samples to use the new String methods * [C#] Fixed checkstyle * [C#] Cleaning * Added Modified Benchmarks\nBoth a modified version of the the CarBenchmark which encodes and decodes to/from string; and a version wich uses the new methods to encode and decode strings Co-authored-by: Rob Purdy <[email protected]>
aeron-io · May 25, 2021 · 7690fae · 7690fae
1 parent 11cda3a
commit 7690fae
Show file tree

Hide file tree

Showing 7 changed files with 754 additions and 25 deletions.
diff --git a/csharp/sbe-benchmarks/Bench/SBE/CarBenchmark_with_strings_new.cs b/csharp/sbe-benchmarks/Bench/SBE/CarBenchmark_with_strings_new.cs
@@ -0,0 +1,193 @@
+using System.Text;
+using Baseline;
+using BenchmarkDotNet.Attributes;
+using BenchmarkDotNet.Diagnosers;
+using Org.SbeTool.Sbe.Dll;
+
+namespace Org.SbeTool.Sbe.Benchmarks.Bench.Benchmarks
+{
+    [MemoryDiagnoser]
+    public class CarBenchmark_with_strings_new
+    {
+
+        private readonly byte[] _eBuffer = new byte[1024];
+        private readonly byte[] _dBuffer = new byte[1024];
+        private DirectBuffer _encodeBuffer;
+        private DirectBuffer _decodeBuffer;
+        private readonly Car _car = new Car();
+        private readonly MessageHeader _messageHeader = new MessageHeader();
+
+        [GlobalSetup]
+        public void Setup()
+        {
+            _encodeBuffer = new DirectBuffer(_eBuffer);
+            _decodeBuffer = new DirectBuffer(_dBuffer);
+            Encode(_car, _decodeBuffer, 0);
+        }
+
+        [Benchmark]
+        public int Encode()
+        {
+            return Encode(_car, _encodeBuffer, 0);
+        }
+
+        [Benchmark]
+        public int Decode()
+        {
+            return Decode(_car, _decodeBuffer, 0);
+        }
+
+        public int Encode(Car car, DirectBuffer directBuffer, int bufferOffset)
+        {
+            _car.WrapForEncodeAndApplyHeader(directBuffer, bufferOffset, _messageHeader);
+
+            const int srcOffset = 0;
+
+            car.SerialNumber = 1234;
+            car.ModelYear = 2013;
+            car.Available = BooleanType.T;
+            car.Code = Baseline.Model.A;
+            car.SetVehicleCode("CODE12");
+
+            for (int i = 0, size = Car.SomeNumbersLength; i < size; i++)
+            {
+                car.SetSomeNumbers(i, (uint)i);
+            }
+
+            car.Extras = OptionalExtras.CruiseControl | OptionalExtras.SportsPack;
+            car.Engine.Capacity = 2000;
+            car.Engine.NumCylinders = 4;
+            car.Engine.SetManufacturerCode("123");
+            car.Engine.Efficiency = 35;
+            car.Engine.BoosterEnabled = BooleanType.T;
+            car.Engine.Booster.BoostType = BoostType.NITROUS;
+            car.Engine.Booster.HorsePower = 200;
+
+            var fuelFigures = car.FuelFiguresCount(3);
+            fuelFigures.Next();
+            fuelFigures.Speed = 30;
+            fuelFigures.Mpg = 35.9f;
+            fuelFigures.SetUsageDescription("Urban Cycle");
+
+            fuelFigures.Next();
+            fuelFigures.Speed = 55;
+            fuelFigures.Mpg = 49.0f;
+            fuelFigures.SetUsageDescription("Combined Cycle");
+
+            fuelFigures.Next();
+            fuelFigures.Speed = 75;
+            fuelFigures.Mpg = 40.0f;
+            fuelFigures.SetUsageDescription("Highway Cycle");
+
+            Car.PerformanceFiguresGroup perfFigures = car.PerformanceFiguresCount(2);
+            perfFigures.Next();
+            perfFigures.OctaneRating = 95;
+
+            Car.PerformanceFiguresGroup.AccelerationGroup acceleration = perfFigures.AccelerationCount(3).Next();
+            acceleration.Mph = 30;
+            acceleration.Seconds = 4.0f;
+
+            acceleration.Next();
+            acceleration.Mph = 60;
+            acceleration.Seconds = 7.5f;
+
+            acceleration.Next();
+            acceleration.Mph = 100;
+            acceleration.Seconds = 12.2f;
+
+            perfFigures.Next();
+            perfFigures.OctaneRating = 99;
+            acceleration = perfFigures.AccelerationCount(3).Next();
+
+            acceleration.Mph = 30;
+            acceleration.Seconds = 3.8f;
+
+            acceleration.Next();
+            acceleration.Mph = 60;
+            acceleration.Seconds = 7.1f;
+
+            acceleration.Next();
+            acceleration.Mph = 100;
+            acceleration.Seconds = 11.8f;
+
+            car.SetManufacturer("Honda");
+            car.SetModel("Civic VTi");
+            car.SetActivationCode("code");
+
+            return car.Size;
+        }
+
+        private readonly byte[] _buffer = new byte[128];
+
+        public int Decode(Car car, DirectBuffer directBuffer, int bufferOffset)
+        {
+            _messageHeader.Wrap(directBuffer, bufferOffset, 0);
+
+            car.WrapForDecode(directBuffer, bufferOffset + MessageHeader.Size, _messageHeader.BlockLength, _messageHeader.Version);
+
+            var templateId = Car.TemplateId;
+            var schemaVersion = Car.SchemaVersion;
+            var serialNumber = car.SerialNumber;
+            var modelYear = car.ModelYear;
+            var available = car.Available;
+            var code = car.Code;
+
+            for (int i = 0, size = Car.SomeNumbersLength; i < size; i++)
+            {
+                var number = car.GetSomeNumbers(i);
+            }
+
+            var vehicleCode = car.GetVehicleCode();
+
+            OptionalExtras extras = car.Extras;
+            var cruiseControl = (extras & OptionalExtras.CruiseControl) == OptionalExtras.CruiseControl;
+            var sportsPack = (extras & OptionalExtras.SportsPack) == OptionalExtras.SportsPack;
+            var sunRoof = (extras & OptionalExtras.SunRoof) == OptionalExtras.SunRoof;
+
+            Engine engine = car.Engine;
+            var capacity = engine.Capacity;
+            var numCylinders = engine.NumCylinders;
+            var maxRpm = engine.MaxRpm;
+            for (int i = 0, size = Engine.ManufacturerCodeLength; i < size; i++)
+            {
+                engine.GetManufacturerCode(i);
+            }
+
+            var length = engine.GetFuel(_buffer, 0, _buffer.Length);
+
+            var efficiency = engine.Efficiency;
+            var boosterEnabled = engine.BoosterEnabled;
+            var boostType = engine.Booster.BoostType;
+            var horsePower = engine.Booster.HorsePower;
+
+            var fuelFiguresGroup = car.FuelFigures;
+            while (fuelFiguresGroup.HasNext)
+            {
+                var fuelFigures = fuelFiguresGroup.Next();
+                var speed = fuelFigures.Speed;
+                var mpg = fuelFigures.Mpg;
+                var usage = fuelFigures.GetUsageDescription();
+            }
+
+            var performanceFiguresGroup = car.PerformanceFigures;
+            while (performanceFiguresGroup.HasNext)
+            {
+                performanceFiguresGroup.Next();
+                var octanceRating = performanceFiguresGroup.OctaneRating;
+
+                var accelerationGroup = performanceFiguresGroup.Acceleration;
+                for (int i = 0; i < accelerationGroup.Count; i++)
+                {
+                    var acceleration = accelerationGroup.Next();
+                    var mpg = acceleration.Mph;
+                    var seconds = acceleration.Seconds;
+                }
+            }
+
+            var man = car.GetManufacturer();
+            var model = car.GetModel();
+            var actCode = car.GetActivationCode();
+            return car.Size;
+        }
+    }
+}