File: STest.java

package info (click to toggle)
openjdk-11 11.0.22%2B7-2
  • links: PTS, VCS
  • area: main
  • in suites: sid
  • size: 781,236 kB
  • sloc: java: 5,174,754; xml: 1,192,262; cpp: 1,133,036; ansic: 461,316; javascript: 162,554; sh: 16,859; objc: 13,683; python: 4,753; asm: 3,570; makefile: 2,894; perl: 357; awk: 351; sed: 172; jsp: 24; csh: 3
file content (119 lines) | stat: -rw-r--r-- 3,766 bytes parent folder | download | duplicates (5)
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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
/*
 * Copyright (c) 2019, Oracle and/or its affiliates. All rights reserved.
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
 *
 * This code is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License version 2 only, as
 * published by the Free Software Foundation.
 *
 * This code is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
 * version 2 for more details (a copy is included in the LICENSE file that
 * accompanied this code).
 *
 * You should have received a copy of the GNU General Public License version
 * 2 along with this work; if not, write to the Free Software Foundation,
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
 *
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
 * or visit www.oracle.com if you need additional information or have any
 * questions.
 */

import org.testng.annotations.DataProvider;
import org.testng.annotations.Test;

import java.io.IOException;
import java.io.InputStream;
import java.nio.ByteBuffer;
import java.util.Arrays;
import java.util.List;

import static org.testng.Assert.assertEquals;
import static org.testng.Assert.assertTrue;

public class STest {

    @DataProvider(name = "bufferSizes")
    public static Object[][] bufferSizes() {
        return new Object[][]{
                { 1},
                { 2},
                { 3},
                { 4},
                {16},
                {17},
        };
    }

    @DataProvider
    public static Object[][] inputStream() {
        return new Object[][] {
                {  0,   1},
                {  1,   2},
                {  1,   3},
                {  1,   4},
                {  2,   1},
                {  2,   2},
                {  2,   3},
                {  2,   4},
                {  2,  13},
                {  3,   1},
                {  3,   2},
                {  3,   3},
                {  3,   4},
                {  3,  17},
                {  4,   1},
                {  4,   2},
                {  4,   3},
                {  4,   4},
                {  4,   5},
                { 13,   1},
                { 13,   2},
                { 13,  13},
                { 16,  18},
                { 17,   2},
                {255,   1},
                {256, 255},
                {257, 267},
        };
    }

    @Test
    public void testScatter0() {
        List<ByteBuffer> buffers = S.scatterBuffer(
                ByteBuffer.allocate(0));
        assertEquals(buffers.size(), 0);
    }

    @Test(dataProvider = "bufferSizes")
    public void testScatterN(int n) {
        final ByteBuffer src = S.bufferOfNRandomBytes(n);
        final int srcLength = src.remaining();
        ByteBuffer copy = ByteBuffer.wrap(Arrays.copyOf(src.array(),
                                                        src.array().length));
        List<ByteBuffer> buffers = S.scatterBuffer(src);
        int m = 0;
        for (ByteBuffer b : buffers) {
            m += b.remaining();
            while (b.hasRemaining() & copy.hasRemaining()) {
                assertEquals(b.get(), copy.get());
            }
        }
        assertEquals(m, srcLength);
    }

    @Test(dataProvider = "inputStream")
    public void testInputStreamOfNReads(int n, int capacity) throws IOException {
        InputStream s = S.inputStreamOfNReads(n);
        int count = 0;
        byte[] b = new byte[capacity];
        while (s.read(b) != -1) {
            count++;
        }
        assertEquals(count, n);
        assertTrue(s.read() == -1);
        assertTrue(s.read(b) == -1);
    }
}