1/*
2 * Copyright (c) 2008, 2012, 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 "jni.h"
27#include "jni_util.h"
28#include "jvm.h"
29#include "jlong.h"
30#include "nio_util.h"
31
32#include <stdlib.h>
33#include <dlfcn.h>
34#include <sys/types.h>
35#include <port.h>
36
37#include "sun_nio_ch_SolarisEventPort.h"
38
39JNIEXPORT jint JNICALL
40Java_sun_nio_ch_SolarisEventPort_port_1create
41    (JNIEnv* env, jclass clazz)
42{
43    int port = port_create();
44    if (port == -1) {
45        JNU_ThrowIOExceptionWithLastError(env, "port_create");
46    }
47    return (jint)port;
48}
49
50JNIEXPORT void JNICALL
51Java_sun_nio_ch_SolarisEventPort_port_1close
52    (JNIEnv* env, jclass clazz, jint port)
53{
54    int res;
55    RESTARTABLE(close(port), res);
56}
57
58JNIEXPORT jboolean JNICALL
59Java_sun_nio_ch_SolarisEventPort_port_1associate
60    (JNIEnv* env, jclass clazz, jint port, jint source, jlong objectAddress, jint events)
61{
62    uintptr_t object = (uintptr_t)jlong_to_ptr(objectAddress);
63    if (port_associate((int)port, (int)source, object, (int)events, NULL) == 0) {
64        return JNI_TRUE;
65    } else {
66        if (errno != EBADFD)
67            JNU_ThrowIOExceptionWithLastError(env, "port_associate");
68        return JNI_FALSE;
69    }
70}
71
72JNIEXPORT jboolean JNICALL
73Java_sun_nio_ch_SolarisEventPort_port_1dissociate
74    (JNIEnv* env, jclass clazz, jint port, jint source, jlong objectAddress)
75{
76    uintptr_t object = (uintptr_t)jlong_to_ptr(objectAddress);
77
78    if (port_dissociate((int)port, (int)source, object) == 0) {
79        return JNI_TRUE;
80    } else {
81        if (errno != ENOENT)
82            JNU_ThrowIOExceptionWithLastError(env, "port_dissociate");
83        return JNI_FALSE;
84    }
85}
86
87JNIEXPORT void JNICALL
88Java_sun_nio_ch_SolarisEventPort_port_1send(JNIEnv* env, jclass clazz,
89    jint port, jint events)
90{
91    if (port_send((int)port, (int)events, NULL) == -1) {
92        JNU_ThrowIOExceptionWithLastError(env, "port_send");
93    }
94}
95
96JNIEXPORT void JNICALL
97Java_sun_nio_ch_SolarisEventPort_port_1get(JNIEnv* env, jclass clazz,
98    jint port, jlong eventAddress)
99{
100    int res;
101    port_event_t* ev = (port_event_t*)jlong_to_ptr(eventAddress);
102
103    RESTARTABLE(port_get((int)port, ev, NULL), res);
104    if (res == -1) {
105        JNU_ThrowIOExceptionWithLastError(env, "port_get");
106    }
107}
108
109JNIEXPORT jint JNICALL
110Java_sun_nio_ch_SolarisEventPort_port_1getn(JNIEnv* env, jclass clazz,
111    jint port, jlong arrayAddress, jint max, jlong timeout)
112{
113    int res;
114    uint_t n = 1;
115    port_event_t* list = (port_event_t*)jlong_to_ptr(arrayAddress);
116    timespec_t ts;
117    timespec_t* tsp;
118
119    if (timeout >= 0L) {
120        ts.tv_sec = timeout / 1000;
121        ts.tv_nsec = 1000000 * (timeout % 1000);
122        tsp = &ts;
123    } else {
124        tsp = NULL;
125    }
126
127    res = port_getn((int)port, list, (uint_t)max, &n, tsp);
128    if (res == -1) {
129        if (errno != ETIME && errno != EINTR)
130            JNU_ThrowIOExceptionWithLastError(env, "port_getn");
131    }
132
133    return (jint)n;
134}
135