source: cheroxy/trunk/src/main.cpp@ 20

// LocalProxy.cpp : ÄÜ¼Ö ÀÀ¿ë ÇÁ·Î±×·¥¿¡ ´ëÇÑ ÁøÀÔÁ¡À» Á¤ÀÇÇÕ´Ï´Ù.
//

#ifdef _WIN32
# define _CRT_SECURE_NO_WARNINGS
#endif

#include "CRXSocket.h"
#include "CRXProxy.h"

#include <iostream>
#include <iomanip>
#include <sstream>

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

using namespace std;

#ifdef _WIN32
# define __func__           __FUNCTION__
#endif

#define CRX_PRINT_ERROR(__code, __message)                                                              \
    do {                                                                                                \
        char __error[4096] = {0x00, };                                                                  \
        ostringstream __stream;                                                                         \
        __stream << __message;                                                                          \
        string __string = __stream.str ();                                                              \
        sprintf (__error, "[%s][%d] (%d) %s\n", __func__, __LINE__, __code, __string.c_str ());         \
        cout << __error;                                                                                \
    } while (0)

int main (int argc, char* argv[])
{
    int                     aResult = 0;
    const unsigned short    aPort   = 8080;

    CRXSocket               aSocket;
    CRXProxy                * aProxy = NULL;

    /*----------------------------------------------------------------*/
    /*----------------------------------------------------------------
     * Initialize
     *----------------------------------------------------------------*/
    aResult = aSocket.CreateServer (aPort);
    if (aResult < 0)
    {
        CRX_PRINT_ERROR (aResult, "failed to create server");
        return aResult;
    }

    for (;;)
    {
        aResult = aSocket.Accept ();
        if (aResult < 0)
        {
            CRX_PRINT_ERROR (aResult, "failed to accept");
            break;
        }

        if ((aProxy = CRXProxy::GetNewInstance (aResult)) == NULL)
        {
            aResult = -1;
            break;
        }

        aResult = aProxy->ForwardMT ();
        if (aResult < 0)
        {
            CRX_PRINT_ERROR (aResult, "failed to create thread");
            break;
        }
    }

    /*----------------------------------------------------------------*/
    aSocket.Close ();

    return aResult;
}