0N/A/*
3909N/A * Copyright (c) 2001, 2011, Oracle and/or its affiliates. All rights reserved.
0N/A * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
0N/A *
0N/A * This code is free software; you can redistribute it and/or modify it
0N/A * under the terms of the GNU General Public License version 2 only, as
2362N/A * published by the Free Software Foundation. Oracle designates this
0N/A * particular file as subject to the "Classpath" exception as provided
2362N/A * by Oracle in the LICENSE file that accompanied this code.
0N/A *
0N/A * This code is distributed in the hope that it will be useful, but WITHOUT
0N/A * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
0N/A * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
0N/A * version 2 for more details (a copy is included in the LICENSE file that
0N/A * accompanied this code).
0N/A *
0N/A * You should have received a copy of the GNU General Public License version
0N/A * 2 along with this work; if not, write to the Free Software Foundation,
0N/A * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
0N/A *
2362N/A * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
2362N/A * or visit www.oracle.com if you need additional information or have any
2362N/A * questions.
0N/A */
0N/A
0N/A#include <windows.h>
0N/A#include <winsock2.h>
0N/A#include "jni.h"
0N/A#include "jni_util.h"
0N/A#include "jvm.h"
0N/A#include "jlong.h"
0N/A
0N/A#include "nio.h"
0N/A#include "nio_util.h"
0N/A#include "net_util.h"
0N/A
0N/A#include "sun_nio_ch_Net.h"
0N/A
524N/A/**
524N/A * Definitions to allow for building with older SDK include files.
524N/A */
0N/A
524N/A#ifndef MCAST_BLOCK_SOURCE
524N/A
524N/A#define MCAST_BLOCK_SOURCE 43
524N/A#define MCAST_UNBLOCK_SOURCE 44
524N/A#define MCAST_JOIN_SOURCE_GROUP 45
524N/A#define MCAST_LEAVE_SOURCE_GROUP 46
524N/A
524N/A#endif /* MCAST_BLOCK_SOURCE */
0N/A
524N/Atypedef struct my_ip_mreq_source {
524N/A IN_ADDR imr_multiaddr;
524N/A IN_ADDR imr_sourceaddr;
524N/A IN_ADDR imr_interface;
524N/A};
524N/A
524N/Atypedef struct my_group_source_req {
524N/A ULONG gsr_interface;
524N/A SOCKADDR_STORAGE gsr_group;
524N/A SOCKADDR_STORAGE gsr_source;
524N/A};
524N/A
524N/A/**
524N/A * Copy IPv6 address as jbytearray to target
0N/A */
524N/A#define COPY_INET6_ADDRESS(env, source, target) \
524N/A (*env)->GetByteArrayRegion(env, source, 0, 16, target)
524N/A
2464N/A/**
2464N/A * Enable or disable receipt of WSAECONNRESET errors.
2464N/A */
2464N/Astatic void setConnectionReset(SOCKET s, BOOL enable) {
2464N/A DWORD bytesReturned = 0;
2464N/A WSAIoctl(s, SIO_UDP_CONNRESET, &enable, sizeof(enable),
2464N/A NULL, 0, &bytesReturned, NULL, NULL);
2464N/A}
524N/A
0N/A
0N/AJNIEXPORT void JNICALL
0N/AJava_sun_nio_ch_Net_initIDs(JNIEnv *env, jclass clazz)
0N/A{
524N/A /* nothing to do */
0N/A}
0N/A
524N/AJNIEXPORT jboolean JNICALL
524N/AJava_sun_nio_ch_Net_isIPv6Available0(JNIEnv* env, jclass cl)
524N/A{
524N/A /*
524N/A * Return true if Windows Vista or newer, and IPv6 is configured
524N/A */
524N/A OSVERSIONINFO ver;
524N/A ver.dwOSVersionInfoSize = sizeof(ver);
524N/A GetVersionEx(&ver);
524N/A if ((ver.dwPlatformId == VER_PLATFORM_WIN32_NT) &&
524N/A (ver.dwMajorVersion >= 6) && ipv6_available())
524N/A {
524N/A return JNI_TRUE;
524N/A }
524N/A return JNI_FALSE;
524N/A}
0N/A
6272N/AJNIEXPORT jint JNICALL
6272N/AJava_sun_nio_ch_Net_isExclusiveBindAvailable(JNIEnv *env, jclass clazz) {
6272N/A OSVERSIONINFO ver;
6272N/A int version;
6272N/A ver.dwOSVersionInfoSize = sizeof(ver);
6272N/A GetVersionEx(&ver);
6272N/A version = ver.dwMajorVersion * 10 + ver.dwMinorVersion;
6272N/A //if os <= xp exclusive binding is off by default
6272N/A return version >= 60 ? 1 : 0;
6272N/A}
6272N/A
6272N/A
3759N/AJNIEXPORT jboolean JNICALL
3759N/AJava_sun_nio_ch_Net_canIPv6SocketJoinIPv4Group0(JNIEnv* env, jclass cl)
3759N/A{
3759N/A return JNI_FALSE;
3759N/A}
3759N/A
3759N/AJNIEXPORT jboolean JNICALL
3759N/AJava_sun_nio_ch_Net_canJoin6WithIPv4Group0(JNIEnv* env, jclass cl)
3759N/A{
3759N/A return JNI_FALSE;
3759N/A}
3759N/A
0N/AJNIEXPORT jint JNICALL
524N/AJava_sun_nio_ch_Net_socket0(JNIEnv *env, jclass cl, jboolean preferIPv6,
524N/A jboolean stream, jboolean reuse)
0N/A{
0N/A SOCKET s;
524N/A int domain = (preferIPv6) ? AF_INET6 : AF_INET;
0N/A
524N/A s = socket(domain, (stream ? SOCK_STREAM : SOCK_DGRAM), 0);
0N/A if (s != INVALID_SOCKET) {
0N/A SetHandleInformation((HANDLE)s, HANDLE_FLAG_INHERIT, 0);
524N/A
524N/A /* IPV6_V6ONLY is true by default */
524N/A if (domain == AF_INET6) {
524N/A int opt = 0;
524N/A setsockopt(s, IPPROTO_IPV6, IPV6_V6ONLY,
524N/A (const char *)&opt, sizeof(opt));
524N/A }
2464N/A
2464N/A /* Disable WSAECONNRESET errors for initially unconnected UDP sockets */
2464N/A if (!stream) {
2464N/A setConnectionReset(s, FALSE);
2464N/A }
2464N/A
0N/A } else {
0N/A NET_ThrowNew(env, WSAGetLastError(), "socket");
0N/A }
524N/A
0N/A return (jint)s;
0N/A}
0N/A
0N/AJNIEXPORT void JNICALL
6272N/AJava_sun_nio_ch_Net_bind0(JNIEnv *env, jclass clazz, jobject fdo, jboolean preferIPv6,
6272N/A jboolean isExclBind, jobject iao, jint port)
0N/A{
0N/A SOCKETADDRESS sa;
0N/A int rv;
524N/A int sa_len;
0N/A
524N/A if (NET_InetAddressToSockaddr(env, iao, port, (struct sockaddr *)&sa, &sa_len, preferIPv6) != 0) {
0N/A return;
0N/A }
0N/A
6272N/A rv = NET_WinBind(fdval(env, fdo), (struct sockaddr *)&sa, sa_len, isExclBind);
0N/A if (rv == SOCKET_ERROR)
0N/A NET_ThrowNew(env, WSAGetLastError(), "bind");
0N/A}
0N/A
524N/AJNIEXPORT void JNICALL
524N/AJava_sun_nio_ch_Net_listen(JNIEnv *env, jclass cl, jobject fdo, jint backlog)
524N/A{
524N/A if (listen(fdval(env,fdo), backlog) == SOCKET_ERROR) {
524N/A NET_ThrowNew(env, WSAGetLastError(), "listen");
524N/A }
524N/A}
524N/A
524N/A
0N/AJNIEXPORT jint JNICALL
524N/AJava_sun_nio_ch_Net_connect0(JNIEnv *env, jclass clazz, jboolean preferIPv6, jobject fdo,
524N/A jobject iao, jint port)
0N/A{
0N/A SOCKETADDRESS sa;
0N/A int rv;
524N/A int sa_len;
2464N/A SOCKET s = (SOCKET)fdval(env, fdo);
0N/A
524N/A if (NET_InetAddressToSockaddr(env, iao, port, (struct sockaddr *)&sa, &sa_len, preferIPv6) != 0) {
524N/A return IOS_THROWN;
0N/A }
0N/A
2464N/A rv = connect(s, (struct sockaddr *)&sa, sa_len);
0N/A if (rv != 0) {
0N/A int err = WSAGetLastError();
0N/A if (err == WSAEINPROGRESS || err == WSAEWOULDBLOCK) {
0N/A return IOS_UNAVAILABLE;
0N/A }
0N/A NET_ThrowNew(env, err, "connect");
0N/A return IOS_THROWN;
2464N/A } else {
2464N/A /* Enable WSAECONNRESET errors when a UDP socket is connected */
2464N/A int type = 0, optlen = sizeof(type);
2464N/A rv = getsockopt(s, SOL_SOCKET, SO_TYPE, (char*)&type, &optlen);
2464N/A if (rv == 0 && type == SOCK_DGRAM) {
2464N/A setConnectionReset(s, TRUE);
2464N/A }
0N/A }
0N/A return 1;
0N/A}
0N/A
0N/AJNIEXPORT jint JNICALL
0N/AJava_sun_nio_ch_Net_localPort(JNIEnv *env, jclass clazz, jobject fdo)
0N/A{
524N/A SOCKETADDRESS sa;
0N/A int sa_len = sizeof(sa);
0N/A
0N/A if (getsockname(fdval(env, fdo), (struct sockaddr *)&sa, &sa_len) < 0) {
0N/A int error = WSAGetLastError();
0N/A if (error == WSAEINVAL) {
0N/A return 0;
0N/A }
0N/A NET_ThrowNew(env, error, "getsockname");
0N/A return IOS_THROWN;
0N/A }
524N/A return NET_GetPortFromSockaddr((struct sockaddr *)&sa);
0N/A}
0N/A
0N/AJNIEXPORT jobject JNICALL
0N/AJava_sun_nio_ch_Net_localInetAddress(JNIEnv *env, jclass clazz, jobject fdo)
0N/A{
524N/A SOCKETADDRESS sa;
0N/A int sa_len = sizeof(sa);
524N/A int port;
0N/A
0N/A if (getsockname(fdval(env, fdo), (struct sockaddr *)&sa, &sa_len) < 0) {
0N/A NET_ThrowNew(env, WSAGetLastError(), "getsockname");
0N/A return NULL;
0N/A }
524N/A return NET_SockaddrToInetAddress(env, (struct sockaddr *)&sa, &port);
0N/A}
0N/A
0N/AJNIEXPORT jint JNICALL
524N/AJava_sun_nio_ch_Net_remotePort(JNIEnv *env, jclass clazz, jobject fdo)
0N/A{
524N/A SOCKETADDRESS sa;
524N/A int sa_len = sizeof(sa);
524N/A
524N/A if (getpeername(fdval(env, fdo), (struct sockaddr *)&sa, &sa_len) < 0) {
524N/A int error = WSAGetLastError();
524N/A if (error == WSAEINVAL) {
524N/A return 0;
524N/A }
524N/A NET_ThrowNew(env, error, "getsockname");
524N/A return IOS_THROWN;
524N/A }
524N/A return NET_GetPortFromSockaddr((struct sockaddr *)&sa);
524N/A}
524N/A
524N/AJNIEXPORT jobject JNICALL
524N/AJava_sun_nio_ch_Net_remoteInetAddress(JNIEnv *env, jclass clazz, jobject fdo)
524N/A{
524N/A SOCKETADDRESS sa;
524N/A int sa_len = sizeof(sa);
524N/A int port;
524N/A
524N/A if (getpeername(fdval(env, fdo), (struct sockaddr *)&sa, &sa_len) < 0) {
524N/A NET_ThrowNew(env, WSAGetLastError(), "getsockname");
524N/A return NULL;
524N/A }
524N/A return NET_SockaddrToInetAddress(env, (struct sockaddr *)&sa, &port);
524N/A}
524N/A
524N/AJNIEXPORT jint JNICALL
524N/AJava_sun_nio_ch_Net_getIntOption0(JNIEnv *env, jclass clazz, jobject fdo,
524N/A jboolean mayNeedConversion, jint level, jint opt)
524N/A{
524N/A int result = 0;
0N/A struct linger linger;
0N/A char *arg;
524N/A int arglen, n;
0N/A
524N/A if (level == SOL_SOCKET && opt == SO_LINGER) {
0N/A arg = (char *)&linger;
0N/A arglen = sizeof(linger);
0N/A } else {
0N/A arg = (char *)&result;
0N/A arglen = sizeof(result);
0N/A }
0N/A
524N/A /**
524N/A * HACK: IP_TOS is deprecated on Windows and querying the option
524N/A * returns a protocol error. NET_GetSockOpt handles this and uses
524N/A * a fallback mechanism.
524N/A */
524N/A if (level == IPPROTO_IP && opt == IP_TOS) {
524N/A mayNeedConversion = JNI_TRUE;
524N/A }
524N/A
524N/A if (mayNeedConversion) {
524N/A n = NET_GetSockOpt(fdval(env, fdo), level, opt, arg, &arglen);
524N/A } else {
524N/A n = getsockopt(fdval(env, fdo), level, opt, arg, &arglen);
524N/A }
524N/A if (n < 0) {
524N/A handleSocketError(env, WSAGetLastError());
0N/A return IOS_THROWN;
0N/A }
0N/A
524N/A if (level == SOL_SOCKET && opt == SO_LINGER)
0N/A return linger.l_onoff ? linger.l_linger : -1;
0N/A else
0N/A return result;
0N/A}
0N/A
0N/AJNIEXPORT void JNICALL
524N/AJava_sun_nio_ch_Net_setIntOption0(JNIEnv *env, jclass clazz, jobject fdo,
524N/A jboolean mayNeedConversion, jint level, jint opt, jint arg)
0N/A{
0N/A struct linger linger;
0N/A char *parg;
524N/A int arglen, n;
0N/A
524N/A if (level == SOL_SOCKET && opt == SO_LINGER) {
0N/A parg = (char *)&linger;
0N/A arglen = sizeof(linger);
0N/A if (arg >= 0) {
0N/A linger.l_onoff = 1;
0N/A linger.l_linger = (unsigned short)arg;
0N/A } else {
0N/A linger.l_onoff = 0;
0N/A linger.l_linger = 0;
0N/A }
0N/A } else {
0N/A parg = (char *)&arg;
0N/A arglen = sizeof(arg);
0N/A }
0N/A
524N/A if (mayNeedConversion) {
524N/A n = NET_SetSockOpt(fdval(env, fdo), level, opt, parg, arglen);
524N/A } else {
524N/A n = setsockopt(fdval(env, fdo), level, opt, parg, arglen);
524N/A }
524N/A if (n < 0)
524N/A handleSocketError(env, WSAGetLastError());
524N/A}
524N/A
524N/AJNIEXPORT jint JNICALL
524N/AJava_sun_nio_ch_Net_joinOrDrop4(JNIEnv *env, jobject this, jboolean join, jobject fdo,
524N/A jint group, jint interf, jint source)
524N/A{
524N/A struct ip_mreq mreq;
524N/A struct my_ip_mreq_source mreq_source;
524N/A int opt, n, optlen;
524N/A void* optval;
524N/A
524N/A if (source == 0) {
524N/A mreq.imr_multiaddr.s_addr = htonl(group);
524N/A mreq.imr_interface.s_addr = htonl(interf);
524N/A opt = (join) ? IP_ADD_MEMBERSHIP : IP_DROP_MEMBERSHIP;
524N/A optval = (void*)&mreq;
524N/A optlen = sizeof(mreq);
524N/A } else {
524N/A mreq_source.imr_multiaddr.s_addr = htonl(group);
524N/A mreq_source.imr_sourceaddr.s_addr = htonl(source);
524N/A mreq_source.imr_interface.s_addr = htonl(interf);
524N/A opt = (join) ? IP_ADD_SOURCE_MEMBERSHIP : IP_DROP_SOURCE_MEMBERSHIP;
524N/A optval = (void*)&mreq_source;
524N/A optlen = sizeof(mreq_source);
524N/A }
524N/A
524N/A n = setsockopt(fdval(env,fdo), IPPROTO_IP, opt, optval, optlen);
524N/A if (n < 0) {
524N/A if (join && (WSAGetLastError() == WSAENOPROTOOPT))
524N/A return IOS_UNAVAILABLE;
524N/A handleSocketError(env, WSAGetLastError());
524N/A }
524N/A return 0;
524N/A}
524N/A
524N/AJNIEXPORT jint JNICALL
524N/AJava_sun_nio_ch_Net_blockOrUnblock4(JNIEnv *env, jobject this, jboolean block, jobject fdo,
524N/A jint group, jint interf, jint source)
524N/A{
524N/A struct my_ip_mreq_source mreq_source;
524N/A int n;
524N/A int opt = (block) ? IP_BLOCK_SOURCE : IP_UNBLOCK_SOURCE;
524N/A
524N/A mreq_source.imr_multiaddr.s_addr = htonl(group);
524N/A mreq_source.imr_sourceaddr.s_addr = htonl(source);
524N/A mreq_source.imr_interface.s_addr = htonl(interf);
524N/A
524N/A n = setsockopt(fdval(env,fdo), IPPROTO_IP, opt,
524N/A (void*)&mreq_source, sizeof(mreq_source));
524N/A if (n < 0) {
524N/A if (block && (WSAGetLastError() == WSAENOPROTOOPT))
524N/A return IOS_UNAVAILABLE;
524N/A handleSocketError(env, WSAGetLastError());
524N/A }
524N/A return 0;
524N/A}
524N/A
524N/A/**
524N/A * Call setsockopt with a IPPROTO_IPV6 level socket option
524N/A * and a group_source_req structure as the option value. The
524N/A * given IPv6 group, interface index, and IPv6 source address
524N/A * are copied into the structure.
524N/A */
524N/Astatic int setGroupSourceReqOption(JNIEnv* env,
524N/A jobject fdo,
524N/A int opt,
524N/A jbyteArray group,
524N/A jint index,
524N/A jbyteArray source)
524N/A{
524N/A struct my_group_source_req req;
524N/A struct sockaddr_in6* sin6;
524N/A
524N/A req.gsr_interface = (ULONG)index;
524N/A
524N/A sin6 = (struct sockaddr_in6*)&(req.gsr_group);
524N/A sin6->sin6_family = AF_INET6;
524N/A COPY_INET6_ADDRESS(env, group, (jbyte*)&(sin6->sin6_addr));
524N/A
524N/A sin6 = (struct sockaddr_in6*)&(req.gsr_source);
524N/A sin6->sin6_family = AF_INET6;
524N/A COPY_INET6_ADDRESS(env, source, (jbyte*)&(sin6->sin6_addr));
524N/A
524N/A return setsockopt(fdval(env,fdo), IPPROTO_IPV6, opt, (void*)&req, sizeof(req));
524N/A}
524N/A
524N/AJNIEXPORT jint JNICALL
524N/AJava_sun_nio_ch_Net_joinOrDrop6(JNIEnv *env, jobject this, jboolean join, jobject fdo,
524N/A jbyteArray group, jint index, jbyteArray source)
524N/A{
524N/A struct ipv6_mreq mreq6;
524N/A int n;
524N/A
524N/A if (source == NULL) {
524N/A int opt = (join) ? IPV6_ADD_MEMBERSHIP : IPV6_DROP_MEMBERSHIP;
524N/A COPY_INET6_ADDRESS(env, group, (jbyte*)&(mreq6.ipv6mr_multiaddr));
524N/A mreq6.ipv6mr_interface = (int)index;
524N/A n = setsockopt(fdval(env,fdo), IPPROTO_IPV6, opt,
524N/A (void*)&mreq6, sizeof(mreq6));
524N/A } else {
524N/A int opt = (join) ? MCAST_JOIN_SOURCE_GROUP : MCAST_LEAVE_SOURCE_GROUP;
524N/A n = setGroupSourceReqOption(env, fdo, opt, group, index, source);
524N/A }
524N/A
524N/A if (n < 0) {
524N/A handleSocketError(env, errno);
524N/A }
524N/A return 0;
524N/A}
524N/A
524N/AJNIEXPORT jint JNICALL
524N/AJava_sun_nio_ch_Net_blockOrUnblock6(JNIEnv *env, jobject this, jboolean block, jobject fdo,
524N/A jbyteArray group, jint index, jbyteArray source)
524N/A{
524N/A int opt = (block) ? MCAST_BLOCK_SOURCE : MCAST_UNBLOCK_SOURCE;
524N/A int n = setGroupSourceReqOption(env, fdo, opt, group, index, source);
524N/A if (n < 0) {
524N/A handleSocketError(env, errno);
524N/A }
524N/A return 0;
524N/A}
524N/A
524N/AJNIEXPORT void JNICALL
524N/AJava_sun_nio_ch_Net_setInterface4(JNIEnv* env, jobject this, jobject fdo, jint interf)
524N/A{
524N/A struct in_addr in;
524N/A int arglen = sizeof(struct in_addr);
524N/A int n;
524N/A
524N/A in.s_addr = htonl(interf);
524N/A
524N/A n = setsockopt(fdval(env, fdo), IPPROTO_IP, IP_MULTICAST_IF,
524N/A (void*)&(in.s_addr), arglen);
524N/A if (n < 0) {
524N/A handleSocketError(env, WSAGetLastError());
0N/A }
0N/A}
524N/A
524N/AJNIEXPORT jint JNICALL
524N/AJava_sun_nio_ch_Net_getInterface4(JNIEnv* env, jobject this, jobject fdo)
524N/A{
524N/A struct in_addr in;
524N/A int arglen = sizeof(struct in_addr);
524N/A int n;
524N/A
524N/A n = getsockopt(fdval(env, fdo), IPPROTO_IP, IP_MULTICAST_IF, (void*)&in, &arglen);
524N/A if (n < 0) {
524N/A handleSocketError(env, WSAGetLastError());
524N/A return IOS_THROWN;
524N/A }
524N/A return ntohl(in.s_addr);
524N/A}
524N/A
524N/AJNIEXPORT void JNICALL
524N/AJava_sun_nio_ch_Net_setInterface6(JNIEnv* env, jobject this, jobject fdo, jint index)
524N/A{
524N/A int value = (jint)index;
524N/A int arglen = sizeof(value);
524N/A int n;
524N/A
524N/A n = setsockopt(fdval(env, fdo), IPPROTO_IPV6, IPV6_MULTICAST_IF,
524N/A (void*)&(index), arglen);
524N/A if (n < 0) {
524N/A handleSocketError(env, errno);
524N/A }
524N/A}
524N/A
524N/AJNIEXPORT jint JNICALL
524N/AJava_sun_nio_ch_Net_getInterface6(JNIEnv* env, jobject this, jobject fdo)
524N/A{
524N/A int index;
524N/A int arglen = sizeof(index);
524N/A int n;
524N/A
524N/A n = getsockopt(fdval(env, fdo), IPPROTO_IPV6, IPV6_MULTICAST_IF, (void*)&index, &arglen);
524N/A if (n < 0) {
524N/A handleSocketError(env, errno);
524N/A return -1;
524N/A }
524N/A return (jint)index;
524N/A}
524N/A
524N/AJNIEXPORT void JNICALL
524N/AJava_sun_nio_ch_Net_shutdown(JNIEnv *env, jclass cl, jobject fdo, jint jhow) {
524N/A int how = (jhow == sun_nio_ch_Net_SHUT_RD) ? SD_RECEIVE :
524N/A (jhow == sun_nio_ch_Net_SHUT_WR) ? SD_SEND : SD_BOTH;
524N/A if (shutdown(fdval(env, fdo), how) == SOCKET_ERROR) {
524N/A NET_ThrowNew(env, WSAGetLastError(), "shutdown");
524N/A }
524N/A}