| Methods Summary |
|---|
| public void | disable_testConnectWithIP4IPAddr()Regression test for 1062928: Dotted IP addresses (e.g., 192.168.100.1)
appear to be broken in the M5 SDK.
Tests that a connection given a ip-addressv4 such as 192.168.100.100 does
not fail - sdk m5 seems only to accept dns names instead of ip numbers.
ip 209.85.129.147 (one address of www.google.com) on port 80 (http) is
used to test the connection.
// call a Google Web server
InetSocketAddress scktAddrss = new InetSocketAddress(KNOW_GOOD_ADDRESS,
80);
Socket clntSckt = new Socket();
try {
clntSckt.connect(scktAddrss, 5000);
} catch (Throwable e) {
fail("connection problem:" + e.getClass().getName() + ": "
+ e.getMessage());
} finally {
try {
clntSckt.close();
} catch (Exception e) {
// ignore
}
}
|
| public void | disable_testSocketConnectClose()
try {
client = new Socket();
new Thread() {
@Override
public void run() {
try {
client.connect(new InetSocketAddress(PACKAGE_DROPPING_ADDRESS, 1357));
} catch (Exception ex) {
error = ex;
}
connected = true;
}
}.start();
Thread.sleep(1000);
Assert.assertNull("Connect must not fail immediately. Maybe try different address.", error);
Assert.assertFalse("Connect must not succeed. Maybe try different address.", connected);
client.close();
Thread.sleep(1000);
if (error == null) {
fail("Socket connect still ongoing");
} else if (!(error instanceof SocketException)) {
fail("Socket connect interrupted with wrong error: " + error.toString());
}
} catch (Exception ex) {
throw new RuntimeException(ex);
}
|
| public void | testNativeSocketChannelOpen()
SocketChannel.open();
|
| public void | testServerSocketClose()
ServerSocket s3 = new ServerSocket(23456);
s3.close();
ServerSocket s4 = new ServerSocket(23456);
s4.close();
|
| public void | testSetReuseAddress()
InetSocketAddress addr = new InetSocketAddress(8383);
final ServerSocket serverSock = new ServerSocket();
serverSock.setReuseAddress(true);
serverSock.bind(addr);
final Semaphore semThreadEnd = new Semaphore(0);
new Thread() {
@Override
public void run() {
try {
Socket sock = serverSock.accept();
sock.getInputStream().read();
sock.close();
} catch (IOException e) {
serverError = e;
}
semThreadEnd.release();
}
}.start();
// Give the server a bit of time for startup
try {
Thread.sleep(2000);
} catch (InterruptedException ex) {
// Ignored.
}
Socket client = new Socket("localhost", 8383);
client.getOutputStream().write(1);
// Just leave this connection open from the client side. It will be
// closed from the server side so the server stays in the TIME_WAIT
// state for a while. setReuseAddress() should be able to handle this.
try {
semThreadEnd.acquire();
} catch (InterruptedException e) {
// ignore
}
serverSock.close();
ServerSocket serverSock2 = new ServerSocket();
serverSock2.setReuseAddress(true);
serverSock2.bind(addr);
serverSock2.close();
if (serverError != null) {
throw new RuntimeException("Server must complete without error", serverError);
}
|
| public void | testSocketSimple()
// Test for basic bind/connect/accept behavior.
ServerSocket ss;
Socket s, s1;
int port;
IOException lastEx = null;
ss = new ServerSocket();
for (port = 9900; port < 9999; port++) {
try {
ss.bind(new InetSocketAddress("127.0.0.1", port));
lastEx = null;
break;
} catch (IOException ex) {
lastEx = ex;
}
}
if (lastEx != null) {
throw lastEx;
}
s = new Socket("127.0.0.1", port);
s1 = ss.accept();
s.getOutputStream().write(0xa5);
assertEquals(0xa5, s1.getInputStream().read());
s1.getOutputStream().write(0x5a);
assertEquals(0x5a, s.getInputStream().read());
|
| public void | testTimeoutException()
ServerSocket s = new ServerSocket(9800);
s.setSoTimeout(2000);
try {
s.accept();
} catch (SocketTimeoutException e) {
// this is ok.
}
|
| public void | testWildcardAddress()
Socket s2 = new Socket();
s2.bind(new InetSocketAddress((InetAddress) null, 12345));
byte[] addr = s2.getLocalAddress().getAddress();
for (int i = 0; i < 4; i++) {
assertEquals("Not the wildcard address", 0, addr[i]);
}
|
