channels/SocketChannel/VectorParams.java

0N/A/*
5501N/A * Copyright (c) 2003, 2012, Oracle and/or its affiliates. All rights reserved.
0N/A * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
0N/A *
0N/A * This code is free software; you can redistribute it and/or modify it
0N/A * under the terms of the GNU General Public License version 2 only, as
0N/A * published by the Free Software Foundation.
0N/A *
0N/A * This code is distributed in the hope that it will be useful, but WITHOUT
0N/A * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
0N/A * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
0N/A * version 2 for more details (a copy is included in the LICENSE file that
0N/A * accompanied this code).
0N/A *
0N/A * You should have received a copy of the GNU General Public License version
0N/A * 2 along with this work; if not, write to the Free Software Foundation,
0N/A * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
0N/A *
2362N/A * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
2362N/A * or visit www.oracle.com if you need additional information or have any
2362N/A * questions.
0N/A */
0N/A
0N/A/* @test
0N/A * @bug 4865031
0N/A * @summary Test ScatteringByteChannel/GatheringByteChannel read/write
0N/A * @library ..
0N/A */
0N/A
5501N/Aimport java.io.*;
0N/Aimport java.net.*;
0N/Aimport java.nio.*;
0N/Aimport java.nio.channels.*;
0N/A
0N/Apublic class VectorParams {
0N/A
0N/A    static java.io.PrintStream out = System.out;
0N/A
0N/A    static final int testSize = 10;
0N/A    static ByteBuffer[] bufs = null;
0N/A    static InetSocketAddress isa = null;
0N/A
0N/A    public static void main(String[] args) throws Exception {
5501N/A        try (TestServers.DayTimeServer daytimeServer
5501N/A                = TestServers.DayTimeServer.startNewServer(100)) {
5501N/A            initBufs(daytimeServer);
5501N/A            testSocketChannelVectorParams();
5501N/A            testDatagramChannelVectorParams();
5501N/A            testPipeVectorParams();
5501N/A            testFileVectorParams();
5501N/A        }
0N/A    }
0N/A
5501N/A    static void initBufs(TestServers.DayTimeServer daytimeServer) throws Exception {
0N/A        bufs = new ByteBuffer[testSize];
0N/A        for(int i=0; i<testSize; i++) {
0N/A            String source = "buffer" + i;
0N/A            bufs[i] = ByteBuffer.allocate(source.length());
0N/A            bufs[i].put(source.getBytes("8859_1"));
0N/A            bufs[i].flip();
0N/A        }
5501N/A        isa = new InetSocketAddress(daytimeServer.getAddress(),
5501N/A                                    daytimeServer.getPort());
0N/A    }
0N/A
0N/A    static void testSocketChannelVectorParams() throws Exception {
0N/A        SocketChannel sc = SocketChannel.open(isa);
0N/A        tryBadWrite(sc, bufs, 0, -1);
0N/A        tryBadWrite(sc, bufs, -1, 0);
0N/A        tryBadWrite(sc, bufs, 0, 1000);
0N/A        tryBadWrite(sc, bufs, 1000, 1);
0N/A        tryBadRead(sc, bufs, 0, -1);
0N/A        tryBadRead(sc, bufs, -1, 0);
0N/A        tryBadRead(sc, bufs, 0, 1000);
0N/A        tryBadRead(sc, bufs, 1000, 1);
0N/A        sc.close();
0N/A    }
0N/A
0N/A    static void testDatagramChannelVectorParams() throws Exception {
0N/A        DatagramChannel dc = DatagramChannel.open();
0N/A        dc.connect(isa);
0N/A        tryBadRead(dc, bufs, 0, -1);
0N/A        tryBadRead(dc, bufs, -1, 0);
0N/A        tryBadRead(dc, bufs, 0, 1000);
0N/A        tryBadRead(dc, bufs, 1000, 1);
0N/A        tryBadWrite(dc, bufs, 0, -1);
0N/A        tryBadWrite(dc, bufs, -1, 0);
0N/A        tryBadWrite(dc, bufs, 0, 1000);
0N/A        tryBadWrite(dc, bufs, 1000, 1);
0N/A        dc.close();
0N/A    }
0N/A
0N/A    static void testPipeVectorParams() throws Exception {
0N/A        Pipe p = Pipe.open();
0N/A        Pipe.SinkChannel sink = p.sink();
0N/A        Pipe.SourceChannel source = p.source();
0N/A        tryBadWrite(sink, bufs, 0, -1);
0N/A        tryBadWrite(sink, bufs, -1, 0);
0N/A        tryBadWrite(sink, bufs, 0, 1000);
0N/A        tryBadWrite(sink, bufs, 1000, 1);
0N/A        tryBadRead(source, bufs, 0, -1);
0N/A        tryBadRead(source, bufs, -1, 0);
0N/A        tryBadRead(source, bufs, 0, 1000);
0N/A        tryBadRead(source, bufs, 1000, 1);
0N/A        sink.close();
0N/A        source.close();
0N/A    }
0N/A
0N/A    static void testFileVectorParams() throws Exception {
0N/A        File testFile = File.createTempFile("filevec", null);
0N/A        testFile.deleteOnExit();
0N/A        RandomAccessFile raf = new RandomAccessFile(testFile, "rw");
0N/A        FileChannel fc = raf.getChannel();
0N/A        tryBadWrite(fc, bufs, 0, -1);
0N/A        tryBadWrite(fc, bufs, -1, 0);
0N/A        tryBadWrite(fc, bufs, 0, 1000);
0N/A        tryBadWrite(fc, bufs, 1000, 1);
0N/A        tryBadRead(fc, bufs, 0, -1);
0N/A        tryBadRead(fc, bufs, -1, 0);
0N/A        tryBadRead(fc, bufs, 0, 1000);
0N/A        tryBadRead(fc, bufs, 1000, 1);
0N/A        fc.close();
0N/A    }
0N/A
0N/A    private static void tryBadWrite(GatheringByteChannel gbc,
0N/A                                    ByteBuffer[] bufs, int offset, int len)
0N/A        throws Exception
0N/A    {
0N/A        try {
0N/A            gbc.write(bufs, offset, len);
0N/A            throw new RuntimeException("Expected exception not thrown");
0N/A        } catch (IndexOutOfBoundsException ioobe) {
0N/A            // Correct result
0N/A        }
0N/A    }
0N/A
0N/A    private static void tryBadRead(ScatteringByteChannel sbc,
0N/A                                   ByteBuffer[] bufs, int offset, int len)
0N/A        throws Exception
0N/A    {
0N/A        try {
0N/A            sbc.read(bufs, offset, len);
0N/A            throw new RuntimeException("Expected exception not thrown");
0N/A        } catch (IndexOutOfBoundsException ioobe) {
0N/A            // Correct result
0N/A        }
0N/A    }
0N/A
0N/A}