/openjdk7/jdk/src/windows/classes/java/net/ |
H A D | TwoStacksPlainSocketImpl.java | 103 * Binds the socket to the specified address of the specified local port. 105 * @param port the port 136 void socketBind(InetAddress address, int port) throws IOException { argument 137 socketBind(address, port, exclusiveBind); 221 native void socketConnect(InetAddress address, int port, int timeout) argument 224 native void socketBind(InetAddress address, int port, boolean exclBind) argument
|
/openjdk7/jdk/src/windows/classes/sun/nio/ch/ |
H A D | Iocp.java | 43 * completion port. 57 // handle to completion port 58 private final long port; field in class:Iocp 60 // true if port has been closed 72 this.port = 84 * associated with a completion port. 107 close0(port); 184 postQueuedCompletionStatus(port, 0); 228 // associate with I/O completion port 230 createIoCompletionPort(handle, port, ke [all...] |
/openjdk7/jdk/src/windows/classes/sun/nio/fs/ |
H A D | WindowsWatchService.java | 46 // background thread to service I/O completion port 50 * Creates an I/O completion port and a daemon thread to service it 53 // create I/O completion port 54 long port = 0L; 56 port = CreateIoCompletionPort(INVALID_HANDLE_VALUE, 0, 0); 61 this.poller = new Poller(fs, this, port); 242 * Background thread to service I/O completion port. 275 private final long port; field in class:WindowsWatchService.Poller 286 Poller(WindowsFileSystem fs, WindowsWatchService watcher, long port) { argument 289 this.port [all...] |
/openjdk7/jdk/src/windows/native/java/net/ |
H A D | DualStackPlainDatagramSocketImpl.c | 32 * This function "purges" all outstanding ICMP port unreachable packets 48 * Peek at the queue to see if there is an ICMP port unreachable. If there 116 (JNIEnv *env, jclass clazz, jint fd, jobject iaObj, jint port, jboolean exclBind) { 121 if (NET_InetAddressToSockaddr(env, iaObj, port, (struct sockaddr *)&sa, 141 (JNIEnv *env, jclass clazz, jint fd, jobject iaObj, jint port) { 148 if (NET_InetAddressToSockaddr(env, iaObj, port, (struct sockaddr *)&sa, 220 int port; local 227 iaObj = NET_SockaddrToInetAddress(env, (struct sockaddr *)&sa, &port); 241 int port, rv, flags=0; local 306 /* An icmp port unreachabl 115 Java_java_net_DualStackPlainDatagramSocketImpl_socketBind(JNIEnv *env, jclass clazz, jint fd, jobject iaObj, jint port, jboolean exclBind) argument 140 Java_java_net_DualStackPlainDatagramSocketImpl_socketConnect(JNIEnv *env, jclass clazz, jint fd, jobject iaObj, jint port) argument 401 Java_java_net_DualStackPlainDatagramSocketImpl_socketSend(JNIEnv *env, jclass clazz, jint fd, jbyteArray data, jint offset, jint length, jobject iaObj, jint port, jboolean connected) argument [all...] |
H A D | DualStackPlainSocketImpl.c | 85 (JNIEnv *env, jclass clazz, jint fd, jobject iaObj, jint port, 92 if (NET_InetAddressToSockaddr(env, iaObj, port, (struct sockaddr *)&sa, 109 (JNIEnv *env, jclass clazz, jint fd, jobject iaObj, jint port) { 114 if (NET_InetAddressToSockaddr(env, iaObj, port, (struct sockaddr *)&sa, 126 "connect: Address is invalid on local machine, or port is not valid on remote machine"); 236 int port; local 247 iaObj = NET_SockaddrToInetAddress(env, (struct sockaddr *)&sa, &port); 276 int newfd, port=0; local 296 ia = NET_SockaddrToInetAddress(env, (struct sockaddr *)&sa, &port); 297 isa = (*env)->NewObject(env, isa_class, isa_ctorID, ia, port); 84 Java_java_net_DualStackPlainSocketImpl_bind0(JNIEnv *env, jclass clazz, jint fd, jobject iaObj, jint port, jboolean exclBind) argument 108 Java_java_net_DualStackPlainSocketImpl_connect0(JNIEnv *env, jclass clazz, jint fd, jobject iaObj, jint port) argument [all...] |
/openjdk7/jdk/test/java/net/Socket/ |
H A D | SocketImplTest.java | 52 protected void bind(InetAddress host, int port){ argument 58 protected void connect(InetAddress address, int port){ argument 61 protected void connect(String host, int port){ argument
|
/openjdk7/jdk/test/java/net/Socks/ |
H A D | SocksServer.java | 57 private int port; field in class:SocksServer 199 int port = ((in.read() & 0xff) << 8); 200 port += (in.read() & 0xff); 211 dest = new Socket(addr, port); 229 out.write((port >> 8) & 0xff); 230 out.write(port & 0xff); 406 int port = 0; 447 port = ((in.read()&0xff) << 8); 448 port += (in.read()&0xff); 450 InetSocketAddress socAddr = new InetSocketAddress(addr, port); 488 SocksServer(int port, boolean v4) argument 493 SocksServer(int port) argument [all...] |
/openjdk7/jdk/test/java/net/URL/ |
H A D | Test.java | 105 static Test test(String protocol, String host, int port, String file) { argument 106 return new Test(protocol, host, port, file); 108 private Test(String protocol, String host, int port, String file) { argument 111 url = new URL(protocol, host, port, file); 139 // n port Number 289 show("port", "" + u.getPort()); 304 if ((failed & PORT) != 0) sb.append(" port");
|
/openjdk7/jdk/test/java/nio/channels/Selector/ |
H A D | SelectorTest.java | 48 * java SelectorTest [server] [client <host>] [<port>] 51 * using the default port of 31452. 66 = new InetSocketAddress(InetAddress.getLocalHost(), server.port()); 102 System.out.println("java SelectorTest [server] [client <host>] [<port>]"); 103 System.out.println("No arguments runs both client and server in separate threads using the default port of 31452."); 146 Server(int port) throws IOException { argument 148 this.ssc = ServerSocketChannel.open().bind(new InetSocketAddress(port)); 151 int port() { method in class:SelectorTest.Server
|
/openjdk7/jdk/test/java/nio/channels/ |
H A D | TestServers.java | 40 * An abstract server identifies a server which listens on a port on on a 57 * other servers are started afterwards, the address/port might get reused 59 * connections using this address/port will always be refused. Connections 60 * will be refused as long as the address/port of the refusing server has 66 final int port; field in class:TestServers.RefusingServer 68 private RefusingServer(InetAddress address, int port) { argument 70 this.port = port; 75 return port; 121 * The local port t 169 newServerSocket(int port, int backlog, InetAddress address) argument 549 newDatagramSocket(int port, InetAddress address) argument [all...] |
/openjdk7/jdk/test/sun/security/ssl/sanity/pluggability/ |
H A D | MySSLSocketFacImpl.java | 52 public Socket createSocket(Socket s, String host, int port, argument 54 public Socket createSocket(InetAddress host, int port) { argument 57 public Socket createSocket(InetAddress address, int port, argument 61 public Socket createSocket(String host, int port) { argument 64 public Socket createSocket(String host, int port, InetAddress argument
|
/openjdk7/jdk/src/share/native/java/net/ |
H A D | net_util.c | 140 NET_SockaddrToInetAddress(JNIEnv *env, struct sockaddr *him, int *port) { argument 192 *port = ntohs(him6->sin6_port); 210 *port = ntohs(him4->sin_port);
|
/openjdk7/jdk/src/share/classes/sun/security/krb5/ |
H A D | KdcComm.java | 214 String tempKdc = null; // may include the port number also 260 int port = Krb5.KDC_INET_DEFAULT_PORT; 284 if (pos != tempKdc.length() - 1) { // with port number 296 if (nextColon > 0) { // >=2 ":", IPv6 with no port 298 } else { // 1 ":", hostname or IPv4 with port 307 port = tempPort; 313 + port + ", timeout=" 321 new KdcCommunication(kdc, port, useTCP, timeout, retries, obuf); 343 private int port; field in class:KdcComm.KdcCommunication 349 public KdcCommunication(String kdc, int port, boolea argument [all...] |
/openjdk7/jdk/test/java/rmi/reliability/benchmark/bench/rmi/ |
H A D | Main.java | 104 static int port; field in class:Main 134 p.println(" -client <host:port> run benchmark client using server " + 135 "on specified host/port"); 136 p.println(" -server <port> run benchmark server on given port"); 246 die("Error: -client missing host/port"); 250 port = Integer.parseInt(args[i].substring(sepi + 1)); 252 die("Error: illegal host/port specified for -client"); 261 die("Error: -server missing port"); 263 port [all...] |
/openjdk7/jdk/test/java/rmi/testlibrary/ |
H A D | TestLibrary.java | 72 * RMI tests are run concurrently and port conflicts result when a single 73 * port number is used by multiple tests. When needing a port, use 75 * be used, reserve and specify a port to use for your test here. This 76 * will ensure there are no port conflicts amongst the RMI tests. The 77 * port numbers specified here may also be specified in the respective 78 * tests. Do not change the reserved port numbers here without also 79 * changing the port numbers in the respective tests. 82 * createRegistryOnUnusedPort wherever possible to prevent port conflicts. 84 * Reserved port rang 440 isReservedPort(int port) argument [all...] |
/openjdk7/jdk/test/sun/management/jmxremote/bootstrap/ |
H A D | RmiBootstrapTest.java | 56 * <p>The rmi port number can be specified with the "rmi.port" system property. 77 * When launching several registries, we increment the port number 78 * to avoid falling into "port number already in use" problems. 104 "com.sun.management.jmxremote.port"; 623 * port and then calls ConnectorBootstrap.initialize(). 627 private String testConfiguration(File file,int port) { argument 642 System.out.println("*** Testing configuration (port=" + port + "): " 646 System.setProperty("com.sun.management.jmxremote.port", 715 testConfigurationKo(File conf,int port) argument [all...] |
/openjdk7/jdk/test/sun/net/ftp/ |
H A D | FtpGetContent.java | 42 private int port; field in class:FtpGetContent.FtpServer 259 int port = pasv.getLocalPort(); 261 (port >> 8) + "," + (port & 0xff) +")"); 369 public FtpServer(int port) { argument 370 this.port = port; 372 server = new ServerSocket(port); 457 int port = server.getPort(); 461 URL url = new URL("ftp://localhost:" + port [all...] |
H A D | FtpURL.java | 40 private int port; field in class:FtpURL.FtpServer 258 int port = pasv.getLocalPort(); 260 (port >> 8) + "," + (port & 0xff) +")"); 371 public FtpServer(int port) { argument 372 this.port = port; 374 server = new ServerSocket(port); 456 int port = server.getPort(); 460 URL url = new URL("ftp://user:password@localhost:" + port [all...] |
/openjdk7/jdk/test/sun/net/www/httptest/ |
H A D | HttpServer.java | 74 * the same as the 4 arg constructor, where the port argument is set to zero. 91 * the specified port. The specified number of threads are created to 100 * @param port the port number to bind the server to. <code>Zero</code> 101 * means choose any free port. 104 public HttpServer (HttpCallback cb, int threads, int cperthread, int port) argument 107 InetSocketAddress addr = new InetSocketAddress (port); 131 * return the local port number to which the server is bound. 132 * @return the local port number
|
/openjdk7/jdk/src/share/classes/sun/net/www/protocol/ftp/ |
H A D | FtpURLConnection.java | 100 int port; field in class:FtpURLConnection 174 port = url.getPort(); 291 if (port != -1) { 292 ftp.connect(new InetSocketAddress(host, port)); 551 * Gets the <code>Permission</code> associated with the host & port.
|
/openjdk7/jdk/src/share/classes/sun/net/www/protocol/http/ |
H A D | AuthenticationInfo.java | 95 return port; 160 //return ("{"+type+":"+authScheme+":"+protocol+":"+host+":"+port+":"+realm+":"+path+"}"); 182 /** The port on the host we're authenticating against. */ 183 int port; field in class:AuthenticationInfo 192 public AuthenticationInfo(char type, AuthScheme authScheme, String host, int port, String realm) { argument 197 this.port = port; 220 this.port = url.getPort(); 221 if (this.port == -1) { 222 this.port 310 getProxyAuth(String host, int port) argument 321 getProxyAuthKey(String host, int port, String realm, AuthScheme scheme) argument [all...] |
/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | DatagramSocketAdaptor.java | 73 int port = isa.getPort(); 74 if (port < 0 || port > 0xFFFF) 75 throw new IllegalArgumentException("connect: " + port); 97 public void connect(InetAddress address, int port) { argument 99 connectInternal(new InetSocketAddress(address, port)); 151 // and set address and port of the packet
|
/openjdk7/jdk/src/share/classes/sun/rmi/server/ |
H A D | UnicastServerRef.java | 136 * on the specified port. 138 public UnicastServerRef(int port) { argument 139 super(new LiveRef(port)); 144 * anonymous port (i.e., 0) and that uses a pregenerated stub class
|
/openjdk7/jdk/src/share/classes/sun/rmi/transport/tcp/ |
H A D | TCPEndpoint.java | 66 /** port number */ 67 private int port; field in class:TCPEndpoint 73 /** if local, the port number to listen on */ 154 * Create an endpoint for a specified host and port. 158 public TCPEndpoint(String host, int port) { argument 159 this(host, port, null, null); 163 * Create a custom socket factory endpoint for a specified host and port. 167 public TCPEndpoint(String host, int port, RMIClientSocketFactory csf, argument 173 this.port = port; 183 getLocalEndpoint(int port) argument 187 getLocalEndpoint(int port, RMIClientSocketFactory csf, RMIServerSocketFactory ssf) argument 322 setDefaultPort(int port, RMIClientSocketFactory csf, RMIServerSocketFactory ssf) argument [all...] |
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
H A D | SctpNet.java | 94 static void bindx(int fd, InetAddress[] addrs, int port, boolean add) argument 96 bindx(fd, addrs, port, addrs.length, add, 333 static native void bindx(int fd, InetAddress[] addrs, int port, int length, argument 349 int port) throws IOException; 352 InetAddress ia, int port, boolean preferIPv6) throws IOException; 348 setPrimAddrOption0(int fd, int assocId, InetAddress ia, int port) argument 351 setPeerPrimAddrOption0(int fd, int assocId, InetAddress ia, int port, boolean preferIPv6) argument
|