logtask.h

#include "target_syssvc.h"

ソースコードを見る。

マクロ定義
#define	LOGTASK_PRIORITY   3
#define	LOGTASK_STACK_SIZE   1024
#define	LOGTASK_PORTID   1
#define	LOGTASK_INTERVAL   10U
#define	LOGTASK_FLUSH_WAIT   1U
関数
ER	logtask_flush (uint_t count) throw ()
void	logtask_main (intptr_t exinf) throw ()
void	logtask_terminate (intptr_t exinf) throw ()

---

マクロ定義

#define LOGTASK_FLUSH_WAIT   1U

logtask.h の 76 行で定義されています。

参照元 logtask_flush().

#define LOGTASK_INTERVAL   10U

logtask.h の 72 行で定義されています。

参照元 logtask_main().

#define LOGTASK_PORTID   1

logtask.h の 68 行で定義されています。

#define LOGTASK_PRIORITY   3

logtask.h の 60 行で定義されています。

#define LOGTASK_STACK_SIZE   1024

logtask.h の 64 行で定義されています。

---

関数

ER logtask_flush

(

uint_t

count

)

throw ()

logtask.c の 72 行で定義されています。

参照先 t_syslog_rlog::count, dly_tsk(), E_CTX, E_OK, E_RLWAI, E_SYS, LOGTASK_FLUSH_WAIT, logtask_portid, serial_ref_por(), sns_dpn(), syslog_ref_log(), と T_SERIAL_RPOR::wricnt.

参照元 print_hist().

{
    T_SYSLOG_RLOG   rlog;
    T_SERIAL_RPOR   rpor;
    ER              ercd, rercd;

    if (sns_dpn()) {
        ercd = E_CTX;
    }
    else {
        for (;;) {
            if (syslog_ref_log(&rlog) < 0) {
                ercd = E_SYS;
                goto error_exit;
            }
            if (rlog.count <= count) {
                if (count == 0U) {
                    /*
                     *  countが0の場合には，シリアルバッファが空かを確
                     *  認する．
                     */
                    if (serial_ref_por(logtask_portid, &rpor) < 0) {
                        ercd = E_SYS;
                        goto error_exit;
                    }
                    if (rpor.wricnt == 0U) {
                        ercd = E_OK;
                        goto error_exit;
                    }
                }
                else {
                    ercd = E_OK;
                    goto error_exit;
                }
            }

            /*
             *  LOGTASK_FLUSH_WAITミリ秒待つ．
             */
            rercd = dly_tsk(LOGTASK_FLUSH_WAIT);
            if (rercd < 0) {
                ercd = (rercd == E_RLWAI) ? rercd : E_SYS;
                goto error_exit;
            }
        }
    }

  error_exit:
    return(ercd);
}

void logtask_main

(

intptr_t

exinf

)

throw ()

logtask.c の 127 行で定義されています。

参照先 dly_tsk(), LOG_EMERG, LOG_NOTICE, LOG_TYPE_COMMENT, LOG_UPTO, LOGTASK_INTERVAL, logtask_portid, logtask_putc(), SYSLOG::logtype, serial_opn_por(), syslog(), syslog_1, syslog_lostmsg(), syslog_msk_log(), syslog_print(), と syslog_rea_log().

{
    SYSLOG  syslog;
    uint_t  lost;
    ER_UINT rercd;

    logtask_portid = (ID) exinf;
    serial_opn_por(logtask_portid);
    syslog_msk_log(LOG_UPTO(LOG_NOTICE), LOG_UPTO(LOG_EMERG));
    syslog_1(LOG_NOTICE, "System logging task is started on port %d.",
                                                    logtask_portid);
    for (;;) {
        lost = 0U;
        while ((rercd = syslog_rea_log(&syslog)) >= 0) {
            lost += (uint_t) rercd;
            if (syslog.logtype >= LOG_TYPE_COMMENT) {
                if (lost > 0U) {
                    syslog_lostmsg(lost, logtask_putc);
                    lost = 0U;
                }
                syslog_print(&syslog, logtask_putc);
                logtask_putc('\n');
            }
        }
        if (lost > 0U) {
            syslog_lostmsg(lost, logtask_putc);
        }
        dly_tsk(LOGTASK_INTERVAL);
    }
}

void logtask_terminate

(

intptr_t

exinf

)

throw ()

logtask.c の 162 行で定義されています。

参照先 LOG_TYPE_COMMENT, logtask_portid, SYSLOG::logtype, serial_get_chr(), syslog(), syslog_lostmsg(), syslog_print(), syslog_rea_log(), と target_fput_log().

{
    char_t  c;
    SYSLOG  syslog;
    ER_UINT rercd;

    /*
     *  シリアルインタフェースドライバの送信バッファに蓄積されたデータ
     *  を，低レベル出力機能を用いて出力する．
     */
    while (serial_get_chr(logtask_portid, &c)) {
        target_fput_log(c);
    }

    /*
     *  ログバッファに記録されたログ情報を，低レベル出力機能を用いて出
     *  力する．
     */
    while ((rercd = syslog_rea_log(&syslog)) >= 0) {
        if (rercd > 0) {
            syslog_lostmsg((uint_t) rercd, target_fput_log);
        }
        if (syslog.logtype >= LOG_TYPE_COMMENT) {
            syslog_print(&syslog, target_fput_log);
            target_fput_log('\n');
        }
    }
}