/*

 * Copyright (C) 2009 The Sipdroid Open Source Project

 * Copyright (C) 2007 The Android Open Source Project

 * 

 * This file is part of Sipdroid (http://www.sipdroid.org)

 * 

 * Sipdroid is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 3 of the License, or

 * (at your option) any later version.

 * 

 * This source code is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 * 

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

 * along with this source code; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

#define LOG_TAG "OSNetworkSystem"

#include <android/log.h>

#include "jni.h"

#include "errno.h"

#include <unistd.h>

#include <stdio.h>

#include <sys/socket.h>

#include <netinet/in.h>

#include <netinet/tcp.h>

#include <netdb.h>

#include <sys/time.h>

#include <stdlib.h>

#include <sys/ioctl.h>

#include <sys/un.h>

//#include <cutils/properties.h>

//#include <cutils/adb_networking.h>

//#include <utils/LogSocket.h>

//#include "AndroidSystemNatives.h"

/**

 * @name Socket Errors

 * Error codes for socket operations

 *

 * @internal SOCKERR* range from -200 to -299 avoid overlap

 */

#define SOCKERR_BADSOCKET          -200 /* generic error */

#define SOCKERR_NOTINITIALIZED     -201 /* socket library uninitialized */

#define SOCKERR_BADAF              -202 /* bad address family */

#define SOCKERR_BADPROTO           -203 /* bad protocol */

#define SOCKERR_BADTYPE            -204 /* bad type */

#define SOCKERR_SYSTEMBUSY         -205 /* system busy handling requests */

#define SOCKERR_SYSTEMFULL         -206 /* too many sockets */

#define SOCKERR_NOTCONNECTED       -207 /* socket is not connected */

#define SOCKERR_INTERRUPTED        -208 /* the call was cancelled */

#define SOCKERR_TIMEOUT            -209 /* the operation timed out */

#define SOCKERR_CONNRESET          -210 /* the connection was reset */

#define SOCKERR_WOULDBLOCK         -211 /* the socket is marked as nonblocking operation would block */

#define SOCKERR_ADDRNOTAVAIL       -212 /* address not available */

#define SOCKERR_ADDRINUSE          -213 /* address already in use */

#define SOCKERR_NOTBOUND           -214 /* the socket is not bound */

#define SOCKERR_UNKNOWNSOCKET      -215 /* resolution of fileDescriptor to socket failed */

#define SOCKERR_INVALIDTIMEOUT     -216 /* the specified timeout is invalid */

#define SOCKERR_FDSETFULL          -217 /* Unable to create an FDSET */

#define SOCKERR_TIMEVALFULL        -218 /* Unable to create a TIMEVAL */

#define SOCKERR_REMSOCKSHUTDOWN    -219 /* The remote socket has shutdown gracefully */

#define SOCKERR_NOTLISTENING       -220 /* listen() was not invoked prior to accept() */

#define SOCKERR_NOTSTREAMSOCK      -221 /* The socket does not support connection-oriented service */

#define SOCKERR_ALREADYBOUND       -222 /* The socket is already bound to an address */

#define SOCKERR_NBWITHLINGER       -223 /* The socket is marked non-blocking & SO_LINGER is non-zero */

#define SOCKERR_ISCONNECTED        -224 /* The socket is already connected */

#define SOCKERR_NOBUFFERS          -225 /* No buffer space is available */

#define SOCKERR_HOSTNOTFOUND       -226 /* Authoritative Answer Host not found */

#define SOCKERR_NODATA             -227 /* Valid name, no data record of requested type */

#define SOCKERR_BOUNDORCONN        -228 /* The socket has not been bound or is already connected */

#define SOCKERR_OPNOTSUPP          -229 /* The socket does not support the operation */

#define SOCKERR_OPTUNSUPP          -230 /* The socket option is not supported */

#define SOCKERR_OPTARGSINVALID     -231 /* The socket option arguments are invalid */

#define SOCKERR_SOCKLEVELINVALID   -232 /* The socket level is invalid */

#define SOCKERR_TIMEOUTFAILURE     -233

#define SOCKERR_SOCKADDRALLOCFAIL  -234 /* Unable to allocate the sockaddr structure */

#define SOCKERR_FDSET_SIZEBAD      -235 /* The calculated maximum size of the file descriptor set is bad */

#define SOCKERR_UNKNOWNFLAG        -236 /* The flag is unknown */

#define SOCKERR_MSGSIZE            -237 /* The datagram was too big to fit the specified buffer & was truncated. */

#define SOCKERR_NORECOVERY         -238 /* The operation failed with no recovery possible */

#define SOCKERR_ARGSINVALID        -239 /* The arguments are invalid */

#define SOCKERR_BADDESC            -240 /* The socket argument is not a valid file descriptor */

#define SOCKERR_NOTSOCK            -241 /* The socket argument is not a socket */

#define SOCKERR_HOSTENTALLOCFAIL   -242 /* Unable to allocate the hostent structure */

#define SOCKERR_TIMEVALALLOCFAIL   -243 /* Unable to allocate the timeval structure */

#define SOCKERR_LINGERALLOCFAIL    -244 /* Unable to allocate the linger structure */

#define SOCKERR_IPMREQALLOCFAIL    -245 /* Unable to allocate the ipmreq structure */

#define SOCKERR_FDSETALLOCFAIL     -246 /* Unable to allocate the fdset structure */

#define SOCKERR_OPFAILED           -247 /* Operation failed */

#define SOCKERR_VALUE_NULL         -248 /* The value indexed was NULL */

#define SOCKERR_CONNECTION_REFUSED -249 /* connection was refused */

#define SOCKERR_ENETUNREACH        -250 /* network is not reachable */

#define SOCKERR_EACCES             -251 /* permissions do not allow action on socket */

#define SOCKERR_EHOSTUNREACH       -252 /* no route to host */

#define SOCKERR_EPIPE              -253 /* broken pipe */

#define JAVASOCKOPT_TCP_NODELAY 1

#define JAVASOCKOPT_IP_TOS 3

#define JAVASOCKOPT_SO_REUSEADDR 4

#define JAVASOCKOPT_SO_KEEPALIVE 8

#define JAVASOCKOPT_MCAST_TIME_TO_LIVE 10 /* Currently unused */

#define JAVASOCKOPT_SO_BINDADDR 15

#define JAVASOCKOPT_MCAST_INTERFACE 16

#define JAVASOCKOPT_MCAST_TTL 17

#define JAVASOCKOPT_IP_MULTICAST_LOOP 18

#define JAVASOCKOPT_MCAST_ADD_MEMBERSHIP 19

#define JAVASOCKOPT_MCAST_DROP_MEMBERSHIP 20

#define JAVASOCKOPT_IP_MULTICAST_IF2 31

#define JAVASOCKOPT_SO_BROADCAST 32

#define JAVASOCKOPT_SO_LINGER 128

#define JAVASOCKOPT_REUSEADDR_AND_REUSEPORT  10001

#define JAVASOCKOPT_SO_SNDBUF 4097

#define JAVASOCKOPT_SO_RCVBUF 4098

#define JAVASOCKOPT_SO_RCVTIMEOUT  4102

#define JAVASOCKOPT_SO_OOBINLINE  4099

/* constants for calling multi-call functions */

#define SOCKET_STEP_START 10

#define SOCKET_STEP_CHECK 20

#define SOCKET_STEP_DONE 30

#define BROKEN_MULTICAST_IF 1

#define BROKEN_MULTICAST_TTL 2

#define BROKEN_TCP_NODELAY 4

#define SOCKET_CONNECT_STEP_START 0

#define SOCKET_CONNECT_STEP_CHECK 1

#define SOCKET_OP_NONE 0

#define SOCKET_OP_READ 1

#define SOCKET_OP_WRITE 2

#define SOCKET_READ_WRITE 3

#define SOCKET_MSG_PEEK 1

#define SOCKET_MSG_OOB 2

#define SOCKET_NOFLAGS 0

#undef BUFFERSIZE

#define BUFFERSIZE 2048

// wait for 500000 usec = 0.5 second

#define SEND_RETRY_TIME 500000

struct CachedFields {

    jfieldID fd_descriptor;

    jclass iaddr_class;

    jmethodID iaddr_class_init;

    jmethodID iaddr_getbyaddress;

    jfieldID iaddr_ipaddress;

    jclass genericipmreq_class;

    jclass integer_class;

    jmethodID integer_class_init;

    jfieldID integer_class_value;

    jclass boolean_class;

    jmethodID boolean_class_init;

    jfieldID boolean_class_value;

    jclass byte_class;

    jmethodID byte_class_init;

    jfieldID byte_class_value;

    jclass string_class;

    jmethodID string_class_init;

    jfieldID socketimpl_address;

    jfieldID socketimpl_port;

    jclass dpack_class;

    jfieldID dpack_address;

    jfieldID dpack_port;

    jfieldID dpack_length;

    jclass fd_class;

    jfieldID descriptor;

} gCachedFields;

static int useAdbNetworking = 0;

/* needed for connecting with timeout */

typedef struct selectFDSet {

  int nfds;

  int sock;

  fd_set writeSet;

  fd_set readSet;

  fd_set exceptionSet;

} selectFDSet;

static const char * netLookupErrorString(int anErrorNum);

#define log_socket_close(a,b)

#define log_socket_connect(a,b,c)

#define add_send_stats(a,b)

#define add_recv_stats(a,b)

#define adb_networking_connect_fd(a,b) 0

#define adb_networking_gethostbyname(a,b) 0

#define PROPERTY_VALUE_MAX 1

#define property_get(a,b,c)

#define assert(a)

/*

 * Throw an exception with the specified class and an optional message.

 */

int jniThrowException(JNIEnv* env, const char* className, const char* msg)

{

    jclass exceptionClass;

    exceptionClass = env->FindClass(className);

    if (exceptionClass == NULL) {

//        LOGE("Unable to find exception class %s\n", className);

        assert(0);      /* fatal during dev; should always be fatal? */

        return -1;

    }

    if (env->ThrowNew(exceptionClass, msg) != JNI_OK) {

//        LOGE("Failed throwing '%s' '%s'\n", className, msg);

        assert(!"failed to throw");

    }

    return 0;

}

/*

 * Internal helper function.

 *

 * Get the file descriptor.

 */

static inline int getFd(JNIEnv* env, jobject obj)

{

    return env->GetIntField(obj, gCachedFields.descriptor);

}

/*

 * Internal helper function.

 *

 * Set the file descriptor.

 */

static inline void setFd(JNIEnv* env, jobject obj, jint value)

{

    env->SetIntField(obj, gCachedFields.descriptor, value);

}

/* 

 * For JNIHelp.c

 * Get an int file descriptor from a java.io.FileDescriptor

 */

static int jniGetFDFromFileDescriptor (JNIEnv* env, jobject fileDescriptor) {

    return getFd(env, fileDescriptor);

}

/*

 * For JNIHelp.c

 * Set the descriptor of a java.io.FileDescriptor

 */

static void jniSetFileDescriptorOfFD (JNIEnv* env, jobject fileDescriptor, int value) {

    setFd(env, fileDescriptor, value);

}

/**

 * Throws an SocketException with the message affiliated with the errorCode.

 */

static void throwSocketException(JNIEnv *env, int errorCode) {

    jniThrowException(env, "java/net/SocketException",

        netLookupErrorString(errorCode));

}

/**

 * Throws an IOException with the given message.

 */

static void throwIOExceptionStr(JNIEnv *env, const char *message) {

    jniThrowException(env, "java/io/IOException", message);

}

/**

 * Throws a NullPointerException.

 */

static void throwNullPointerException(JNIEnv *env) {

    jniThrowException(env, "java/lang/NullPointerException", NULL);

}

/**

 * Converts a 4-byte array to a native address structure. Throws a

 * NullPointerException or an IOException in case of error. This is

 * signaled by a return value of -1. The normal return value is 0.

 */

static int javaAddressToStructIn(

        JNIEnv *env, jbyteArray java_address, struct in_addr *address) {

    memset(address, 0, sizeof(address));

    if (java_address == NULL) {

        return -1;

    }

    if (env->GetArrayLength(java_address) != sizeof(address->s_addr)) {

        return -1;

    }

    jbyte * java_address_bytes

        =  env->GetByteArrayElements(java_address, NULL);

    memcpy(&(address->s_addr),

        java_address_bytes,

        sizeof(address->s_addr));

    env->ReleaseByteArrayElements(java_address, java_address_bytes, JNI_ABORT);

    return 0;

}

/**

 * Converts a native address structure to a 4-byte array. Throws a

 * NullPointerException or an IOException in case of error. This is

 * signaled by a return value of -1. The normal return value is 0.

 */

static int structInToJavaAddress(

        JNIEnv *env, struct in_addr *address, jbyteArray java_address) {

    if (java_address == NULL) {

        return -1;

    }

    if (env->GetArrayLength(java_address) != sizeof(address->s_addr)) {

        return -1;

    }

    jbyte *java_address_bytes;

    java_address_bytes = env->GetByteArrayElements(java_address, NULL);

    memcpy(java_address_bytes, &(address->s_addr), sizeof(address->s_addr));

    env->ReleaseByteArrayElements(java_address, java_address_bytes, 0);

    return 0;

}

/**

 * Converts a native address structure to an InetAddress object.

 * Throws a NullPointerException or an IOException in case of

 * error. This is signaled by a return value of -1. The normal

 * return value is 0.

 */

static int socketAddressToInetAddress(JNIEnv *env,

        struct sockaddr_in *sockaddress, jobject inetaddress, int *port) {

    jbyteArray ipaddress;

    int result;

    ipaddress = (jbyteArray)env->GetObjectField(inetaddress,

            gCachedFields.iaddr_ipaddress);

    if (structInToJavaAddress(env, &sockaddress->sin_addr, ipaddress) < 0) {

        return -1;

    }

    *port = ntohs(sockaddress->sin_port);

    return 0;

}

/**

 * Converts an InetAddress object to a native address structure.

 * Throws a NullPointerException or an IOException in case of

 * error. This is signaled by a return value of -1. The normal

 * return value is 0.

 */

static int inetAddressToSocketAddress(JNIEnv *env,

        jobject inetaddress, int port, struct sockaddr_in *sockaddress) {

    jbyteArray ipaddress;

    int result;

    ipaddress = (jbyteArray)env->GetObjectField(inetaddress,

            gCachedFields.iaddr_ipaddress);

    memset(sockaddress, 0, sizeof(sockaddress));

    sockaddress->sin_family = AF_INET;

    sockaddress->sin_port = htons(port);

    if (javaAddressToStructIn(env, ipaddress, &(sockaddress->sin_addr)) < 0) {

        return -1;

    }

    return 0;

}

static jobject structInToInetAddress(JNIEnv *env, struct in_addr *address) {

    jbyteArray bytes;

    int success;

    bytes = env->NewByteArray(4);

    if (bytes == NULL) {

        return NULL;

    }

    if (structInToJavaAddress(env, address, bytes) < 0) {

        return NULL;

    }

    return env->CallStaticObjectMethod(gCachedFields.iaddr_class,

            gCachedFields.iaddr_getbyaddress, bytes);

}

/**

 * Answer a new java.lang.Boolean object.

 *

 * @param env   pointer to the JNI library

 * @param anInt the Boolean constructor argument

 *

 * @return  the new Boolean

 */

static jobject newJavaLangBoolean(JNIEnv * env, jint anInt) {

    jclass tempClass;

    jmethodID tempMethod;

    tempClass = gCachedFields.boolean_class;

    tempMethod = gCachedFields.boolean_class_init;

    return env->NewObject(tempClass, tempMethod, (jboolean) (anInt != 0));

}

/**

 * Answer a new java.lang.Byte object.

 *

 * @param env   pointer to the JNI library

 * @param anInt the Byte constructor argument

 *

 * @return  the new Byte

 */

static jobject newJavaLangByte(JNIEnv * env, jbyte val) {

    jclass tempClass;

    jmethodID tempMethod;

    tempClass = gCachedFields.byte_class;

    tempMethod = gCachedFields.byte_class_init;

    return env->NewObject(tempClass, tempMethod, val);

}

/**

 * Answer a new java.lang.Integer object.

 *

 * @param env   pointer to the JNI library

 * @param anInt the Integer constructor argument

 *

 * @return  the new Integer

 */

static jobject newJavaLangInteger(JNIEnv * env, jint anInt) {

    jclass tempClass;

    jmethodID tempMethod;

    tempClass = gCachedFields.integer_class;

    tempMethod = gCachedFields.integer_class_init;

    return env->NewObject(tempClass, tempMethod, anInt);

}

/**

 * Answer a new java.lang.String object.

 *

 * @param env   pointer to the JNI library

 * @param anInt the byte[] constructor argument

 *

 * @return  the new String

 */

static jobject newJavaLangString(JNIEnv * env, jbyteArray bytes) {

    jclass tempClass;

    jmethodID tempMethod;

    tempClass = gCachedFields.string_class;

    tempMethod = gCachedFields.string_class_init;

    return env->NewObject(tempClass, tempMethod, (jbyteArray) bytes);

}

/**

 * Query OS for timestamp.

 * Retrieve the current value of system clock and convert to milliseconds.

 *

 * @param[in] portLibrary The port library.

 *

 * @return 0 on failure, time value in milliseconds on success.

 * @deprecated Use @ref time_hires_clock and @ref time_hires_delta

 *

 * technically, this should return I_64 since both timeval.tv_sec and

 * timeval.tv_usec are long

 */

static int time_msec_clock() {

    struct timeval tp;

    struct timezone tzp;

    gettimeofday(&tp, &tzp);

    return (tp.tv_sec * 1000) + (tp.tv_usec / 1000);

}

/**

 * check if the passed sockaddr_in struct contains a localhost address

 *

 * @param[in] address pointer to the address to check

 *

 * @return 0 if the passed address isn't a localhost address

 */

static int isLocalhost(struct sockaddr_in *address) {

    // return address == 127.0.0.1

    return (unsigned int) address->sin_addr.s_addr == 16777343;

}

/**

 * Answer the errorString corresponding to the errorNumber, if available.

 * This function will answer a default error string, if the errorNumber is not

 * recognized.

 *

 * This function will have to be reworked to handle internationalization

 * properly, removing the explicit strings.

 *

 * @param anErrorNum    the error code to resolve to a human readable string

 *

 * @return  a human readable error string

 */