#include <LogRingBuffer.h>

Collaboration diagram for CLogRingBuffer:

Public Member Functions
	CLogRingBuffer (int size)

virtual	~CLogRingBuffer (void)

int	init (int size)

void	clear (void)

void	putRingBuffer (Buffer buf, int input=LOG_RB_MESG, int kind=LOG_RB_UNKNOWN_DATA)

void	rewriteBinHexRingBuffer (int n, int input)

void	putRingFormat (int input, char *fmt,...)

void	putRingFormat (int input, char *fmt, va_list args)

Buffer	getRingBuffer (void)

Buffer	getRingBuffer (int pos)

int	getMaxBufSize (void)

int	getMaxLineX (void)

int	getMaxLineY (void)

int	getTotalSize (void)

int	getLastPosition (void)

int	getLengthX (int n)

int	getKindData (int n)

Public Attributes
Buffer *	pBuf

Protected Attributes
int	maxBufSize

int	tlDataSize

int	maxLineX

int	maxLineY

int	indentSize

int	rPos

int	wPos

int *	kindData

int *	inputSrc

Detailed Description

Definition at line 35 of file LogRingBuffer.h.

Constructor & Destructor Documentation

◆ CLogRingBuffer()

CLogRingBuffer ( int size )

inline

Definition at line 38 of file LogRingBuffer.h.

38{ init(size);}

jbxl::CLogRingBuffer::init

int init(int size)

Definition LogRingBuffer.cpp:23

References CLogRingBuffer::init().

Here is the call graph for this function:

◆ ~CLogRingBuffer()

~CLogRingBuffer ( void )

virtual

Definition at line 13 of file LogRingBuffer.cpp.

{
    //DEBUG_INFO("INFO: DESTRUCTOR: CLogRingBuffer");
 
    if (pBuf!=NULL) del_Buffer_dim(&pBuf);
 
    //DEBUG_INFO("INFO: DESTRUCTOR: CLogRingBuffer");
}

References del_Buffer_dim(), and CLogRingBuffer::pBuf.

Here is the call graph for this function:

Member Function Documentation

◆ clear()

void clear ( void )

Definition at line 66 of file LogRingBuffer.cpp.

{
    for (int i=0; i<maxBufSize; i++) {
        pBuf[i].buf[0] = '\0';
        pBuf[i].vldsz  = 0;
    }
 
    tlDataSize = 0;
    maxLineX = maxLineY = 0;
    rPos = wPos = 0;
 
    return;
}

References Buffer::buf, CLogRingBuffer::maxBufSize, CLogRingBuffer::maxLineX, CLogRingBuffer::maxLineY, CLogRingBuffer::pBuf, CLogRingBuffer::rPos, CLogRingBuffer::tlDataSize, Buffer::vldsz, and CLogRingBuffer::wPos.

◆ getKindData()

int getKindData ( int n )

inline

Definition at line 59 of file LogRingBuffer.h.

59{ if(n<0) n+=maxBufSize; return kindData[n%maxBufSize];}

jbxl::CLogRingBuffer::kindData

int * kindData

Definition LogRingBuffer.h:75

References CLogRingBuffer::kindData, and CLogRingBuffer::maxBufSize.

◆ getLastPosition()

int getLastPosition ( void )

inline

Definition at line 56 of file LogRingBuffer.h.

56{ return wPos;}

References CLogRingBuffer::wPos.

◆ getLengthX()

int getLengthX ( int n )

inline

Definition at line 58 of file LogRingBuffer.h.

58{ if(n<0) n+=maxBufSize; return (int)strlen((const char*)pBuf[n%maxBufSize].buf);}

References CLogRingBuffer::maxBufSize, and CLogRingBuffer::pBuf.

Referenced by CLogRingBuffer::putRingBuffer().

Here is the caller graph for this function:

◆ getMaxBufSize()

int getMaxBufSize ( void )

inline

Definition at line 52 of file LogRingBuffer.h.

52{ return maxBufSize;}

References CLogRingBuffer::maxBufSize.

◆ getMaxLineX()

int getMaxLineX ( void )

inline

Definition at line 53 of file LogRingBuffer.h.

53{ return maxLineX;}

References CLogRingBuffer::maxLineX.

◆ getMaxLineY()

int getMaxLineY ( void )

inline

Definition at line 54 of file LogRingBuffer.h.

54{ return maxLineY;}

References CLogRingBuffer::maxLineY.

◆ getRingBuffer() [1/2]

Buffer getRingBuffer ( int pos )

Buffer CLogRingBuffer::getRingBuffer(int pos)

バッファの位置を指定して読み込む．データポインタの移動無し．

Returns: 指定した位置のデータ

Definition at line 305 of file LogRingBuffer.cpp.

{
    Buffer buf = init_Buffer();
    buf.state  = -1;
 
    if (pos<0) return buf;
    if (pos>=maxBufSize) pos = pos%maxBufSize;
 
    buf = make_Buffer(LBUF);
    copy_Buffer(&pBuf[pos], &buf);
    buf.state = inputSrc[pos];
 
    return buf;
}

References copy_Buffer(), init_Buffer(), CLogRingBuffer::inputSrc, LBUF, make_Buffer(), CLogRingBuffer::maxBufSize, CLogRingBuffer::pBuf, and Buffer::state.

Here is the call graph for this function:

◆ getRingBuffer() [2/2]

Buffer getRingBuffer ( void )

Buffer CLogRingBuffer::getRingBuffer(void)

バッファの先頭のデータを読み込む．データポインタを移動させる．

Returns: バッファの先頭のデータ

Definition at line 284 of file LogRingBuffer.cpp.

{
    Buffer buf = make_Buffer(LBUF);
 
    copy_Buffer(&pBuf[rPos], &buf);
    buf.state = inputSrc[rPos];
 
    rPos++;
    if (rPos>=maxBufSize) rPos -= maxBufSize;
 
    return buf;
}

References copy_Buffer(), CLogRingBuffer::inputSrc, LBUF, make_Buffer(), CLogRingBuffer::maxBufSize, CLogRingBuffer::pBuf, CLogRingBuffer::rPos, and Buffer::state.

Here is the call graph for this function:

◆ getTotalSize()

int getTotalSize ( void )

inline

Definition at line 55 of file LogRingBuffer.h.

55{ return tlDataSize;}

References CLogRingBuffer::tlDataSize.

◆ init()

int init ( int size )

Definition at line 23 of file LogRingBuffer.cpp.

{
    bool  err_flag = false;
 
    maxBufSize = tlDataSize = 0;
    maxLineX   = maxLineY   = 0;
    rPos = wPos = 0;
    indentSize = 13;    // 5 + 8  "1234 SERVER: "
 
    pBuf     = (Buffer*)malloc(sizeof(Buffer)*size);
    kindData = (int*)malloc(sizeof(int)*size);
    inputSrc = (int*)malloc(sizeof(int)*size);
 
    if (pBuf!=NULL && inputSrc!=NULL && kindData!=NULL) {
        memset(pBuf,     0, sizeof(Buffer)*size);
        memset(kindData, 0, sizeof(int)*size);
        memset(inputSrc, 0, sizeof(int)*size);
        maxBufSize = size;
 
        for (int i=0; i<size; i++) {
            pBuf[i] = make_Buffer(LBUF);
            if (pBuf[i].buf==NULL) {
                err_flag = true;
                break;
            }
            pBuf[i].state = size;
        }
    }
    else {
        err_flag = true;
    }
 
    if (err_flag) {
        if (pBuf!=NULL) del_Buffer_dim(&pBuf);
        if (kindData!=NULL) free(kindData);
        if (inputSrc!=NULL) free(inputSrc);
        kindData = inputSrc = NULL;
        return 1;
    }
    return 0;
}

References del_Buffer_dim(), CLogRingBuffer::indentSize, CLogRingBuffer::inputSrc, CLogRingBuffer::kindData, LBUF, make_Buffer(), CLogRingBuffer::maxBufSize, CLogRingBuffer::maxLineX, CLogRingBuffer::maxLineY, CLogRingBuffer::pBuf, CLogRingBuffer::rPos, Buffer::state, CLogRingBuffer::tlDataSize, and CLogRingBuffer::wPos.

Referenced by CLogRingBuffer::CLogRingBuffer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ putRingBuffer()

void putRingBuffer	(	Buffer	buf,
		int	input = LOG_RB_MESG,
		int	kind = LOG_RB_UNKNOWN_DATA )

void CLogRingBuffer::putRingBuffer(Buffer buf, int input, int kind)

バッファの最後にデータを追加する．

Parameters

buf	追加するデータ．
input	データのタグ LOG_RB_MESG, LOG_RB_INFO, LOG_RB_DEBUG, LOG_RB_WARN, LOG_RB_ERR
kind	データの種類 LOG_RB_UNKNOWN_DATA, LOG_RB_TEXT_DATA, LOG_RB_TEXT_HALF_DATA, LOG_RB_BINARY_DATA, LOG_RB_BINHEX_DATA

Definition at line 90 of file LogRingBuffer.cpp.

{
    int  i,  nxt = 0;
    bool recalcX = false;
    char num[10];
 
    if (buf.buf==NULL || buf.vldsz<=0) return;
    Buffer* dim = decompline_Buffer_dim(buf, ON);
    if (dim==NULL || dim->state<=0) return;
    tlDataSize += buf.vldsz;    
 
#ifdef DEBUG
    int total = 0;
    for (i=0; i<dim->state; i++) {
        total += dim[i].vldsz;
    }
    if (buf.vldsz!=total) {
        DEBUG_ERR("ERROR: CLogRingBuffer::putRingBuffer(): mismatch total data size!! %d %d", buf.vldsz, total);
    }
#endif
    
    // 前の行の続き
    int pos = wPos - 1;
    if (pos<0) pos += maxBufSize;
    if (kindData[pos]==LOG_RB_TEXT_HALF_DATA && isText_Buffer(dim[0]) 
            && inputSrc[pos]==input && input!=LOG_RB_INFO && kind==LOG_RB_UNKNOWN_DATA) {
        cat_Buffer(&dim[0], &pBuf[pos]);
        kindData[pos] = LOG_RB_TEXT_DATA;
        maxLineX = Max(maxLineX, getLengthX(pos));
        nxt = 1;    // 処理済
    }
    
    // 新しい行．
    pos = wPos - 1; 
    for (i=nxt; i<dim->state; i++) {
        pos++;      // == wPos
        if (pos>=maxBufSize) pos -= maxBufSize;
        if (!recalcX && maxLineY==maxBufSize && maxLineX==getLengthX(pos)) recalcX = true;
 
        snprintf(num, 10, "%05d| ", pos);
        copy_s2Buffer(num, &pBuf[pos]);
        if      (input==LOG_RB_ERROR)   cat_s2Buffer("ERROR: ", &pBuf[pos]);
        else if (input==LOG_RB_WARNING) cat_s2Buffer("WARN : ", &pBuf[pos]);
        else if (input==LOG_RB_DEBUG)   cat_s2Buffer("DEBUG: ", &pBuf[pos]);
        else if (input==LOG_RB_INFO)    cat_s2Buffer("INFO : ", &pBuf[pos]);
        //else                          cat_s2Buffer("        ", &pBuf[pos]);
 
        cat_Buffer(&dim[i], &pBuf[pos]);
        if (kind==LOG_RB_UNKNOWN_DATA) kindData[pos] = LOG_RB_TEXT_DATA;
        else                           kindData[pos] = kind;
        inputSrc[pos] = input;
        maxLineX = Max(maxLineX, getLengthX(pos));
    }
 
    // 最後のデータの再確認
    if (nxt<dim->state && kind==LOG_RB_UNKNOWN_DATA) {
        if (isText_Buffer(dim[dim->state-1])) {
            unsigned char end = dim[dim->state-1].buf[dim[dim->state-1].vldsz-1]; 
            if (end!=CHAR_CR && end!=CHAR_LF) kindData[pos] = LOG_RB_TEXT_HALF_DATA;
        }
        else {
            kindData[pos] = LOG_RB_BINARY_DATA;
        }
    }
 
    pos++;
    if (pos>=maxBufSize) pos -= maxBufSize;
    wPos = pos;
 
    // 次のn行を目印行にする．
    Buffer spbuf = rept_Buffer(' ', 80);
    cat_s2Buffer("\n", &spbuf);
    for (i=0; i<2; i++) {
        copy_Buffer(&spbuf, &pBuf[pos]);
        inputSrc[pos] = LOG_RB_INFO;
        kindData[pos] = LOG_RB_TEXT_DATA;
        pos++;
        if (pos>=maxBufSize) pos -= maxBufSize;
    }
    free_Buffer(&spbuf);
 
    // コンテキストのサイズを計算
    if (maxLineY<maxBufSize) {
        if (wPos+1<maxLineY) maxLineY = maxBufSize;
        else  maxLineY = wPos + 1;
    }
    //DEBUG_WARN("WARNING: MaxY = %d", maxLineY);
    
    if (recalcX) {
        maxLineX = 0;
        for (i=0; i<maxBufSize; i++) {
            maxLineX = Max(maxLineX, getLengthX(i));
        }
    }
 
    del_Buffer_dim(&dim);
    return;
}

References Buffer::buf, cat_Buffer(), cat_s2Buffer, CHAR_CR, CHAR_LF, copy_Buffer(), copy_s2Buffer, decompline_Buffer_dim(), del_Buffer_dim(), free_Buffer(), CLogRingBuffer::getLengthX(), CLogRingBuffer::inputSrc, isText_Buffer(), CLogRingBuffer::kindData, LOG_RB_BINARY_DATA, LOG_RB_DEBUG, LOG_RB_ERROR, LOG_RB_INFO, LOG_RB_TEXT_DATA, LOG_RB_TEXT_HALF_DATA, LOG_RB_UNKNOWN_DATA, LOG_RB_WARNING, Max, CLogRingBuffer::maxBufSize, CLogRingBuffer::maxLineX, CLogRingBuffer::maxLineY, ON, CLogRingBuffer::pBuf, rept_Buffer(), snprintf, Buffer::state, CLogRingBuffer::tlDataSize, Buffer::vldsz, and CLogRingBuffer::wPos.

Referenced by CLogRingBuffer::putRingFormat(), CLogRingBuffer::putRingFormat(), and CLogRingBuffer::rewriteBinHexRingBuffer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ putRingFormat() [1/2]

void putRingFormat	(	int	input,
		char *	fmt,
		va_list	args )

void CLogRingBuffer::putRingFormat(int input, char* fmt, va_list args)

可変数変数用の書き込み用関数．バッファの最後に生成された文字列を追加する．上位の関数から呼び出して使用する．

Definition at line 253 of file LogRingBuffer.cpp.

{
    char*  nfmt;
    int    len;
    Buffer buf;
 
    len  = (int)strlen(fmt);    
    nfmt = (char*)malloc(len+1);
    if (nfmt==NULL) return;
    strncpy(nfmt, fmt, len);
    nfmt[len] = '\0';
 
    buf = make_Buffer(LBUF);
    vsnprintf((char*)buf.buf, LBUF-1, nfmt, args);
    recalc_strlen_Buffer(&buf);
    free(nfmt);
 
    putRingBuffer(buf, input, LOG_RB_TEXT_DATA);
    free_Buffer(&buf);
    
    return;
}

References Buffer::buf, free_Buffer(), LBUF, LOG_RB_TEXT_DATA, make_Buffer(), CLogRingBuffer::putRingBuffer(), recalc_strlen_Buffer(), and vsnprintf.

Here is the call graph for this function:

◆ putRingFormat() [2/2]

void putRingFormat	(	int	input,
		char *	fmt,
			... )

void CLogRingBuffer::putRingFormat(int input, char* fmt, ...)

可変数変数用の書き込み用関数．バッファの最後に生成された文字列を追加する．

Definition at line 218 of file LogRingBuffer.cpp.

{
    char*  nfmt;
    int    len;
    Buffer buf;
 
    va_list  args;
    va_start(args, fmt);
 
    len  = (int)strlen(fmt);    
    nfmt = (char*)malloc(len+1);
    if (nfmt==NULL) return;
    strncpy(nfmt, fmt, len);
    nfmt[len] = '\0';
 
    buf = make_Buffer(LBUF);
    vsnprintf((char*)buf.buf, LBUF-1, nfmt, args);
    recalc_strlen_Buffer(&buf);
    free(nfmt);
 
    va_end(args);
 
    putRingBuffer(buf, input, LOG_RB_TEXT_DATA);
    free_Buffer(&buf);
    
    return;
}

References Buffer::buf, free_Buffer(), LBUF, LOG_RB_TEXT_DATA, make_Buffer(), CLogRingBuffer::putRingBuffer(), recalc_strlen_Buffer(), and vsnprintf.

Here is the call graph for this function:

◆ rewriteBinHexRingBuffer()

void rewriteBinHexRingBuffer	(	int	n,
		int	input )

void CLogRingBuffer::rewriteBinHexRingBuffer(int n, int input)

バッファ位置 nにあるデータを 16進表示で書き直す．主に，位置 nにあるデータがバイナリの場合に使用する．

Definition at line 196 of file LogRingBuffer.cpp.

{
    while (n<0) n += maxBufSize;
    if (n>=maxBufSize) n = n%maxBufSize;
 
    Buffer dup = pBuf[n];
    dup.buf    = dup.buf   + indentSize;
    dup.vldsz  = dup.vldsz - indentSize;
 
    Buffer buf = dump_Buffer(dup);
    wPos = n;
    putRingBuffer(buf, input, LOG_RB_BINHEX_DATA);
 
    free_Buffer(&buf);
}