Timeout.cs 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  1. #if !BESTHTTP_DISABLE_ALTERNATE_SSL && (!UNITY_WEBGL || UNITY_EDITOR)
  2. #pragma warning disable
  3. using System;
  4. using BestHTTP.SecureProtocol.Org.BouncyCastle.Utilities.Date;
  5. namespace BestHTTP.SecureProtocol.Org.BouncyCastle.Tls
  6. {
  7. internal class Timeout
  8. {
  9. private long durationMillis;
  10. private long startMillis;
  11. internal Timeout(long durationMillis)
  12. : this(durationMillis, DateTimeUtilities.CurrentUnixMs())
  13. {
  14. }
  15. internal Timeout(long durationMillis, long currentTimeMillis)
  16. {
  17. this.durationMillis = System.Math.Max(0, durationMillis);
  18. this.startMillis = System.Math.Max(0, currentTimeMillis);
  19. }
  20. //internal long RemainingMillis()
  21. //{
  22. // return RemainingMillis(DateTimeUtilities.CurrentUnixMs());
  23. //}
  24. internal long RemainingMillis(long currentTimeMillis)
  25. {
  26. lock (this)
  27. {
  28. // If clock jumped backwards, reset start time
  29. if (startMillis > currentTimeMillis)
  30. {
  31. startMillis = currentTimeMillis;
  32. return durationMillis;
  33. }
  34. long elapsed = currentTimeMillis - startMillis;
  35. long remaining = durationMillis - elapsed;
  36. // Once timeout reached, lock it in
  37. if (remaining <= 0)
  38. return durationMillis = 0L;
  39. return remaining;
  40. }
  41. }
  42. //internal static int ConstrainWaitMillis(int waitMillis, Timeout timeout)
  43. //{
  44. // return constrainWaitMillis(waitMillis, timeout, DateTimeUtilities.CurrentUnixMs());
  45. //}
  46. internal static int ConstrainWaitMillis(int waitMillis, Timeout timeout, long currentTimeMillis)
  47. {
  48. if (waitMillis < 0)
  49. return -1;
  50. int timeoutMillis = GetWaitMillis(timeout, currentTimeMillis);
  51. if (timeoutMillis < 0)
  52. return -1;
  53. if (waitMillis == 0)
  54. return timeoutMillis;
  55. if (timeoutMillis == 0)
  56. return waitMillis;
  57. return System.Math.Min(waitMillis, timeoutMillis);
  58. }
  59. internal static Timeout ForWaitMillis(int waitMillis)
  60. {
  61. return ForWaitMillis(waitMillis, DateTimeUtilities.CurrentUnixMs());
  62. }
  63. internal static Timeout ForWaitMillis(int waitMillis, long currentTimeMillis)
  64. {
  65. if (waitMillis < 0)
  66. throw new ArgumentException("cannot be negative", "waitMillis");
  67. if (waitMillis > 0)
  68. return new Timeout(waitMillis, currentTimeMillis);
  69. return null;
  70. }
  71. //internal static int GetWaitMillis(Timeout timeout)
  72. //{
  73. // return GetWaitMillis(timeout, DateTimeUtilities.CurrentUnixMs());
  74. //}
  75. internal static int GetWaitMillis(Timeout timeout, long currentTimeMillis)
  76. {
  77. if (null == timeout)
  78. return 0;
  79. long remainingMillis = timeout.RemainingMillis(currentTimeMillis);
  80. if (remainingMillis < 1L)
  81. return -1;
  82. if (remainingMillis > int.MaxValue)
  83. return int.MaxValue;
  84. return (int)remainingMillis;
  85. }
  86. internal static bool HasExpired(Timeout timeout)
  87. {
  88. return HasExpired(timeout, DateTimeUtilities.CurrentUnixMs());
  89. }
  90. internal static bool HasExpired(Timeout timeout, long currentTimeMillis)
  91. {
  92. return null != timeout && timeout.RemainingMillis(currentTimeMillis) < 1L;
  93. }
  94. }
  95. }
  96. #pragma warning restore
  97. #endif