archive/jdk
1
0
Fork 0
mirror of https://github.com/openjdk/jdk.git synced 2025-09-21 11:34:38 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

6483406: new ServerSocket() sometimes takes more than 3 minutes on Suse Linux

Browse source 
Switch to socketpair() call to create marker fd

Reviewed-by: alanb
This commit is contained in:
Jean-Christophe Collet 2008-06-13 17:43:50 +02:00
parent 840473c1e3
commit 1c4114a2d3
1 changed files with 11 additions and 81 deletions
Download patch file Download diff file Expand all files Collapse all files

92
jdk/src/solaris/native/java/net/PlainSocketImpl.c
View file

@ -95,94 +95,24 @@ static int marker_fd = -1;
*/ */
static int getMarkerFD() static int getMarkerFD()
{ {
int server_fd, child_fd, connect_fd; int sv[2];
SOCKADDR him;
int type, len, port;
type = AF_INET; #ifdef AF_UNIX
#ifdef AF_INET6 if (socketpair(AF_UNIX, SOCK_STREAM, 0, sv) == -1) {
if (ipv6_available()) { return -1;
type = AF_INET6;
} }
#else
return -1;
#endif #endif
/* /*
* Create listener on any port * Finally shutdown sv[0] (any reads to this fd will get
*/
server_fd = JVM_Socket(type, SOCK_STREAM, 0);
if (server_fd < 0) {
return -1;
}
if (JVM_Listen(server_fd, 1) == -1) {
JVM_SocketClose(server_fd);
return -1;
}
len = SOCKADDR_LEN;
if (JVM_GetSockName(server_fd, (struct sockaddr *)&him, &len) == -1) {
JVM_SocketClose(server_fd);
return -1;
}
port = NET_GetPortFromSockaddr((struct sockaddr *)&him);
/*
* Establish connection from client socket.
* Server is bound to 0.0.0.0/X or ::/X
* We connect to 127.0.0.1/X or ::1/X
*/
#ifdef AF_INET6
if (ipv6_available()) {
struct sockaddr_in6 *him6 = (struct sockaddr_in6 *)&him;
jbyte caddr[16];
memset((char *) caddr, 0, 16);
caddr[15] = 1;
memset((char *)him6, 0, sizeof(struct sockaddr_in6));
memcpy((void *)&(him6->sin6_addr), caddr, sizeof(struct in6_addr) );
him6->sin6_port = htons((short) port);
him6->sin6_family = AF_INET6;
len = sizeof(struct sockaddr_in6) ;
} else
#endif /* AF_INET6 */
{
struct sockaddr_in *him4 = (struct sockaddr_in*)&him;
memset((char *) him4, 0, sizeof(struct sockaddr_in));
him4->sin_port = htons((short) port);
him4->sin_addr.s_addr = (uint32_t) htonl(0x7f000001);
him4->sin_family = AF_INET;
len = sizeof(struct sockaddr_in);
}
connect_fd = JVM_Socket(type, SOCK_STREAM, 0);
if (connect_fd < 0) {
JVM_SocketClose(server_fd);
return -1;
}
if (JVM_Connect(connect_fd, (struct sockaddr *) &him, len) == -1) {
JVM_SocketClose(server_fd);
JVM_SocketClose(connect_fd);
return -1;
}
/*
* Server accepts connection - do in in non-blocking mode to avoid
* hanging if there's an error (should never happen!!!)
*/
SET_NONBLOCKING(server_fd);
len = SOCKADDR_LEN;
child_fd = JVM_Accept(server_fd, (struct sockaddr *)&him, (jint *)&len);
if (child_fd == -1) {
JVM_SocketClose(server_fd);
JVM_SocketClose(connect_fd);
return -1;
}
/*
* Finally shutdown connect_fd (any reads to this fd will get
* EOF; any writes will get an error). * EOF; any writes will get an error).
*/ */
JVM_SocketShutdown(connect_fd, 2); JVM_SocketShutdown(sv[0], 2);
JVM_SocketClose(child_fd); JVM_SocketClose(sv[1]);
JVM_SocketClose(server_fd);
return connect_fd; return sv[0];
} }
@ -1087,7 +1017,7 @@ Java_java_net_PlainSocketImpl_socketGetOption(JNIEnv *env, jobject this,
*/ */
if (cmd == java_net_SocketOptions_SO_BINDADDR) { if (cmd == java_net_SocketOptions_SO_BINDADDR) {
SOCKADDR him; SOCKADDR him;
int len = 0; socklen_t len = 0;
int port; int port;
jobject iaObj; jobject iaObj;
jclass iaCntrClass; jclass iaCntrClass;