| giolekva | 892a4e2 | 2020-04-27 16:46:22 +0400 | [diff] [blame^] | 1 | package chunk |
| 2 | |
| 3 | import ( |
| 4 | "bytes" |
| 5 | "testing" |
| 6 | ) |
| 7 | |
| 8 | func TestConcurrentReads(t *testing.T) { |
| 9 | c := InMemoryChunkFactory{}.New(4) |
| 10 | if _, err := c.WriterAt().WriteAt([]byte("abcd"), 0); err != nil { |
| 11 | panic(err) |
| 12 | } |
| 13 | d1 := make([]byte, 2) |
| 14 | d2 := make([]byte, 3) |
| 15 | if _, err := c.ReaderAt().ReadAt(d1, 0); err != nil { |
| 16 | t.Error(err) |
| 17 | } |
| 18 | if bytes.Compare(d1, []byte("ab")) != 0 { |
| 19 | t.Errorf("Expected: %s\nActual: %s", "ab", d1) |
| 20 | } |
| 21 | if _, err := c.ReaderAt().ReadAt(d2, 0); err != nil { |
| 22 | t.Error(err) |
| 23 | } |
| 24 | if bytes.Compare(d2, []byte("abc")) != 0 { |
| 25 | t.Errorf("Expected: %s\nActual: %s", "abc", d2) |
| 26 | } |
| 27 | } |