pcsl_network_na_generic.c

This is a resource based on j2me embedded,if you dont understand,you can connection with me .

/*
 *  
 *
 * Copyright  1990-2007 Sun Microsystems, Inc. All Rights Reserved.
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER
 * 
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License version
 * 2 only, as published by the Free Software Foundation.
 * 
 * This program 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 version 2 for more details (a copy is
 * included at /legal/license.txt).
 * 
 * You should have received a copy of the GNU General Public License
 * version 2 along with this work; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
 * 02110-1301 USA
 * 
 * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa
 * Clara, CA 95054 or visit www.sun.com if you need additional
 * information or have any questions.
 */

/**
 * @file
 * 
 * This file implements the notification adapter functions for a 
 * generic BSD platform
 */

#include <pcsl_network_generic.h>
#include <pcsl_network_na.h>
#include <pcsl_memory.h>

/** Note: We are guaranteed by Protocol Java code that there are no 2
 *  threads performing the same action on the socket, i.e. only one
 *  thread can be registered for reading, so well for writing.
 */

#define SD_RECV   0
#define SD_SEND   1

#define SOCKET_HANDLE(handle)   ((SocketHandle*)handle)

/** List of socket handles registered for read/write checks */
static SocketHandle* rootSocketHandle = NULL;

/** We need this method to unblock threads waiting for socket being destroyed */
extern void NotifySocketStatusChanged(long handle, int waitingFor);

/** Search for handle instance in the sockets list and return its reference */
static SocketHandle** getSocketHandleReference(SocketHandle* handle) {
    SocketHandle** ptr;
    for (ptr = &rootSocketHandle; *ptr != NULL; ptr = &((*ptr)->next)) {
        if (*ptr == handle) return ptr;
    }
    return NULL;
}

/** Add handle to the list */
static void addSocketHandle(SocketHandle* handle) {
    SocketHandle **ptr = getSocketHandleReference(handle);
    if (ptr == NULL) {
        handle->next = rootSocketHandle;
        rootSocketHandle = handle;
    }
}

/** Remove handle from the list */
static void removeSocketHandle(SocketHandle* handle) {
    SocketHandle **ptr = getSocketHandleReference(handle);
    if (ptr != NULL) {
        *ptr = handle->next;
    }
}

/**
 * See pcsl_network_generic.h for definition.
 */
const SocketHandle* GetRegisteredSocketHandles() {
    return (const SocketHandle*)rootSocketHandle;
}

/**
 * See pcsl_network_na.h for definition.
 */
void* na_create(int fd) {
    SocketHandle* handle =
        (SocketHandle*)pcsl_mem_malloc(sizeof(SocketHandle));

    if (handle != NULL) {
        handle->fd = fd;
        handle->check_flags = 0;
        handle->status = PCSL_NET_SUCCESS;
        handle->next = NULL;
    }

    return (void*)handle;
}

/**
 * See pcsl_network_na.h for definition.
 */
int na_get_fd(void *handle) {
    if (handle != NULL) {
        return SOCKET_HANDLE(handle)->fd;
    }
    return -1;
}

/**
 * See pcsl_network_na.h for definition.
 */
void na_register_for_read(void *handle) {
    if (handle != NULL) {
        SocketHandle *sh = SOCKET_HANDLE(handle);
        sh->check_flags |= CHECK_READ;
        addSocketHandle(sh);
    }
}

/**
 * See pcsl_network_na.h for definition.
 */
void na_register_for_write(void *handle) {
    if (handle != NULL) {
        SocketHandle *sh = SOCKET_HANDLE(handle);
        sh->check_flags |= CHECK_WRITE;
        addSocketHandle(sh);
    }
}

/**
 * See pcsl_network_na.h for definition.
 */
void na_unregister_for_read(void *handle) {
    if (handle != NULL) {
        SocketHandle *sh = SOCKET_HANDLE(handle);
        sh->check_flags &= ~CHECK_READ;
        if (sh->check_flags == 0) {
            removeSocketHandle(sh);
        }
    }
}

/**
 * See pcsl_network_na.h for definition.
 */
void na_unregister_for_write(void *handle) {
    if (handle != NULL) {
        SocketHandle *sh = SOCKET_HANDLE(handle);
        sh->check_flags &= ~CHECK_WRITE;
        if (sh->check_flags == 0) {
            removeSocketHandle(sh);
        }
    }
}

/**
 * See pcsl_network_na.h for definition.
 */
int na_get_status(void *handle) {
    if (handle != NULL) {
        return SOCKET_HANDLE(handle)->status;
    }
    return PCSL_NET_INTERRUPTED;
}

/**
 * See pcsl_network_na.h for definition.
 */
void na_destroy(void *handle) {
    if (handle != NULL) {
        SocketHandle *sh = SOCKET_HANDLE(handle);
        removeSocketHandle(SOCKET_HANDLE(handle));

        /* Still registered readers/writers should be unblocked */
        if (sh->check_flags != 0) {
            sh->status = PCSL_NET_INTERRUPTED;
            if (sh->check_flags & CHECK_READ) {
                NotifySocketStatusChanged((long)handle, SD_RECV);
            }
            if (sh->check_flags & CHECK_WRITE) {
                NotifySocketStatusChanged((long)handle, SD_SEND);
            }
        }
        /* It's up to caller to guarantee this handle will be used no more */
        pcsl_mem_free(handle);
    }
}