1 /*

     2  * Copyright 2000-2002 Sun Microsystems, Inc.  All Rights Reserved.

     3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

     4  *

     5  * This code is free software; you can redistribute it and/or modify it

     6  * under the terms of the GNU General Public License version 2 only, as

     7  * published by the Free Software Foundation.  Sun designates this

     8  * particular file as subject to the "Classpath" exception as provided

     9  * by Sun in the LICENSE file that accompanied this code.

    10  *

    11  * This code is distributed in the hope that it will be useful, but WITHOUT

    12  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or

    13  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License

    14  * version 2 for more details (a copy is included in the LICENSE file that

    15  * accompanied this code).

    16  *

    17  * You should have received a copy of the GNU General Public License version

    18  * 2 along with this work; if not, write to the Free Software Foundation,

    19  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

    20  *

    21  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,

    22  * CA 95054 USA or visit www.sun.com if you need additional information or

    23  * have any questions.

    24  */

    25 

    26 #include <stdlib.h>

    27 #include <netdb.h>

    28 #include <sys/types.h>

    29 #include <sys/socket.h>

    30 

    31 #if __linux__

    32 #include <netinet/in.h>

    33 #endif

    34 

    35 #if defined(__solaris__) && !defined(_SOCKLEN_T)

    36 typedef size_t socklen_t;       /* New in SunOS 5.7, so need this for 5.6 */

    37 #endif

    38 

    39 #include "jni.h"

    40 #include "jni_util.h"

    41 #include "net_util.h"

    42 #include "jvm.h"

    43 #include "jlong.h"

    44 #include "sun_nio_ch_ServerSocketChannelImpl.h"

    45 #include "nio.h"

    46 #include "nio_util.h"

    47 

    48 

    49 static jfieldID fd_fdID;        /* java.io.FileDescriptor.fd */

    50 static jclass isa_class;        /* java.net.InetSocketAddress */

    51 static jmethodID isa_ctorID;    /*   .InetSocketAddress(InetAddress, int) */

    52 

    53 

    54 JNIEXPORT void JNICALL

    55 Java_sun_nio_ch_ServerSocketChannelImpl_initIDs(JNIEnv *env, jclass c)

    56 {

    57     jclass cls;

    58 

    59     cls = (*env)->FindClass(env, "java/io/FileDescriptor");

    60     fd_fdID = (*env)->GetFieldID(env, cls, "fd", "I");

    61 

    62     cls = (*env)->FindClass(env, "java/net/InetSocketAddress");

    63     isa_class = (*env)->NewGlobalRef(env, cls);

    64     isa_ctorID = (*env)->GetMethodID(env, cls, "<init>",

    65                                      "(Ljava/net/InetAddress;I)V");

    66 }

    67 

    68 JNIEXPORT void JNICALL

    69 Java_sun_nio_ch_ServerSocketChannelImpl_listen(JNIEnv *env, jclass cl,

    70                                                jobject fdo, jint backlog)

    71 {

    72     if (listen(fdval(env, fdo), backlog) < 0)

    73         handleSocketError(env, errno);

    74 }

    75 

    76 JNIEXPORT jint JNICALL

    77 Java_sun_nio_ch_ServerSocketChannelImpl_accept0(JNIEnv *env, jobject this,

    78                                                 jobject ssfdo, jobject newfdo,

    79                                                 jobjectArray isaa)

    80 {

    81     jint ssfd = (*env)->GetIntField(env, ssfdo, fd_fdID);

    82     jint newfd;

    83     struct sockaddr *sa;

    84     int sa_len;

    85     jobject remote_ia = 0;

    86     jobject isa;

    87     jint remote_port;

    88 

    89     NET_AllocSockaddr(&sa, &sa_len);

    90 

    91     /*

    92      * accept connection but ignore ECONNABORTED indicating that

    93      * a connection was eagerly accepted but was reset before

    94      * accept() was called.

    95      */

    96     for (;;) {

    97         newfd = accept(ssfd, sa, &sa_len);

    98         if (newfd >= 0) {

    99             break;

   100         }

   101         if (errno != ECONNABORTED) {

   102             break;

   103         }

   104         /* ECONNABORTED => restart accept */

   105     }

   106 

   107     if (newfd < 0) {

   108         free((void *)sa);

   109         if (errno == EAGAIN)

   110             return IOS_UNAVAILABLE;

   111         if (errno == EINTR)

   112             return IOS_INTERRUPTED;

   113         JNU_ThrowIOExceptionWithLastError(env, "Accept failed");

   114         return IOS_THROWN;

   115     }

   116 

   117     (*env)->SetIntField(env, newfdo, fd_fdID, newfd);

   118     remote_ia = NET_SockaddrToInetAddress(env, sa, (int *)&remote_port);

   119     free((void *)sa);

   120     isa = (*env)->NewObject(env, isa_class, isa_ctorID,

   121                             remote_ia, remote_port);

   122     (*env)->SetObjectArrayElement(env, isaa, 0, isa);

   123     return 1;

   124 }