/*********************************************************************************
 *      Copyright:  (C) 2012 Guo Wenxue<guowenxue@gmail.com>  
 *                  All rights reserved.
 *
 *       Filename:  test_queue.c
 *    Description:  This file used to test the queue library
 *                 
 *        Version:  1.0.0(08/14/2012~)
 *         Author:  Guo Wenxue <guowenxue@gmail.com>
 *      ChangeLog:  1, Release initial version on "08/14/2012 05:17:03 PM"
 *                 
 ********************************************************************************/

#include <stdio.h>
#include <string.h>
#include <stdlib.h>

#include "cp_queue.h"
#include "cp_sock.h"

#define MAX_ITEMS  10

/********************************************************************************
 *  Description:
 *   Input Args:
 *  Output Args:
 * Return Value:
 ********************************************************************************/
int main (int argc, char **argv)
{
    int i;

    CP_SOCK *sock = NULL;
    CP_SOCK *tmp = NULL;

    CP_QUEUE *queue = NULL;
    
    queue = cp_queue_init(NULL, MAX_ITEMS);

    //for (i=0; i<MAX_ITEMS; i++)
    for (i=0; i<MAX_ITEMS+10; i++)
    //for (i=0; i<MAX_ITEMS-3; i++)
    {
        sock = cp_sock_init(NULL, 1024, 1024, 10, 30);
        if( NULL==cp_enqueue(queue, sock) )
        {
            cp_sock_term(sock);
        }
        else
        {
            if(i==3)
            {
                tmp = sock;
            }
            printf("enqueue sock %p\n", sock);
        }
    }


    printf("queue usage %d/%d \n", cp_queue_count(queue), cp_queue_size(queue));

    cp_travel_queue(queue);
    if( cp_rmqueue(queue, tmp) )
    {
        printf("remove and terminate sock [%p] from queue\n", tmp);
        cp_sock_term(tmp);
    }
    cp_travel_queue(queue);

    while(!cp_queue_is_empty(queue))
    {
        if( (sock=cp_dequeue(queue)) )
        {
            printf("Terminate socket: %p\n", sock);
            cp_sock_term(sock);
        }
    }

    cp_queue_destroy(queue);

    return 0;

} /* ----- End of main() ----- */