1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
|
Author: Andreas Tille <tille@debian.org>
Last-Update: 2024-12-16
Bug-Debian: https://bugs.debian.org/842836
Description: Remove flaky test
--- a/flowrate/io_test.go
+++ b/flowrate/io_test.go
@@ -98,49 +99,3 @@ func TestReader(t *testing.T) {
t.Errorf("r.Read() input doesn't match output")
}
}
-
-func TestWriter(t *testing.T) {
- b := make([]byte, 100)
- for i := range b {
- b[i] = byte(i)
- }
- w := NewWriter(&bytes.Buffer{}, 200)
- start := time.Now()
-
- // Make sure w implements Limiter
- _ = Limiter(w)
-
- // Non-blocking 20-byte write for the first sample returns ErrLimit
- w.SetBlocking(false)
- if n, err := w.Write(b); n != 20 || err != ErrLimit {
- t.Fatalf("w.Write(b) expected 20 (ErrLimit); got %v (%v)", n, err)
- } else if rt := time.Since(start); rt > _50ms {
- t.Fatalf("w.Write(b) took too long (%v)", rt)
- }
-
- // Blocking 80-byte write
- w.SetBlocking(true)
- if n, err := w.Write(b[20:]); n != 80 || err != nil {
- t.Fatalf("w.Write(b[20:]) expected 80 (<nil>); got %v (%v)", n, err)
- } else if rt := time.Since(start); rt < _400ms {
- t.Fatalf("w.Write(b[20:]) returned ahead of time (%v)", rt)
- }
-
- w.SetTransferSize(100)
- status := []Status{w.Status(), nextStatus(w.Monitor)}
- start = status[0].Start
-
- // Active, Start, Duration, Idle, Bytes, Samples, InstRate, CurRate, AvgRate, PeakRate, BytesRem, TimeRem, Progress
- want := []Status{
- Status{true, start, _400ms, 0, 80, 4, 200, 200, 200, 200, 20, _100ms, 80000},
- Status{true, start, _500ms, _100ms, 100, 5, 200, 200, 200, 200, 0, 0, 100000},
- }
- for i, s := range status {
- if !reflect.DeepEqual(&s, &want[i]) {
- t.Errorf("w.Status(%v) expected %v; got %v", i, want[i], s)
- }
- }
- if !bytes.Equal(b, w.Writer.(*bytes.Buffer).Bytes()) {
- t.Errorf("w.Write() input doesn't match output")
- }
-}
|
