DtlsReassembler.cs 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122
  1. #if !BESTHTTP_DISABLE_ALTERNATE_SSL && (!UNITY_WEBGL || UNITY_EDITOR)
  2. #pragma warning disable
  3. using System;
  4. using System.Collections.Generic;
  5. namespace Best.HTTP.SecureProtocol.Org.BouncyCastle.Tls
  6. {
  7. internal sealed class DtlsReassembler
  8. {
  9. private readonly short m_msg_type;
  10. private readonly byte[] m_body;
  11. private readonly List<Range> m_missing = new List<Range>();
  12. internal DtlsReassembler(short msg_type, int length)
  13. {
  14. this.m_msg_type = msg_type;
  15. this.m_body = new byte[length];
  16. this.m_missing.Add(new Range(0, length));
  17. }
  18. internal short MsgType
  19. {
  20. get { return m_msg_type; }
  21. }
  22. internal byte[] GetBodyIfComplete()
  23. {
  24. return m_missing.Count > 0 ? null : m_body;
  25. }
  26. internal void ContributeFragment(short msg_type, int length, byte[] buf, int off, int fragment_offset,
  27. int fragment_length)
  28. {
  29. int fragment_end = fragment_offset + fragment_length;
  30. if (m_msg_type != msg_type || m_body.Length != length || fragment_end > length)
  31. return;
  32. if (fragment_length == 0)
  33. {
  34. // NOTE: Empty messages still require an empty fragment to complete it
  35. if (fragment_offset == 0 && m_missing.Count > 0)
  36. {
  37. Range firstRange = (Range)m_missing[0];
  38. if (firstRange.End == 0)
  39. {
  40. m_missing.RemoveAt(0);
  41. }
  42. }
  43. return;
  44. }
  45. for (int i = 0; i < m_missing.Count; ++i)
  46. {
  47. Range range = (Range)m_missing[i];
  48. if (range.Start >= fragment_end)
  49. break;
  50. if (range.End > fragment_offset)
  51. {
  52. int copyStart = System.Math.Max(range.Start, fragment_offset);
  53. int copyEnd = System.Math.Min(range.End, fragment_end);
  54. int copyLength = copyEnd - copyStart;
  55. Array.Copy(buf, off + copyStart - fragment_offset, m_body, copyStart, copyLength);
  56. if (copyStart == range.Start)
  57. {
  58. if (copyEnd == range.End)
  59. {
  60. m_missing.RemoveAt(i--);
  61. }
  62. else
  63. {
  64. range.Start = copyEnd;
  65. }
  66. }
  67. else
  68. {
  69. if (copyEnd != range.End)
  70. {
  71. m_missing.Insert(++i, new Range(copyEnd, range.End));
  72. }
  73. range.End = copyStart;
  74. }
  75. }
  76. }
  77. }
  78. internal void Reset()
  79. {
  80. m_missing.Clear();
  81. m_missing.Add(new Range(0, m_body.Length));
  82. }
  83. private sealed class Range
  84. {
  85. private int m_start, m_end;
  86. internal Range(int start, int end)
  87. {
  88. this.m_start = start;
  89. this.m_end = end;
  90. }
  91. public int Start
  92. {
  93. get { return m_start; }
  94. set { this.m_start = value; }
  95. }
  96. public int End
  97. {
  98. get { return m_end; }
  99. set { this.m_end = value; }
  100. }
  101. }
  102. }
  103. }
  104. #pragma warning restore
  105. #endif