harmony-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ge...@apache.org
Subject svn commit: r350181 [152/198] - in /incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core: ./ depends/ depends/files/ depends/jars/ depends/libs/ depends/libs/linux.IA32/ depends/libs/win.IA32/ depends/oss/ depends/oss/linux.IA32/ depends/oss/win....
Date Thu, 01 Dec 2005 06:04:00 GMT
Added: incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/luni/socket.c
URL: http://svn.apache.org/viewcvs/incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/luni/socket.c?rev=350181&view=auto
==============================================================================
--- incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/luni/socket.c (added)
+++ incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/luni/socket.c Wed Nov 30 21:29:27 2005
@@ -0,0 +1,1447 @@
+/* Copyright 1998, 2005 The Apache Software Foundation or its licensors, as applicable
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include "nethelp.h"
+#include "jclprots.h"
+#include "helpers.h"
+#include "jclglob.h"
+#include "portsock.h"
+
+#define BROKEN_MULTICAST_IF 1
+#define BROKEN_MULTICAST_TTL 2
+#define BROKEN_TCP_NODELAY 4
+/* signals that when SO_LINGER is enabled and shutdown() is called, a subsequent call to closesocket() will unnecessarily hang */
+#define BROKEN_SO_LINGER_SHUTDOWN 8
+
+jobject getByteSocketOption (JNIEnv * env, hysocket_t hysocketP, int option);
+void setIPV6McastInterface (JNIEnv * env, hysocket_t hysocketP,
+                            jobject optVal);
+void setByteSocketOption (JNIEnv * env, hysocket_t hysocketP, int option,
+                          jobject optVal);
+jobject getIPV6McastInterface (JNIEnv * env, hysocket_t hysocketP);
+void setSendBufferSize (JNIEnv * env, hysocket_t hysocketP, jobject optVal);
+jobject getReceiveBufferSize (JNIEnv * env, hysocket_t hysocketP);
+jobject getMcastInterface (JNIEnv * env, hysocket_t hysocketP);
+void mcastAddMembership (JNIEnv * env, hysocket_t hysocketP, jobject optVal,
+                         BOOLEAN ignoreIF);
+void setIntegerSocketOption (JNIEnv * env, hysocket_t hysocketP, int level,
+                             int option, jobject optVal);
+jobject getSendBufferSize (JNIEnv * env, hysocket_t hysocketP);
+void mcastDropMembership (JNIEnv * env, hysocket_t hysocketP, jobject optVal,
+                          BOOLEAN ignoreIF);
+void setReuseAddrAndReusePort (JNIEnv * env, hysocket_t hysocketP,
+                               jobject optVal);
+void setBoolSocketOption (JNIEnv * env, hysocket_t hysocketP, int level,
+                          int option, jobject optVal);
+void setMcastInterface (JNIEnv * env, hysocket_t hysocketP, jobject optVal);
+jobject getIntegerValue (JNIEnv * env, hysocket_t hysocketP, int level,
+                         int option);
+void setLingerOption (JNIEnv * env, hysocket_t hysocketP, jobject optVal);
+jobject getBooleanValue (JNIEnv * env, hysocket_t hysocketP, int level,
+                         int option);
+jobject getLingerOption (JNIEnv * env, hysocket_t hysocketP);
+void setReceiveBufferSize (JNIEnv * env, hysocket_t hysocketP,
+                           jobject optVal);
+
+/**
+ * A helper method, to create a socket of stream or datagram type and update the
+ * descriptor of the java socketImpl argument.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	thisObj			pointer to java socket object to update the descriptor of
+ * @param	sockType		constant, indicating to create either a stream or datagram socket
+ * @param preferIPv4Stack if application preference is to use only IPv4 sockets (default is false)
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+void
+createSocket (JNIEnv * env, jobject thisObjFD, int sockType,
+              jboolean preferIPv4Stack)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  hysocket_t sockdesc;
+  int family = HYADDR_FAMILY_AFINET4;
+  int supportsIPv6 = JCL_CACHE_GET (env, jcl_supports_ipv6);
+
+  if (supportsIPv6 && !(preferIPv4Stack))
+    {
+      /* We are creating a server socket on the any address */
+      family = HYADDR_FAMILY_UNSPEC;
+    }
+
+  result = hysock_socket (&sockdesc, family, sockType, HYSOCK_DEFPROTOCOL);
+  if (0 != result)
+    {
+      /* ok now if we tried to create an IPv6 socket and it failed it could be that the
+         platform does not have IPv6 enabled.  In this case we should revert back to 
+         creating an IPv4 socket */
+      if (HYADDR_FAMILY_UNSPEC == family)
+        {
+          /* now try to create an IPv4 socket */
+          family = HYADDR_FAMILY_AFINET4;
+          result =
+            hysock_socket (&sockdesc, family, sockType, HYSOCK_DEFPROTOCOL);
+        }
+
+      if (0 != result)
+        {
+          throwJavaNetSocketException (env, result);
+        }
+    }
+
+  if (0 == result)
+    {
+      setJavaIoFileDescriptorContentsAsPointer (env, thisObjFD, sockdesc);
+    }
+}
+
+/**
+ * Answer the linger value of the socket argument.  A value of -1 indicates linger is disabled.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to query
+ *
+ * @return	the Integer value of the socket linger, in milliSeconds
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+jobject
+getLingerOption (JNIEnv * env, hysocket_t hysocketP)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  hylinger_struct lingerOpt;
+  U_16 linger;
+  BOOLEAN enabled;
+  jobject option;
+
+  result = hysock_linger_init (&lingerOpt, 0, 0);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+      return NULL;
+    }
+  result =
+    hysock_getopt_linger (hysocketP, HY_SOL_SOCKET, HY_SO_LINGER, &lingerOpt);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+      return NULL;
+    }
+  hysock_linger_enabled (&lingerOpt, &enabled);
+  if (enabled)
+    {
+      hysock_linger_linger (&lingerOpt, &linger);
+      option = newJavaLangInteger (env, linger);
+    }
+  else
+    {
+      option = newJavaLangInteger (env, -1);
+    }
+  return option;
+}
+
+/**
+ * Answer the multicast interface address of the socket argument.  Implemented by getting
+ * the multicast interface option at the HY_IPPROTO_IP level on the socket.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to query
+ *
+ * @return	the InetAddress for the socket multicast interface
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+jobject
+getMcastInterface (JNIEnv * env, hysocket_t hysocketP)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  U_8 byte_array[HYSOCK_INADDR6_LEN];
+  hysockaddr_struct sockaddrP;
+  U_32 length;
+  U_32 scope_id = 0;
+
+  memset (byte_array, 0, HYSOCK_INADDR6_LEN);
+  hysock_sockaddr_init6 (&sockaddrP, byte_array, HYSOCK_INADDR_LEN,
+                         HYADDR_FAMILY_AFINET4, 0, 0, 0, hysocketP);
+
+  result =
+    hysock_getopt_sockaddr (hysocketP, HY_IPPROTO_IP, HY_MCAST_INTERFACE,
+                            &sockaddrP);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+      return NULL;
+    }
+  hysock_sockaddr_address6 (&sockaddrP, byte_array, &length, &scope_id);
+  return newJavaNetInetAddressGenericB (env, byte_array, length, scope_id);
+
+}
+
+/**
+ * Answer the receive buffer size for the socket argument.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to query
+ *
+ * @return	the receive buffer size, as an Integer value
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+jobject
+getReceiveBufferSize (JNIEnv * env, hysocket_t hysocketP)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  I_32 optval = 0;
+
+  result =
+    hysock_getopt_int (hysocketP, HY_SOL_SOCKET, HY_SO_RCVBUF, &optval);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+      return NULL;
+    }
+  return newJavaLangInteger (env, optval);
+}
+
+/**
+ * Answer the send buffer size for the socket argument.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to query
+ *
+ * @return	the send buffer size, as an Integer value
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+jobject
+getSendBufferSize (JNIEnv * env, hysocket_t hysocketP)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  I_32 optval = 0;
+
+  result =
+    hysock_getopt_int (hysocketP, HY_SOL_SOCKET, HY_SO_SNDBUF, &optval);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+      return NULL;
+    }
+  return newJavaLangInteger (env, optval);
+}
+
+/**
+ * Join the nominated multicast group on the specified socket .  Implemented by setting
+ * the multicast 'add membership' option at the HY_IPPROTO_IP level on the socket.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to join on
+ * @param	optVal			pointer to the InetAddress, the multicast group to join
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+void
+mcastAddMembership (JNIEnv * env, hysocket_t hysocketP, jobject optVal,
+                    BOOLEAN ignoreIF)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  U_8 nipmcast[HYSOCK_INADDR6_LEN], nipInterface[HYSOCK_INADDR6_LEN];
+  U_32 length, lengthIF = HYSOCK_INADDR_LEN;
+  hyipmreq_struct ipmreqP;
+  hysockaddr_struct sockaddrP;
+  hyipv6_mreq_struct ipv6Mreq;
+  U_32 interfaceIndex;
+  U_32 scope_id = 0;
+
+  /* JNI objects needed to access the information in the optVal oject passed in */
+  /* the object passed in is a GenericIPMreq object */
+  jclass cls;
+  jfieldID multiaddrID;
+  jfieldID interfaceAddrID;
+  jfieldID isIPV6AddressID;
+  jfieldID interfaceIdxID;
+  jobject multiaddr;
+  jobject interfaceAddr;
+  jboolean isIPV6Address;
+  jint interfaceIdx;
+  jclass inetAddressClass;
+
+  memset (nipInterface, 0, HYSOCK_INADDR6_LEN);
+
+  /* check whether we are getting an InetAddress or an Generic IPMreq, for now we support both so that we will not
+     break the tests */
+  inetAddressClass = (*env)->FindClass (env, "java/net/InetAddress");
+  if ((*env)->IsInstanceOf (env, optVal, inetAddressClass))
+    {
+
+      netGetJavaNetInetAddressValue (env, optVal, nipmcast, &length);
+
+      if (!ignoreIF)
+        {
+          /* nipInterface is initialized to zero and we are supposed to initialize this with zero */
+          hysock_sockaddr_init6 (&sockaddrP, nipInterface, HYSOCK_INADDR_LEN,
+                                 HYADDR_FAMILY_AFINET4, 0, 0, 0, hysocketP);
+          result =
+            hysock_getopt_sockaddr (hysocketP, HY_IPPROTO_IP,
+                                    HY_MCAST_INTERFACE, &sockaddrP);
+          if (0 != result)
+            {
+              throwJavaNetSocketException (env, result);
+              return;
+            }
+          hysock_sockaddr_address6 (&sockaddrP, nipInterface, &lengthIF,
+                                    &scope_id);
+        }
+
+      result =
+        hysock_ipmreq_init (&ipmreqP, *((U_32 *) nipmcast),
+                            *((U_32 *) nipInterface));
+      if (0 != result)
+        {
+          throwJavaNetSocketException (env, result);
+          return;
+        }
+      result =
+        hysock_setopt_ipmreq (hysocketP, HY_IPPROTO_IP,
+                              HY_MCAST_ADD_MEMBERSHIP, &ipmreqP);
+      if (0 != result)
+        {
+          throwJavaNetSocketException (env, result);
+        }
+    }
+  else
+    {
+      /* we need the multicast address and isIPV6Address regardless of the type of address */
+      cls = (*env)->GetObjectClass (env, optVal);
+      multiaddrID =
+        (*env)->GetFieldID (env, cls, "multiaddr", "Ljava/net/InetAddress;");
+      isIPV6AddressID = (*env)->GetFieldID (env, cls, "isIPV6Address", "Z");
+      isIPV6Address = (*env)->GetBooleanField (env, optVal, isIPV6AddressID);
+      multiaddr = (*env)->GetObjectField (env, optVal, multiaddrID);
+      netGetJavaNetInetAddressValue (env, multiaddr, nipmcast, &length);
+
+      /* now get either the address or the index depending on wether it is an IPV4 or IPV6 address 
+         and add the mcast address */
+      if (isIPV6Address)
+        {
+          /* ok we need to use an IPV6_MREQ.  */
+
+          /* get the interface index */
+          interfaceIdxID = (*env)->GetFieldID (env, cls, "interfaceIdx", "I");
+          interfaceIdx = (*env)->GetIntField (env, optVal, interfaceIdxID);
+          interfaceIndex = interfaceIdx;
+          if ((!ignoreIF) && (0 == interfaceIndex))
+            {
+              result =
+                hysock_getopt_int (hysocketP, HY_IPPROTO_IPV6,
+                                   HY_MCAST_INTERFACE_2, &interfaceIndex);
+              if (0 != result)
+                {
+                  throwJavaNetSocketException (env, result);
+                  return;
+                }
+            }
+
+          /* get the multicast group address , multiaddr allready has the multicast group address */
+          interfaceIdxID = (*env)->GetFieldID (env, cls, "interfaceIdx", "I");
+          interfaceIdx = (*env)->GetIntField (env, optVal, interfaceIdxID);
+
+          /* initiaze the ip_mreq with the multicast address passed in and the appropriate interface number */
+          result =
+            hysock_ipv6_mreq_init (&ipv6Mreq, ((U_8 *) multiaddr),
+                                   interfaceIdx);
+          if (0 != result)
+            {
+              throwJavaNetSocketException (env, result);
+              return;
+            }
+
+          result =
+            hysock_setopt_ipv6_mreq (hysocketP, HY_IPPROTO_IPV6,
+                                     HY_IPV6_ADD_MEMBERSHIP, &ipv6Mreq);
+          if (0 != result)
+            {
+              throwJavaNetSocketException (env, result);
+              return;
+            }
+          return;
+        }
+      else
+        {
+          /* we need to use an IP_MREQ as it is an IPV4 address */
+          interfaceAddrID =
+            (*env)->GetFieldID (env, cls, "interfaceAddr",
+                                "Ljava/net/InetAddress;");
+          interfaceAddr =
+            (*env)->GetObjectField (env, optVal, interfaceAddrID);
+
+          /* if an interfaceAddr was passed then use that value, otherwise set the interface to all 0 to 
+             indicate the system should select the interface used */
+
+          if (NULL != interfaceAddr)
+            {
+              netGetJavaNetInetAddressValue (env, interfaceAddr, nipInterface,
+                                             &length);
+            }
+          else
+            {
+              memset (nipInterface, 0, HYSOCK_INADDR6_LEN);
+            }
+
+          /* if we did not pass in an interface and we are not ignoring the interface that was set on the socket then 
+             get address for the interface set and included that in the ip_mreq */
+          if ((!ignoreIF) && (NULL == interfaceAddr))
+            {
+              /* nipInterface is initialized to zero and we are supposed to initialize this with zero */
+              hysock_sockaddr_init6 (&sockaddrP, nipInterface,
+                                     HYSOCK_INADDR_LEN, HYADDR_FAMILY_AFINET4,
+                                     0, 0, 0, hysocketP);
+              result =
+                hysock_getopt_sockaddr (hysocketP, HY_IPPROTO_IP,
+                                        HY_MCAST_INTERFACE, &sockaddrP);
+              if (0 != result)
+                {
+                  throwJavaNetSocketException (env, result);
+                  return;
+                }
+              hysock_sockaddr_address6 (&sockaddrP, nipInterface, &lengthIF,
+                                        &scope_id);
+            }
+
+          /* initiaze the ip_mreq with the multicast address passed in and the appropriate interface address */
+          result =
+            hysock_ipmreq_init (&ipmreqP, *((U_32 *) nipmcast),
+                                *((U_32 *) nipInterface));
+          if (0 != result)
+            {
+              throwJavaNetSocketException (env, result);
+              return;
+            }
+
+          /* add the multicast address */
+          result =
+            hysock_setopt_ipmreq (hysocketP, HY_IPPROTO_IP,
+                                  HY_MCAST_ADD_MEMBERSHIP, &ipmreqP);
+          if (0 != result)
+            {
+              throwJavaNetSocketException (env, result);
+              return;
+            }
+        }
+      return;
+    }
+}
+
+/**
+ * Leave the nominated multicast group on the specified socket .  Implemented by setting
+ * the multicast 'drop membership' option at the HY_IPPROTO_IP level on the socket.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to leave on
+ * @param	optVal			pointer to the InetAddress, the multicast group to drop
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+void
+mcastDropMembership (JNIEnv * env, hysocket_t hysocketP, jobject optVal,
+                     BOOLEAN ignoreIF)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  hyipmreq_struct ipmreqP;
+  hysockaddr_struct sockaddrP;
+  U_32 length, lengthIF;
+  U_8 nipmcast[HYSOCK_INADDR6_LEN];
+  U_8 nipInterface[HYSOCK_INADDR6_LEN];
+  hyipv6_mreq_struct ipv6Mreq;
+  U_32 interfaceIndex;
+  U_32 scope_id = 0;
+
+/* JNI objects needed to access the information in the optVal oject passed in */
+  /* the object passed in is a GenericIPMreq object */
+  jclass cls;
+  jfieldID multiaddrID;
+  jfieldID interfaceAddrID;
+  jfieldID isIPV6AddressID;
+  jfieldID interfaceIdxID;
+  jobject multiaddr;
+  jobject interfaceAddr;
+  jboolean isIPV6Address;
+  jint interfaceIdx;
+  jclass inetAddressClass;
+
+  memset (nipInterface, 0, HYSOCK_INADDR6_LEN);
+
+  /* check whether we are getting an InetAddress or an Generic IPMreq, for now we support both so that we will not
+     break the tests */
+  inetAddressClass = (*env)->FindClass (env, "java/net/InetAddress");
+  if ((*env)->IsInstanceOf (env, optVal, inetAddressClass))
+    {
+      netGetJavaNetInetAddressValue (env, optVal, nipmcast, &length);
+      if (!ignoreIF)
+        {
+          hysock_sockaddr_init6 (&sockaddrP, nipInterface, length,
+                                 HYADDR_FAMILY_AFINET4, 0, 0, 0, hysocketP);
+          result =
+            hysock_getopt_sockaddr (hysocketP, HY_IPPROTO_IP,
+                                    HY_MCAST_INTERFACE, &sockaddrP);
+          if (0 != result)
+            {
+              throwJavaNetSocketException (env, result);
+              return;
+            }
+          hysock_sockaddr_address6 (&sockaddrP, nipInterface, &lengthIF,
+                                    &scope_id);
+        }
+
+      result =
+        hysock_ipmreq_init (&ipmreqP, *((int *) nipmcast),
+                            *((int *) nipInterface));
+      if (0 != result)
+        {
+          throwJavaNetSocketException (env, result);
+          return;
+        }
+
+      result =
+        hysock_setopt_ipmreq (hysocketP, HY_IPPROTO_IP,
+                              HY_MCAST_DROP_MEMBERSHIP, &ipmreqP);
+      if (0 != result)
+        {
+          throwJavaNetSocketException (env, result);
+        }
+    }
+  else
+    {
+      /* we need the multicast address and isIPV6Address regardless of the type of address */
+      cls = (*env)->GetObjectClass (env, optVal);
+      multiaddrID =
+        (*env)->GetFieldID (env, cls, "multiaddr", "Ljava/net/InetAddress;");
+      isIPV6AddressID = (*env)->GetFieldID (env, cls, "isIPV6Address", "Z");
+      isIPV6Address = (*env)->GetBooleanField (env, optVal, isIPV6AddressID);
+      multiaddr = (*env)->GetObjectField (env, optVal, multiaddrID);
+      netGetJavaNetInetAddressValue (env, multiaddr, nipmcast, &length);
+
+      /* now get either the address or the index depending on wether it is an IPV4 or IPV6 address 
+         and add the mcast address */
+      if (isIPV6Address)
+        {
+          /* ok we need to use an IPV6_MREQ.  */
+
+          /* get the interface index */
+          interfaceIdxID = (*env)->GetFieldID (env, cls, "interfaceIdx", "I");
+          interfaceIdx = (*env)->GetIntField (env, optVal, interfaceIdxID);
+          interfaceIndex = interfaceIdx;
+          if ((!ignoreIF) && (0 == interfaceIndex))
+            {
+              result =
+                hysock_getopt_int (hysocketP, HY_IPPROTO_IPV6,
+                                   HY_MCAST_INTERFACE_2, &interfaceIndex);
+              if (0 != result)
+                {
+                  throwJavaNetSocketException (env, result);
+                  return;
+                }
+            }
+
+          /* get the multicast group address , multiaddr allready has the multicast group address */
+          interfaceIdxID = (*env)->GetFieldID (env, cls, "interfaceIdx", "I");
+          interfaceIdx = (*env)->GetIntField (env, optVal, interfaceIdxID);
+
+          /* initiaze the ip_mreq with the multicast address passed in and the appropriate interface number */
+          result =
+            hysock_ipv6_mreq_init (&ipv6Mreq, ((U_8 *) multiaddr),
+                                   interfaceIdx);
+          if (0 != result)
+            {
+              throwJavaNetSocketException (env, result);
+              return;
+            }
+
+          result =
+            hysock_setopt_ipv6_mreq (hysocketP, HY_IPPROTO_IPV6,
+                                     HY_IPV6_DROP_MEMBERSHIP, &ipv6Mreq);
+          if (0 != result)
+            {
+              throwJavaNetSocketException (env, result);
+              return;
+            }
+          return;
+        }
+      else
+        {
+          /* we need to use an IP_MREQ as it is an IPV4 address */
+          interfaceAddrID =
+            (*env)->GetFieldID (env, cls, "interfaceAddr",
+                                "Ljava/net/InetAddress;");
+          interfaceAddr =
+            (*env)->GetObjectField (env, optVal, interfaceAddrID);
+
+          /* if an interfaceAddr was passed then use that value, otherwise set the interface to all 0 to 
+             indicate the system should select the interface used */
+          if (NULL != interfaceAddr)
+            {
+              netGetJavaNetInetAddressValue (env, interfaceAddr, nipInterface,
+                                             &length);
+            }
+          else
+            {
+              memset (nipInterface, 0, HYSOCK_INADDR6_LEN);
+            }
+
+          if ((!ignoreIF) && (NULL == interfaceAddr))
+            {
+              /* nipInterface is initialized to zero and we are supposed to initialize this with zero */
+              hysock_sockaddr_init6 (&sockaddrP, nipInterface,
+                                     HYSOCK_INADDR_LEN, HYADDR_FAMILY_AFINET4,
+                                     0, 0, 0, hysocketP);
+              result =
+                hysock_getopt_sockaddr (hysocketP, HY_IPPROTO_IP,
+                                        HY_MCAST_INTERFACE, &sockaddrP);
+              if (0 != result)
+                {
+                  throwJavaNetSocketException (env, result);
+                  return;
+                }
+              hysock_sockaddr_address6 (&sockaddrP, nipInterface, &lengthIF,
+                                        &scope_id);
+            }
+
+          /* initiaze the ip_mreq with the multicast address passed in and the appropriate interface address */
+          result =
+            hysock_ipmreq_init (&ipmreqP, *((U_32 *) nipmcast),
+                                *((U_32 *) nipInterface));
+          if (0 != result)
+            {
+              throwJavaNetSocketException (env, result);
+              return;
+            }
+
+          /* drop the multicast address */
+          result =
+            hysock_setopt_ipmreq (hysocketP, HY_IPPROTO_IP,
+                                  HY_MCAST_DROP_MEMBERSHIP, &ipmreqP);
+          if (0 != result)
+            {
+              throwJavaNetSocketException (env, result);
+              return;
+            }
+        }
+      return;
+    }
+}
+
+/**
+ * Set the linger value for the socket argument.  A value of -1 indicates linger is disabled.
+ * Note, the optVal from Java is in milliseconds.
+ * The caller is expected to limit the value of optVal to 65535000 (mSec),
+ * which is the max portable linger value.
+ * Since the IP stack deals in seconds, any attempt to set a linger value 0 < linger < 1 sec, will
+ * set a value of 1 second, so that truncation does not yield the unexpected result of linger indefinitely.
+ *
+ * @param	env			pointer to the JNI library
+ * @param	socketP	pointer to the hysocket to set linger on
+ * @param	optVal		the linger value to set, in milliSeconds
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+void
+setLingerOption (JNIEnv * env, hysocket_t hysocketP, jobject optVal)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  hylinger_struct lingerOpt;
+  I_32 enabled = 0;
+  I_32 result = 0;
+
+  I_32 value = intValue (env, optVal);
+  enabled = value >= 0;
+  result = hysock_linger_init (&lingerOpt, enabled, (U_16) value);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+      return;
+    }
+  result =
+    hysock_setopt_linger (hysocketP, HY_SOL_SOCKET, HY_SO_LINGER, &lingerOpt);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+    }
+}
+
+/**
+ * Set the multicast interface address of the socket argument.  Implemented by setting
+ * the multicast interface option at the HY_IPPROTO_IP level on the socket.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to set the interface on
+ * @param	optVal			pointer to the InetAddress representing the interface address
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+void
+setMcastInterface (JNIEnv * env, hysocket_t hysocketP, jobject optVal)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  int length;
+  U_8 address[HYSOCK_INADDR6_LEN];
+  hysockaddr_struct sockaddrP;
+
+  netGetJavaNetInetAddressValue (env, optVal, address, &length);
+  hysock_sockaddr_init6 (&sockaddrP, address, length, HYADDR_FAMILY_AFINET4,
+                         0, 0, 0, hysocketP);
+  result =
+    hysock_setopt_sockaddr (hysocketP, HY_IPPROTO_IP, HY_MCAST_INTERFACE,
+                            &sockaddrP);
+  if (0 != result)
+    throwJavaNetSocketException (env, result);
+}
+
+/**
+ * Set the receive buffer size for the socket argument.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to set receive buffer size on
+ * @param	optVal			the buffer size to set
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+void
+setReceiveBufferSize (JNIEnv * env, hysocket_t hysocketP, jobject optVal)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  I_32 value;
+
+  value = intValue (env, optVal);
+  result = hysock_setopt_int (hysocketP, HY_SOL_SOCKET, HY_SO_RCVBUF, &value);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+    }
+}
+
+/**
+ * Set the send buffer size for the socket argument.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to set send buffer size on
+ * @param	optVal			the buffer size to set
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+void
+setSendBufferSize (JNIEnv * env, hysocket_t hysocketP, jobject optVal)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  I_32 value;
+
+  value = intValue (env, optVal);
+  result = hysock_setopt_int (hysocketP, HY_SOL_SOCKET, HY_SO_SNDBUF, &value);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+    }
+}
+
+/**
+ * Answer the local host address to which the socket argument is bound.
+ *
+ * @param	env					pointer to the JNI library
+ * @param	thisClz				pointer to the class of the receiver (of the java message)
+ * @param	fileDescriptor 	pointer to the file descriptor of the socket to query
+ * @param preferIPv6Addresses on V4/V6 nodes, a preference as to which address to return for the node
+ *
+ * @return	the InetAddress, representing the local host address to which the socket is bound
+ */
+
+jobject JNICALL
+Java_java_net_Socket_getSocketLocalAddressImpl (JNIEnv * env, jclass thisClz,
+                                                jobject fileDescriptor,
+                                                jboolean preferIPv6Addresses)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  hysockaddr_struct sockaddrP;
+  jbyte byte_array[HYSOCK_INADDR6_LEN];
+  U_32 length;
+  U_32 scope_id = 0;
+  memset (byte_array, 0, HYSOCK_INADDR6_LEN);
+
+  result =
+    netGetSockAddr (env, fileDescriptor, &sockaddrP, preferIPv6Addresses);
+  if (0 != result)
+    {
+      return newJavaNetInetAddressGenericB (env, byte_array,
+                                            HYSOCK_INADDR_LEN, 0);
+      /*The Java spec allows no exception on this call */
+    }
+  else
+    {
+      hysock_sockaddr_address6 (&sockaddrP, byte_array, &length, &scope_id);
+      return newJavaNetInetAddressGenericB (env, byte_array, length,
+                                            scope_id);
+    }
+}
+
+/**
+ * Answer the local port to which the socket argument is bound.
+ *
+ * @param	env					pointer to the JNI library
+ * @param	thisClz				pointer to the class of the receiver (of the java message)
+ * @param	fileDescriptor 	pointer to the file descriptor of the socket to query
+ * @param preferIPv6Addresses on V4/V6 nodes, a preference as to which address to return for the node
+ *
+ * @return	the local host port to which the socket is bound
+ */
+
+jint JNICALL
+Java_java_net_Socket_getSocketLocalPortImpl (JNIEnv * env, jclass thisClz,
+                                             jobject fileDescriptor,
+                                             jboolean preferIPv6Addresses)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  hysockaddr_struct sockaddrP;
+  U_16 nPort, hPort;
+
+  result =
+    netGetSockAddr (env, fileDescriptor, &sockaddrP, preferIPv6Addresses);
+  if (0 != result)
+    {
+      return (jint) 0;          /* The java spec does not indicate any exceptions on this call */
+    }
+  else
+    {
+      nPort = hysock_sockaddr_port (&sockaddrP);
+      hPort = hysock_ntohs (nPort);
+      return (jint) hPort;
+    }
+}
+
+/**
+ * Answer the value of the socket option for the socket argument.  Refer to the file nethelp.h
+ * for the declarations which map the java option constants to portLib constants.
+ *
+ * @param	env					pointer to the JNI library
+ * @param	thisClz				pointer to the class of the receiver (of the java message)
+ * @param	fileDescriptor 	pointer to the file descriptor of the socket to query
+ * @param	anOption			a constant, representing the option type to query
+ *
+ * @return	the java Object, represent the option value
+ * @exception SocketException	if an error occurs during the call
+ */
+
+jobject JNICALL
+Java_java_net_Socket_getSocketOptionImpl (JNIEnv * env, jclass thisClz,
+                                          jobject aFileDescriptor,
+                                          jint anOption)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  hysocket_t hysocketP;
+
+  hysocketP = getJavaIoFileDescriptorContentsAsPointer (env, aFileDescriptor);
+  if (!hysock_socketIsValid (hysocketP))
+    {
+      throwJavaNetSocketException (env, HYPORT_ERROR_SOCKET_BADSOCKET);
+      return NULL;
+    }
+  switch ((I_32) anOption & 0xffff)
+    {
+    case JAVASOCKOPT_SO_LINGER:
+      return getLingerOption (env, hysocketP);
+    case JAVASOCKOPT_TCP_NODELAY:
+      if ((anOption >> 16) & BROKEN_TCP_NODELAY)
+        return NULL;
+      return getBooleanValue (env, hysocketP, HY_IPPROTO_TCP, HY_TCP_NODELAY);
+    case JAVASOCKOPT_MCAST_TTL:
+      if ((anOption >> 16) & BROKEN_MULTICAST_TTL)
+        return newJavaLangByte (env, 0);
+      return getByteSocketOption (env, hysocketP, HY_MCAST_TTL);
+    case JAVASOCKOPT_MCAST_INTERFACE:
+      if ((anOption >> 16) & BROKEN_MULTICAST_IF)
+        return NULL;
+      return getMcastInterface (env, hysocketP);
+    case JAVASOCKOPT_IP_MULTICAST_IF2:
+      return getIPV6McastInterface (env, hysocketP);
+    case JAVASOCKOPT_SO_SNDBUF:
+      return getSendBufferSize (env, hysocketP);
+    case JAVASOCKOPT_SO_RCVBUF:
+      return getReceiveBufferSize (env, hysocketP);
+    case JAVASOCKOPT_SO_BROADCAST:
+      return getBooleanValue (env, hysocketP, HY_SOL_SOCKET, HY_SO_BROADCAST);
+    case JAVASOCKOPT_SO_REUSEADDR:
+      return getBooleanValue (env, hysocketP, HY_SOL_SOCKET, HY_SO_REUSEADDR);
+    case JAVASOCKOPT_SO_REUSEPORT:
+      return getBooleanValue (env, hysocketP, HY_SOL_SOCKET, HY_SO_REUSEPORT);
+    case JAVASOCKOPT_SO_KEEPALIVE:
+      return getBooleanValue (env, hysocketP, HY_SOL_SOCKET, HY_SO_KEEPALIVE);
+    case JAVASOCKOPT_SO_OOBINLINE:
+      return getBooleanValue (env, hysocketP, HY_SOL_SOCKET, HY_SO_OOBINLINE);
+    case JAVASOCKOPT_IP_MULTICAST_LOOP:
+      return getBooleanValue (env, hysocketP, HY_IPPROTO_IP,
+                              HY_IP_MULTICAST_LOOP);
+    case JAVASOCKOPT_IP_TOS:
+      return getIntegerValue (env, hysocketP, HY_IPPROTO_IP, HY_IP_TOS);
+
+    default:
+      throwJavaNetSocketException (env, HYPORT_ERROR_SOCKET_OPTUNSUPP);
+      return NULL;
+    }
+}
+
+/**
+ * Set the value of the socket option to the nominated value.  Refer to the file nethelp.h
+ * for the declarations which map the java option constants to portLib constants.
+ *
+ * @param	env					pointer to the JNI library
+ * @param	thisClz				pointer to the class of the receiver (of the java message)
+ * @param	fileDescriptor 	pointer to the file descriptor of the socket to set the option on
+ * @param	anOption			a constant, representing the option type to set
+ * @param	aValue				the option value to set
+ *
+ * @exception SocketException	if an error occurs during the call
+ */
+/* Support datagram broadcasts */
+
+void JNICALL
+Java_java_net_Socket_setSocketOptionImpl (JNIEnv * env, jclass thisClz,
+                                          jobject aFileDescriptor,
+                                          jint anOption, jobject aValue)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  hysocket_t hysocketP;
+
+  hysocketP = getJavaIoFileDescriptorContentsAsPointer (env, aFileDescriptor);
+  if (!hysock_socketIsValid (hysocketP))
+    {
+      throwJavaNetSocketException (env, HYPORT_ERROR_SOCKET_BADSOCKET);
+      return;
+    }
+  switch ((I_32) anOption & 0xffff)
+    {
+    case JAVASOCKOPT_SO_LINGER:
+      setLingerOption (env, hysocketP, aValue);
+      break;
+    case JAVASOCKOPT_TCP_NODELAY:
+      if ((anOption >> 16) & BROKEN_TCP_NODELAY)
+        return;
+      setBoolSocketOption (env, hysocketP, HY_IPPROTO_TCP, HY_TCP_NODELAY,
+                           aValue);
+      break;
+    case JAVASOCKOPT_MCAST_TTL:
+      if ((anOption >> 16) & BROKEN_MULTICAST_TTL)
+        return;
+      setByteSocketOption (env, hysocketP, HY_MCAST_TTL, aValue);
+      break;
+    case JAVASOCKOPT_MCAST_ADD_MEMBERSHIP:
+      mcastAddMembership (env, hysocketP, aValue,
+                          (anOption >> 16) & BROKEN_MULTICAST_IF);
+      break;
+    case JAVASOCKOPT_MCAST_DROP_MEMBERSHIP:
+      mcastDropMembership (env, hysocketP, aValue,
+                           (anOption >> 16) & BROKEN_MULTICAST_IF);
+      break;
+    case JAVASOCKOPT_MCAST_INTERFACE:
+      if ((anOption >> 16) & BROKEN_MULTICAST_IF)
+        return;
+      setMcastInterface (env, hysocketP, aValue);
+      break;
+    case JAVASOCKOPT_IP_MULTICAST_IF2:
+      setIPV6McastInterface (env, hysocketP, aValue);
+      break;
+    case JAVASOCKOPT_SO_SNDBUF:
+      setSendBufferSize (env, hysocketP, aValue);
+      break;
+    case JAVASOCKOPT_SO_RCVBUF:
+      setReceiveBufferSize (env, hysocketP, aValue);
+      break;
+    case JAVASOCKOPT_SO_BROADCAST:
+      setBoolSocketOption (env, hysocketP, HY_SOL_SOCKET, HY_SO_BROADCAST,
+                           aValue);
+      break;
+    case JAVASOCKOPT_SO_REUSEADDR:
+      setBoolSocketOption (env, hysocketP, HY_SOL_SOCKET, HY_SO_REUSEADDR,
+                           aValue);
+      break;
+    case JAVASOCKOPT_SO_REUSEPORT:
+      setBoolSocketOption (env, hysocketP, HY_SOL_SOCKET, HY_SO_REUSEPORT,
+                           aValue);
+      break;
+    case JAVASOCKOPT_SO_KEEPALIVE:
+      setBoolSocketOption (env, hysocketP, HY_SOL_SOCKET, HY_SO_KEEPALIVE,
+                           aValue);
+      break;
+    case JAVASOCKOPT_SO_OOBINLINE:
+      setBoolSocketOption (env, hysocketP, HY_SOL_SOCKET, HY_SO_OOBINLINE,
+                           aValue);
+      break;
+    case JAVASOCKOPT_IP_MULTICAST_LOOP:
+      setBoolSocketOption (env, hysocketP, HY_IPPROTO_IP,
+                           HY_IP_MULTICAST_LOOP, aValue);
+      break;
+    case JAVASOCKOPT_IP_TOS:
+      setIntegerSocketOption (env, hysocketP, HY_IPPROTO_IP, HY_IP_TOS,
+                              aValue);
+      break;
+    case JAVASOCKOPT_REUSEADDR_AND_REUSEPORT:
+      setReuseAddrAndReusePort (env, hysocketP, aValue);
+      break;
+
+    default:
+      throwJavaNetSocketException (env, HYPORT_ERROR_SOCKET_OPTUNSUPP);
+    }
+}
+
+/**
+ * Close the socket.  The behavior of this call is influenced by the set linger option.
+ * The Java method calling this native, by specification, does not return completion status 
+ * and thus currently this function does return completion status.
+ *
+ * @param	env					pointer to the JNI library
+ * @param	thisClz				pointer to the class of the receiver (of the java message)
+ * @param	fileDescriptor 	pointer to the file descriptor of the socket to close
+ */
+
+/* Descriptor field now set after socket closed. */
+
+void JNICALL
+Java_java_net_Socket_socketCloseImpl (JNIEnv * env, jclass thisClz,
+                                      jobject fileDescriptor)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  hysocket_t socketP;
+
+  socketP = getJavaIoFileDescriptorContentsAsPointer (env, fileDescriptor);
+  if (hysock_socketIsValid (socketP))
+    {
+      /* Set the file descriptor before closing so the select polling loop will terminate. */
+      /* Some platforms wait in the socket close. */
+      setJavaIoFileDescriptorContentsAsPointer (env, fileDescriptor,
+                                                (void *) -1);
+      hysock_close (&socketP);
+    }
+}
+
+void JNICALL
+Java_java_net_Socket_oneTimeInitialization (JNIEnv * env, jclass clazz,
+                                            jboolean jcl_supports_ipv6)
+{
+  netInitializeIDCaches (env, jcl_supports_ipv6);
+}
+
+/**
+ * Set a boolean socket option.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to set the broadcast status of
+ * @param	level			the socket option level
+ * @param	option			the socket option
+ * @param	optVal			the broadcast value to set
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+void
+setBoolSocketOption (JNIEnv * env, hysocket_t hysocketP, int level,
+                     int option, jobject optVal)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  BOOLEAN value;
+
+  value = booleanValue (env, optVal);
+  result = hysock_setopt_bool (hysocketP, level, option, &value);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+    }
+}
+
+/**
+ * A helper method, call selectRead with a small timeout until read is ready or an error occurs.
+ *
+ * @param	env						pointer to the JNI library
+ * @param	hysocketP				socket pointer
+ * @param	timeout				timeout value
+ *
+ */
+
+I_32
+pollSelectRead (JNIEnv * env, jobject fileDescriptor, jint timeout,
+                BOOLEAN poll)
+{
+
+  I_32 result;
+  hysocket_t hysocketP;
+
+#if (defined(WIN32))
+  PORT_ACCESS_FROM_ENV (env);
+  hysocketP = getJavaIoFileDescriptorContentsAsPointer (env, fileDescriptor);
+  if (!hysock_socketIsValid (hysocketP))
+    {
+      throwJavaNetSocketException (env, HYPORT_ERROR_SOCKET_BADSOCKET);
+      return (jint) - 1;
+    }
+
+  if (0 == timeout)
+    {
+      result = hysock_select_read (hysocketP, 0, 0, FALSE);
+    }
+  else
+    {
+      result =
+        hysock_select_read (hysocketP, timeout / 1000,
+                            (timeout % 1000) * 1000, FALSE);
+    }
+  if (HYPORT_ERROR_SOCKET_TIMEOUT == result)
+    throwJavaIoInterruptedIOException (env, result);
+  else if (0 > result)
+    throwJavaNetSocketException (env, result);
+#else
+  PORT_ACCESS_FROM_ENV (env);
+  if (!poll)
+    {
+      /* A zero timeout means wait forever. If not polling, return success */
+      /* and call receive() or accept() to block. */
+      if (!timeout)
+        return 0;
+      hysocketP =
+        getJavaIoFileDescriptorContentsAsPointer (env, fileDescriptor);
+      if (!hysock_socketIsValid (hysocketP))
+        {
+          throwJavaNetSocketException (env, HYPORT_ERROR_SOCKET_BADSOCKET);
+          return (jint) - 1;
+        }
+      result =
+        hysock_select_read (hysocketP, timeout / 1000,
+                            (timeout % 1000) * 1000, FALSE);
+      if (HYPORT_ERROR_SOCKET_TIMEOUT == result)
+        throwJavaIoInterruptedIOException (env, result);
+      else if (0 > result)
+        throwJavaNetSocketException (env, result);
+    }
+  else
+    {
+      I_32 pollTimeout = 100000, pollMsec = 100;
+      UDATA finishTime;
+      IDATA timeLeft = timeout;
+      BOOLEAN hasTimeout = timeout > 0;
+      if (hasTimeout)
+        finishTime = hytime_msec_clock () + (UDATA) timeout;
+    select:
+      /* Fetch the handle every time in case the socket is closed. */
+      hysocketP =
+        getJavaIoFileDescriptorContentsAsPointer (env, fileDescriptor);
+      if (!hysock_socketIsValid (hysocketP))
+        {
+          throwJavaNetSocketException (env, HYPORT_ERROR_SOCKET_INTERRUPTED);
+          return (jint) - 1;
+        }
+      if (hasTimeout)
+        {
+          if (timeLeft - 10 < pollMsec)
+            pollTimeout = timeLeft <= 0 ? 0 : (timeLeft * 1000);
+          result = hysock_select_read (hysocketP, 0, pollTimeout, FALSE);
+          if (HYPORT_ERROR_SOCKET_TIMEOUT == result)
+            {
+              timeLeft = finishTime - hytime_msec_clock ();
+              if (timeLeft <= 0)
+                throwJavaIoInterruptedIOException (env, result);
+              else
+                {
+                  goto select;
+                }
+            }
+          else if (0 > result)
+            throwJavaNetSocketException (env, result);
+        }
+      else
+        {
+          result = hysock_select_read (hysocketP, 0, pollTimeout, FALSE);
+          if (HYPORT_ERROR_SOCKET_TIMEOUT == result)
+            {
+              goto select;
+            }
+          else if (0 > result)
+            throwJavaNetSocketException (env, result);
+        }
+    }
+#endif
+
+  return result;
+}
+
+/**
+ * Answer the status of the specified boolean option for the socket argument.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to query
+ * @param	level			the socket option level
+ * @param	option			the socket option
+ *
+ * @return	the Boolean value
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+jobject
+getBooleanValue (JNIEnv * env, hysocket_t hysocketP, int level, int option)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  BOOLEAN optval;
+
+  result = hysock_getopt_bool (hysocketP, level, option, &optval);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+      return NULL;
+    }
+  return newJavaLangBoolean (env, optval);
+}
+
+jint JNICALL
+Java_java_net_Socket_getSocketFlags (JNIEnv * env, jclass thisClz)
+{
+  /* Return the flags indicating the socket state to save in the class library. */
+  /* 1 - Multicast interface */
+  /* 2 - Multicast TTL */
+  /* 4 - Socket TCP_NODELAY */
+  /* 8 - Calling shutdown output before close when SO_LINGER is set */
+
+  return 0;
+
+}
+
+/**
+ * Answer the byte value of the specified option for the socket argument,
+ * at the HY_IPPROTO_IP level on the socket.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to query
+ * @param	option			the socket option
+ *
+ * @return	a Byte value
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+jobject
+getByteSocketOption (JNIEnv * env, hysocket_t hysocketP, int option)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  U_8 optval;
+
+  result = hysock_getopt_byte (hysocketP, HY_IPPROTO_IP, option, &optval);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+      return NULL;
+    }
+  return newJavaLangByte (env, optval);
+}
+
+/**
+ * Set the byte value of the specified option for the socket argument,
+ * at the HY_IPPROTO_IP level on the socket.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to set the TTL on
+ * @param	option			the socket option
+ * @param	optVal			the value to set
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+void
+setByteSocketOption (JNIEnv * env, hysocket_t hysocketP, int option,
+                     jobject optVal)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  U_8 value;
+
+  value = byteValue (env, optVal);
+  result = hysock_setopt_byte (hysocketP, HY_IPPROTO_IP, option, &value);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+    }
+}
+
+/**
+ * Answer the IPV6 multicast interface index of the socket argument.  Implemented by getting
+ * the multicast interface index at the HY_IPPROTO_IP level on the socket.
+ *
+ * @param	env			pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to query
+ *
+ * @return	the index for the interface interface bound to the multicast socket
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+jobject
+getIPV6McastInterface (JNIEnv * env, hysocket_t hysocketP)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  jint valueJNI;
+  I_32 value;
+
+  /* get the value */
+  result =
+    hysock_getopt_int (hysocketP, HY_IPPROTO_IPV6, HY_MCAST_INTERFACE_2,
+                       &value);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+      return NULL;
+    }
+
+  /* turn it into an integer and return it */
+  valueJNI = value;
+  return newJavaLangInteger (env, value);
+}
+
+/**
+ * Set the multicast interface index of the socket argument.  Implemented by setting
+ * the multicast interface index at the HY_IPPROTO_IP level on the socket.
+ *
+ * @param	env			pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to set the interface on
+ * @param	optVal		pointer to the InetAddress representing the interface address
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+void
+setIPV6McastInterface (JNIEnv * env, hysocket_t hysocketP, jobject optVal)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+
+  /* get the integer value that should have been passed in */
+  jint index = intValue (env, optVal);
+
+  /* set the option */
+  result =
+    hysock_setopt_int (hysocketP, HY_IPPROTO_IPV6, HY_MCAST_INTERFACE_2,
+                       &index);
+  if (0 != result)
+    throwJavaNetSocketException (env, result);
+}
+
+/**
+ * Set an integer socket option.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to set the broadcast status of
+ * @param	level			the socket option level
+ * @param	option			the socket option
+ * @param	optVal			the broadcast value to set
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+void
+setIntegerSocketOption (JNIEnv * env, hysocket_t hysocketP, int level,
+                        int option, jobject optVal)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  U_32 value;
+
+  value = intValue (env, optVal);
+  result = hysock_setopt_int (hysocketP, level, option, &value);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+    }
+}
+
+/**
+ * Answer the status of the specified integer option for the socket argument.
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to query
+ * @param	level			the socket option level
+ * @param	option			the socket option
+ *
+ * @return	the Integer value
+ * @exception	SocketException	if an error occurs during the call
+ */
+
+jobject
+getIntegerValue (JNIEnv * env, hysocket_t hysocketP, int level, int option)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  BOOLEAN optval;
+
+  result = hysock_getopt_int (hysocketP, level, option, &optval);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+      return NULL;
+    }
+
+  return newJavaLangInteger (env, optval);
+}
+
+/**
+ * Set both REUSEADDR and REUSEPORT if appropriate.  Datagram sockets require that when REUSEADDR is set REUSEPORT is also set
+ * on platforms which support this option.  Other types of sockets should not have this behavior so we cannot do it lower down in the port
+ * library
+ *
+ * @param	env				pointer to the JNI library
+ * @param	socketP		pointer to the hysocket to set the broadcast status of
+ * @param	level			the socket option level
+ * @param	option			the socket option
+ * @param	optVal			the broadcast value to set
+ *
+ * @exception	SocketException	if an error occurs during the call
+ */
+void
+setReuseAddrAndReusePort (JNIEnv * env, hysocket_t hysocketP, jobject optVal)
+{
+  PORT_ACCESS_FROM_ENV (env);
+  I_32 result;
+  U_32 value;
+
+  value = intValue (env, optVal);
+
+  /* first set REUSEPORT.  Ignore the error as not all platforms will support this */
+  result =
+    hysock_setopt_int (hysocketP, HY_SOL_SOCKET, HY_SO_REUSEPORT, &value);
+
+  /* now set REUSEADDR.  We expect this to work */
+  result =
+    hysock_setopt_int (hysocketP, HY_SOL_SOCKET, HY_SO_REUSEADDR, &value);
+  if (0 != result)
+    {
+      throwJavaNetSocketException (env, result);
+    }
+}

Added: incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/luni/timezone.c
URL: http://svn.apache.org/viewcvs/incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/luni/timezone.c?rev=350181&view=auto
==============================================================================
--- incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/luni/timezone.c (added)
+++ incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/luni/timezone.c Wed Nov 30 21:29:27 2005
@@ -0,0 +1,28 @@
+/* Copyright 1998, 2005 The Apache Software Foundation or its licensors, as applicable
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <string.h>
+#include <stdlib.h>
+#include "jcl.h"
+#include "helpers.h"
+
+jstring JNICALL
+Java_java_util_TimeZone_getCustomTimeZone (JNIEnv * env, jclass clazz,
+                                           jintArray tzinfo,
+                                           jbooleanArray isCustomTimeZone)
+{
+  /* fill tzinfo array with Custom timezone information and return timezone location name */
+  return getCustomTimeZoneInfo (env, tzinfo, isCustomTimeZone);
+}

Added: incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/makefile
URL: http://svn.apache.org/viewcvs/incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/makefile?rev=350181&view=auto
==============================================================================
--- incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/makefile (added)
+++ incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/makefile Wed Nov 30 21:29:27 2005
@@ -0,0 +1,84 @@
+# Copyright 1998, 2005 The Apache Software Foundation or its licensors, as applicable
+# 
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+# 
+#     http://www.apache.org/licenses/LICENSE-2.0
+# 
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+#
+# Main Makefile
+#
+
+all: \
+	_sig _common _pool _thread _port _fdlibm _zip \
+	_zlib _vmi _luni _nio _archive \
+	_math _text _launcher
+
+_pool: 
+	(cd pool && $(MAKE) && cd ..)
+
+_common:
+	(cd common && $(MAKE) && cd ..)
+
+_thread: _pool _common
+	(cd thread && $(MAKE) && cd ..)
+
+_port: _thread _sig
+	(cd port && $(MAKE) && cd ..)
+
+_sig:
+	(cd sig && $(MAKE) && cd ..)
+
+_fdlibm: 
+	(cd fdlibm && $(MAKE) && cd ..)
+
+_zip: 
+	(cd zip && $(MAKE) && cd ..)
+
+_zlib: 
+	(cd zlib && $(MAKE) && cd ..)
+
+_vmi: _zip _pool
+	(cd vmi && $(MAKE) && cd ..)
+
+_luni: _common _sig _zip _zlib _pool _fdlibm _thread _vmi
+	(cd luni && $(MAKE) && cd ..)
+	
+_nio: _sig _zip _zlib _pool _fdlibm _thread _vmi
+	(cd nio && $(MAKE) && cd ..)
+	
+_archive: _common _sig _zip _zlib _pool _fdlibm _thread _vmi
+	(cd archive && $(MAKE) && cd ..)
+	
+_math: _common _sig _zip _zlib _pool _fdlibm _thread _vmi
+	(cd math && $(MAKE) && cd ..)
+	
+_text: _sig _zip _zlib _pool _fdlibm _thread _vmi
+	(cd text && $(MAKE) && cd ..)
+	
+_launcher: _thread _port
+	(cd launcher && $(MAKE) && cd ..)	
+
+clean:
+	(cd sig && $(MAKE) clean && cd ..)
+	(cd pool  && $(MAKE) clean && cd ..)
+	(cd thread && $(MAKE) clean && cd ..)
+	(cd port && $(MAKE) clean && cd ..)
+	(cd fdlibm && $(MAKE) clean && cd ..)
+	(cd zip && $(MAKE) clean && cd ..)
+	(cd zlib && $(MAKE) clean && cd ..)
+	(cd vmi && $(MAKE) clean && cd ..)
+	(cd common && $(MAKE) clean && cd ..)
+	(cd luni && $(MAKE) clean && cd ..)
+	(cd nio && $(MAKE) clean && cd ..)
+	(cd archive && $(MAKE) clean && cd ..)
+	(cd math && $(MAKE) clean && cd ..)
+	(cd text && $(MAKE) clean && cd ..)
+	(cd launcher && $(MAKE) clean && cd ..)

Added: incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/makefile.include
URL: http://svn.apache.org/viewcvs/incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/makefile.include?rev=350181&view=auto
==============================================================================
--- incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/makefile.include (added)
+++ incubator/harmony/enhanced/trunk/sandbox/contribs/ibm_core/native-src/linux.IA32/makefile.include Wed Nov 30 21:29:27 2005
@@ -0,0 +1,24 @@
+# Copyright 1998, 2005 The Apache Software Foundation or its licensors, as applicable
+# 
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+# 
+#     http://www.apache.org/licenses/LICENSE-2.0
+# 
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+#
+# Configuration Makefile
+#
+
+CXX = $(CC)
+CPP = $(CC) -E
+AS = as
+AR = ar
+DLL_LD = $(CC)
+CXX_DLL_LD = $(CXX)



Mime
View raw message