1 ?TTextQueue 클래스 #

class TTextQueue
{
protected :
    int const_maxsize;

    typedef char * pchar;
    list<pchar> listline;

    char *lastdata;

public :
    TTextQueue(const int maxsize) : const_maxsize(maxsize)
    {
        lastdata = new char [const_maxsize];
        lastdata[0]  = 0;
    };

    ~TTextQueue()
    {
        delete []lastdata;

        while(! listline.empty()){
            list<pchar>::iterator iptr = listline.begin();
            listline.erase(iptr);
            delete (*iptr);
        }
    }

    int Push(const int nsize, const char *buffer);
    int Pop(char *outbuffer);
    int View(char *outbuffer) const;

    int Skip(void);

    bool empty(void){ return listline.empty(); };
    int  size(void) { return listline.size(); };
}; 

?TTextQueue는 binary 버퍼를 사용하지 않고, list<char *> 를 이용하여 라인별로 리스트를 구성하도록 했다. 다만, 도착된 데이터가 한 라인이 되지 못하는 경우를 처리하기 위해 lastdata라는 마지막 도착데이터를 보관하기 위한 공간을 마련해놓았다.

수신된 데이터가 있다고 하더라도, 한 라인을 채우지 못했을 경우(CR이 들어오지 않았을 경우)에는 아직 더 기다려야 하므로, empty()함수는 lastdata를 검토하지 않고 false 를 리턴할 것이다. 마찬가지로 size() 함수도 여태까지 들어온 라인의 갯수를 돌려줄 뿐 미완료된 라인은 검토하지 않도록 한다.

2 TTextQueue:?:Push()의 구현 #

int TTextQueue::Push(const int nsize, const char *buffer)
{
    int n = 0;
    int nlast = strlen(lastdata);

    char *ptr;

    while(n < nsize){
        // New Line
        if( buffer[n] == 0x0A ) {
            lastdata[nlast] = 0; // NULL terminator

            // 새 char* data를 생성하여 리스트에 추가
            ptr = new char [nlast + 1];
            strcpy(ptr, lastdata);
            listline.push_back(ptr);

            // 변수 초기화
            lastdata[0] = 0;
            nlast       = 0;
        } else if (buffer[n] != 0x0D){
            lastdata[nlast++] = buffer[n];
        }
        n++;
    }
    lastdata[nlast] = 0; // NULL terminator

    return listline.size();
} 

라인 브레이커로 0x0A = LF를 잡았고, 0x0D = CR은 무시하도록 했다. strchr나 strcat을 쓰지않고 한 바이트씩 검사해서 복사하도록 했는데, strchr 함수가 NULL로 끝나는 문자열에 동작하므로 이 함수를 이용하려면 데이타전체를 다시 어딘가 복사해놓고 0 을 붙여준후에 검사해야하므로 더 복잡해 질 듯해서 사용하지 않았다.

새 라인이 도착했을 경우에는, char *를 하나 새로생성한후 문자열을 복사하고 리스트에 추가한다. 그 이외의 경우, 즉 LF가 도착하지 않은 경우에는 lastdata에 추가하도록 했다.

에러처리는 두가지 사건에 대해서 해 줘야 하는데, 1) lastdata의 할당된 공간을 초과하는 경우, 즉 MAX_LINE보다 한 라인이 길어질 경우와, 2) list의 사이즈가 너무 커지는 경우이다. 여러가지 대처법이 있겠지만, 여기서는 단지 에러를 리턴하기로 했다.

3 개선된 TTextQueue:?:Push() : 에러처리 #

#define BUF_ERROR          -1
#define BUF_ERROR_MAX_LINE -2
#define BUF_ERROR_MAX_LIST -3

#define MAX_LIST            500

// NewLine은 protected로 선언
int TTextQueue::NewLine(const char *buffer)
{
    char *ptr;

    ptr = new char [strlen(buffer) + 1];
    strcpy(ptr, buffer);
    listline.insert(listline.end(), ptr);

    return listline.size();
}

int TTextQueue::Push(const int nsize, const char *buffer)
{
    int n = 0;
    int nlast = strlen(lastdata);

    char *ptr;

    while(n < nsize){
        // Line overflow 검사
        if(nlast >= const_maxsize) return BUF_ERROR_MAX_LINE;

        // New Line
        if( buffer[n] == 0x0A ) {
            lastdata[nlast] = 0; // NULL terminator

            if(listline.size() < MAX_LIST ) NewLine(lastdata);
            else return BUF_ERROR_MAX_LIST;

            // 변수 초기화
            lastdata[0] = 0;
            nlast       = 0;
        } else if (buffer[n] != 0x0D){
            lastdata[nlast++] = buffer[n];
        }
        n++;
    }
    lastdata[nlast] = 0; // NULL terminator

    return listline.size();
} 

4 Pop, View, Skip() 구현 #

 /*-----------------------------------------
    return value 
        0 : 꺼낼 데이타가 없음
        1 : 한라인 popping 성공
-------------------------------------------*/
int TTextQueue::Pop(char *outbuffer)
{
    if(View(outbuffer) < 1) return 0;
    Skip();

    return 1;
}

/*-----------------------------------------
    return value 
        0 : 꺼낼 데이타가 없음
        1 : 한라인 popping 성공
-------------------------------------------*/
int TTextQueue::View(char *outbuffer) const
{
    if(listline.empty()) return 0;

    list<pchar>::const_iterator pit = listline.begin();
    strcpy(outbuffer, *pit);

    return 1;
}

/*-----------------------------------------
    return value 
        n : skip한 결과 listline의 사이즈
-------------------------------------------*/
int TTextQueue::Skip(void)
{
    if(! listline.empty()) listline.erase(listline.begin());
    return listline.size();
}