123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589 |
- #include "stdafx.h"
- #include <fstream>
- #include <string>
- #include <algorithm>
- #ifdef RVC_OS_WIN
- #include <io.h>
- #else
- #include <unistd.h>
- #include <fcntl.h>
- #include <errno.h>
- #endif
- #include "CommEntityUtil.hpp"
- #include "CommEntitySettings.hpp"
- #include "mod_healthmanager.h"
- #include "publicFunExport.h"
- #include "iniutil.h"
- using namespace std;
- const int MAX_AYSNC_TIMEOUT = 60000;
- const int MAX_IGNORE_TIMEOUT = 100;
- unsigned long long GetTickCountRVC() {
- #ifdef RVC_OS_WIN
- return GetTickCount64();
- #else
- struct timespec ts;
- clock_gettime(CLOCK_MONOTONIC, &ts);
- return (ts.tv_sec * 1000 + ts.tv_nsec / 1000000);
- #endif //RVC_OS_WIN
- }
- unsigned long long GetLastErrorRVC() {
- #ifdef RVC_OS_WIN
- return GetLastError();
- #else
- return errno;
- #endif //RVC_OS_WIN
- }
- enum EntityOP
- {
- OP_STOP_ENTITY,
- OP_START_ENTITY,
- OP_PAUSE_ENTITY,
- OP_TERMINATE_ENTITY,
- OP_CONTINUE_ENTITY,
- };
- bool StrEqualNoCase(const char *s1, const char *s2,int len)
- {
- if (strlen(s1) != strlen(s2))
- return false;
- for (int i = 0; i < len; ++i)
- {
- if (toupper(s1[i]) != toupper(s2[i]))
- return false;
- }
- return true;
- }
- void CHealthManagerFSM::WaitALittleIfNecessary()
- {
- if (IsCoolBootThisTime()) {
- GetEntityBase()->GetFunction()->ShowStartupInfo("正在初始化,请稍等片刻......");
- int millsec = 0;
- SP::Module::Comm::Settings::ReadConfigFromCenterAfterCfg(m_pEntity, "CoolBootDefaultWaitMillsecs", NULL, &millsec);
- if (millsec <= 0) {
- millsec = 30000;
- }
- Dbg("Sleep a little time %d", millsec);
- Sleep(millsec);
- }
- }
- ErrorCodeEnum CHealthManagerFSM::Initial()
- {
- CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- CSmartPointer<IAsynWaitSp> spWait;
- ErrorCodeEnum err;
- CSimpleStringA cfgPath = "";
- CSimpleStringA strCoreBoot("CoreBoot"), strSafeLoad("SafeLoad"), strOp("Operating"), strIEBrower("IEBrowser");
-
- GetEntityBase()->GetFunction()->GetSystemStaticInfo(m_sysInfo);
- Dbg("machinetype[%s],terminalID[%s]", (LPCTSTR)m_sysInfo.strMachineType, (LPCTSTR)m_sysInfo.strTerminalID);
- strCoreBoot = strCoreBoot + "." + m_sysInfo.strMachineType;
- strSafeLoad = strSafeLoad + "." + m_sysInfo.strMachineType;
- strOp = strOp + "." + m_sysInfo.strMachineType;
- m_strURL = strIEBrower + "." + m_sysInfo.strMachineType + ".Url";
- m_AccessAuthTries = 4;
- m_InitTries = 4;
- m_AccessAuthTimeout = 180000;
- m_InitializationTimeout = 180000;
- int tmpAATries, tmpInitTries, tmpAATimeout, tmpInitTimout;
- CSmartPointer<IConfigInfo> spConfig;
- err = GetEntityBase()->GetFunction()->OpenConfig(Config_Software, spConfig);
- if (err != Error_Succeed) {
- Dbg("open cfg file failed!");
- return Error_IO;
- }
- if (spConfig->ReadConfigValueInt("init", "AccessAuthTries", tmpAATries) == Error_Succeed)
- m_AccessAuthTries = tmpAATries;
- if (spConfig->ReadConfigValueInt("init", "InitTries", tmpInitTries) == Error_Succeed)
- m_InitTries = tmpInitTries;
- if (spConfig->ReadConfigValueInt("init", "AccessAuthTimeout", tmpAATimeout) == Error_Succeed)
- m_AccessAuthTimeout = tmpAATimeout;
- if (spConfig->ReadConfigValueInt("init", "InitializationTimeout", tmpInitTimout) == Error_Succeed)
- m_InitializationTimeout = tmpInitTimout;
- CSmartPointer<IConfigInfo> spConfigRoot;
- GetEntityBase()->GetFunction()->OpenConfig(Config_Root, spConfigRoot);
- CSimpleStringA csGpioVendor("");
- spConfigRoot->ReadConfigValue("Device.Gpio", "Vendor", csGpioVendor);
- if (csGpioVendor.GetLength() > 1) {
- m_hasCfgGpioInRootIni = true;
- }
- int count, cbNum, slNum, opNum;
- count = cbNum = slNum = opNum = 0;
- err = GetEntityBase()->GetFunction()->GetPath("cfg", cfgPath);
- cfgPath = cfgPath + "/HealthManager.ini";
- Dbg("cfgpath[%s]", (const char*)cfgPath);
- ifstream is;
- is.open(cfgPath, ios::binary);
- if (!is.is_open()) {
- DWORD dwErr = GetLastErrorRVC();
- Dbg("open cfg file failed. [%d]", dwErr);
- return Error_IO;
- }
- string line;
- long curr, end;
- is.seekg(0, ios_base::end);
- end = is.tellg();
- is.seekg(0, ios_base::beg);
- LoadStage eSection = LOADSTAGE_UNKNOWN;
- do {
- getline(is, line);
- if (line[0] == '[') {
- size_t secEnd = line.find(']', 1);
- if (secEnd != string::npos) {
- string strSec = line.substr(1, secEnd - 1);
- if (StrEqualNoCase(strSec.c_str(), strCoreBoot, strSec.length()))
- eSection = LOADSTAGE_COREBOOT;
- else if (StrEqualNoCase(strSec.c_str(), strSafeLoad, strSec.length()))
- eSection = LOADSTAGE_SAFELOAD;
- else if (StrEqualNoCase(strSec.c_str(), strOp, strSec.length()))
- eSection = LOADSTAGE_OPERATING;
- else
- eSection = LOADSTAGE_UNKNOWN;
- }
- } else if (((unsigned)(line[0] + 1) > 256) || line[0] == ';') {//Chinese and other...
- curr = is.tellg();
- continue;
- } else if (isalpha(line[0])) {
- if (eSection == LOADSTAGE_UNKNOWN) {
- curr = is.tellg();
- continue;
- }
- size_t keyPos = line.find('=', 0);
- if (keyPos != string::npos) {
- string keyName = line.substr(0, keyPos);
- count++;
- switch (eSection) {
- case LOADSTAGE_COREBOOT:
- spConfig->ReadConfigValueInt(strCoreBoot, keyName.c_str(), m_coreBootOpt[keyName.c_str()].loadOpt);
- m_vCoreBoot.push_back(keyName.c_str());
- m_vAllCfgEntity.push_back(keyName.c_str());
- m_coreBootOpt[keyName.c_str()].eResult = LOADING_INIT;
- m_coreBootOpt[keyName.c_str()].initSn = cbNum;
- cbNum++;
- break;
- case LOADSTAGE_SAFELOAD:
- spConfig->ReadConfigValueInt(strSafeLoad, keyName.c_str(), m_safeLoadOpt[keyName.c_str()].loadOpt);
- m_vSafeLoad.push_back(keyName.c_str());
- m_vAllCfgEntity.push_back(keyName.c_str());
- m_safeLoadOpt[keyName.c_str()].eResult = LOADING_INIT;
- m_safeLoadOpt[keyName.c_str()].initSn = slNum;
- slNum++;
- break;
- case LOADSTAGE_OPERATING:
- spConfig->ReadConfigValueInt(strOp, keyName.c_str(), m_operatingOpt[keyName.c_str()].loadOpt);
- if (keyName.compare("Gpio") == 0 && !m_hasCfgGpioInRootIni)
- Dbg("have configure gpio in HealthManager.ini,but can't find gpio in root.ini,ignore start gpio.");
- else {
- m_vOperating.push_back(keyName.c_str());
- m_vAllCfgEntity.push_back(keyName.c_str());
- m_operatingOpt[keyName.c_str()].eResult = LOADING_INIT;
- m_operatingOpt[keyName.c_str()].initSn = opNum;
- opNum++;
- }
- break;
- default:
- break;
- }
- }
- }
- curr = is.tellg();
- } while (curr < end);
- is.close();
- Dbg("opt num:[%d]c[%d]s[%d]o[%d]", count, m_coreBootOpt.size(), m_safeLoadOpt.size(), m_operatingOpt.size());
- //read entity loading history record
- CSimpleStringA sysinfoPath = "";
- #if defined(RVC_OS_LINUX)
- if (!m_sysInfo.strMachineType.IsNullOrEmpty() && m_sysInfo.strMachineType.Compare("RVC.Stand2S") != 0) {
- CSimpleStringA strErrMsg = CSimpleStringA::Format("当前版本不支持此机型:%s", (LPCTSTR)m_sysInfo.strMachineType);
- SP::Module::Comm::LogErrorNotiyStruct notifyItem(Error_NotSupport, 0);
- SP::Module::Comm::LogNotiyMessageStruct notifyMsg(strErrMsg);
- notifyItem.Notify(notifyMsg);
- return Error_Succeed;
- }
- #endif //RVC_OS_LINUX
- GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "X");
- WaitDeamonFinishTask* task = new WaitDeamonFinishTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- return Error_Succeed;
- }
- ErrorCodeEnum CHealthManagerFSM::OnInit(void)
- {
- m_hMD5OKEvt = CreateEventA(NULL, FALSE, FALSE, NULL);
- if (m_hMD5OKEvt == NULL)
- {
- Dbg("CreateEvent failed(%d).", GetLastErrorRVC());
- }
- return Initial();
- }
- ErrorCodeEnum CHealthManagerFSM::OnExit(void)
- {
- return Error_Succeed;
- }
- void CHealthManagerFSM::s0_on_entry(void)
- {
- LOG_FUNCTION();
- m_fsmState = HM_FSM_INIT;
- }
- void CHealthManagerFSM::s0_on_exit(void)
- {
- }
- unsigned int CHealthManagerFSM::s0_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- int ret = 0;
- switch(pEvt->iEvt)
- {
- case USER_EVT_WAIT_DEAMON_FINISHED:
- ret = pEvt->param1;
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return ret;
- }
- bool CHealthManagerFSM::IsCoolBootThisTime()
- {
- //oilyang@20190924
- //修改为判断冷热启动,热重启不再等待10s
- //系统启动小于1.5分钟,认为是冷启动
- const ULONGLONG dwElapse = GetTickCountRVC();
- int millsec = 0;
- SP::Module::Comm::Settings::ReadConfigFromCenterAfterCfg(m_pEntity, "BootMaxMillsecsSeeAsAutoRun", NULL, &millsec);
- if (millsec <= 0) {
- millsec = 90000;
- }
- Dbg("have elapsed %d seconds from system start vs %d", dwElapse / 1000, millsec / 1000);
- if (dwElapse < millsec) {
- return true;
- }
- return false;
- }
- //CoreBoot
- void CHealthManagerFSM::s1_on_entry()
- {
- ErrorCodeEnum eErrCode;
- CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = spEntityFunction.ConvertCase<IEntityFunctionPrivilege>();
- CEntityRunInfo browserInfo;
- if (IsCutIEBrowser())
- eErrCode = spEntityFunction->GetEntityRunInfo("Chromium", browserInfo);
- else
- eErrCode = spEntityFunction->GetEntityRunInfo("IEBrowser", browserInfo);
- if (browserInfo.eState == EntityState_Idle)
- {
- Dbg("IE idle before healthmanager, maybe healthmanager have been losted.");
- m_bIEBeforeHealth = true;
- }
- m_fsmState = HM_FSM_STATE_COREBOOT;
- WaitALittleIfNecessary();
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","B");
- if (eErrCode != Error_Succeed)
- {
- Dbg("set RunState B failed %s.", SpStrError(eErrCode));
- }
- bool bWatchDog = false,bAsync = false;
- m_eStage = LOADSTAGE_COREBOOT;
- int ret = 0;
- map<CSimpleStringA,EntityLoadInfo>::iterator it;
- //start entity
-
- vector<CSimpleStringA>::iterator vIt;
- if (m_coreBootOpt.size() == 0)
- goto COREBOOT_FINISH;
- char startMsg[128];
- for (vIt = m_vCoreBoot.begin(); vIt != m_vCoreBoot.end(); ++ vIt)
- {
- CSmartPointer<IAsynWaitSp> spWait;//oilyang 20160325 see the following comment
- it = m_coreBootOpt.find(*vIt);
- if (it == m_coreBootOpt.end())
- {
- Dbg("cannot find %s",(LPCSTR)*vIt);
- continue;
- }
- Dbg("start,%s,%d",(LPCSTR)it->first,it->second.loadOpt);
- CEntityRunInfo entRunInfo;
- ErrorCodeEnum errCode = spEntityFunction->GetEntityRunInfo(it->first,entRunInfo);
- if (errCode == Error_Succeed && entRunInfo.eState == EntityState_Idle)
- {
- it->second.eResult = LOADING_SUCCEED;
- ret = CheckLoadResult(LOADSTAGE_COREBOOT);
- if (ret == 0 || ret == 2)
- goto COREBOOT_FINISH;
- else
- continue;
- }
- ZeroMemory(startMsg, 128);
- //sprintf(startMsg, "正在启动实体%s...", it->first.GetData());
- //GetEntityBase()->GetFunction()->ShowStartupInfo(startMsg);
- switch(it->second.loadOpt)
- {
- case LOADOPT_IGNORE:
- {
- pFuncPrivilege->StartEntity(it->first,NULL,spWait);
- if (spWait != NULL)
- spWait->WaitAnswer(MAX_IGNORE_TIMEOUT);//oilyang 20160325 the null pointer
- it->second.eResult = LOADING_SUCCEED;
- ret = CheckLoadResult(LOADSTAGE_COREBOOT);
- if (ret == 0 || ret == 2)
- goto COREBOOT_FINISH;
- }
- break;
- case LOADOPT_ASYNC_VERIFY:
- errCode = AsyncStartEntity(it->first,NULL,NULL);
- Dbg("%d",errCode);
- bAsync = true;
- break;
- case LOADOPT_SYNC_VERIFY:
- {
- pFuncPrivilege->StartEntity(it->first,NULL,spWait);
- if (spWait != NULL)
- errCode = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
- Dbg("(coreboot)sync...%d",errCode);
- if (errCode == Error_Succeed)
- it->second.eResult = LOADING_SUCCEED;
- else if (errCode == Error_TimeOut)
- it->second.eResult = LOADING_TIMEOUT;
- else
- it->second.eResult = LOADING_FAILED;
- if (_strnicmp(it->first,"WatchDog",strlen("WatchDog")) == 0
- && it->second.eResult == LOADING_SUCCEED)
- bWatchDog = true;
- if (errCode != Error_Succeed) {
- ShowEntityBootFailedAtFront(it->first, errCode);
- return;
- }
- else
- ret = CheckLoadResult(LOADSTAGE_COREBOOT);
- Dbg("s1 check ret %d",ret);
- if (ret == 0 || ret == 2)
- goto COREBOOT_FINISH;
- }
- break;
- default:
- break;
- }
- }
- COREBOOT_FINISH:
- //start watchdog if have load it sucessfully
- if (bWatchDog)
- {
- /**TODO(Gifur@5/21/2021): 国产化容易出现卡死现象,找个时间点把看门狗的逻辑加上去 */
- }
- if (!bAsync)
- {
- FSMEvent *e = new FSMEvent(USER_EVT_COREBOOT_FINISHED);
- e->param1 = ret;
- PostEventFIFO(e);
- }
- else
- {
- ret = CheckLoadResult(LOADSTAGE_COREBOOT);
- if (ret == 0 || ret == 2)
- {
- FSMEvent *e = new FSMEvent(USER_EVT_COREBOOT_FINISHED);
- e->param1 = ret;
- PostEventFIFO(e);
- }
- }
- return;
- }
- void CHealthManagerFSM::s1_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s1_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- Dbg("s1 evt %d",pEvt->iEvt);
- switch(pEvt->iEvt)
- {
- case USER_EVT_COREBOOT_FINISHED:
- pEvt->SetHandled();
- if (pEvt->param1 == 2) {
- ShowEntityBootFailedAtFront(m_csErrEntity, Error_InvalidState);
- }
- return pEvt->param1;
- break;
- case USER_EVT_ENTER_CUSTOMER_MANAGER:
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return 0;
- }
- //SafeLoad
- void CHealthManagerFSM::s2_on_entry()
- {
- LOG_FUNCTION();
- m_fsmState = HM_FSM_STATE_SAFELOAD;
- Sleep(1000);
- #if defined(RVC_OS_WIN)
- USBControl();
- #endif //RVC_OS_WIN
- CSimpleStringA xMsg = CSimpleStringA::Format("\"Decripstion\":\"Enter safeload state.\",\"version:\"%s\"}"
- , m_sysInfo.InstallVersion.ToString().GetData());
- LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_Enter_SafeLoad_State, xMsg);
-
- ErrorCodeEnum eErrCode;
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","S");
- if (eErrCode != Error_Succeed)
- {
- Dbg("set RunState S failed (%d).",eErrCode);
- }
- bool bAsync = false;
- m_eStage = LOADSTAGE_SAFELOAD;
- int ret = 0;
- map<CSimpleStringA,EntityLoadInfo>::iterator it;
- CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
-
- ErrorCodeEnum errCode;
- vector<CSimpleStringA>::iterator vIt;
- if (m_safeLoadOpt.size() == 0)
- goto SAFELOAD_FINISH;
- char startMsg[128];
- for (vIt = m_vSafeLoad.begin(); vIt != m_vSafeLoad.end(); ++vIt)
- {
- CSmartPointer<IAsynWaitSp> spWait;
- it = m_safeLoadOpt.find(*vIt);
- if (it == m_safeLoadOpt.end())
- {
- Dbg("cannot find %s",(LPCSTR)*vIt);
- continue;
- }
- CEntityRunInfo entRunInfo;
- errCode = pFunc->GetEntityRunInfo(it->first,entRunInfo);
- if (errCode == Error_Succeed && entRunInfo.eState == EntityState_Idle)
- {
- it->second.eResult = LOADING_SUCCEED;
- ret = CheckLoadResult(LOADSTAGE_SAFELOAD);
- if (ret == 0 || ret == 2)
- goto SAFELOAD_FINISH;
- else
- continue;
- }
- Dbg("start %s,%d",(LPCTSTR)it->first,it->second.loadOpt);
- switch(it->second.loadOpt)
- {
- case LOADOPT_IGNORE:
- {
- pFuncPrivilege->StartEntity(it->first,NULL,spWait);
- if (spWait != NULL)
- spWait->WaitAnswer(MAX_IGNORE_TIMEOUT);
- it->second.eResult = LOADING_SUCCEED;
- ret = CheckLoadResult(LOADSTAGE_SAFELOAD);
- if (ret == 0 || ret == 2)
- goto SAFELOAD_FINISH;
- }
- break;
- case LOADOPT_ASYNC_VERIFY:
- AsyncStartEntity(it->first,NULL,NULL);
- bAsync = true;
- break;
- case LOADOPT_SYNC_VERIFY:
- {
- ZeroMemory(startMsg, 128);
- sprintf(startMsg, "正在启动实体%s...", it->first.GetData());
- GetEntityBase()->GetFunction()->ShowStartupInfo(startMsg);
- pFuncPrivilege->StartEntity(it->first,NULL,spWait);
- if (spWait != NULL)
- errCode = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
- Dbg("sync...%d",eErrCode);
- if (errCode == Error_Succeed) {
- it->second.eResult = LOADING_SUCCEED;
- #if defined(RVC_OS_WIN)
- if (StrEqualNoCase("MaintainWatcher", it->first, strlen("MaintainWatcher"))) {
- Sleep(10000);
- if (m_custMngerState == CM_ENTER) {
- Dbg("enter CMS...");
- FSMEvent* pEvt = new FSMEvent(USER_EVT_ENTER_CUSTOMER_MANAGER);
- PostEventFIFO(pEvt);
- goto SAFELOAD_END;
- }
- }
- #endif //RVC_OS_WIN
- }
- else if (errCode == Error_TimeOut)
- it->second.eResult = LOADING_TIMEOUT;
- else
- it->second.eResult = LOADING_FAILED;
- if (it->second.eResult != Error_Succeed)
- {
- char tmp[64] = {0};
- sprintf(tmp, "实体 %s 启动失败 %d", it->first.GetData(), it->second.eResult);
- Dbg("%s",tmp);
- }
- if (errCode != Error_Succeed) {
- ShowEntityBootFailedAtFront(it->first, errCode);
- m_csErrEntity = m_csErrEntity + "|" + it->first;
- FSMEvent* e = new FSMEvent(USER_EVT_SAFELOAD_FINISHED);
- e->param1 = 2;//"SYNC START" enity started failed.
- PostEventFIFO(e);
- return;
- }
- //if (errCode != Error_Succeed)
- // return;
- //else
- ret = CheckLoadResult(LOADSTAGE_SAFELOAD);
- if (ret == 0 || ret == 2)
- goto SAFELOAD_FINISH;
- }
- break;
- default:
- break;
- }
- }
- SAFELOAD_FINISH:
- if (!bAsync)
- {
- FSMEvent *e = new FSMEvent(USER_EVT_SAFELOAD_FINISHED);
- e->param1 = ret;
- PostEventFIFO(e);
- }
- else
- {
- ret = CheckLoadResult(LOADSTAGE_SAFELOAD);
- Dbg("s2 %d",ret);
- if (ret == 0 || ret == 2)
- {
- FSMEvent *e = new FSMEvent(USER_EVT_SAFELOAD_FINISHED);
- e->param1 = ret;
- PostEventFIFO(e);
- }
- }
- SAFELOAD_END:
- return ;
- }
- void CHealthManagerFSM::s2_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s2_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- int ret = 0;
- Dbg("s2 event %d,%d",pEvt->iEvt,pEvt->param1);
- switch(pEvt->iEvt)
- {
- case USER_EVT_SAFELOAD_FINISHED:
- {
- pEvt->SetHandled();
- //ToCheckUPS();
- //oiltmp
- //according to the system varible TerminalState to do sth.
- //Configed
- //Breakdown
- //Blocking
- //Authentication
- {
- if(pEvt->param1 == 0)
- {
- //initializer if configured
- CSimpleStringA csTermStage("");
- ErrorCodeEnum eErrCode;
- eErrCode = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage",csTermStage);
- Dbg("after safeload to get termstage %s",(LPCTSTR)csTermStage);
- if (csTermStage == "B" || csTermStage == "N")
- return 1;
- }
- else if (pEvt->param1 == 2)
- {
- ShowEntityBootFailedAtFront(m_csErrEntity, Error_InvalidState);
- ret = 2;
- }
- }
- //Unsubscrible
- }
- break;
- case USER_EVT_SAFELOAD_EXMINE_FINISHED:
- if (pEvt->param1 == 0)
- ret = 0;
- //do something else oiltmp
- pEvt->SetHandled();
- break;
- case USER_EVT_ACCESSAUTH_FINISHED:
- pEvt->SetHandled();
- ret = pEvt->param1;
- break;
- case USER_EVT_ENTER_CUSTOMER_MANAGER:
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return ret;
- }
- //Operating
- void CHealthManagerFSM::s3_on_entry()
- {
- LOG_FUNCTION();
- m_fsmState = HM_FSM_STATE_OP;
- #if defined(RVC_OS_WIN)
- Sleep(5000);//oilyang for nantian pinpad 20150703
- #endif //RVC_OS_WIN
- if (m_custMngerState == CM_ENTER)
- {
- Dbg("in CMS,no need to start hardware.");
- return;
- }
- ErrorCodeEnum eErrCode;
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","O");
- if (eErrCode != Error_Succeed)
- {
- Dbg("set RunState O failed (%d).",eErrCode);
- }
-
- bool bAsync = false;
- m_eStage = LOADSTAGE_OPERATING;
- int ret = 0;
- map<CSimpleStringA,EntityLoadInfo>::iterator it;
- CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- //start entity
-
- ErrorCodeEnum errCode;
- vector<CSimpleStringA>::iterator vIt;
- if (m_operatingOpt.size() == 0)
- goto OPERATING_FINISH;
- char startMsg[128];
- for (vIt = m_vOperating.begin(); vIt != m_vOperating.end(); ++vIt)
- {
- CSmartPointer<IAsynWaitSp> spWait;
- it = m_operatingOpt.find(*vIt);
- if (it == m_operatingOpt.end())
- {
- Dbg("cannot find %s",(LPCSTR)*vIt);
- continue;
- }
- CEntityRunInfo entRunInfo;
- errCode = pFunc->GetEntityRunInfo(it->first,entRunInfo);
- if (errCode == Error_Succeed && entRunInfo.eState == EntityState_Idle)
- {
- it->second.eResult = LOADING_SUCCEED;
- ret = CheckLoadResult(LOADSTAGE_OPERATING);
- if (ret == 0 || ret == 2)
- goto OPERATING_FINISH;
- else
- continue;
- }
- Dbg("op start %s,%d",(LPCTSTR)it->first,it->second.loadOpt);
- switch(it->second.loadOpt)
- {
- case LOADOPT_IGNORE:
- {
- pFuncPrivilege->StartEntity(it->first,NULL,spWait);
- if (spWait != NULL)
- spWait->WaitAnswer(MAX_IGNORE_TIMEOUT);
- it->second.eResult = LOADING_SUCCEED;
- ret = CheckLoadResult(LOADSTAGE_OPERATING);
- if (ret == 0 || ret == 2)
- goto OPERATING_FINISH;
- }
- break;
- case LOADOPT_ASYNC_VERIFY:
- errCode = AsyncStartEntity(it->first,NULL,NULL);
- bAsync = true;
- break;
- case LOADOPT_SYNC_VERIFY:
- {
- ZeroMemory(startMsg, 128);
- sprintf(startMsg, "正在启动实体%s...", it->first.GetData());
- GetEntityBase()->GetFunction()->ShowStartupInfo(startMsg);
- errCode = pFuncPrivilege->StartEntity(it->first,NULL,spWait);
- if (errCode == Error_Succeed)
- {
- if (spWait != NULL)
- errCode = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
- }
- else
- {
- Dbg("StartEntity %s failed(%d).",(LPCSTR)it->first,errCode);
- break;
- }
- if (errCode == Error_Succeed)
- it->second.eResult = LOADING_SUCCEED;
- else if (errCode == Error_TimeOut)
- it->second.eResult = LOADING_TIMEOUT;
- else
- it->second.eResult = LOADING_FAILED;
- if (it->second.eResult != Error_Succeed)
- {
- char tmp[64] = {0};
- sprintf(tmp, "实体 %s 启动失败", it->first.GetData());
- Dbg("%s", tmp);
- }
- if (errCode != Error_Succeed) {
- ShowEntityBootFailedAtFront(it->first, errCode);
- m_csErrEntity = m_csErrEntity + "|" + it->first;
- FSMEvent* e = new FSMEvent(USER_EVT_OPERATING_FINISHED);
- e->param1 = 2;//"SYNC START" enity started failed.
- PostEventFIFO(e);
- return;
- return;
- }
- else
- ret = CheckLoadResult(LOADSTAGE_OPERATING);
- if (ret == 0 || ret == 2)
- goto OPERATING_FINISH;
- }
- break;
- default:
- break;
- }
- }
- OPERATING_FINISH:
- Dbg("s3 ret %d",ret);
- if (!bAsync)
- {
- FSMEvent *e = new FSMEvent(USER_EVT_OPERATING_FINISHED);
- e->param1 = ret;
- PostEventFIFO(e);
- }
- else
- {
- ret = CheckLoadResult(LOADSTAGE_OPERATING);
- if (ret == 0 || ret == 2)
- {
- FSMEvent *e = new FSMEvent(USER_EVT_OPERATING_FINISHED);
- e->param1 = ret;
- PostEventFIFO(e);
- }
- }
- return ;
- }
- void CHealthManagerFSM::s3_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s3_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- Dbg("s3(Operating) event %d,%d",pEvt->iEvt,pEvt->param1);
- int ret = 0;
- switch(pEvt->iEvt)
- {
- case USER_EVT_OPERATING_FINISHED:
- ret = pEvt->param1;
- if (ret == 2) {
- ShowEntityBootFailedAtFront(m_csErrEntity, Error_InvalidState);
- }
- pEvt->SetHandled();
- break;
- case USER_EVT_ENTER_CUSTOMER_MANAGER:
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return ret;
- }
- //Idle(Operating finished)
- void CHealthManagerFSM::s4_on_entry()
- {
- LOG_FUNCTION();
- m_fsmState = HM_FSM_STATE_IDLE;
- m_accessAuthCheckMD5 = 0;
- CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
- CSmartPointer<IConfigInfo> spConfig, spCerConfig;
- ErrorCodeEnum eErrCer = spEntityFunction->OpenConfig(Config_CenterSetting, spCerConfig);
- if (eErrCer != Error_Succeed) {
- Dbg("open central cfg file failed!");
- }
- else
- spCerConfig->ReadConfigValueInt("AccessAuthorization", "CheckMD5", m_accessAuthCheckMD5);
- Dbg("before access auth,read MD5 flag:%d",m_accessAuthCheckMD5);
- if (!m_bIdleToMaintain)
- {
- if (!m_bAccessAuth)
- {
- AccessAuthTask* pTask = new AccessAuthTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
- }
- }
- else
- m_bIdleToMaintain = false;
- }
- void CHealthManagerFSM::s4_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s4_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- Dbg("s4 event %d,%d",pEvt->iEvt,pEvt->param1);
- switch(pEvt->iEvt)
- {
- case USER_EVT_ACCESSAUTH_FINISHED:
- {
- pEvt->SetHandled();
- if (pEvt->param1 == 1)
- {
- SetAccessAuth(false);
- //why to do this???
- //LogEvent(Severity_Middle,EVENT_CONSOLE_REQ_RESTART_SHELL,"AccessAuth failed,to restart spshell.");
- //return 1;
- }
-
- CSimpleStringA csTermStage;
- ErrorCodeEnum eErrCode;
- eErrCode = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage",csTermStage);
- Dbg("after accessauth to get termstage %s",(LPCTSTR)csTermStage);
- //oilyang@20170316@comment
- //for user desktop,start iebrowser no matter what TerminalStage is.
- //if (csTermStage[0] != 'A')
- // break;
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","O");
- if (eErrCode != Error_Succeed)
- {
- Dbg("set RunState O failed (%d).",eErrCode);
- }
- CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
- CSmartPointer<IConfigInfo> spConfigRun,spCerConfig;
- ErrorCodeEnum eErrIE = spEntityFunction->OpenConfig(Config_Run, spConfigRun);
- if (eErrIE != Error_Succeed) {
- Dbg("open cfg file(ie) failed!");
- //return err;
- }
- ErrorCodeEnum eErrCerUrl = spEntityFunction->OpenConfig(Config_CenterSetting, spCerConfig);
- if (eErrCerUrl != Error_Succeed) {
- Dbg("open central cfg file(ie) failed!");
- }
- //if load successfully,set FailTimes to 0
- spConfigRun->WriteConfigValueInt("Run","FailTimes",0);
- if (m_bAccessAuth)
- {
- eErrCode = QueryCheckCode(m_checkCode);
- if (eErrCode && m_checkCode.GetLength() > 1)
- m_bEverAuthSucWithDevice = true;
- else
- m_bEverAuthSucWithDevice = false;
- }
- else
- {
- AuthStatus as;
- if (m_bEverAuthSucWithDevice)
- {
- as.result = 1;
- as.msg = "设备混用,请接入对应设备或后台重新绑定当前设备";
- //SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(AuthStatus), SP_MSG_SIG_OF(AuthStatus), as);
- }
- else
- {
- as.result = 11;
- as.msg = "请检查设备是否正常初始化或是否对应绑定设备";
- //SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(AuthStatus), SP_MSG_SIG_OF(AuthStatus), as);
- }
- }
- m_strURLValue = "";
- #ifdef RVC_OS_WIN
- eErrCerUrl = spCerConfig->ReadConfigValue(GetEntityBase()->GetEntityName(), m_strURL, m_strURLValue);
- if (eErrIE == Error_Succeed)
- {
- Dbg("write ie url.sys [%s]", (const char*)m_strURLValue);
- GetEntityBase()->GetFunction()->SetSysVar("IEUrl", m_strURLValue);
- }
- CSmartPointer<IAsynWaitSp> spWait;
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = spEntityFunction.ConvertCase<IEntityFunctionPrivilege>();
- CEntityRunInfo acInfo;
- if (IsCutIEBrowser())
- eErrCode = spEntityFunction->GetEntityRunInfo("Chromium",acInfo);
- else
- eErrCode = spEntityFunction->GetEntityRunInfo("IEBrowser", acInfo);
- if (eErrCode == Error_Succeed && acInfo.eState == EntityState_NoStart)
- {
- //have NOT cut "IEBrowser"
- if (!IsCutIEBrowser())
- {
- GetEntityBase()->GetFunction()->ShowStartupInfo("正在启动实体IEBrowser...");
- eErrIE = pFuncPrivilege->StartEntity("IEBrowser", m_strURLValue, spWait);
- if (eErrIE == Error_Succeed)
- {
- if (spWait != NULL)
- eErrIE = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
- }
- else
- {
- Dbg("Start IEBrowser failed(%d).", eErrIE);
- }
- }
- }
- else if (eErrCode == Error_Succeed && acInfo.eState == EntityState_Idle)
- {//if IE/Chromium start before healthmanager,we suppose healthmanager is restart unexpectly,then set m_bEnterMainPageEver true
- //m_bIEBeforeHealth = true;
- }
- #endif //RVC_OS_WIN
- LogTermInfoTask* task = new LogTermInfoTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- if (!m_bAccessAuth)
- PostProcessAfterUpgrade();
- }
- break;
- case USER_EVT_MAITAIN:
- Dbg("to maintain...");
- m_stateBeforeMaintain = m_fsmState;
- m_bIdleToMaintain = true;
- pEvt->SetHandled();
- break;
- case USER_EVT_ENTER_CUSTOMER_MANAGER:
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return 0;
- }
- //Fault
- void CHealthManagerFSM::s5_on_entry()
- {
- LOG_FUNCTION();
- LogTermInfoTask* task = new LogTermInfoTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
- m_fsmState = HM_FSM_STATE_FAULT;
- CSmartPointer<IConfigInfo> spConfig,spConfigRun;
- ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Software, spConfig);
- eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
- int failTimes = 0,maxFailTimes = 3;
- spConfig->ReadConfigValueInt("Run","MaxFailTimes",maxFailTimes);
- spConfigRun->ReadConfigValueInt("Run","FailTimes",failTimes);
- failTimes++;
- LogWarn(Severity_High, Error_Unexpect, LOG_ERR_HEALTH_FAILED, "HealthManager failed.");
- //oilyang@20210930 add to call for Close Page
- GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "C");
- if (failTimes > maxFailTimes)
- {
- LogEvent(Severity_Middle,LOG_EVT_HEADLIGHT_RED_ON,"设备故障");
- eErr = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage","D");
- if (eErr != Error_Succeed)
- Dbg("set termstage D failed (%d).",eErr);
- else
- Dbg("Set TerminalStage D.");
- }
- else
- {
- Dbg("have failed %d times.",failTimes);
- spConfigRun->WriteConfigValueInt("Run","FailTimes",failTimes);
- eErr = GetEntityBase()->GetFunction()->SetSysVar("RunState","F");
- if (eErr != Error_Succeed)
- {
- Dbg("set RunState failed (%d).",eErr);
- }
- }
- PostProcessAfterUpgrade();
- }
- void CHealthManagerFSM::s5_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s5_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- Dbg("s5(Fault) event %d,%d",pEvt->iEvt,pEvt->param1);
- switch(pEvt->iEvt)
- {
- case USER_EVT_MAITAIN:
- Dbg("to maintain...");
- m_stateBeforeMaintain = m_fsmState;
- pEvt->SetHandled();
- break;
- case USER_EVT_ENTER_CUSTOMER_MANAGER:
- pEvt->SetHandled();
- break;
- case USER_EVT_ACCESSAUTH_FINISHED:
- pEvt->SetHandled();
- if (pEvt->param1 == 1)
- {
- SetAccessAuth(false);
- return 1;
- }
- break;
- default:
- break;
- }
- return 0;
- }
- //Maintaining
- void CHealthManagerFSM::s6_on_entry()
- {
- LOG_FUNCTION();
- m_preFsmState = m_fsmState;
- m_fsmState = HM_FSM_STATE_MAINTAINING;
- ErrorCodeEnum eErrCode;
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","M");
- if (eErrCode != Error_Succeed)
- {
- Dbg("set RunState M failed (%d).",eErrCode);
- }
- CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- if (pFuncPrivilege == NULL)
- {
- Dbg("display screen NoPrivilege");
- return;
- }
- ErrorCodeEnum eErr = pFuncPrivilege->DisplayBlueScreen("暂停服务");
- Dbg("display blue screen %d",eErr);
- }
- void CHealthManagerFSM::s6_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s6_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- int ret = 0;
- switch(pEvt->iEvt)
- {
- case USER_EVT_MAITAIN_FINISHED:
- pEvt->SetHandled();
- {
- CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- if (pFuncPrivilege == NULL)
- {
- Dbg("un-display screen NoPrivilege");
- return 1;
- }
- ErrorCodeEnum eErr = pFuncPrivilege->UndisplayBlueScreen();
- Dbg("un-display blue screen %d",eErr);
- if (m_stateBeforeMaintain == HM_FSM_STATE_IDLE)
- {
- ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->SetSysVar("RunState","O");
- if (eErr != Error_Succeed)
- {
- Dbg("set RunState O failed (%d).",eErr);
- }
- }
- ret = m_preFsmState;
- }
- break;
- case USER_EVT_ENTER_CUSTOMER_MANAGER:
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return ret;
- }
- //PrepareOff
- void CHealthManagerFSM::s7_on_entry()
- {
- LOG_FUNCTION();
- m_fsmState = HM_FSM_STATE_PREPAREOFF;
- ErrorCodeEnum eErrCode;
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","P");
- if (eErrCode != Error_Succeed)
- {
- Dbg("set RunState P failed (%d).",eErrCode);
- }
- }
- void CHealthManagerFSM::s7_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s7_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- Dbg("s7(PrepareOff) event %d",pEvt->iEvt);
- switch(pEvt->iEvt)
- {
- case USER_EVT_MAITAIN:
- Dbg("to maintain...");
- m_stateBeforeMaintain = m_fsmState;
- pEvt->SetHandled();
- break;
- case USER_EVT_ENTER_CUSTOMER_MANAGER:
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return 0;
- }
- //Terminating
- void CHealthManagerFSM::s8_on_entry()
- {
- LOG_FUNCTION();
- m_fsmState = HM_FSM_STATE_TERMINATING;
- ErrorCodeEnum eErrCode;
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","T");
- if (eErrCode != Error_Succeed)
- {
- Dbg("set RunState T failed (%d).",eErrCode);
- }
- }
- void CHealthManagerFSM::s8_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s8_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- Dbg("s8(Terminating) event %d",pEvt->iEvt);
- switch(pEvt->iEvt)
- {
- case USER_EVT_MAITAIN:
- Dbg("to maintain...");
- m_stateBeforeMaintain = m_fsmState;
- pEvt->SetHandled();
- break;
- case USER_EVT_ENTER_CUSTOMER_MANAGER:
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return 0;
- }
- //Exitting
- void CHealthManagerFSM::s9_on_entry()
- {
- LOG_FUNCTION();
- m_fsmState = HM_FSM_STATE_EXITTING;
- ErrorCodeEnum eErrCode;
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","E");
- if (eErrCode != Error_Succeed)
- {
- Dbg("set RunState E failed (%d).",eErrCode);
- }
- }
- void CHealthManagerFSM::s9_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s9_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- Dbg("s9(Exitting) event %d",pEvt->iEvt);
- switch(pEvt->iEvt)
- {
- case USER_EVT_MAITAIN:
- Dbg("to maintain...");
- m_stateBeforeMaintain = m_fsmState;
- pEvt->SetHandled();
- break;
- case USER_EVT_ENTER_CUSTOMER_MANAGER:
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return 0;
- }
- //Sleep(L)
- void CHealthManagerFSM::s10_on_entry()
- {
- LOG_FUNCTION();
- m_fsmState = HM_FSM_STATE_SLEEP;
- ErrorCodeEnum eErrCode;
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","L");
- if (eErrCode != Error_Succeed)
- {
- Dbg("set RunState L failed (%d).",eErrCode);
- }
- }
- void CHealthManagerFSM::s10_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s10_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- Dbg("s10(Sleep) event %d",pEvt->iEvt);
- switch(pEvt->iEvt)
- {
- case USER_EVT_MAITAIN:
- Dbg("to maintain...");
- m_stateBeforeMaintain = m_fsmState;
- pEvt->SetHandled();
- break;
- case USER_EVT_ENTER_CUSTOMER_MANAGER:
- pEvt->SetHandled();
- break;
- default:
- break;
- }
- return 0;
- }
- //In Customer Manager System
- void CHealthManagerFSM::s11_on_entry()
- {
- LOG_FUNCTION();
- m_preFsmState = m_fsmState;
- m_fsmState = HM_FSM_STATE_CMS;
- }
- void CHealthManagerFSM::s11_on_exit()
- {
- LOG_FUNCTION();
- }
- unsigned int CHealthManagerFSM::s11_on_event(FSMEvent* pEvt)
- {
- LOG_FUNCTION();
- Dbg("s11(In CMS) event %d",pEvt->iEvt);
- int ret = 0;
- switch (pEvt->iEvt)
- {
- case USER_EVT_MAITAIN:
- Dbg("to maintain...");
- m_stateBeforeMaintain = m_fsmState;
- pEvt->SetHandled();
- break;
- case USER_EVT_SWITCH_BACK_TO_RVC:
- pEvt->SetHandled();
- ret = m_preFsmState;
- break;
- default:
- break;
- }
- return ret;
- }
- int CHealthManagerFSM::WaitDeamonFinish()
- {
- int count = 0;
- while(1)//max waiting time
- {
- count++;
- //query if update deamon process is started oiltmp
- //case custody
- //case needreboot
- //case rollback
- //case timeout
- if (count > 2)
- break;
- //Sleep(5000);
- }
- /** 添加此操作以让状态机停留在s0状态 [Gifur@20211017]*/
- if (mCofigMode) {
- return 1;
- }
- return 0;
- }
- int CHealthManagerFSM::DoInitialization()
- {
- LOG_FUNCTION();
- ErrorCodeEnum eErr;
- CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- CEntityRunInfo acInfo;
- eErr = pFunc->GetEntityRunInfo("Initializer",acInfo);
- Dbg("Initializer state return %d",eErr);
- if (eErr == Error_Succeed && (acInfo.eState == EntityState_NoStart || acInfo.eState == EntityState_Idle))
- {
- if (acInfo.eState == EntityState_NoStart)
- {
- CSmartPointer<IAsynWaitSp> spWaitInit;
- eErr = pFuncPrivilege->StartEntity("Initializer",NULL,spWaitInit);
- if (eErr == Error_Succeed)
- eErr = spWaitInit->WaitAnswer(MAX_AYSNC_TIMEOUT);
- eErr = pFunc->GetEntityRunInfo("Initializer",acInfo);
- if (eErr != Error_Succeed || acInfo.eState != EntityState_Idle)
- {
- Dbg("start Initializer failed(%d,%d).",eErr,acInfo.eState);
- return 1;
- }
- }
- if (m_pInitClient == NULL)
- {
- m_pInitClient = new InitializerService_ClientBase(this->GetEntityBase());
- eErr = m_pInitClient->Connect();
- if (eErr != Error_Succeed) {
- Dbg("Initializer connected failed.");
- m_pInitClient->SafeDelete();
- m_pInitClient = NULL;
- return 2;
- }
- else
- Dbg("Initializer connected.");
- }
- InitializerService_Initialize_Info initInfo;
- m_pInitClient->Initialize(initInfo);
- //no need to wait,just go
- return 0;
- }
- else
- {
- Dbg("Get Initializer RunInfo failed(%d).",eErr);
- return 3;
- }
- }
- //0:auth suc or have already authed;1:auth failed;
- int CHealthManagerFSM::AccessAuthDoWork()
- {
- //oilyang@20190924 comment the following Sleep(5000);
- //Sleep(5000);//oilyang wait for a few
- //oilyang@20210329 comment the following lines,
- //as no "LOG_EVT_SYSTMECUSTOM_START_ACCESSAUTH" event throw
- //if (m_bFirstAccessAuth && m_accessAuthCheckMD5 == 1 && m_havReceiveMD5OK == 0)
- //{
- // Dbg("wait md5 ok.");
- // WaitForSingleObject(m_hMD5OKEvt, INFINITE);
- // m_bFirstAccessAuth = false;
- // Dbg("have received md5 ok event.");
- //}
- LOG_FUNCTION();
- m_bInAccessAuthDoWork = true;
- m_bAccessAuth = false;
- CSimpleStringA csTermStage("");
- ErrorCodeEnum eErr;
- eErr = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage",csTermStage);
- Dbg("oninit get termstage %s",(LPCTSTR)csTermStage);
- bool bToDoInit = false;
- if (eErr == Error_Succeed)
- {
- if (csTermStage[0] == 'U')
- {
- bToDoInit = true;
- int initTime = 0;
- INITIALIZATION:
- int rc = DoInitialization();
- Dbg("the %d init",initTime);
- initTime++;
- DWORD dwStart = GetTickCountRVC();
- while(1)
- {
- if (!m_bInitSuc && !m_bInitFail)
- {
- Sleep(1000);
- continue;
- }
- else if (m_bInitSuc || m_bInitFail)
- {
- Dbg("init result %d,%d",m_bInitSuc,m_bInitFail);
- if (m_bInitFail)
- {
- Sleep(5000);
- m_bInitFail = false;
- goto INITIALIZATION;
- }
- if (m_bInitSuc)
- break;
- }
- }
- }
- }
- else
- {
- Dbg("get TerminalStage failed(%d).", eErr);
- m_bInAccessAuthDoWork = false;
- return 1;
- }
- Dbg("after proc initialization.");
- if (bToDoInit)
- {
- if (m_bInitSuc)
- {
- }
- else
- {
- Dbg("initialization failed.");
- m_bInAccessAuthDoWork = false;
- return 1;
- }
- }
- //to accessauth
- ErrorCodeEnum eErrCode;
- eErrCode = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage",csTermStage);
- Dbg("before accessauth get termstage %s",(LPCTSTR)csTermStage);
- if (eErrCode == Error_Succeed)
- {
- //if (csTermStage[0] == 'C' || csTermStage[0] == 'A')
- if (csTermStage[0] != 'U')
- {
- CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- //terminate pinpad
- //CSmartPointer<IAsynWaitSp> spWait;
- //eErrCode = pFuncPrivilege->CloseEntity("PinPad",spWait);
- //Dbg("close pinpad %d.",eErrCode);
- //eErrCode = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
- //if (eErrCode != Error_Succeed)
- //{
- // //terminate pinpad
- // CSmartPointer<IAsynWaitSp> spWait;
- // pFuncPrivilege->TerminateEntity("PinPad",spWait);
- // spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
- //}
- //if (eErrCode == Error_Succeed)
- {
- CEntityRunInfo acInfo;
- eErrCode = pFunc->GetEntityRunInfo("AccessAuthorization",acInfo);
- Dbg("AccessAuth state return %d",eErrCode);
- if (eErrCode == Error_Succeed)
- {
- switch(acInfo.eState)
- {
- case EntityState_NoStart:
- {
- CSmartPointer<IAsynWaitSp> spWaitAC;
- eErrCode = pFuncPrivilege->StartEntity("AccessAuthorization",NULL,spWaitAC);
- eErrCode = spWaitAC->WaitAnswer(MAX_AYSNC_TIMEOUT);
- Dbg("start accessauth %d.",eErrCode);
- }
- break;
- case EntityState_Idle:
- Dbg("AccessAuth state idle.");
- break;
- default:
- break;
- }
-
- if (m_pACClient == NULL)
- {
- m_pACClient = new AccessAuthService_ClientBase(this->GetEntityBase());
- eErrCode = m_pACClient->Connect();
- if (eErrCode != Error_Succeed) {
- Dbg("accessauth connected failed.");
- m_pACClient->SafeDelete();
- m_pACClient = NULL;
- StartPinPadEntity();
- m_bInAccessAuthDoWork = false;
- return 1;
- }
- else
- Dbg("accessauth connected.");
- }
- }
- else
- {
- Dbg("Get AccessAuth RunInfo failed(%d).",eErrCode);
- StartPinPadEntity();
- m_bInAccessAuthDoWork = false;
- return 1;
- }
- if (m_pACClient != NULL)
- {
- DWORD dwStart = GetTickCountRVC();
- int registCount = 0;
- REGIST: eErrCode = m_pACClient->Regist();
- m_bHasAuthEver = true;
- registCount++;
- Dbg("accessauth regist %d",eErrCode);
- if (eErrCode == Error_Succeed)
- {
- while(1)
- {
- //oilyang@20210823 as have retry logic,no need to
- //DWORD dwEnd = GetTickCount();
- //DWORD dwElapse = dwEnd - dwStart;
- //if (dwElapse > m_AccessAuthTimeout)
- //{
- // Dbg("after x minute");
- // StartPinPadEntity();
- // //auth failed,rollback to C
- // eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "C");
- // Dbg("auth fail,set TerminalStage C 1");
- // if (eErr != Error_Succeed)
- // Dbg("set TerminalStage C failed(%d).", eErr);
- // m_bFirstAccessAuth = false;
- // m_bInAccessAuthDoWork = false;
- // return 1;
- //}
- Sleep(1000);
- if (!m_bAccessAuth && !m_bACFailed)
- continue;
- // && registCount < m_AccessAuthTries
- if (m_bACFailed)
- {
- LogWarn(Severity_Low,Error_Unexpect,LOG_WARN_HEALTH_ACCESSAUTH_FAILED,"AccessAuth failed.");
- m_bACFailed = false;
- //Sleep(1000);
- //goto REGIST;
- }
- Dbg("regist try %d times",registCount);
- StartPinPadEntity();
- if (!m_bAccessAuth)
- {
- //auth failed,rollback to C
- SetAccessAuth(false);
- Dbg("auth fail,set TerminalStage C 2");
- }
- break;
- }
- m_bFirstAccessAuth = false;
- m_bInAccessAuthDoWork = false;
- return 0;
- }
- else
- {
- Dbg("accessauth regist failed(%d).",eErrCode);
- StartPinPadEntity();
- //auth failed,rollback to C
- SetAccessAuth(false);
- Dbg("auth fail,set TerminalStage C 3");
- m_bInAccessAuthDoWork = false;
- return 1;
- }
- }
- else
- {
- Dbg("Start accessauth failed(%d).",eErrCode);
- StartPinPadEntity();
- //auth failed,rollback to C
- SetAccessAuth(false);
- Dbg("auth fail,set TerminalStage C 4");
- m_bInAccessAuthDoWork = false;
- return 1;
- }
- }
- }
- else
- {
- StartPinPadEntity();
- m_bInAccessAuthDoWork = false;
- return 0;
- }
- }
- else
- Dbg("Get termstage failed(%d).", eErrCode);
- m_bInAccessAuthDoWork = false;
- return 1;
- }
- //return value:
- //0:all entity have started suc
- //1:some entity havn't try to start
- //2:all entity have tried to started,but some failed
- int CHealthManagerFSM::CheckLoadResult(LoadStage eStage)
- {
- int ret = 0;
- map<CSimpleStringA,EntityLoadInfo>::iterator it;
- if (eStage == LOADSTAGE_COREBOOT)
- it = m_coreBootOpt.begin();
- else if (eStage == LOADSTAGE_SAFELOAD)
- it = m_safeLoadOpt.begin();
- else
- it = m_operatingOpt.begin();
- while(1)
- {
- switch(it->second.loadOpt)
- {
- case LOADOPT_IGNORE:
- if (it->second.eResult == LOADING_INIT)
- return 1;
- break;
- case LOADOPT_ASYNC_VERIFY:
- case LOADOPT_SYNC_VERIFY:
- default:
- if (it->second.eResult == LOADING_INIT)
- return 3;
- else if (it->second.eResult != LOADING_SUCCEED)
- {
- Dbg("m_csErrEntity:%s",(LPCTSTR)m_csErrEntity);
- m_csErrEntity = m_csErrEntity + "|" + it->first;
- ret = 2;
- }
- break;
- }
- it++;
- if (eStage == LOADSTAGE_COREBOOT && it == m_coreBootOpt.end())
- break;
- else if (eStage == LOADSTAGE_SAFELOAD && it == m_safeLoadOpt.end())
- break;
- else if (eStage == LOADSTAGE_OPERATING && it == m_operatingOpt.end())
- break;
- }
- return ret;
- }
- void CHealthManagerFSM::SetAccessAuth(bool bResult)
- {
- m_bAccessAuth = bResult;
- ErrorCodeEnum eErrCode;
- if (bResult)
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage","A");
- else
- eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "C");
- Dbg("Set AccessAuth TerminalState %d returned: %s",bResult, SpStrError(eErrCode));
- }
- int CHealthManagerFSM::StartPinPadEntity()
- {
- if (m_coreBootOpt.find("PinPad") == m_coreBootOpt.end() && m_safeLoadOpt.find("PinPad") == m_safeLoadOpt.end()
- && m_operatingOpt.find("PinPad") == m_operatingOpt.end())
- {
- Dbg("not configure pinpad.");
- return 0;
- }
- CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- CEntityRunInfo acInfo;
- ErrorCodeEnum eErrCode;
- eErrCode = pFunc->GetEntityRunInfo("PinPad",acInfo);
- Dbg("pinpad state %d,%d",eErrCode,acInfo.eState);
- if (acInfo.eState == EntityState_NoStart || acInfo.eState == EntityState_Close || acInfo.eState == EntityState_Killed)
- {
- CSmartPointer<IAsynWaitSp> spWait;
- eErrCode = pFuncPrivilege->StartEntity("PinPad",NULL,spWait);
- Dbg("start pinpad %d.",eErrCode);
- if (spWait != NULL)
- eErrCode = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
- Dbg("start pinpad wait %d",eErrCode);
- }
- return eErrCode;
- }
- void CHealthManagerFSM::ToReAccessAuth(bool bEver)
- {
- Sleep(1500);//for function "AccessAuthDoWork" to quit while
- if (m_bFirstAccessAuth)
- return;
- ToCallAccessAuthDoWork();
- //SetAccessAuth(false);
- //AccessAuthTask *pTask = new AccessAuthTask(this);
- //GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
- }
- ErrorCodeEnum CHealthManagerFSM::AsyncStartEntity(const char *entity_name, const char *cmdline, void *pData)
- {
- CSmartPointer<IEntityFunction> pFunc = m_pEntity->GetFunction();
- ErrorCodeEnum errCode;
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- if (pFuncPrivilege != NULL) {
- CSmartPointer<IAsynWaitSp> spWait;
- errCode = pFuncPrivilege->StartEntity(entity_name, cmdline, spWait);
- Dbg("start entity %s",entity_name);
- if (errCode == Error_Succeed) {
- callback_entry *entry = new callback_entry();
- entry->pRawData = pData;
- entry->EntityName = entity_name;
- entry->ErrorResult = Error_Unexpect;
- entry->op = OP_START_ENTITY;
- if (spWait != NULL)
- spWait->SetCallback(this, entry);
- }
- return errCode;
- } else {
- return Error_NoPrivilege;
- }
- }
- ErrorCodeEnum CHealthManagerFSM::AsyncStopEntity(const char *entity_name, void *pData)
- {
- CSmartPointer<IEntityFunction> pFunc = m_pEntity->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- if (pFuncPrivilege != NULL) {
- CSmartPointer<IAsynWaitSp> spWait;
- ErrorCodeEnum Error = pFuncPrivilege->StopEntity(entity_name, spWait);
- if (Error == Error_Succeed) {
- callback_entry *entry = new callback_entry();
- entry->pRawData = pData;
- entry->EntityName = entity_name;
- entry->ErrorResult = Error_Unexpect;
- entry->op = OP_STOP_ENTITY;
- if (spWait != NULL)
- spWait->SetCallback(this, entry);
- }
- return Error;
- } else {
- return Error_NoPrivilege;
- }
- }
- ErrorCodeEnum CHealthManagerFSM::AsyncPauseEntity(const char *entity_name, void *pData)
- {
- CSmartPointer<IEntityFunction> pFunc = m_pEntity->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- if (pFuncPrivilege != NULL) {
- CSmartPointer<IAsynWaitSp> spWait;
- ErrorCodeEnum Error = pFuncPrivilege->PauseEntity(entity_name, spWait);
- if (Error == Error_Succeed) {
- callback_entry *entry = new callback_entry();
- entry->pRawData = pData;
- entry->EntityName = entity_name;
- entry->ErrorResult = Error_Unexpect;
- entry->op = OP_PAUSE_ENTITY;
- if (spWait != NULL)
- spWait->SetCallback(this, entry);
- }
- return Error;
- } else {
- return Error_NoPrivilege;
- }
- }
- ErrorCodeEnum CHealthManagerFSM::AsyncContinueEntity(const char *entity_name, void *pData)
- {
- CSmartPointer<IEntityFunction> pFunc = m_pEntity->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- if (pFuncPrivilege != NULL) {
- CSmartPointer<IAsynWaitSp> spWait;
- ErrorCodeEnum Error = pFuncPrivilege->ContinueEntity(entity_name, spWait);
- if (Error == Error_Succeed) {
- callback_entry *entry = new callback_entry();
- entry->pRawData = pData;
- entry->EntityName = entity_name;
- entry->ErrorResult = Error_Unexpect;
- entry->op = OP_CONTINUE_ENTITY;
- if (spWait != NULL)
- spWait->SetCallback(this, entry);
- }
- return Error;
- } else {
- return Error_NoPrivilege;
- }
- }
- ErrorCodeEnum CHealthManagerFSM::AsyncTerminateEntity(const char *entity_name, void *pData)
- {
- CSmartPointer<IEntityFunction> pFunc = m_pEntity->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- if (pFuncPrivilege != NULL) {
- CSmartPointer<IAsynWaitSp> spWait;
- ErrorCodeEnum Error = pFuncPrivilege->TerminateEntity(entity_name, spWait);
- if (Error == Error_Succeed) {
- callback_entry *entry = new callback_entry();
- entry->pRawData = pData;
- entry->EntityName = entity_name;
- entry->ErrorResult = Error_Unexpect;
- entry->op = OP_TERMINATE_ENTITY;
- if (spWait != NULL)
- spWait->SetCallback(this, entry);
- }
- return Error;
- } else {
- return Error_NoPrivilege;
- }
- }
- void CHealthManagerFSM::OnAnswer(CSmartPointer<IAsynWaitSp> pAsynWaitSp)
- {
- CSmartPointer<ICallbackListener> spCallback;
- CSmartPointer<IReleasable> pData;
- pAsynWaitSp->GetCallback(spCallback, pData);
- callback_entry *entry = dynamic_cast<callback_entry*>((IReleasable*)(pData.GetRawPointer()));
- entry->ErrorResult = pAsynWaitSp->AsyncGetAnswer();
- callback_entry *new_entry = new callback_entry();
- new_entry->EntityName = entry->EntityName;
- new_entry->ErrorResult = entry->ErrorResult;
- new_entry->op = entry->op;
- new_entry->state = entry->state;
- map<CSimpleStringA,EntityLoadInfo>::iterator it;
- int ret;
- Dbg("stage %d,%s,result %d",m_eStage,(LPCSTR)new_entry->EntityName,new_entry->ErrorResult);
- if (entry->op == OP_START_ENTITY && new_entry->ErrorResult != Error_Succeed) {
- //ShowEntityBootFailedAtFront(new_entry->EntityName, new_entry->ErrorResult, false);
- }
- switch(m_eStage)
- {
- case LOADSTAGE_COREBOOT:
- it = m_coreBootOpt.find(new_entry->EntityName);
- if (it != m_coreBootOpt.end())
- {
- if (new_entry->ErrorResult == Error_Succeed)
- it->second.eResult = LOADING_SUCCEED;
- else if (new_entry->ErrorResult == Error_TimeOut)
- it->second.eResult = LOADING_TIMEOUT;
- else
- it->second.eResult = LOADING_FAILED;
- if (it->second.eResult != Error_Succeed)
- {
- char tmp[64] = {0};
- sprintf(tmp, "实体 %s 启动失败", it->first.GetData());
- Dbg("%s", tmp);
- }
- ret = CheckLoadResult(LOADSTAGE_COREBOOT);
- if (ret == 0 || ret == 2)
- {
- FSMEvent *e = new FSMEvent(USER_EVT_COREBOOT_FINISHED);
- e->param1 = ret;
- PostEventFIFO(e);
- }
- }
- break;
- case LOADSTAGE_SAFELOAD:
- it = m_safeLoadOpt.find(new_entry->EntityName);
- if (it != m_safeLoadOpt.end())
- {
- if (new_entry->ErrorResult == Error_Succeed)
- it->second.eResult = LOADING_SUCCEED;
- else if (new_entry->ErrorResult == Error_TimeOut)
- it->second.eResult = LOADING_TIMEOUT;
- else
- it->second.eResult = LOADING_FAILED;
- ret = CheckLoadResult(LOADSTAGE_SAFELOAD);
- Dbg("safeload answer %d",ret);
- if (ret == 0 || ret == 2)
- {
- FSMEvent *e = new FSMEvent(USER_EVT_SAFELOAD_FINISHED);
- e->param1 = ret;
- PostEventFIFO(e);
- }
- }
- else
- Dbg("cannot find %s",(LPCTSTR)new_entry->EntityName);
- break;
- case LOADSTAGE_OPERATING:
- it = m_operatingOpt.find(new_entry->EntityName);
- if (it != m_operatingOpt.end())
- {
- if (new_entry->ErrorResult == Error_Succeed)
- it->second.eResult = LOADING_SUCCEED;
- else if (new_entry->ErrorResult == Error_TimeOut)
- it->second.eResult = LOADING_TIMEOUT;
- else
- it->second.eResult = LOADING_FAILED;
- ret = CheckLoadResult(LOADSTAGE_OPERATING);
- if (ret == 0 || ret == 2)
- {
- FSMEvent *e = new FSMEvent(USER_EVT_OPERATING_FINISHED);
- e->param1 = ret;
- PostEventFIFO(e);
- }
- }
- break;
- default:
- break;
- }
- }
- void CHealthManagerFSM::ToCheckUPS()
- {
- CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- CEntityRunInfo acInfo;
- ErrorCodeEnum eErrCode;
- eErrCode = pFunc->GetEntityRunInfo("Ups",acInfo);
- Dbg("ups state %d,%d",eErrCode,acInfo.eState);
- if (acInfo.eState != EntityState_NoStart)
- {
- CSmartPointer<IAsynWaitSp> spWait;
- eErrCode = pFuncPrivilege->TerminateEntity("Ups",spWait);
- Sleep(2000);
- eErrCode = pFuncPrivilege->StartEntity("Ups",NULL,spWait);
- if (spWait != NULL)
- eErrCode = spWait->WaitAnswer(5000);
- Dbg("restart ups wait %d",eErrCode);
- }
- }
- int CHealthManagerFSM::USBControl()
- {
- ErrorCodeEnum eErr;
- if (m_sysInfo.strMachineType.Compare("RVC.PAD") == 0)
- {
- if (m_pDevCtrlClient == NULL)
- {
- m_pDevCtrlClient = new DeviceControlService_ClientBase(this->m_pEntity);
- ErrorCodeEnum eErr = m_pDevCtrlClient->Connect();
- if (eErr != Error_Succeed) {
- Dbg("DeviceControl connected failed(%d).",eErr);
- m_pDevCtrlClient->SafeDelete();
- m_pDevCtrlClient = NULL;
- return -1;
- }
- }
- if (m_pDevCtrlClient != NULL)
- {
- DeviceControlService_USB_Req req;
- DeviceControlService_USB_Ans ans;
- req.open = true;
- eErr = m_pDevCtrlClient->USB(req,ans,5000);
- if (eErr != Error_Succeed)
- {
- Dbg("usb control failed(%d).",eErr);
- return -1;
- }
- else
- Dbg("usb opened.");
- }
- }
- return 0;
- }
- CSimpleStringA CHealthManagerFSM::GetEntityCfgInfo(CSimpleStringA name,int &loadOpt)
- {
- CSimpleStringA entityList(""),csBrowserName("IEBrowser");
- Dbg("GetEntityCfgInfo %s",(LPCTSTR)name);
- if (!name.IsNullOrEmpty() && name.Compare("AllConfiguredEntity") == 0)
- {
- for (auto itor = m_vAllCfgEntity.cbegin(); itor != m_vAllCfgEntity.cend(); itor++)
- {
- entityList += (*itor) + ",";
- }
- return entityList;
- }
- #ifdef RVC_OS_WIN
- if (!name.IsNullOrEmpty() && name.Compare("IEBrowser") == 0)
- {
- Dbg("IEBrowser just return 2");
- loadOpt = 2;
- return "";
- }
- #endif //RVC_OS_WIN
- map<CSimpleStringA,EntityLoadInfo>::iterator it;
- for (it = m_coreBootOpt.begin(); it != m_coreBootOpt.end(); ++it)
- {
- if (_strnicmp(name,it->first,name.GetLength()) == 0)
- {
- loadOpt = it->second.loadOpt;
- Dbg("GetEntityCfgInfo %d",loadOpt);
- return "";
- }
- }
- for (it = m_safeLoadOpt.begin(); it != m_safeLoadOpt.end(); ++it)
- {
- if (_strnicmp(name,it->first,name.GetLength()) == 0)
- {
- loadOpt = it->second.loadOpt;
- Dbg("GetEntityCfgInfo %d",loadOpt);
- return "";
- }
- }
- for (it = m_operatingOpt.begin(); it != m_operatingOpt.end(); ++it)
- {
- if (_strnicmp(name,it->first,name.GetLength()) == 0)
- {
- loadOpt = it->second.loadOpt;
- Dbg("GetEntityCfgInfo %d",loadOpt);
- return "";
- }
- }
- loadOpt = 99;
- return "";
- }
- ErrorCodeEnum CHealthManagerFSM::QueryCheckCode(CSimpleStringA& csCkCode, bool bMaster)
- {
- LOG_FUNCTION();
- ErrorCodeEnum eErr = Error_Unexpect;
- CSimpleStringA tmpCheckCode("");
- PinPadService_ClientBase *pClient = new PinPadService_ClientBase(this->m_pEntity);
- if (pClient != NULL)
- {
- eErr = pClient->Connect();
- if (eErr == Error_Succeed)
- {
- PinPadService_QueryFunc_Req reqQ;
- PinPadService_QueryFunc_Ans ansQ;
- eErr = pClient->QueryFunc(reqQ, ansQ, 5000);
- if (eErr == Error_Succeed)
- {
- PinPadService_GetCheckCode_Req reqG;
- PinPadService_GetCheckCode_Ans ansG;
- if (ansQ.reserved1 == 2)//if sm only
- {
- reqG.mSN.Init(1);
- reqG.wSN.Init(1);
- reqG.mSN[0] = 1;
- if (bMaster)
- reqG.wSN[0] = 99;
- else
- reqG.wSN[0] = 0;
- eErr = pClient->GetCheckCode(reqG, ansG, 10000);
- if (eErr == Error_Succeed)
- {
- tmpCheckCode = ansG.checkcode[0];
- }
- }
- else//3des only or 3des&sm both ok
- {
- reqG.mSN.Init(1);
- reqG.wSN.Init(1);
- reqG.mSN[0] = 0;
- if (bMaster)
- reqG.wSN[0] = 99;
- else
- reqG.wSN[0] = 0;
- eErr = pClient->GetCheckCode(reqG, ansG, 10000);
- if (eErr == Error_Succeed)
- {
- tmpCheckCode = ansG.checkcode[0];
- }
- }
- }
- else
- Dbg("QueryFunc failed.error code:%d",eErr);
- }
- else
- Dbg("connect to pinpad failed.error code:%d",eErr);
- }
- csCkCode = tmpCheckCode;
- return eErr;
- }
- void CHealthManagerFSM::QueryDeviceInfo(std::map<std::string, std::string>& termInfo)
- {
- LOG_FUNCTION();
- ErrorCodeEnum eErr = Error_Unexpect;
- //PinPad
- CSimpleStringA sm3desInfo("support:");
- PinPadService_ClientBase* pClient = new PinPadService_ClientBase(this->m_pEntity);
- if (pClient != NULL)
- {
- eErr = pClient->Connect();
- if (eErr == Error_Succeed)
- {
- PinPadService_GetDevInfo_Req reqDev;
- PinPadService_GetDevInfo_Ans ansDev;
- eErr = pClient->GetDevInfo(reqDev, ansDev, 5000);
- if (eErr == Error_Succeed)
- {
- if (ansDev.model.GetLength() > 1 && ansDev.model.GetLength() < 255)
- termInfo["pinpadModel"] = ansDev.model;
- if (ansDev.type.GetLength() > 1 && ansDev.type.GetLength() < 255)
- termInfo["pinpadType"] = ansDev.type;
- }
- else
- return;
- PinPadService_QueryFunc_Req reqQ;
- PinPadService_QueryFunc_Ans ansQ;
- eErr = pClient->QueryFunc(reqQ, ansQ, 5000);
- if (eErr == Error_Succeed)
- {
- sm3desInfo = CSimpleStringA::Format("support:%d,loadkey:%d", ansQ.encryptkey, ansQ.reserved1);
- if (ansQ.encryptkey == 3 || ansQ.encryptkey == 2){
- LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_PinPad_Dev_SP_SM, "PinPad(hardware) support sm.");
- }
- else {
- LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_PinPad_Dev_NOT_SP_SM, "PinPad(hardware) DON'T support sm.");
- }
- if (ansQ.reserved1 == 3|| ansQ.reserved1 == 2) {
- LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_PinPad_HaveLoad_SM, "PinPad have loaded sm key.");
- }
- else if ((ansQ.reserved1 == 2)) {
- LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_PinPad_HaveLoad_SM, "PinPad have loaded sm key.");
- }
- else {
- LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_PinPad_HaveLoad_SM, "PinPad have loaded sm key.");
- }
- termInfo["pinpad"] = sm3desInfo;
- }
- else
- Dbg("QueryFunc failed.error code:%d", eErr);
- }
- else
- Dbg("connect to pinpad failed.error code:%d", eErr);
- }
- return;
- }
- void CHealthManagerFSM::DeviceReConnect()
- {
- //if haven't called access auth ever or in the 1st accessauth processing,no need to call access auth
- if (QueryAccessAuthStatus() == 2 || m_bFirstAccessAuth)
- return;
- CSimpleStringA tmpCheckCode;
- ErrorCodeEnum eErr = QueryCheckCode(tmpCheckCode);
- if (eErr == Error_Succeed)
- {
- Dbg("pre check code size:%d,now:%d", m_checkCode.GetLength(), tmpCheckCode.GetLength());
- SetAccessFailedFlag(false);
- if (tmpCheckCode.GetLength() == 0 || m_checkCode.Compare(tmpCheckCode, true) != 0 || !GetAccessAuthFlag() || !m_bEverAuthSucWithDevice)
- {
- if (m_checkCode.GetLength() > 1 && tmpCheckCode.GetLength() > 1 && m_checkCode.Compare(tmpCheckCode, true) != 0)
- {
- AuthStatus as;
- as.result = 1;
- as.msg = "设备混用,请接入对应设备或后台重新绑定当前设备";
- //SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(AuthStatus), SP_MSG_SIG_OF(AuthStatus), as);
- }
- else
- {
- if (m_checkCode.GetLength() > 1)
- ToReAccessAuth(true);
- else
- ToReAccessAuth();
- }
- }
- }
- }
- int CHealthManagerFSM::QuitFrameworkAndSaveInfo(RebootTriggerEnum eTrigger, RebootWayEnum eWay)
- {
- LOG_FUNCTION();
- CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
- CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
- if (pFuncPrivilege == NULL) {
- Dbg("has no privilege");
- return (int)(Error_NoPrivilege);
- }
- Dbg("quit framework and info %d, %d.", eTrigger, eWay);
- const auto result = pFuncPrivilege->Reboot(eTrigger, eWay);
- return (int)result;
- }
- void CHealthManagerFSM::PostProcessAfterUpgrade()
- {
- LOG_FUNCTION();
- CSimpleStringA csRunInfoPath(""), csFileName("");
- ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetPath("RunInfo", csRunInfoPath);
- csFileName = csRunInfoPath + "/runcfg/starttime.dat";
- Dbg("file:%s", (const char*)csFileName);
- bool bUpgradeFileExist = false;
- #ifdef RVC_OS_WIN
- bUpgradeFileExist = (_access((const char*)csFileName, 0) == 0);
- #else
- bUpgradeFileExist = (access((const char*)csFileName, F_OK) == 0);
- #endif //RVC_OS_WIN
- if (bUpgradeFileExist)
- {
- Dbg("exist upgrade flag file,to decide if restart framework.");
- //存在升级后的启动文件
- CSmartPointer<IConfigInfo> spConfigRun;
- eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
- if (eErr == Error_Succeed)
- {
- int xTimes = 0;
- spConfigRun->ReadConfigValueInt("Run", "UpgradeRestartTimes", xTimes);
- if (xTimes < 3)
- {
- xTimes++;
- Dbg("write Run--UpgradeRestartTimes:%d", xTimes);
- spConfigRun->WriteConfigValueInt("Run", "UpgradeRestartTimes", xTimes);
- if (xTimes == 3)
- {
- //DeleteFileA((const char*)csFileName);
- QuitFrameworkAndSaveInfo(RebootTrigger_Resource, RebootWay_OS);
- }
- else
- QuitFrameworkAndSaveInfo(RebootTrigger_Resource, RebootWay_Framework);
- }
- }
- }
- }
- void CHealthManagerFSM::SaveOsVersion()
- {
- #ifdef RVC_OS_WIN
- CSimpleStringA runInfoPath;
- ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetPath("runinfo", runInfoPath);
- if (eErr != Error_Succeed) {
- Dbg("GetPath runinfo error=%d.", eErr);
- return;
- }
- runInfoPath += "\\runcfg\\osverion";
- ifstream is;
- is.open(runInfoPath.GetData(), ios::binary);
- if (!is.is_open())
- {
- DWORD dwErr = GetLastError();
- Dbg("open runcfg\\osverion file failed. [%d]", dwErr);
- CSimpleStringA csCmd;
- csCmd = CSimpleStringA::Format("cmd /c ver >%s", runInfoPath);
- WinExec((LPCSTR)csCmd, SW_HIDE);
- }
- return;
- #endif
- }
- CSimpleStringA CHealthManagerFSM::GetOsVersion()
- {
- LOG_FUNCTION();
- #ifdef RVC_OS_WIN
- char psBuffer[128];
- FILE* pPipe;
- /* Run DIR so that it writes its output to a pipe. Open this
- * pipe with read text attribute so that we can read it
- * like a text file.
- */
- if ((pPipe = _popen("ver", "rt")) == NULL)
- exit(1);
- /* Read pipe until end of file, or an error occurs. */
- while (fgets(psBuffer, 128, pPipe))
- {
- //puts(psBuffer);
- }
- Dbg("%s", psBuffer);
- /* Close pipe and print return value of pPipe. */
- if (feof(pPipe))
- {
- printf("\nProcess returned %d\n", _pclose(pPipe));
- }
- else
- {
- printf("Error: Failed to read the pipe to the end.\n");
- }
- string str(psBuffer);
- int start = str.find("版本");
- if (start > 0)
- return CSimpleStringA(str.substr(start + 5, str.length() - start - 7).c_str());
- else
- return "";
- #else
- const char filePath[] = "/etc/os-version";
- CSimpleStringA strVersion;
- char tmp[33];
- memset(tmp, 0, 33);
- inifile_read_str_s("Version", "MajorVersion", "unknown", tmp, 32, filePath);
- strVersion = tmp;
- strVersion += ".";
- memset(tmp, 0, 33);
- inifile_read_str_s("Version", "MinorVersion", "unknown", tmp, 32, filePath);
- strVersion += tmp;
- strVersion += ".";
- memset(tmp, 0, 33);
- inifile_read_str_s("Version", "OsBuild", "unknown", tmp, 32, filePath);
- strVersion += tmp;
- return strVersion;
- #endif
- }
- void CHealthManagerFSM::UploadEntityStartComsumeTime()
- {
- CAutoArray<CSimpleStringA> strEntityNames;
- CAutoArray<int> strEntityIdx;
- CAutoArray<CEntityStartInfo> Infos;
- ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetAllEntityStartInfo(strEntityNames, strEntityIdx, Infos);
- int healthmangerStartTimes = 0;
- for (int i = 0; i < strEntityNames.GetCount(); ++i) {
- if (strEntityNames[i].Compare(GetEntityBase()->GetEntityName()) == 0)
- {
- Dbg("%s", (const char*)strEntityNames[i]);
- healthmangerStartTimes = Infos[i].startTimes;
- break;
- }
- }
- if (healthmangerStartTimes == 1) {
- const int i = 0; //SpShell
- const ULONGLONG curTickCount = GetTickCount64();
- ULONGLONG oldTickCount = 0;
- /** 只有SpShell的结构体才能这样做!! [Gifur@202193]*/
- memcpy(&oldTickCount, &Infos[i].InitEndTime, sizeof(ULONGLONG));
- const ULONGLONG deltaSeconds = (curTickCount - oldTickCount);
- LogWarn(Severity_Low, Error_Debug, LOG_TRACE_ENTITY_START_TIME,
- SP::Module::Util::generateConsumeTimeJson("total",
- SP::Module::Util::formatTime(Infos[i].startTime).c_str(), deltaSeconds));
- } else {
- Dbg("entity healthmanage start times: %d", healthmangerStartTimes);
- }
- }
- void CHealthManagerFSM::ToLogWarnTermAboutInfo(BOOL bSuccessFlag)
- {
- LOG_FUNCTION();
- bool bTmpEtyNewStart = m_bEntityNewStart;
- CSimpleStringA csOSVerion(""), csWarnMsg(""), csAsiaInfo;
- std::map<std::string, std::string> termInfo;
- termInfo["version"] = m_sysInfo.InstallVersion.ToString();
- termInfo["TerminalNo"] = m_sysInfo.strTerminalID;
- termInfo["MachineType"] = m_sysInfo.strMachineType;
- termInfo["MachineVersion"] = CSimpleStringA::Format("%d.%d", m_sysInfo.MachineVersion.GetMajor(), m_sysInfo.MachineVersion.GetMinor());
- termInfo["Screen"] = CSimpleStringA::Format("%d", m_sysInfo.eScreen);
- termInfo["Site"] = m_sysInfo.strSite;
- termInfo["EnrolGPS"] = CSimpleStringA::Format("%.3f,%.3f", m_sysInfo.EnrolGPS.GetLongitude(), m_sysInfo.EnrolGPS.GetLatitude());
- termInfo["EnrolAddr"] = m_sysInfo.strEnrolAddr;
- if (!m_csErrEntity.IsNullOrEmpty())
- termInfo["ErrEntity"] = m_csErrEntity;
- termInfo["AccessAuth"] = m_bAccessAuth ? "T" : "F";
- csOSVerion = GetOsVersion();
- if (!csOSVerion.IsNullOrEmpty())
- termInfo["OSVersion"] = csOSVerion;
- #if defined(RVC_OS_WIN)
- csAsiaInfo = GetIsAsiaInfoInstalled();
- #else
- csAsiaInfo = "N";
- #endif //RVC_OS_WIN
- termInfo["AsiaInfo"] = csAsiaInfo;
- NetworkAddressesList macAddrs;
- NetworkAddressesList ipAddrs;
- SP::Module::Net::GetINETMacAddresses(macAddrs, ipAddrs);
- CSimpleStringA csMac(""), csIP("");
- for (int i = 0; i < macAddrs.GetCount(); i++) {
- if (!csMac.IsNullOrEmpty()) {
- csMac += ";";
- }
- csMac += macAddrs[i];
- }
- for (int i = 0; i < ipAddrs.GetCount(); i++) {
- if (!csIP.IsNullOrEmpty()) {
- csIP += ";";
- }
- csIP += ipAddrs[i];
- }
- termInfo["MACs"] = csMac;
- termInfo["IPs"] = csIP;
- #if defined(RVC_OS_LINUX)
- CSystemStaticInfo sysInfo;
- ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetSystemStaticInfo(sysInfo);
- if (eErr == Error_Succeed) {
- termInfo["Manufacturer"] = (LPCTSTR)sysInfo.strManufacturer;
- termInfo["MachineMode"] = (LPCTSTR)sysInfo.strMachineModel;
- termInfo["MachineSN"] = (LPCTSTR)sysInfo.strMachineSN;
- }
- #endif //RVC_OS_LINUX
- std::pair<bool, std::string> strResult;
- strResult = generateJsonStr(termInfo);
- Dbg("[%s]", strResult.second.c_str());
- //oilyang@20210323 discard the following rule of throwing LogWarn.Always throw LogWarn
- //oilyang@20201201 log warn every time if content of msg has changed
- if (bTmpEtyNewStart)
- {
- LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_HEALTH_UPLOAD_INFO_ABOUT_TERM, strResult.second.c_str());
- LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_First_Info_AboutTerm, strResult.second.c_str());
- }
- else
- LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_HEALTH_UPLOAD_INFO_ABOUT_TERM, strResult.second.c_str());
- if (bSuccessFlag) {
- UploadEntityStartComsumeTime();
- }
- CSmartPointer<IConfigInfo> pConfig;
- GetEntityBase()->GetFunction()->OpenConfig(Config_Cache, pConfig);
- int stepStatus(0), curStep(0), lastRecordTime(0);
- CSimpleStringA strInstallVersion(true);
- CSimpleStringA strAdditonalMsg(true);
- pConfig->ReadConfigValueInt("TerminalDeploy", "CurrStep", curStep);
- if (curStep == DeployStep_Finished) {
- pConfig->ReadConfigValueInt("TerminalDeploy", "CurrState", stepStatus);
- pConfig->ReadConfigValueInt("TerminalDeploy", "TimeStamp", lastRecordTime);
- pConfig->ReadConfigValue("TerminalDeploy", "InstallVersion", strInstallVersion);
- pConfig->ReadConfigValue("TerminalDeploy", "LastInfo", strAdditonalMsg);
- LogWarn(Severity_High, Error_Debug, LOG_WARN_HEALTH_INSTALL_TIMESTAMP,
- CSimpleString::Format("[{\"timeStamp\":\"%s\",\"step\":%d,\"state\":%d, \"version\":\"%s\", \"msg\":\"%s\"}]",
- CSmallDateTime(lastRecordTime).ToTimeString().GetData(), curStep, stepStatus
- , strInstallVersion.GetData(), strAdditonalMsg.GetData()));
- pConfig->WriteConfigValueInt("TerminalDeploy", "CurrStep", DeployStep_Begin);
- pConfig->WriteConfigValueInt("TerminalDeploy", "CurrState", DEPLOYSTATE_NOTINIT);
- pConfig->WriteConfigValue("TerminalDeploy", "TimeStamp", CSimpleStringA::Format("0x%08X", (DWORD)CSmallDateTime::GetNow()));
- if (!strAdditonalMsg.IsNullOrEmpty()) {
- pConfig->WriteConfigValue("TerminalDeploy", "LastInfo", NULL);
- }
- }
- }
- void CHealthManagerFSM::ShowEntityBootFailedAtFront(LPCTSTR lpcszEntityName, ErrorCodeEnum bootFailedResult, bool isBlock)
- {
- #if defined(RVC_OS_LINUX)
- CEntityLastErrorInfo errInfo = {};
- ErrorCodeEnum errCode = GetEntityBase()->GetFunction()->GetEntityLastError(lpcszEntityName, errInfo);
- CSimpleStringA strErrMsg(true);
- if (!errInfo.strErrMsg.IsNullOrEmpty()) {
- strErrMsg = CSimpleStringA::Format("%s 模块初始化失败:%s", lpcszEntityName, (LPCTSTR)errInfo.strErrMsg);
- } else {
- strErrMsg = CSimpleStringA::Format("%s 模块初始化失败:%s", lpcszEntityName, (LPCTSTR)SpStrError(bootFailedResult));
- }
- if (isBlock) {
- SP::Module::Comm::LogErrorNotiyStruct notifyItem(bootFailedResult, 0);
- SP::Module::Comm::LogNotiyMessageStruct notifyMsg(strErrMsg);
- notifyItem.Notify(notifyMsg);
- } else {
- LogError(Severity_High, bootFailedResult, 0, strErrMsg);
- }
- #endif //RVC_OS_LINUX
- }
- void CHealthManagerFSM::ToCallAccessAuthDoWork()
- {
- if (!m_bInAccessAuthDoWork)
- {
- Dbg("ToCallAccessAuthDoWork");
- AccessAuthTask* pTask = new AccessAuthTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
- }
- }
- void CHealthManagerFSM::JudgeIfNeedInitFWB()
- {
- LOG_FUNCTION();
- CSimpleStringA csFWBDevSN("");
- GetEntityBase()->GetFunction()->GetSysVar("FWBDevSN", csFWBDevSN);
- if (csFWBDevSN.GetLength() > 12 && csFWBDevSN.IndexOf("FWB") > 2)
- {
- Dbg("This is fwb,we need to check if update master key.");
- FWBDoInitTask* pTask = new FWBDoInitTask(this);
- GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
- }
- }
- void CHealthManagerFSM::FWBDoInit()
- {
- LOG_FUNCTION();
- Sleep(2000);
- CSimpleStringA currCheckCode(""), runcfgCkCode("");
- QueryCheckCode(currCheckCode, true);
-
- CSmartPointer<IConfigInfo> spConfigRun;
- GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
- spConfigRun->ReadConfigValue("Run", "ckCode", runcfgCkCode);
- //Dbg("oiltest currCheckCode[%s],runcfgCheckCode[%s]", (const char*)currCheckCode,(const char*)runcfgCkCode);
- if (!currCheckCode.IsNullOrEmpty() && !runcfgCkCode.IsNullOrEmpty() && !currCheckCode.Compare(runcfgCkCode))
- {
- Dbg("check code is the same.");
- return;
- }
- else
- {
- }
- ErrorCodeEnum eErr;
- if (m_pInitClient == NULL)
- {
- m_pInitClient = new InitializerService_ClientBase(this->GetEntityBase());
- eErr = m_pInitClient->Connect();
- if (eErr != Error_Succeed) {
- Dbg("Initializer connected failed.");
- m_pInitClient->SafeDelete();
- m_pInitClient = NULL;
- return;
- }
- else
- Dbg("Initializer connected.");
- }
- InitializerService_GetAuthServerInfo_Req getAuthInfoReq;
- InitializerService_GetAuthServerInfo_Ans getAuthInfoAns;
- eErr = m_pInitClient->GetAuthServerInfo(getAuthInfoReq, getAuthInfoAns,10000);
- if (eErr == Error_Succeed)
- {
- InitializerService_InitializeForBlueTooth_Req initReq;
- InitializerService_InitializeForBlueTooth_Ans initAns;
- initReq.strAuthServer = getAuthInfoAns.strIP;
- initReq.nAuthPort = getAuthInfoAns.nPort;
- initReq.strUserID = "admin";
- initReq.strPassword = "";
- initReq.type = 1;
- eErr = m_pInitClient->InitializeForBlueTooth(initReq, initAns, 60000);
- if (eErr == Error_Succeed)
- {
- Dbg("InitializeForBlueTooth suc.");
- Dbg("write new check code.");
- QueryCheckCode(currCheckCode, true);
- spConfigRun->WriteConfigValue("Run", "ckCode", currCheckCode);
- LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_InitForFWB_Init_Suc, "Init for fwb suc.");
- }
- else
- {
- Dbg("InitializeForBlueTooth failed:%d",eErr);
- LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_InitForFWB_Init_Fail, "Init for fwb failed.");
- }
- }
- else
- {
- Dbg("GetAuthServerInfo failed:%d", eErr);
- LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_InitForFWB_GetAuthAddr_Fail, "Init for fwb,get authaccess address suc.");
- }
- return;
- }
- bool CHealthManagerFSM::IsCutIEBrowser()
- {
- LOG_FUNCTION();
- CSimpleStringA key = "CutBrowser.";
- CSmartPointer<IConfigInfo> spCerConfig;
- ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCerConfig);
- if (eErr == Error_Succeed)
- {
- int tmpCut = 0;
- key += m_sysInfo.strMachineType;
- spCerConfig->ReadConfigValueInt("Common", key, tmpCut);
- if (tmpCut == 1)
- return true;
- }
- return false;
- //if (m_sysInfo.strMachineType.Compare("RVC.Stand2S",true) == 0 || m_sysInfo.strMachineType.Compare("RVC.PAD", true) == 0)
- // return true;
- //else
- // return false;
- }
|