csu3_am335x/EVSE/Projects/DD360/Apps/ModuleChkSysTask/Module_ChkSysTask.c

/*
 * CheckTask.c
 *
 *  Created on: 2021年9月22日
 *      Author: 8513
 */
#include <stdio.h>      /*標準輸入輸出定義*/
#include <stdlib.h>     /*標準函數庫定義*/
#include <string.h>
#include <stdint.h>
#include <sys/types.h>
#include <dirent.h>
#include "../Config.h"
#include "../Log/log.h"
#include "../Define/define.h"

#include "../ShareMemory/shmMem.h"
#include "Module_ChkSysTask.h"
#include "../common.h"

struct SysConfigData *pSysConfig = NULL;
struct SysInfoData *pSysInfo = NULL;
struct OCPP16Data *ShmOCPP16Data = NULL;
struct ChargingInfoData *pAcChargingInfo = NULL;
static struct ChargingInfoData *pDcChargingInfo = NULL;
struct SysConfigAndInfo         *ShmSysConfigAndInfo;
struct StatusCodeData           *ShmStatusCodeData;
static DcCommonInfo *ShmDcCommonData = NULL;

bool Taskconutstring(char *src, char *taskname)
{
    bool result = false;

    if (src == NULL || strlen(src) == 0)
        return result;

    if (strstr(src, taskname) != NULL &&
        strstr(src, "grep") == NULL &&
        strstr(src, "[") == NULL)
    {
        result = true;
    }

    return result;
}

int GetProcessCount(char *procName)
{
	int result = 0;
	FILE *fp;
	char cmd[256];
	char buf[256];

	sprintf(cmd, "ps -ef |grep %s", procName);
	fp = popen(cmd, "r");
	if(fp != NULL)
	{
		while(fgets(buf, sizeof(buf), fp) != NULL)
		{
			if (Taskconutstring(buf, procName))
				result++;
		}
	}

	pclose(fp);

	return result;
}

unsigned char CheckSystemTask(unsigned char systemPage)
{
	unsigned char result = 0;
	unsigned char count_lcmComm = 0;
	unsigned char count_main 		= GetProcessCount("main");
	unsigned char count_evComm 		= GetProcessCount("Module_EvComm");
	unsigned char count_interComm	= GetProcessCount("Module_InternalComm");
	unsigned char count_eventComm	= GetProcessCount("Module_EventLogging");
	unsigned char count_primaryComm	= GetProcessCount("Module_PrimaryComm");
	if (CheckDispenserGeneration() == _DISPENSER_GENERATION_3_5)
		count_lcmComm	    = GetProcessCount("Module_LcmWistronControl");
	else
		count_lcmComm	    = GetProcessCount("Module_LcmControl");
	unsigned char count_doComm	    = GetProcessCount("Module_DoComm");
	unsigned char count_produceComm	= GetProcessCount("Module_ProduceUtils");
	unsigned char count_updateFW	= GetProcessCount("Module_UpdateFW");
	unsigned char count_DcMeter  	= GetProcessCount("Module_DcMeter");
	int lcmcount = 0;
	if (CheckDispenserGeneration() != _DISPENSER_GENERATION_3_5) {
		lcmcount = _SYSTEM_TASK_COUNT_LCM_7;
	} else {
		lcmcount = _SYSTEM_TASK_COUNT_LCM_21_5;
	}
	//if (systemPage != _LCM_FIX )
	{
		if (count_main < _SYSTEM_TASK_COUNT_MAIN )
		{
            ///*
            system("/usr/bin/fuser -k /dev/watchdog");
            sleep(1);
            system("echo V > /dev/watchdog");
            system("killall main");
			system("killall Module_EventLogging");
			system("killall Module_PrimaryComm");
			system("killall Module_EvComm");
			if (CheckDispenserGeneration() == _DISPENSER_GENERATION_3_5)
				system("killall Module_LcmWistronControl");
			else
				system("killall Module_LcmControl");
			system("killall Module_InternalComm");
			system("killall Module_DoComm");
			system("killall Module_ProduceUtils");
			system("killall Module_UpdateFW");
			if (pSysConfig->ModelName[3] == 'P')
				system("killall Module_DcMeter");
            sleep(3);
            system("/root/main &");
            sleep(20);
            //*/
            /*
            log_info("System task lost (CSU). ");
            sleep(3);
            system("reboot -f");
            */
		}
		else
		{
			if (count_evComm < _SYSTEM_TASK_COUNT_EVCOMM )
			{
				system("killall Module_EvComm");
				sleep(3);
				system("/root/Module_EvComm &");
			}
        	if (count_interComm < _SYSTEM_TASK_COUNT_INTERNALCOMM )
			{
				system("killall Module_InternalComm");
				sleep(3);
				system("/root/Module_InternalComm &");
			}
			if (count_eventComm < _SYSTEM_TASK_COUNT_EVENTLOGGING )
			{
				system("killall Module_EventLogging");
				sleep(3);
				system("/root/Module_EventLogging &");
			}
			if (count_primaryComm < _SYSTEM_TASK_COUNT_PRIMARYCOMM )
			{
				system("killall Module_PrimaryComm");
				sleep(3);
				system("/root/Module_PrimaryComm &");
			}
			if (count_lcmComm < lcmcount )
			{
				if (CheckDispenserGeneration() != _DISPENSER_GENERATION_3_5) {
					system("killall Module_LcmControl");
					sleep(3);
					system("/root/Module_LcmControl &");
				} else {
					system("killall Module_LcmWistronControl");
					sleep(3);
					system("/root/Module_LcmWistronControl &");

				}
			}
			if (count_doComm < _SYSTEM_TASK_COUNT_DOCOMM )
			{
				system("killall Module_DoComm");
				sleep(3);
				system("/root/Module_DoComm &");
			}
			if (count_produceComm < _SYSTEM_TASK_COUNT_PRODUCEUTILS )
			{
				system("killall Module_ProduceUtils");
				sleep(3);
				system("/root/Module_ProduceUtils &");
			}
			if (count_updateFW < _SYSTEM_TASK_COUNT_UPDATEFW )
			{
				system("killall Module_UpdateFW");
				sleep(3);
				system("/root/Module_UpdateFW &");
			}
			if (count_DcMeter < _SYSTEM_TASK_COUNT_DCMETER && pSysConfig->ModelName[3] == 'P' )
			{
				system("killall Module_DcMeter");
				sleep(3);
				system("/root/Module_DcMeter &");
			}
		}

	}

	if (count_main < _SYSTEM_TASK_COUNT_MAIN)
		result = _SYSTEM_TASK_LOST_ITEM_MAIN;
	else if (count_evComm < _SYSTEM_TASK_COUNT_EVCOMM)
		result = _SYSTEM_TASK_LOST_ITEM_EVCOMM;
/*	else if (count_psuComm < 2)
		result = 3; */
    else if (count_eventComm < _SYSTEM_TASK_COUNT_EVENTLOGGING )
        result = _SYSTEM_TASK_LOST_ITEM_EVENTLOG;
    else if (count_primaryComm < _SYSTEM_TASK_COUNT_PRIMARYCOMM)
        result = _SYSTEM_TASK_LOST_ITEM_PRIMARYCOMM;
    else if (count_lcmComm < lcmcount)
        result = _SYSTEM_TASK_LOST_ITEM_LCMCONTROL;
    else if (count_interComm < _SYSTEM_TASK_COUNT_INTERNALCOMM )
        result = _SYSTEM_TASK_LOST_ITEM_INTERCOMM;
    else if (count_doComm < _SYSTEM_TASK_COUNT_DOCOMM)
        result = _SYSTEM_TASK_LOST_ITEM_DOCOMM;
    else if (count_produceComm < _SYSTEM_TASK_COUNT_PRODUCEUTILS)
        result = _SYSTEM_TASK_LOST_ITEM_PRODUCTUTILS;
    else if (count_updateFW < _SYSTEM_TASK_COUNT_UPDATEFW)
        result = _SYSTEM_TASK_LOST_ITEM_UPDATEFW;
    else if (count_DcMeter < _SYSTEM_TASK_COUNT_DCMETER && pSysConfig->ModelName[3] == 'P')
        result = _SYSTEM_TASK_LOST_ITEM_DCMETER;
	else{

	}

	return result;
}

//===============================================
// Check System Task alive
// ==============================================
void CheckSystemTaskAlive()
{
    unsigned char lostId = CheckSystemTask(ShmSysConfigAndInfo->SysInfo.SystemPage);
    if (lostId != 0) {
        log_error("Check task(%d) lost",lostId);
        if (ShmStatusCodeData->AlarmCode.AlarmEvents.bits.SystemTaskLost == NO) {
           if (lostId == _SYSTEM_TASK_LOST_ITEM_MAIN)
               log_error("System task lost (CSU). ");
           else if (lostId == _SYSTEM_TASK_LOST_ITEM_EVCOMM)
               log_error("System task lost (EVComm). ");
//           else if (lostId == _SYSTEM_TASK_LOST_ITEM_PSUCOMM)
//               PRINTF_FUNC("System task lost (PSU Task). ");
           else if (lostId == _SYSTEM_TASK_LOST_ITEM_EVENTLOG)
               log_error("System task lost (Event log). ");
           else if (lostId == _SYSTEM_TASK_LOST_ITEM_PRIMARYCOMM)
               log_error("System task lost (Primary). ");
           else if (lostId == _SYSTEM_TASK_LOST_ITEM_LCMCONTROL)
               log_error("System task lost (LCM Comm). ");
           else if (lostId == _SYSTEM_TASK_LOST_ITEM_INTERCOMM)
               log_error("System task lost (Internal Comm). ");
           else if (lostId == _SYSTEM_TASK_LOST_ITEM_DOCOMM)
               log_error("System task lost (Do Comm). ");
           else if (lostId == _SYSTEM_TASK_LOST_ITEM_PRODUCTUTILS)
               log_error("System task lost (ProcductUtils Comm). ");
           else if (lostId == _SYSTEM_TASK_LOST_ITEM_UPDATEFW)
               log_error("System task lost (Update FW) ");
           else if (lostId == _SYSTEM_TASK_LOST_ITEM_DCMETER)
               log_error("System task lost (DcMeter) ");
           ShmStatusCodeData->AlarmCode.AlarmEvents.bits.SystemTaskLost = YES;
        }
    } else
        ShmStatusCodeData->AlarmCode.AlarmEvents.bits.SystemTaskLost = NO;
}


int main(void)
{
    if (CreateAllCsuShareMemory() == FAIL) {
        log_error("create share memory error");
        return FAIL;
    }
    MappingGunChargingInfo("CheckSystem Task");
    pSysConfig = (struct SysConfigData *)GetShmSysConfigData();
    pSysInfo = (struct SysInfoData *)GetShmSysInfoData();
    ShmOCPP16Data = (struct OCPP16Data *)GetShmOCPP16Data();
    ShmSysConfigAndInfo = (struct SysConfigAndInfo *)GetShmSysConfigAndInfo();
    ShmStatusCodeData = (struct StatusCodeData *)GetShmStatusCodeData();
    ShmDcCommonData = (DcCommonInfo *)GetShmDcCommonData();

    while(true)
    {
      	for (uint8_t gun = 0; gun < pSysConfig->TotalConnectorCount; gun++) {
    		pDcChargingInfo = (struct ChargingInfoData *)GetDcChargingInfoData(gun);
			if (pDcChargingInfo->SystemStatus == SYS_MODE_UPDATE )
				continue;
		}
        if (ShmDcCommonData->debugflag == YES || pSysInfo->FirmwareUpdate) {
            sleep(3);
            continue;
        }
		CheckSystemTaskAlive();
		sleep(3);
    }
}