/*********************************************************************************
|
* Copyright: (C) 2012 Guo Wenxue<guowenxue@gmail.com>
|
* All rights reserved.
|
*
|
* Filename: test_sock_server.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_PORT1 8880
|
#define SERV_PORT2 8881
|
|
#define DOMAIN "kkernel.oicp.net"
|
#define IPADDR "192.168.1.78"
|
|
int service_route(CP_SOCK *sock)
|
{
|
int rv = 0;
|
log_nrml("Process socket [%d %s:%d] get event [%d]\n", sock->fd, sock->laddr, sock->lport, sock->event.events);
|
|
if(sock->event.events & EPOLLIN)
|
{
|
rv = cp_sock_recv(sock);
|
if(0==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);
|
|
return 0;
|
}
|
else if(rv > 0)
|
{
|
log_nrml("Socket[%d] recv buffer %d bytes data:\n", sock->fd, sock->rbuf->len);
|
//cp_log_dump(LOG_LEVEL_NRML, sock->rbuf->data, sock->rbuf->len);
|
|
cp_string_move(sock->sbuf, sock->rbuf);
|
|
log_nrml("Socket[%d] send buffer %d bytes data:\n", sock->fd, sock->sbuf->len);
|
cp_sock_send(sock);
|
cp_string_clear_data(sock->sbuf);
|
}
|
}
|
|
return 0;
|
}
|
|
/********************************************************************************
|
* Description:
|
* Input Args:
|
* Output Args:
|
* Return Value:
|
********************************************************************************/
|
int main (int argc, char **argv)
|
{
|
CP_FDS *fds;
|
CP_SOCK *sock;
|
|
//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())
|
goto cleanup;
|
|
cp_install_proc_signal();
|
|
if( !(fds=cp_fds_init(NULL, CP_DEF_MAX_EVENTS, CP_DEF_FDS_TIMEOUT)) )
|
goto cleanup;
|
|
if( !(sock=cp_sock_server_regist(fds, NULL, SERV_PORT1, 0, service_route, NULL)) )
|
goto cleanup;
|
|
if( !(sock=cp_sock_server_regist(fds, NULL, SERV_PORT2, 0, service_route, NULL)) )
|
goto cleanup;
|
|
while( !g_cp_signal.stop )
|
{
|
cp_fds_detect_event(fds);
|
cp_fds_proc_event(fds);
|
micro_second_sleep(10);
|
}
|
|
cleanup:
|
cp_sock_term_all_service_clear(fds);
|
cp_log_term();
|
return 0;
|
} /* ----- End of main() ----- */
|
