FrameBuffer.cs 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. using System;
  2. using System.Collections.Generic;
  3. using System.IO;
  4. namespace ET
  5. {
  6. public class FrameBuffer
  7. {
  8. public int PredictionFrame { get; set; } = -1;
  9. public int RealFrame { get; set; } = -1;
  10. private const int TotalFrameCount = 128;
  11. private readonly List<OneFrameMessages> messageBuffer = new(TotalFrameCount);
  12. private readonly List<MemoryBuffer> dataBuffer = new(TotalFrameCount);
  13. public FrameBuffer()
  14. {
  15. for (int i = 0; i < this.dataBuffer.Capacity; ++i)
  16. {
  17. this.messageBuffer.Add(new OneFrameMessages());
  18. this.dataBuffer.Add(new MemoryBuffer(10240));
  19. }
  20. }
  21. public OneFrameMessages GetFrame(int frame)
  22. {
  23. if (frame < 0)
  24. {
  25. return null;
  26. }
  27. OneFrameMessages oneFrameMessages = this.messageBuffer[frame % TotalFrameCount];
  28. return oneFrameMessages;
  29. }
  30. public LSWorld GetLSWorld(int frame)
  31. {
  32. MemoryBuffer memoryBuffer = this.dataBuffer[frame % TotalFrameCount];
  33. return MongoHelper.Deserialize(typeof (LSWorld), memoryBuffer) as LSWorld;
  34. }
  35. public void SaveLSWorld(int frame, LSWorld lsWorld)
  36. {
  37. MemoryBuffer memoryBuffer = this.dataBuffer[frame % TotalFrameCount];
  38. memoryBuffer.Seek(0, SeekOrigin.Begin);
  39. memoryBuffer.SetLength(0);
  40. MongoHelper.Serialize(lsWorld, memoryBuffer);
  41. memoryBuffer.Seek(0, SeekOrigin.Begin);
  42. }
  43. }
  44. }