Home | History | Annotate | Download | only in native
      1 /*
      2  * Copyright (c) 2002, 2006, Oracle and/or its affiliates. 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.  Oracle designates this
      8  * particular file as subject to the "Classpath" exception as provided
      9  * by Oracle 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 Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
     22  * or visit www.oracle.com if you need additional information or have any
     23  * questions.
     24  */
     25 
     26 #include <sys/types.h>
     27 #include <string.h>
     28 #include "jni.h"
     29 #include "jni_util.h"
     30 #include "jvm.h"
     31 #include "jlong.h"
     32 #include "nio_util.h"
     33 #include <nativehelper/JNIHelp.h>
     34 
     35 #ifdef __linux__
     36   #include <pthread.h>
     37   #include <sys/signal.h>
     38   // Android-changed: Bionic (and AsynchronousCloseMonitor) expects libcore to use
     39   // __SIGRTMIN + 2, not __SIGRTMAX - 2
     40   /* Also defined in net/linux_close.c */
     41   #define INTERRUPT_SIGNAL (__SIGRTMIN + 2)
     42 #elif __solaris__
     43   #include <thread.h>
     44   #include <signal.h>
     45   #define INTERRUPT_SIGNAL (SIGRTMAX - 2)
     46 #elif _ALLBSD_SOURCE
     47   #include <pthread.h>
     48   #include <signal.h>
     49   /* Also defined in net/bsd_close.c */
     50   #define INTERRUPT_SIGNAL SIGIO
     51 #else
     52   #error "missing platform-specific definition here"
     53 #endif
     54 
     55 #define NATIVE_METHOD(className, functionName, signature) \
     56 { #functionName, signature, (void*)(className ## _ ## functionName) }
     57 
     58 static void
     59 nullHandler(int sig)
     60 {
     61 }
     62 
     63 static void  NativeThread_init(JNIEnv *env)
     64 {
     65     /* Install the null handler for INTERRUPT_SIGNAL.  This might overwrite the
     66      * handler previously installed by java/net/linux_close.c, but that's okay
     67      * since neither handler actually does anything.  We install our own
     68      * handler here simply out of paranoia; ultimately the two mechanisms
     69      * should somehow be unified, perhaps within the VM.
     70      */
     71 
     72     sigset_t ss;
     73     struct sigaction sa, osa;
     74     sa.sa_handler = nullHandler;
     75     sa.sa_flags = 0;
     76     sigemptyset(&sa.sa_mask);
     77     if (sigaction(INTERRUPT_SIGNAL, &sa, &osa) < 0)
     78         JNU_ThrowIOExceptionWithLastError(env, "sigaction");
     79 }
     80 
     81 JNIEXPORT jlong JNICALL
     82 NativeThread_current(JNIEnv *env, jclass cl)
     83 {
     84 #ifdef __solaris__
     85     return (jlong)thr_self();
     86 #else
     87     return (jlong)pthread_self();
     88 #endif
     89 }
     90 
     91 JNIEXPORT void JNICALL
     92 NativeThread_signal(JNIEnv *env, jclass cl, jlong thread)
     93 {
     94     int ret;
     95 #ifdef __solaris__
     96     ret = thr_kill((thread_t)thread, INTERRUPT_SIGNAL);
     97 #else
     98     ret = pthread_kill((pthread_t)thread, INTERRUPT_SIGNAL);
     99 #endif
    100     if (ret != 0)
    101         JNU_ThrowIOExceptionWithLastError(env, "Thread signal failed");
    102 }
    103 
    104 static JNINativeMethod gMethods[] = {
    105   NATIVE_METHOD(NativeThread, current, "()J"),
    106   NATIVE_METHOD(NativeThread, signal, "(J)V"),
    107 };
    108 
    109 void register_sun_nio_ch_NativeThread(JNIEnv* env) {
    110   jniRegisterNativeMethods(env, "sun/nio/ch/NativeThread", gMethods, NELEM(gMethods));
    111   NativeThread_init(env);
    112 }
    113