VmsCommServer/SRC/VMSCommLib/THREAD/LogThreadF.cpp

//---------------------------------------------------------------------------

#include <vcl.h>
#include "FrmCommLogF.h"
#include "FrmSysLogF.h"
#include "VMSCommLibF.h"
#pragma hdrstop

#include "LogThreadF.h"

#pragma package(smart_init)

TLogThread *LogThread = NULL;
//---------------------------------------------------------------------------
TLogThread::TLogThread()
{
    FPnlState = NULL;
}
//---------------------------------------------------------------------------
TLogThread::~TLogThread()
{
}
//---------------------------------------------------------------------------

DWORD __fastcall TLogThread::Process(LPVOID AParam)
{
    IPC_LOG_MESSAGE *pLog;
    DWORD            dwJob;
    TMessage         Msg;

    MSG       qMsg;
    TITSLog  *pLogObj;
    TCDSCtlr *pCDSCtlr;

    TPanel *pState = FPnlState;

    while(!IsTerm() && !g_AppCfg.bThrExit)
    {
        try {
            if (pState) pState->Color = pState->Color == clLime ? clGreen : clRed;
        }catch(Exception &e) {}

        if (!g_logQ.PopBlocking(dwJob))
        {
            continue;
        }
        if (dwJob == Q_CLOSE)
        {
            break;
        }
        else
        if (dwJob == Q_TICK)
        {
            try {
                if (pState) pState->Color = pState->Color == clRed ? clGreen : clRed;
            }catch(Exception &e) {}
            continue;
        }

        if (pState) pState->Color = clLime;

        pLog = (IPC_LOG_MESSAGE*)dwJob;
        Msg.WParam = (int)pLog;
        pLogObj = (TITSLog*)pLog->Obj;
        if (pLogObj && pLog->Write)
        {
            pLogObj->LogWrite(NULL, pLog->Kind, pLog->Msg);
        }

        try {
            if (pLog->Target == log_sys)
            {
                if (FrmSysLog) FrmSysLog->OnWMLogDisplayMessage(Msg);
                if (from_srvTcp == pLog->From || from_cliTcp == pLog->From)
                {
                    if (FrmCommLog)
                    {
                        if (FrmCommLog->Showing && FrmCommLog->CDSCtlr == (TCDSCtlr*)pLog->Ctlr) FrmCommLog->OnWMLogDisplayMessage(Msg);
                    }
                }
            }
            else
            if (pLog->Target == log_com)
            {
                pCDSCtlr = (TCDSCtlr*)pLog->Ctlr;
                if (pCDSCtlr && FrmCommLog)
                {
                    if (pCDSCtlr->FDispLog && FrmCommLog->Showing) FrmCommLog->OnWMLogDisplayMessage(Msg);
                }
            }
        }catch(Exception &e) {}

        //SAFE_DELETE(pLog);
    }

    Term();
    g_AppCfg.bThrJobExit = true;
    return 0;
}
//---------------------------------------------------------------------------