FrameBuffer.cs 1.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  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; }
  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. oneFrameMessages.Frame = frame;
  29. return oneFrameMessages;
  30. }
  31. public LSWorld GetLSWorld(int frame)
  32. {
  33. MemoryBuffer memoryBuffer = this.dataBuffer[frame % TotalFrameCount];
  34. return MongoHelper.Deserialize(typeof (LSWorld), memoryBuffer) as LSWorld;
  35. }
  36. public void SaveLSWorld(int frame, LSWorld lsWorld)
  37. {
  38. MemoryBuffer memoryBuffer = this.dataBuffer[frame % TotalFrameCount];
  39. memoryBuffer.Seek(0, SeekOrigin.Begin);
  40. memoryBuffer.SetLength(0);
  41. MongoHelper.Serialize(lsWorld, memoryBuffer);
  42. memoryBuffer.Seek(0, SeekOrigin.Begin);
  43. }
  44. }
  45. }