...
Source file
src/crypto/rand/rand_batched_test.go
1
2
3
4
5
6
7 package rand
8
9 import (
10 "bytes"
11 "errors"
12 prand "math/rand"
13 "testing"
14 )
15
16 func TestBatched(t *testing.T) {
17 fillBatched := batched(func(p []byte) error {
18 for i := range p {
19 p[i] = byte(i)
20 }
21 return nil
22 }, 5)
23
24 p := make([]byte, 13)
25 if err := fillBatched(p); err != nil {
26 t.Fatalf("batched function returned error: %s", err)
27 }
28 expected := []byte{0, 1, 2, 3, 4, 0, 1, 2, 3, 4, 0, 1, 2}
29 if !bytes.Equal(expected, p) {
30 t.Errorf("incorrect batch result: got %x, want %x", p, expected)
31 }
32 }
33
34 func TestBatchedBuffering(t *testing.T) {
35 backingStore := make([]byte, 1<<23)
36 prand.Read(backingStore)
37 backingMarker := backingStore[:]
38 output := make([]byte, len(backingStore))
39 outputMarker := output[:]
40
41 fillBatched := batched(func(p []byte) error {
42 n := copy(p, backingMarker)
43 backingMarker = backingMarker[n:]
44 return nil
45 }, 731)
46
47 for len(outputMarker) > 0 {
48 max := 9200
49 if max > len(outputMarker) {
50 max = len(outputMarker)
51 }
52 howMuch := prand.Intn(max + 1)
53 if err := fillBatched(outputMarker[:howMuch]); err != nil {
54 t.Fatalf("batched function returned error: %s", err)
55 }
56 outputMarker = outputMarker[howMuch:]
57 }
58 if !bytes.Equal(backingStore, output) {
59 t.Error("incorrect batch result")
60 }
61 }
62
63 func TestBatchedError(t *testing.T) {
64 b := batched(func(p []byte) error { return errors.New("failure") }, 5)
65 if b(make([]byte, 13)) == nil {
66 t.Fatal("batched function should have returned an error")
67 }
68 }
69
70 func TestBatchedEmpty(t *testing.T) {
71 b := batched(func(p []byte) error { return errors.New("failure") }, 5)
72 if b(make([]byte, 0)) != nil {
73 t.Fatal("empty slice should always return successful")
74 }
75 }
76
View as plain text