socketprotocol_md.c

用于移动设备上的java虚拟机源代码

            *exception = "java/io/IOException";
        } else {
            /* success */
            return fd;
        }
    }

    closesocket(fd);
    return -1;
}

/*=========================================================================
 * FUNCTION:      accept()
 * CLASS:         com.sun.midp.io.j2me.serversocket.Protocol
 * TYPE:          virtual native function
 * OVERVIEW:      Accept and open a connection
 *=======================================================================*/

int prim_com_sun_midp_io_j2me_serversocket_Protocol_accept(int fd)
{
    int res;
    struct sockaddr_in sa;
    int saLen = sizeof (sa);

    res = accept(fd, (struct sockaddr *)&sa, &saLen);

    if ((res == -1) && (errno == EWOULDBLOCK)) {
        res = IO_WOULDBLOCK;
    }

    return res;
}

/*=========================================================================
 * FUNCTION:      close0()
 * CLASS:         com.sun.midp.io.j2me.serversocket.Protocol
 * TYPE:          virtual native function
 * OVERVIEW:      Close a TCP socket
 *=======================================================================*/

int prim_com_sun_midp_io_j2me_serversocket_Protocol_close(int fd)
{
    return prim_com_sun_midp_io_j2me_socket_Protocol_close0(fd);
}

/*=========================================================================
 * FUNCTION:      wsaInit()
 * TYPE:          machine-specific implementation of native function
 * OVERVIEW:      Initialize the windows socket system
 * INTERFACE:
 *   parameters:  none
 *   returns:     none
 *=======================================================================*/

void networkInit(void) {
}

/*=========================================================================
 * FUNCTION:      netError()
 * TYPE:          machine-specific implementation of native function
 * OVERVIEW:      return fatal windows socket error
 * INTERFACE:
 *   parameters:  none
 *   returns:     int
 *=======================================================================*/

int netError(void) {
    int res = errno;
    errno = 0;
    return res;
}



/*=========================================================================
 * FUNCTION:      getsockopt0()
 * CLASS:         com.sun.midp.io.j2me.socket.Protocol
 * TYPE:          virtual native function
 * OVERVIEW:      Get a socket option value.
 *=======================================================================*/
int prim_com_sun_midp_io_j2me_socket_Protocol_getsockopt0(int fd, int flag, int *optval)
{
    int level = SOL_SOCKET;
    int optname;
    int optsize = sizeof(optname);
    struct linger lbuf ;
    void * opttarget = (void *) optval ;

    switch (flag) { 
    case 0: /* DELAY */
        level = IPPROTO_TCP;
        optname = TCP_NODELAY;
        break;
    case 1: /* LINGER */
        opttarget = (void *) &lbuf ;
        optsize = sizeof (struct linger);
        optname = SO_LINGER;
        break;
    case 2: /* KEEPALIVE */
        optname = SO_KEEPALIVE;
        break;
    case 3: /* RCVBUF */
        optname = SO_RCVBUF;
        break;
    case 4: /* SNDBUF */
        optname = SO_SNDBUF;
        break;
    default: /* IllegalArgumentException */
        KNI_ThrowNew("java/lang/IllegalArgumentException","");
        return -1;
    }
    if (getsockopt(fd, level,  optname, opttarget, &optsize) == 0 ) {
        if (optname == SO_LINGER) {
            /* If linger is on return the number of seconds. */
            *optval = (lbuf.l_onoff == 0 ? 0 : lbuf.l_linger) ;
        }
#if INCLUDEDEBUGCODE
        if (tracenetworking) {
            fprintf(stdout, "getSockopt option=%d value=%d size=%d\n", 
                optname, *optval, optsize);
        }
#endif /* INCLUDEDEBUGCODE */

        return 0;
    } else {
        fprintf (stderr, "getsockopt errno=%d option=%d level=%d\n", 
                 errno, optname, level );
        return -1;
    }
}

/*=========================================================================
 * FUNCTION:      setsockopt0()
 * CLASS:         com.sun.midp.io.j2me.socket.Protocol
 * TYPE:          virtual native function
 * OVERVIEW:      Set a socket option value.
 *=======================================================================*/
int prim_com_sun_midp_io_j2me_socket_Protocol_setsockopt0(int fd, int flag, int optval)
{
    int    level = SOL_SOCKET;
    int    optsize =  sizeof(optval);
    int    optname;
    struct linger lbuf ;
    void * opttarget = (void *) & optval ;

    switch (flag) { 
    case 0: /* DELAY */
        level = IPPROTO_TCP;
        optname = TCP_NODELAY;
        break;
    case 1: /* LINGER */
        opttarget = (void *) &lbuf ;
        optsize = sizeof (struct linger);
        optname = SO_LINGER;
        if (optval == 0) {
            lbuf.l_onoff = 0;
            lbuf.l_linger = 0;
        } else {
            lbuf.l_onoff = 1;
            lbuf.l_linger = optval;
        }           
        break;
    case 2: /* KEEPALIVE */
        optname = SO_KEEPALIVE;
        break;
    case 3: /* RCVBUF */
        optname = SO_RCVBUF;
        break;
    case 4: /* SNDBUF */
        optname = SO_SNDBUF;
        break;
    default: /* IllegalArgumentException */
        KNI_ThrowNew("java/lang/IllegalArgumentException","");
        return -1;
    }

    if (setsockopt(fd, level,  optname, opttarget, optsize) == 0){

#if INCLUDEDEBUGCODE
    if (tracenetworking) {
        fprintf(stdout, "setSockopt option=%d value=%d\n", 
                optname, optval);
        }
#endif /* INCLUDEDEBUGCODE */

    } else {
        fprintf (stderr, "setsockopt errno=%d\n", errno);
        return -1;
    }

    
    return ;
}

/*=========================================================================
 * FUNCTION:      getipnumber1()
 * CLASS:         com.sun.midp.io.j2me.socket.Protocol
 * TYPE:          virtual native function
 * OVERVIEW:      Get the IP address of the local or remote socket endpoint.
 *=======================================================================*/
char * prim_com_sun_midp_io_j2me_socket_Protocol_getipnumber1(int fd,
                                                              int local){
    int res;
    struct sockaddr_in sa;
    int saLen = sizeof (sa);

    sa.sin_family = AF_INET;

    if (local) {
        res = getsockname(fd, (struct sockaddr*)&sa, &saLen);
    } else {
        res = getpeername(fd, (struct sockaddr*)&sa, &saLen);
    }

    if (res < 0) {
        return NULL;
    }

#if INCLUDEDEBUGCODE
    if (tracenetworking) {
        fprintf(stdout, "get ip number port=%d addr=%s\n",  
                sa.sin_port, inet_ntoa(sa.sin_addr) );
    }
#endif /* INCLUDEDEBUGCODE */

    return inet_ntoa(sa.sin_addr);
}
        

/*=========================================================================
 * FUNCTION:      getport1()
 * CLASS:         com.sun.midp.io.j2me.socket.Protocol
 * TYPE:          virtual native function
 * OVERVIEW:      Get the port number of the local or remote socket endpoint.
 *=======================================================================*/
int prim_com_sun_midp_io_j2me_socket_Protocol_getport1(int fd, int local){
    int res;
    struct sockaddr_in sa;
    int saLen = sizeof (sa);

    if (local == 1 ) {
        res = getsockname(fd, (struct sockaddr*)&sa, &saLen);
    } else {
        res = getpeername(fd, (struct sockaddr*)&sa, &saLen);
    }

    if (res < 0) {
        return -1;
    }

#if INCLUDEDEBUGCODE
    if (tracenetworking) {
        fprintf(stdout, "get ip number family=%x port=%d addr=%s\n",  
                sa.sin_family, sa.sin_port, inet_ntoa(sa.sin_addr) );
        }
#endif /* INCLUDEDEBUGCODE */
    return ntohs(sa.sin_port);
}
        
/*=========================================================================
 * FUNCTION:      getLocalIPNumber_md()
 * TYPE:          common native function
 * OVERVIEW:      Get the IP address of the local device.
 *=======================================================================*/
int getLocalIPNumber_md() {
    char hostname[MAXHOSTNAMELEN];
    struct hostent *hp;

    gethostname(hostname, sizeof (hostname));

#if INCLUDEDEBUGCODE
    if (tracenetworking) {
        fprintf(stdout, "local hostname = %s\n", hostname);
    }
#endif /* INCLUDEDEBUGCODE */

    hp = gethostbyname(hostname);
    return ((struct in_addr*)*hp->h_addr_list)->s_addr;
}

/*=========================================================================
 * FUNCTION:      getLocalIPAddressAsString_md()
 * TYPE:          common native function
 * OVERVIEW:      Get the IP address of the local device.
 *=======================================================================*/
char *getLocalIPAddressAsString_md() {
    struct in_addr addr;

    addr.s_addr = getLocalIPNumber_md();
    return inet_ntoa(addr);
}