1561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes/* 2561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * Licensed to the Apache Software Foundation (ASF) under one or more 3561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * contributor license agreements. See the NOTICE file distributed with 4561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * this work for additional information regarding copyright ownership. 5561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * The ASF licenses this file to You under the Apache License, Version 2.0 6561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * (the "License"); you may not use this file except in compliance with 7561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * the License. You may obtain a copy of the License at 8561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * 9561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * http://www.apache.org/licenses/LICENSE-2.0 10561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * 11561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * Unless required by applicable law or agreed to in writing, software 12561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * distributed under the License is distributed on an "AS IS" BASIS, 13561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 14561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * See the License for the specific language governing permissions and 15561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * limitations under the License. 16561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes */ 17561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 18561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughespackage org.apache.harmony.luni.tests.java.net; 19561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 20561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughesimport java.io.IOException; 21561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughesimport java.io.InputStream; 22561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughesimport java.io.OutputStream; 23561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughesimport java.net.ConnectException; 24561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughesimport java.net.InetAddress; 25561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughesimport java.net.InetSocketAddress; 26561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughesimport java.net.ServerSocket; 27561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughesimport java.net.Socket; 28561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughesimport java.net.SocketException; 29561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 30561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughesimport junit.framework.TestCase; 31561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 32561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughespublic class UnixSocketTest extends TestCase { 33561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 34561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes /** 35561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes * @tests java.net.Socket#getInputStream() 36561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes */ 37561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes public void test_getInputStream() throws IOException { 38561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // Simple read/write test over the IO streams 39561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes final ServerSocket pingServer = new ServerSocket(0); 40561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes Socket pingClient = new Socket(); 41561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 42561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes try { 43561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes pingClient.connect(new InetSocketAddress( 44561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes InetAddress.getLocalHost(), pingServer.getLocalPort())); 45561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 46561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes Socket worker = pingServer.accept(); 47561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes pingServer.close(); 48561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 49561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // Write some data to the server to provoke it 50561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes OutputStream clientOut = pingClient.getOutputStream(); 51561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes clientOut.write(new byte[256]); 52561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes InputStream in = worker.getInputStream(); 53561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes in.read(); 54561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 55561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes OutputStream out = worker.getOutputStream(); 56561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes out.write(new byte[42]); 57561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes worker.close(); 58561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes InputStream clientIn = pingClient.getInputStream(); 59561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes clientIn.read(new byte[42]); 60561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 61561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes try { 62561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes clientIn.read(); 63561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes fail("Should throw SocketException"); 64561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } catch (SocketException e) { 65561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // expected 66561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } 67561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes clientIn.close(); 68561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 69561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes try { 70561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes clientIn.read(); 71561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes fail("Should throw SocketException"); 72561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } catch (SocketException e) { 73561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // expected 74561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } 75561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes try { 76561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes clientIn.read(new byte[5]); 77561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes fail("Should throw SocketException"); 78561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } catch (SocketException e) { 79561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // expected 80561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } 81561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } finally { 82561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes pingClient.close(); 83561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes pingServer.close(); 84561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } 85561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } 86561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 87561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes public void test_connectLjava_net_SocketAddressI() throws Exception { 88561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // Now validate that we get a interrupted exception if we try to connect 89561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // to an address on which nobody is accepting connections and the 90561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // timeout expired 91561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes Socket theSocket = new Socket(); 92561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes try { 93561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes theSocket.connect(new InetSocketAddress(InetAddress.getLocalHost(), 94561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 1), 200); 95561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes fail("No interrupted exception when connecting to address nobody listening on with short timeout 200"); 96561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } catch (ConnectException e) { 97561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // Expected 98561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } 99561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes theSocket.close(); 100561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } 101561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 102561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes public void test_getOutputStream() throws Exception { 103561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // Regression test for HARMONY-2934 104561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // Port 0 is not allowed to be used in connect() on some platforms, 105561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // get a free port here 106561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes ServerSocket ss = new ServerSocket(0); 107561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes int port = ss.getLocalPort(); 108561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes ss.close(); 109561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes 110561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes Socket socket = new Socket("127.0.0.1", port, false); 111561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes OutputStream o = socket.getOutputStream(); 112561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes try { 113561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes o.write(1); 114561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } catch (SocketException e) { 115561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes // expected 116561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } finally { 117561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes socket.close(); 118561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } 119561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes } 120561ee011997c6c2f1befbfaa9d5f0a99771c1d63Elliott Hughes} 121