Changeset 35 in libcf for trunk/src/cf_log.c

Timestamp:

02/05/13 18:18:37 (11 years ago)

Author:

cheese

Message:

#1 separate example code and doxygen comment and fix logging push logic by vfire

File:

• trunk/src/cf_log.c (modified) (14 diffs)

trunk/src/cf_log.c

@@ -161 +161 @@
 
 static int
-CF_Log_Local_Push (CF_LOG_CTX   * ctx,
-                   const char   * buffer)
-{
-    strncat (ctx->buffer + ctx->length,
-             buffer,
-             ctx->size - ctx->length);
-    ctx->length = strlen (ctx->buffer);
-
-    return CF_OK;
-}
-
-static int
 CF_Log_Local_Flush (CF_LOG_CTX * ctx)
 {
@@ -184 +172 @@
 }
 
+/**
+ * 로그 데이터 처리
+ *
+ * @return 성공 시, CF_OK; 실패 시, 오류 코드
+ *
+ * @param ctx           로그 컨텍스트
+ * @param buffer        로그 데이터
+ * @param demandSize    로그 데이터 길이
+ *
+ * @author vfire
+ */
+/* static */int
+CF_Log_Local_Push (CF_LOG_CTX   * ctx,
+                   const char   * buffer,
+                   const size_t demandSize)
+{
+    if( ctx->size > 0 ) /* 버퍼단위 버퍼링.... */
+    {
+        size_t writeSize;
+        size_t remainSize;
+
+        remainSize = demandSize;
+        while (remainSize)
+        {
+            writeSize = (ctx->size - ctx->length) < remainSize ? (ctx->size - ctx->length) : remainSize;
+
+            memcpy (ctx->buffer + ctx->length, buffer + demandSize - remainSize, writeSize);
+            ctx->length += writeSize;
+
+            if (ctx->length == ctx->size)
+                CF_Log_Local_Flush (ctx);
+
+            remainSize -= writeSize;
+        }
+    }
+    else /* flush되어야 함. */
+    {
+        if (CF_File_Write (ctx->fd, buffer, demandSize) < 0)
+            return CF_ERROR_LOG_FLUSH;
+    }
+
+    return CF_OK;
+}
+
+/**
+ * 로그를 사용하기 위해 초기화
+ *
+ * @return 성공 시, CF_OK; 실패 시, 오류 코드
+ *
+ * @param logPool 아이디 넘버 최대 값
+ */
 int
 CF_Log_Initialize (const int logPool)
@@ -201 +240 @@
 }
 
+/**
+ * 로그가 모두 사용된 후 자원 해제
+ *
+ * @return CF_OK 반환
+ */
 int
 CF_Log_Finalize (void)
@@ -219 +263 @@
 }
 
+/**
+ * 로그 컨텍스트 생성
+ *
+ * @return 성공 시, 로그 컨텍스트; 실패 시, NULL
+ *
+ * @param path      로그 파일 경로
+ * @param memsize   로그 버퍼 크기
+ *
+ * @see CF_LOG_BUFFER_DEFAULT, CF_LOG_BUFFER_NO
+ */
 CF_Log_Ctx
 CF_Log_CreateCtx (const char    * path,
@@ -269 +323 @@
 }
 
+/**
+ * 로그 컨텍스트 해제
+ *
+ * @return 성공 시, CF_OK; 실패 시, 오류 코드 
+ *
+ * @param ctx 로그 컨텍스트
+ */
 int
 CF_Log_DestroyCtx (CF_Log_Ctx ctx)
@@ -300 +361 @@
 }
 
+/**
+ * 로그 컨텍스트에 멀티쓰레드 모드 설정
+ *
+ * @return 성공 시, CF_OK; 실패 시, 오류 코드 
+ *
+ * @param ctx 로그 컨텍스트
+ */
 int
 CF_Log_SetMultiThread (CF_Log_Ctx ctx)
@@ -314 +382 @@
 }
 
+/**
+ * 로그 컨텍스트에 멀티쓰레드 모드 설정 해제
+ *
+ * @return 성공 시, CF_OK; 실패 시, 오류 코드 
+ *
+ * @param ctx 로그 컨텍스트
+ */
 int
 CF_Log_UnsetMultiThread (CF_Log_Ctx ctx)
@@ -328 +403 @@
 }
 
+/**
+ * 로그 컨텍스트에 따라 로그 쓰기
+ *
+ * @return 성공 시, CF_OK; 실패 시, 오류 코드
+ *
+ * @param ctx       로그 컨텍스트
+ * @param prefix    로그의 프리픽스 문자열
+ * @param fmt       포맷 스트링
+ * @param ...       가변 인자
+ */
 int
 CF_Log_Write (CF_Log_Ctx    ctx,
@@ -335 +420 @@
     CF_LOG_CTX  * context = (CF_LOG_CTX *) ctx;
     va_list     valist;
-    char        buffer[4096] = {0x00,};
+    char        buffer[16 * 1024] = {0x00,};
     char        datetime[CF_LOG_DATETIME_LENGTH + 1] = {0x00,};
-    size_t      length = 0;
 
     if (CHECK_INVALID_CTX (ctx))
@@ -349 +433 @@
     vsprintf (buffer + strlen (buffer), fmt, valist);
 
-    if (context->size == CF_LOG_BUFFER_NO)
-    {
-        context->buffer = buffer;
-        context->length = strlen (buffer);
-
-        CF_Log_Local_Flush (context);
-
-        context->buffer = NULL;
-        /* context->length = 0; // already did this in flush */
-    }
-    else /* (context->size > 0) */
-    {
-        length = context->size - context->length;
-        CF_Log_Local_Push (context, buffer);
-
-        if (context->length == context->size)
-        {
-            CF_Log_Local_Flush (context);
-            CF_Log_Local_Push (context, buffer + length);
-        }
-    }
+    CF_Log_Local_Push (context, buffer, strlen (buffer));
 
     va_end (valist);
@@ -377 +441 @@
 }
 
+/**
+ * 로그 버퍼의 데이터를 즉시 로그 파일에 쓰기
+ *
+ * @return 성공 시, CF_OK; 실패 시, 오류 코드
+ *
+ * @param ctx 로그 컨텍스트
+ */
 int
 CF_Log_Flush (CF_Log_Ctx ctx)
@@ -392 +463 @@
 }
 
+/**
+ * 로그 컨텍스트에 아이디 넘버 할당<br />
+ * 로그 기록 시, 아이디 넘버를 사용하면 해당 로그로 기록할 수 있음
+ *
+ * @return 성공 시, CF_OK; 실패 시, 오류 코드
+ *
+ * @param mapid 부여할 아이디 넘버
+ * @param ctx   로그 컨텍스트
+ *
+ * @remark 반드시 먼저 초기화 해야하며, 초기화 시에 주어진 번호보다 작은 아이디 넘버를 사용해야 함
+ *
+ * @see CF_LOG_OPEN, CF_Log_CreateCtx
+ */
 int
 CF_Log_MapCtxID (const int          mapid,
@@ -427 +511 @@
 }
 
+/**
+ * 아이디 넘버에 해당하는 로그를 닫고 해당하는 컨텍스트를 해제
+ *
+ * @return 성공 시, CF_OK; 실패 시, 오류 코드
+ *
+ * @param mapid 로그의 아이디 넘버
+ *
+ * @remark 아이디 넘버에 해당하는 컨텍스트가 해제되므로 주의
+ *
+ * @see CF_LOG_CLOSE, CF_Log_DestroyCtx
+ */
 int
 CF_Log_UnmapCtxID (const int mapid)
@@ -445 +540 @@
 }
 
+/**
+ * 아이디 넘버에 해당하는 로그 컨텍스트를 얻기
+ *
+ * @return 성공 시, 로그 컨텍스트; 실패 시, NULL
+ *
+ * @param mapid 로그의 아이디 넘버
+ */
 CF_Log_Ctx
 CF_Log_GetMappedCtx (const int mapid)