/*********************************************************************************
 *      Copyright:  (C) 2012 Guo Wenxue<guowenxue@gmail.com>  
 *                  All rights reserved.
 *
 *       Filename:  test_client_sock.c
 *    Description:  This file 
 *                 
 *        Version:  1.0.0(10/30/2012~)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
 *      ChangeLog:  1, Release initial version on "10/30/2012 01:15:18 PM"
 *                 
 ********************************************************************************/

#include "cp_network.h"
#include "cp_logger.h"
#include "cp_proc.h"
#include "cp_time.h"


//#define SERV_ADDR              "192.168.1.175"
#define SERV_ADDR              "192.168.1.78"
//#define SERV_ADDR              "kkernel.oicp.net"
#define SERV_PORT              8880

int service_route(CP_SOCK *sock)
{
    int      rv;

    if( !sock ) 
        return -1;

    printf("Client socket [%d] get event: %d\n", sock->fd, sock->event.events);
    if(sock->event.events & EPOLLIN)
    {
        rv = cp_sock_recv(sock);
        if(!rv)
        {
            log_nrml("Socket [%d %s:%d] remote socket [%s:%d] disconnect, remove it now\n",
                    sock->fd, sock->laddr, sock->lport, sock->raddr, sock->rport);

            cp_fds_destroy_sock(sock);
            g_cp_signal.stop = 1;

            return 0;
        }
        else if(rv > 0)
        {
            log_nrml("Socket [%d %s:%d] receive [%d] bytes data:\n", sock->fd, sock->laddr, sock->lport, sock->rbuf->len);
            cp_log_dump(LOG_LEVEL_DEBUG, sock->rbuf->data, sock->rbuf->len);
            cp_string_clear_data(sock->rbuf);
        }
    }

    return 0;
}


/********************************************************************************
 *  Description:
 *   Input Args:
 *  Output Args:
 * Return Value:
 ********************************************************************************/
int main (int argc, char **argv)
{
    CP_FDS     *fds;
    CP_SOCK    *sock = NULL;

    if ( !cp_log_init(NULL, DBG_LOG_FILE, LOG_LEVEL_NRML, LOG_ROLLBACK_NONE) || cp_log_open() )
    //if ( !cp_log_init(NULL, DBG_LOG_FILE, LOG_LEVEL_MAX, LOG_ROLLBACK_NONE) || cp_log_open() )
        return -1;

    cp_install_proc_signal();

    if( !(fds=cp_fds_init(NULL, CP_DEF_MAX_EVENTS, CP_DEF_FDS_TIMEOUT)) )
        return -2;

    while( !g_cp_signal.stop )
    {
        sock = cp_sock_connect_regist(fds, sock, SERV_ADDR, SERV_PORT, 0, service_route);
        if( sock && sock->status==SOCK_STAT_CONNECTING)
        {
            /* Connect is in progress */
            sleep(1);
            continue;
        }
        else if(!sock || sock->status!=SOCK_STAT_CONNECTED)
        {
            break;
        }

        cp_string_cstrcpy(sock->sbuf, "Hello World!\n");
        printf("Send buffer data: %s", cp_string_data(sock->sbuf));
        cp_sock_send(sock);

        cp_fds_detect_event(fds);

        cp_fds_proc_event(fds);

        micro_second_sleep(100);
    }

    cp_sock_term_all_service_clear(fds);

    cp_log_term();

    return 0;
} /* ----- End of main() ----- */