139 lines
4.8 KiB
Java
139 lines
4.8 KiB
Java
/*
|
|
* Copyright (c) 2009, 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 java.net.NetworkInterface;
|
|
import java.net.InetSocketAddress;
|
|
import java.net.SocketAddress;
|
|
import java.net.InetAddress;
|
|
import java.net.Inet4Address;
|
|
import java.net.SocketException;
|
|
import java.io.IOException;
|
|
import java.io.PrintStream;
|
|
import java.io.UnsupportedEncodingException;
|
|
import java.util.List;
|
|
import java.util.ArrayList;
|
|
import java.util.Set;
|
|
import java.util.Collections;
|
|
import java.util.Enumeration;
|
|
import java.util.Iterator;
|
|
import java.nio.ByteBuffer;
|
|
import com.sun.nio.sctp.SctpChannel;
|
|
import static java.lang.System.out;
|
|
|
|
public class Util {
|
|
static final int SMALL_BUFFER = 128;
|
|
static final String SMALL_MESSAGE =
|
|
"Under the bridge and over the dam, looking for berries, berries for jam";
|
|
|
|
static final int LARGE_BUFFER = 32768;
|
|
static final String LARGE_MESSAGE;
|
|
|
|
static {
|
|
StringBuffer sb = new StringBuffer(LARGE_BUFFER);
|
|
for (int i=0; i<460; i++)
|
|
sb.append(SMALL_MESSAGE);
|
|
|
|
LARGE_MESSAGE = sb.toString();
|
|
}
|
|
|
|
static boolean isSCTPSupported() {
|
|
try {
|
|
SctpChannel c = SctpChannel.open();
|
|
c.close();
|
|
return true;
|
|
} catch (IOException ioe) {
|
|
ioe.printStackTrace();
|
|
} catch (UnsupportedOperationException e) {
|
|
out.println(e);
|
|
}
|
|
|
|
return false;
|
|
}
|
|
/**
|
|
* Returns a list of all the addresses on the system.
|
|
* @param inclLoopback
|
|
* if {@code true}, include the loopback addresses
|
|
* @param ipv4Only
|
|
* it {@code true}, only IPv4 addresses will be included
|
|
*/
|
|
static List<InetAddress> getAddresses(boolean inclLoopback,
|
|
boolean ipv4Only)
|
|
throws SocketException {
|
|
ArrayList<InetAddress> list = new ArrayList<InetAddress>();
|
|
Enumeration<NetworkInterface> nets =
|
|
NetworkInterface.getNetworkInterfaces();
|
|
for (NetworkInterface netInf : Collections.list(nets)) {
|
|
Enumeration<InetAddress> addrs = netInf.getInetAddresses();
|
|
for (InetAddress addr : Collections.list(addrs)) {
|
|
if (!list.contains(addr) &&
|
|
(inclLoopback ? true : !addr.isLoopbackAddress()) &&
|
|
(ipv4Only ? (addr instanceof Inet4Address) : true)) {
|
|
list.add(addr);
|
|
}
|
|
}
|
|
}
|
|
|
|
return list;
|
|
}
|
|
|
|
static void dumpAddresses(SctpChannel channel,
|
|
PrintStream printStream)
|
|
throws IOException {
|
|
Set<SocketAddress> addrs = channel.getAllLocalAddresses();
|
|
printStream.println("Local Addresses: ");
|
|
for (Iterator<SocketAddress> it = addrs.iterator(); it.hasNext(); ) {
|
|
InetSocketAddress addr = (InetSocketAddress)it.next();
|
|
printStream.println("\t" + addr);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Compare the contents of the given ByteBuffer with the contens of the
|
|
* given byte array. true if, and only if, the contents are the same.
|
|
*/
|
|
static boolean compare(ByteBuffer bb, byte[] message) {
|
|
if (message.length != bb.remaining()) {
|
|
out.println("Compare failed, byte array length != to buffer remaining");
|
|
return false;
|
|
}
|
|
|
|
for (int i=0; i<message.length; i++) {
|
|
byte b = bb.get();
|
|
if (message[i] != b) {
|
|
out.println("Position " + i + ": " + message[i] + " != " + b);
|
|
return false;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
static boolean compare(ByteBuffer bb, String str) {
|
|
try{
|
|
return Util.compare(bb, str.getBytes("ISO-8859-1"));
|
|
} catch (UnsupportedEncodingException unsupported) {
|
|
throw new AssertionError(unsupported);
|
|
}
|
|
}
|
|
}
|