(t *testing.T)
| 78 | } |
| 79 | |
| 80 | func TestLimiter_TryAck2(t *testing.T) { |
| 81 | if !testutils.IsSingleTesting() { |
| 82 | return |
| 83 | } |
| 84 | |
| 85 | var a = assert.NewAssertion(t) |
| 86 | |
| 87 | { |
| 88 | var limiter = fsutils.NewLimiter(4) |
| 89 | var count = limiter.FreeThreads() |
| 90 | a.IsTrue(count == 4) |
| 91 | for i := 0; i < count-1; i++ { |
| 92 | limiter.Ack() |
| 93 | } |
| 94 | a.IsTrue(limiter.FreeThreads() == 1) |
| 95 | a.IsTrue(limiter.TryAck()) |
| 96 | a.IsFalse(limiter.TryAck()) |
| 97 | a.IsFalse(limiter.TryAck()) |
| 98 | |
| 99 | limiter.Release() |
| 100 | a.IsTrue(limiter.TryAck()) |
| 101 | } |
| 102 | } |
| 103 | |
| 104 | func TestLimiter_Timout(t *testing.T) { |
| 105 | var timeout = time.NewTimer(100 * time.Millisecond) |
nothing calls this directly
no test coverage detected