| | | 1 | | using System; |
| | | 2 | | |
| | | 3 | | namespace KernelCommunication |
| | | 4 | | { |
| | | 5 | | public class ByteArrayReader : IBinaryReader |
| | | 6 | | { |
| | | 7 | | private readonly byte[] bytes; |
| | | 8 | | private int currentOffset; |
| | | 9 | | |
| | 3 | 10 | | public ByteArrayReader(byte[] bytes) |
| | | 11 | | { |
| | 3 | 12 | | this.bytes = bytes; |
| | 3 | 13 | | currentOffset = 0; |
| | 3 | 14 | | } |
| | | 15 | | |
| | 0 | 16 | | int IBinaryReader.offset => currentOffset; |
| | | 17 | | |
| | 0 | 18 | | bool IBinaryReader.CanRead() => currentOffset < bytes.Length; |
| | | 19 | | |
| | | 20 | | unsafe int IBinaryReader.ReadInt32() |
| | | 21 | | { |
| | 6 | 22 | | int ofs = currentOffset; |
| | 6 | 23 | | currentOffset += 4; |
| | | 24 | | |
| | 6 | 25 | | if (bytes == null) |
| | 0 | 26 | | throw new NullReferenceException("bytes array == null"); |
| | 6 | 27 | | if ((long)(uint)ofs >= (long)bytes.Length) |
| | 0 | 28 | | throw new IndexOutOfRangeException("offset is bigger than bytes array lenght"); |
| | 6 | 29 | | if (ofs > bytes.Length - 4) |
| | 0 | 30 | | throw new IndexOutOfRangeException("bytes.Length is not large enough to contain a valid Int32"); |
| | | 31 | | |
| | 6 | 32 | | fixed (byte* numPtr = &bytes[ofs]) |
| | | 33 | | { |
| | 6 | 34 | | return ByteUtils.PointerToInt32(numPtr); |
| | | 35 | | } |
| | | 36 | | } |
| | | 37 | | |
| | | 38 | | unsafe long IBinaryReader.ReadInt64() |
| | | 39 | | { |
| | 0 | 40 | | int ofs = currentOffset; |
| | 0 | 41 | | currentOffset += 8; |
| | | 42 | | |
| | 0 | 43 | | if (bytes == null) |
| | 0 | 44 | | throw new NullReferenceException("bytes array == null"); |
| | 0 | 45 | | if ((long)(uint)ofs >= (long)bytes.Length) |
| | 0 | 46 | | throw new IndexOutOfRangeException("offset is bigger than bytes array lenght"); |
| | 0 | 47 | | if (ofs > bytes.Length - 8) |
| | 0 | 48 | | throw new IndexOutOfRangeException("bytes.Length is not large enough to contain a valid Int64"); |
| | | 49 | | |
| | 0 | 50 | | fixed (byte* numPtr = &bytes[ofs]) |
| | | 51 | | { |
| | 0 | 52 | | return ByteUtils.PointerToInt64(numPtr); |
| | | 53 | | } |
| | | 54 | | } |
| | | 55 | | |
| | | 56 | | byte[] IBinaryReader.ReadBytes(int length) |
| | | 57 | | { |
| | 0 | 58 | | int ofs = currentOffset; |
| | 0 | 59 | | currentOffset += length; |
| | 0 | 60 | | byte[] data = new byte[length]; |
| | 0 | 61 | | Buffer.BlockCopy(bytes, ofs, data, 0, length); |
| | 0 | 62 | | return data; |
| | | 63 | | } |
| | | 64 | | |
| | | 65 | | void IBinaryReader.Skip(int bytesCount) |
| | | 66 | | { |
| | 0 | 67 | | currentOffset += bytesCount; |
| | 0 | 68 | | } |
| | | 69 | | } |
| | | 70 | | } |