myvtm/Framework/spbase/SpBase.cpp

#include "stdafx.h"
#include "version.h"
#include "SpBase.h"

#include <base64File.hpp>

#include "SpTimer.h"
#include "SpEntity.h"
#include "SpModule.h"
#include "RVCEventCode.h"
#ifdef WIN32
#include "SpBaseRoutine.h"
#endif
#include "SpMisc.h"
#include "SpClientSessionFunction.h"

#include "sockutil.h"
#include "fileutil.h"
#include "memutil.h"
#include "dbgutil.h"
#include "sp_shm.h"
#include "sp_dbg_export.h"
#include "sp_def.h"
#include "sp_env.h"

#include "DumpException.h"


#ifdef RVC_OS_WIN
#include "sp_checkEntity.h"
#include <DbgHelp.h>
#else
#include <exception>
#endif // RVC_OS_WIN
#include "SpSecureClient.h"
#include "IHttpFunc.h"
#include <RestfulFunc.h>
#include <winpr/library.h>
#include <winpr/locale.h>
#include <winpr/exception.h>
#include "uuid4.h"
#include <chrono>


#ifndef RVC_OS_WIN

static SpModule* g_module = NULL;

#endif //NOT RVC_OS_WIN

SpModule *GetSpModule()
{
#ifdef RVC_OS_WIN
	SpModule *curModule = NULL;
	if (findThreadModule(GetCurrentThreadId(), (void **)&curModule))
		return curModule;
	else
	{
		CSimpleStringA mod_name = TraceStack();
		if (CSimpleStringA("") == mod_name) {
			return NULL;
		}
		SetthreadGroup(GetCurrentThreadId(), mod_name);
		if (findThreadModule(GetCurrentThreadId(), (void**)&curModule))
			return curModule;
	}
	return NULL;
#else
	return g_module;
#endif //RVC_OS_WIN
}

#ifdef RVC_OS_WIN

static LONG WINAPI SuppressError(struct _EXCEPTION_POINTERS* ExceptionInfo)
{
	//get active ver
	sp_version_t active_version = { 0 };
	sscanf(strrchr(sp_get_env()->dir->base_path, '\\') + 1, "%d.%d.%d.%d",
		&active_version.major, &active_version.minor, &active_version.revision, &active_version.build);
	

	std::string dmpFileStr;
	char tmp[MAX_PATH], tmpPath[MAX_PATH];
	GetModuleFileNameA(NULL, tmpPath, MAX_PATH);
	*strrchr(tmpPath, SPLIT_SLASH) = 0;
	*strrchr(tmpPath, SPLIT_SLASH) = 0;
	*strrchr(tmpPath, SPLIT_SLASH) = 0;
	*strrchr(tmpPath, SPLIT_SLASH) = 0;
	*strrchr(tmpPath, SPLIT_SLASH) = 0;
	wsprintfA(tmp, "%s\\rvc\\dmp\\expt.%d_%d_%d_%d.%s.%d.%d.log", tmpPath, active_version.major, active_version.minor
		, active_version.revision, active_version.build, GetSpModule() ? GetSpModule()->get_mod()->cfg->name : "", GetCurrentThreadId(), GetCurrentProcessId());
	HANDLE hLogFile = ::CreateFileA(tmp, GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
	if (hLogFile != INVALID_HANDLE_VALUE) {
		DumpExceptionInfo(ExceptionInfo, hLogFile);
		FlushFileBuffers(hLogFile);
		SetEndOfFile(hLogFile);
		CloseHandle(hLogFile);
	}

	wsprintfA(tmp, "%s\\rvc\\dmp\\expt.%d_%d_%d_%d.%s.%d.%d.dmp", tmpPath, active_version.major, active_version.minor
		, active_version.revision, active_version.build, GetSpModule() ? GetSpModule()->get_mod()->cfg->name : "", GetCurrentThreadId(), GetCurrentProcessId());
	HANDLE hDumpFile = CreateFileA( tmp, GENERIC_READ | GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL );
	if( ( hDumpFile != NULL ) && ( hDumpFile != INVALID_HANDLE_VALUE ) ) 
	{
		MINIDUMP_EXCEPTION_INFORMATION mdei; 

		mdei.ThreadId           = GetCurrentThreadId(); 
		mdei.ExceptionPointers  = ExceptionInfo; 
		mdei.ClientPointers     = FALSE; 

		MINIDUMP_TYPE mdt       = MiniDumpWithIndirectlyReferencedMemory; 

		MiniDumpWriteDump( GetCurrentProcess(), GetCurrentProcessId(), 
			hDumpFile, mdt, (ExceptionInfo != 0) ? &mdei : 0, 0, 0 ); 
		CloseHandle( hDumpFile );
	}
	DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__).setLogCode(ERR_ENTITY_EXCEPTION).setVtmCode(RTAERR_ENTITY_EXCEPTION)("exit entity exception, saveDmp, %s, detail:%d:%s"
		, tmp, dmpFileStr.length(), dmpFileStr.c_str());

	Sleep(1500);//wait until all log send
	ExitProcess(Error_Exception); // exit process to suppress reporting exception

	return EXCEPTION_EXECUTE_HANDLER;
}



#else 

#include <execinfo.h>

static void HandleSignalCallback(int signalNo)
{
	switch (signalNo) {
	case SIGSEGV:
	{
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("=========>>> capture signal SIGSEGV  <<<=========");
        void* l_buffer[512];
        char** l_ptrace;
        //char l_s8aBuff[128] = { 0x00 };
        //snprintf(l_s8aBuff, sizeof(l_s8aBuff), "cat /proc/%d/maps", getpid());
        //system(l_s8aBuff);

		//objdump -d libbacktrace.so > log.txt

        DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("Dump stack start...");
        int size = backtrace(l_buffer, 512);
        l_ptrace = backtrace_symbols(l_buffer, size);
        if (NULL == l_ptrace) {
			DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("backtrace_symbols");
            exit(1);
        }

        for (int i = 0; i < size; i++) {
			DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("  [%02d] %s", i, l_ptrace[i]);
        }

		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("Dump stack end...");
        free(l_ptrace);
        exit(-1);
        break;
	}
    case SIGKILL:
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("=========>>> capture signal SIGKILL  <<<=========");
		break;
    case SIGTERM:
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("=========>>> capture signal SIGTERM  <<<=========");
        break;
	default:
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("=========>>> capture signal %d  <<<=========", signalNo);
		break;
	}
	return;
}

static LONG WINAPI SuppressError(struct _EXCEPTION_POINTERS* ExceptionInfo)
{
	LONG result(0);
#if 1
    struct sigaction siga;

    siga.sa_handler = HandleSignalCallback;
    siga.sa_flags = 0;
    sigemptyset(&siga.sa_mask);

    if (0 > sigaction(SIGSEGV, &siga, NULL)) {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("register signal 'SIGSEGV' failed! %s %d", strerror(errno), errno);
		result = -1;
    }

    //if (0 > sigaction(SIGTERM, &siga, NULL)) {
    //    sp_dbg_error("register signal 'SIGTERM' failed! %s %d", strerror(errno), errno);  result = -1;
    //}

    //if (0 > sigaction(SIGKILL, &siga, NULL)) {
    //    sp_dbg_error("register signal 'SIGKILL' failed! %d", errno);  result = -1;
    //}
#endif

	return result;
}

#endif //RVC_OS_WIN

SPBASE_API void GetLibVersion(CVersion& version)
{
	CVersion ver(VER_Major, VER_Minor, VER_Revision, VER_Build);
	version = ver;
}

SPBASE_API LPCSTR GetLibBuildDate()
{
#if defined(WITH_DEBUG)
	static char buildDate[] = __DATE__ " " __TIME__ " Debug";
#elif defined(WITH_NO_DEBUG)
	static char buildDate[] = __DATE__ " " __TIME__ " Release";
#else
	static char buildDate[] = __DATE__ " " __TIME__;
#endif // WITH_DEBUG

	return buildDate;
}

SPBASE_API void LogEvent(const SeverityLevelEnum eLevel,DWORD dwUserEventCode,const char *pszMessage)
{//MAX string len < 1024
	SpModule *pModule = GetSpModule();
	if (pModule) {
		pModule->LogMessage(Log_Event, eLevel, 0, dwUserEventCode, pszMessage);
	}

	// write a copy in dbg log
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__).setVtmCode(DWORD2Hex(dwUserEventCode).GetData())
		("Event: {%s}(uc=0x%X)", pszMessage, dwUserEventCode);
}

SPBASE_API void LogError(const SeverityLevelEnum eLevel, ErrorCodeEnum dwSysErrorCode,DWORD dwUserErrorCode,const char *pszMessage)
{
	SpModule *pModule = GetSpModule();
	if (pModule) {
		pModule->LogMessage(Log_Error, eLevel, dwSysErrorCode, dwUserErrorCode, pszMessage);
	}
	else {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("LogError failed!can not find the module");
	}

	// write a copy in dbg log
	DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__).setVtmCode(DWORD2Hex(dwUserErrorCode).GetData())
		("Error: {%s}(sc=0x%X, uc=0x%X)", pszMessage, dwSysErrorCode, dwUserErrorCode);
}

SPBASE_API void LogFatal(const SeverityLevelEnum eLevel, ErrorCodeEnum dwSysErrorCode, DWORD dwUserErrorCode, const char* pszMessage)
{
	SpModule* pModule = GetSpModule();
	if (pModule) {
		pModule->LogMessage(Log_Fatal, eLevel, dwSysErrorCode, dwUserErrorCode, pszMessage);
	} else
		sp_dbg_info("LogFatal failed!can not find the module");

    DbgWithLink(LOG_LEVEL_FATAL, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__).setVtmCode(DWORD2Hex(dwUserErrorCode).GetData())
		("Fatal: {%s}(sc=0x%X, uc=0x%X)", pszMessage, dwSysErrorCode, dwUserErrorCode);
}

SPBASE_API void LogWarn(const SeverityLevelEnum eLevel, ErrorCodeEnum dwSysErrorCode,DWORD dwUserErrorCode, const char *pszMessage)
{
	SpModule *pModule = GetSpModule();
	if (pModule) {
		pModule->LogMessage(Log_Warning, eLevel, dwSysErrorCode, dwUserErrorCode, pszMessage);
	}

	// write a copy in dbg log
	DbgWithLink(eLevel == Severity_Low ? LOG_LEVEL_INFO : LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__).setVtmCode(DWORD2Hex(dwUserErrorCode).GetData())
		("Warn: {%s}(sc=0x%X, uc=0x%X)", pszMessage, dwSysErrorCode, dwUserErrorCode);
}

SPBASE_API void LogAssert(const char *pszMessage,const char *pszFile,const int nLine)
{
	SpModule *pModule = GetSpModule();
	if (pModule) {
		pModule->LogMessage(Log_Debug, Severity_Middle, 0, 0,
			CSimpleStringA::Format("assert fail: {%s}, file: {%s}, line: {%d}, stack: {%s}", 
			pszMessage, _GetFileName(pszFile), nLine,
#ifdef RVC_OS_WIN
			(const char*)DumpStack(2)
#else
			"not implement, TODO:"
#endif //RVC_OS_WIN
			));
	}

	// write a copy in dbg log
	DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__).setVtmCode(DWORD2Hex(ERR_ENTITY_ASSERT).GetData())("Assert fail: {%s}, file: {%s}, line: {%d}, stack: {%s}",
		pszMessage, _GetFileName(pszFile), nLine, 
#ifdef RVC_OS_WIN
		(const char*)DumpStack(2)
#else
		"not implement, TODO:"
#endif //RVC_OS_WIN
	);
}

SPBASE_API void LogTrace(const char *pszMessage,const char *pszFile,const int nLine)
{
	SpModule *pModule = GetSpModule();
	if (pModule) {		
		pModule->LogMessage(Log_Debug, Severity_None, 0, 0, pszMessage);
	}

	// write a copy in dbg log
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("Trace: {%s}, file: {%s}, line: {%d}", pszMessage, _GetFileName(pszFile), nLine);
}

SPBASE_API void LogEvent(const SeverityLevelEnum eLevel, DWORD dwUserEventCode, const char* pszMessage, const linkContext& t_context)
{
	SpModule* pModule = GetSpModule();
	if (pModule) {
		pModule->LogMessage(Log_Event, eLevel, 0, dwUserEventCode, pszMessage, t_context);
	}

	// write a copy in dbg log
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__).setVtmCode(DWORD2Hex(dwUserEventCode).GetData())
		("Event: {%s}(uc=0x%X)", pszMessage, dwUserEventCode);
}

SPBASE_API void LogError(const SeverityLevelEnum eLevel, ErrorCodeEnum dwSysErrorCode, DWORD dwUserErrorCode, const char* pszMessage, const linkContext& t_context)
{
	SpModule* pModule = GetSpModule();
	if (pModule) {
		pModule->LogMessage(Log_Error, eLevel, dwSysErrorCode, dwUserErrorCode, pszMessage, t_context);
	}
	else {
        DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("LogError failed!can not find the module");
	}

	// write a copy in dbg log
	DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__).setVtmCode(DWORD2Hex(dwSysErrorCode).GetData())
		("Error: {%s}(sc=0x%X, uc=0x%X)", pszMessage, dwSysErrorCode, dwUserErrorCode);
}

SPBASE_API void LogWarn(const SeverityLevelEnum eLevel, ErrorCodeEnum dwSysErrorCode, DWORD dwUserErrorCode, const char* pszMessage, const linkContext& t_context)
{
	SpModule* pModule = GetSpModule();
	if (pModule) {
		pModule->LogMessage(Log_Warning, eLevel, dwSysErrorCode, dwUserErrorCode, pszMessage, t_context);
	}

	// write a copy in dbg log
	DbgWithLink(eLevel == Severity_Low ? LOG_LEVEL_INFO : LOG_LEVEL_WARN,  LOG_TYPE_SYSTEM).setVtmCode(DWORD2Hex(dwUserErrorCode).GetData())
		("Warn: {%s}(sc=0x%X, uc=0x%X)", pszMessage, dwSysErrorCode, dwUserErrorCode);
}

SPBASE_API void LogAssert(const char* pszMessage, const char* pszFile, const int nLine, const linkContext& t_context)
{
	SpModule* pModule = GetSpModule();
	if (pModule) {
		pModule->LogMessage(Log_Debug, Severity_Middle, 0, 0,
			CSimpleStringA::Format("assert fail: {%s}, file: {%s}, line: {%d}, stack: {%s}",
				pszMessage, _GetFileName(pszFile), nLine,
#ifdef RVC_OS_WIN
                (const char*)DumpStack(2)
#else
                 "not implement, TODO:"
#endif //_WIN32
			), t_context);
	}

	// write a copy in dbg log
	DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__).setVtmCode(DWORD2Hex(ERR_ENTITY_ASSERT).GetData())("Assert fail: {%s}, file: {%s}, line: {%d}, stack: {%s}",
		pszMessage, _GetFileName(pszFile), nLine,
#ifdef RVC_OS_WIN
        (const char*)DumpStack(2)
#else
         "not implement, TODO:"
#endif //_WIN32
												  );
}

SPBASE_API void LogTrace(const char* pszMessage, const char* pszFile, const int nLine, const linkContext& t_context)
{
	SpModule* pModule = GetSpModule();
	if (pModule) {
		pModule->LogMessage(Log_Debug, Severity_None, 0, 0, pszMessage, t_context);
	}

	// write a copy in dbg log
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("Trace: {%s}, file: {%s}, line: {%d}", pszMessage, _GetFileName(pszFile), nLine);
}

#include "log.h"
SPBASE_API void SpGetToken(char* channelId, char* token, char* terminalno, char* reserve1)
{
	sp_env_t* env = sp_get_env();
	if (NULL != env && NULL != env->cfg && NULL != env->cfg->shell_ini &&
		env->cfg->shell_ini->channelId != NULL && env->cfg->shell_ini->token != NULL
		&& env->cfg->root_ini != NULL && env->cfg->root_ini->terminal_no != NULL)
	{
		snprintf(channelId, MAX_TOKEN_LEN, "%s", env->cfg->shell_ini->channelId);
		snprintf(token, MAX_TOKEN_LEN, "%s", env->cfg->shell_ini->token);
		snprintf(terminalno, MAX_TOKEN_LEN, "%s", env->cfg->root_ini->terminal_no);
	}
	else if (NULL == env)
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SpGetToken can not get token!env == NULL");
	else if (NULL == env->cfg)
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SpGetToken can not get token!env->cfg == NULL");
	else if (NULL == env->cfg->shell_ini)
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SpGetToken can not get token!env->cfg->shell_ini == NULL");
	else if (NULL == env->cfg->shell_ini->channelId)
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SpGetToken can not get token!env->cfg->shell_ini->channelId == NULL");
	else if (NULL == env->cfg->shell_ini->token)
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SpGetToken can not get token!env->cfg->shell_ini->token == NULL");
}



extern "C" SPBASE_API void Dbg(const char *str, ...)
{
	if (str == nullptr)
		return;
	va_list arg;
	va_start(arg, str);
	vDbg(str, arg);
	va_end(arg);
}

extern "C" SPBASE_API void vDbg(const char *str, va_list list)
{
    int n = _vscprintf(str, list);
    if (n > 1024)
        n = 1024;

    char *buf = (char*)_alloca(n + 1);
    memset(buf, '\0', n + 1);
    /*write at most n bytes(including the terminating null byte '\0') to buf*/
    vsnprintf(buf, n + 1, str, list); // plus 1 to n, never changed code but the log lost one char [4/1/2020 16:25 Gifur]
    buf[n] = '\0';

#if defined(_MSC_VER)
	sp_dbg_debugNoOut("Debug: {%s}", buf);	//打印到文件
#else
	sp_dbg_debug("Debug: {%s}", buf);
#endif //_MSC_VER


#ifdef RVC_OS_WIN

    SpModule* pModule = GetSpModule();
    if (pModule) {
        SpEntity* pEntity = (SpEntity*)(getEntityResource()->m_Entity);
        if (pEntity != NULL) {
            auto pEntCfg = pEntity->get_cfg_ent();
            if (pEntCfg != NULL)
                pEntity->LogMessage(Log_Debug, Severity_None, 0, 0, buf);
        }
    }

#endif // RVC_OS_WIN
}

static bool RegistMain(HMODULE hModule,EntryRoutine Main, EntryRoutine Exit)
{
	SpModule::SetEntryRoutine(Main, Exit);
	return true;
}

static HMODULE LoadModuleLibrary(sp_mod_t *mod)
{
	sp_env_t *env = sp_get_env();
	char tmp[MAX_PATH];
	sp_dir_get_path(env->dir, SP_DIR_MODULE_BIN, mod->cfg->name, tmp, sizeof(tmp));
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("load module library: %s", tmp);
	return LoadLibraryA(tmp);
}

/*only sphost would invoke it.*/
extern "C" SPBASE_API int __stdcall SpExit(const char* mod_name)
{
#ifdef RVC_OS_WIN
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("Do SpExit!");
	SetthreadGroup(GetCurrentThreadId(), mod_name);
	CleanModuleThread(mod_name);
	sp_iom_stop(GetSpModule()->get_iom());
	GetSpModule()->Term();
	sp_shm_term();

	sp_dbg_term();

	sp_iom_destroy(GetSpModule()->get_iom());
	delete GetSpModule();
	//winsock_term();

	FreeLibrary(getEntityResource()->m_Module);
	DestoryModuleInfo(mod_name);
#else
	if (sp_shm_is_newalloc())
		return 0; /*spshell*/

	if (g_module) {
		delete g_module;
		g_module = nullptr;
	}

#endif //RVC_OS_WIN
	return 0;

}

extern "C" SPBASE_API int __stdcall SpRun(const char *mod_name, int epid, int range, int group, int saveFile)
{
	ErrorCodeEnum Error = Error_Unexpect;

	if (!mod_name) { return Error_Param; }
		
	if (epid == SP_INVALID_MOD_ID) { return Error_Param;  }

#ifdef RVC_OS_WIN

	if (findModuleByName(mod_name))		//检测实体是否已创建
		SpExit(mod_name);

	bool result = group == 0 ? CreateModuleInfo(ENTITY_SINGLE_GROUPNAME) : CreateModuleInfo(mod_name);

	//the SetthreadGroup routine would never return false, so the group variable must be not-zero
	if (!result || !SetthreadGroup(GetCurrentThreadId(), mod_name))
		return Error_Duplication;
#else
	if (g_module) {
		return Error_Duplication;
	}
#endif //RVC_OS_WIN

	void* hint_addr = NULL;
	HMODULE hModule = NULL;
	sp_env_t* env = NULL;
	sp_mod_t* mod = NULL;
	sp_cfg_shell_module_t* cfg_mod = NULL;
	SpModule* curModule = NULL;

	if (winsock_init() != 0) {
		sp_dbg_error("winsock init failed!");
		Error = Error_NetBroken;
		goto on_error;
	}

	SetTokenCallBack(getHttpToken);
	SetRestfulTokenCallBack(getHttpToken);

	//need init shm first, because log_record save in shm
    hint_addr = sp_shm_init(range, FALSE);

	create_log_producer_default(mod_name, epid);
	if (saveFile)
		sp_dbg_init(mod_name, 1);
	else
		sp_dbg_init(mod_name, 0);
	EntityResource::setSaveFile(saveFile);
	sp_dbg_set_level(XLOG_LEVEL_DEBUG);
    if (!hint_addr) {
        DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("shm init failed!");
        Error = Error_Null;
        goto on_error;
    }

	sp_trace_init();


	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("==============SpRun(%s) start==============", mod_name);
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("process id: %d, curLogLevel:%d", GetCurrentProcessId(), getCurLogLevel());
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("shm init ok! hint_addr: %p", hint_addr);

	env = sp_get_env();
	if (!env) {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("module env object init failed(env is null)!");
		Error = Error_Unexpect;
		goto on_error;
	}
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("retrieve env object ok!");
	mod = sp_mod_mgr_find_module_by_idx(env->mod_mgr, epid);
	if (!mod) {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("find shm module object failed!");
		Error = Error_NotExist;
		goto on_error;
	}
	//sp_dbg_info("find module %s id %d ok!", mod->cfg->name, mod->cfg->idx);
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("module %s id %d static file version: %d.%d.%d.%d", mod->cfg->name, mod->cfg->idx,
		mod->cfg->version.major,
		mod->cfg->version.minor,
		mod->cfg->version.revision,
		mod->cfg->version.build);

	SpInitUUID((WORD)mod->cfg->idx);
	cfg_mod = sp_cfg_get_module_by_idx(env->cfg, epid);
	if (!cfg_mod) {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("get module %s cfg object failed!", mod->cfg->name);
        Error = Error_NotExist;
        goto on_error;
	}
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("find cfg module object %s id %d ok!", cfg_mod->name, cfg_mod->idx);

#ifdef RVC_OS_WIN
	SetUnhandledExceptionFilter(&SuppressError);
#else
	SuppressError(NULL);
#endif //RVC_OS_WIN

#ifdef RVC_OS_WIN
	curModule = new SpModule(mod, cfg_mod);

	getEntityResource()->m_Module = LoadModuleLibrary(mod);
	if (!getEntityResource()->m_Module) {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("load module library %s failed! GetLastError = %d", mod->cfg->name, GetLastError());
		Error = Error_Unregisted;
		goto on_error;
	}

	curModule->getEntryRoutine(&(getEntityResource()->m_pfMain), &(getEntityResource()->m_pfExit));
	Error = curModule->Init(env->url);
	if (Error) {
		delete curModule;
		curModule = NULL;
		goto on_error;
	}
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("init moudle succ.");
#else
	g_module = new SpModule(mod, cfg_mod);
	hModule = LoadModuleLibrary(mod);
	if (!hModule) {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("load module library %s failed! %s", mod->cfg->name, DLoadErrorString());
		Error = Error_Unregisted;
		goto on_error;
	}
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("to init module...");
	Error = g_module->Init(env->url);
	if (Error) {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("init moudle returned %s", SpStrError(Error));
		goto on_error;
	}
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("init moudle succ.");

#endif //RVC_OS_WIN
	
	SetThreadPriority(GetCurrentThread(), THREAD_PRIORITY_ABOVE_NORMAL);

#ifdef RVC_OS_WIN 
	if (!SetSpModule(mod_name, curModule)) {
		Error = Error_Unexpect;
		goto on_error;
	}

	sp_trace_term();
	Error = curModule->Run();
	curModule->Term();

	FreeLibrary(getEntityResource()->m_Module);

	delete curModule;
	curModule = NULL;
#else
	sp_trace_term();
	Error = g_module->Run();
	g_module->Term();
	
#endif //RVC_OS_WIN

on_error:

#ifndef RVC_OS_WIN
	if (hModule) {
		FreeLibrary(hModule);
		hModule = NULL;
	}
	if (g_module) {
		delete g_module;
		g_module = nullptr;
	}
#endif //NOT RVC_OS_WIN

	if (!!sp_trace_exist()) {
        char* last_err = NULL;
        sp_trace_retrieve(&last_err, NULL);
        if (last_err) {
			sp_mod_supress_last_err_for_all_entity(mod, last_err);
            FREE(last_err);
        }
	}
    sp_shm_term();
	//destroy_log_producer_default();

	return Error;
}

extern "C" SPBASE_API const char* SpStrError(ErrorCodeEnum errorCode)
{
	return sp_strerror((int)errorCode);
}

SPBASE_API CSimpleStringA GetSysErrMsg(DWORD nErrCode)
{
#if defined(RVC_OS_WIN)
	char szBuf[2048] = {};
	DWORD dwRet = FormatMessageA(
		FORMAT_MESSAGE_IGNORE_INSERTS | FORMAT_MESSAGE_FROM_SYSTEM,
		NULL,
		nErrCode,
		MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
		szBuf,
		sizeof(szBuf) - 1,
		NULL);

	char* p = strrchr(szBuf, '\r');
	if (p != NULL)
		*p = ' ';

	p = strrchr(szBuf, '\n');
	if (p != NULL)
		*p = ' ';

	return dwRet > 0 ? szBuf : CSimpleStringA::Format("get error message fail: %d", GetLastError());

#else
	
	std::string szBuf(strerror(nErrCode));
	return szBuf.c_str();

#endif //RVC_OS_WIN
}

extern "C" SPBASE_API const char *_GetFileName(const char *pszFilePath)
{
	int i=strlen(pszFilePath);
	for( ; i>0 && pszFilePath[i-1]!=SPLIT_SLASH; i--)NULL;
	return pszFilePath+i;
}

#ifdef RVC_OS_WIN
extern "C" BOOL APIENTRY DllMain(HMODULE hModule,
	DWORD  ul_reason_for_call,
	LPVOID lpReserved)
{
	switch (ul_reason_for_call) {
	case DLL_PROCESS_ATTACH:
	{
		DisableThreadLibraryCalls(hModule);
		break;
	}
	case DLL_THREAD_ATTACH:
		break;
	case DLL_THREAD_DETACH:
		break;
	case DLL_PROCESS_DETACH:
		break;
	}
	return TRUE;
}
#endif //RVC_OS_WIN

ModuleBase::~ModuleBase() 
{ 
#ifdef RVC_OS_WIN
	getEntityResource()->m_moduleBase = NULL;
#else
	ModuleBase::s_pModuleInst = NULL;
#endif //RVC_OS_WIN

	for (int i = 0; i < m_nEntityCount; ++i) 
	{
		if (m_pEntityArray[i])
		{
#ifdef RVC_OS_WIN
			//属于实体关闭掉，会自动清理，实际上不做对应的delete也行
			//基于该部分出了的问题，应该用share_ptr来处理
			//不过因为需要导出到spbase.h中，处理比较麻烦
			//__try {
			//	delete m_pEntityArray[i];
			//}
			//__finally {
			//	m_pEntityArray[i] = NULL;
			//}
#else
			delete m_pEntityArray[i];
			m_pEntityArray[i] = NULL;
#endif //RVC_OS_WIN
		}
	}
	m_nEntityCount = 0;
}

static ErrorCodeEnum __Init()
{
#ifdef RVC_OS_WIN
	ModuleBase* pThis = (ModuleBase*)(getEntityResource()->m_moduleBase);
#else
	ModuleBase* pThis = ModuleBase::s_pModuleInst;
#endif //RVC_OS_WIN
	_ASSERT(pThis);
	return pThis->Init();
}

static ErrorCodeEnum __Exit()
{
#ifdef RVC_OS_WIN
	ModuleBase* pThis = (ModuleBase*)(getEntityResource()->m_moduleBase);
#else
	ModuleBase* pThis = ModuleBase::s_pModuleInst;
#endif //RVC_OS_WIN
	_ASSERT(pThis);
	return pThis->Exit();
}

ErrorCodeEnum ModuleBase::Init()
{
	ErrorCodeEnum Error = Error_Succeed; 
	for (int i = 0; i < m_nEntityCount; ++i) 
	{ 
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("to regist entity %s", m_pEntityArray[i]->GetEntityName());
		Error = RegistEntity(m_pEntityArray[i]); 
		if (Error) {
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("regist entity %s returned %s", m_pEntityArray[i]->GetEntityName(), SpStrError(Error));
            break;
		}
	} 
	return Error; 
}

ErrorCodeEnum ModuleBase::Exit()
{
	ErrorCodeEnum Error = Error_Succeed; 
	for (int i = 0; i < m_nEntityCount; ++i) 
	{
		Error = UnregistEntity(m_pEntityArray[i]); 
		if (Error) 
			break; 
	} 
	return Error; 
}

BOOL ModuleBase::DllMain(HINSTANCE hInstance, DWORD dwReason, LPVOID lpReserved)
{
	if (dwReason == DLL_PROCESS_ATTACH) {
		bool ret = RegistMain(hInstance, &__Init, &__Exit);
		if (!ret)
			return FALSE;

		DisableThreadLibraryCalls(hInstance);
		m_hInstance = hInstance;
	}
	return TRUE;
}

ErrorCodeEnum ModuleBase::RegistEntity(CEntityBase *pEntity)
{
	SpModule *pModule = GetSpModule();
	SpSecureClient::SetSecureEntity(pEntity);
	if (!pModule)
		return Error_Null;
	return pModule->AddEntityBase(pEntity);
}

ErrorCodeEnum ModuleBase::UnregistEntity(CEntityBase *pEntity)
{
	SpModule *pModule = GetSpModule();
	return pModule->RemoveEntityBase(pEntity);
}

ErrorCodeEnum ModuleBase::GetRegistEntity(const char *pszEntityName,CSmartPointer<CEntityBase> &pEntity)
{
	SpModule *pModule = GetSpModule();
	return pModule->GetEntityBase(pszEntityName, pEntity);
}

#ifndef RVC_OS_WIN
ModuleBase* ModuleBase::s_pModuleInst = NULL;
#endif //NOT RVC_OS_WIN
ModuleBase* ModuleBase::GetModuleBase()
{
#ifdef RVC_OS_WIN
	return (ModuleBase*)(getEntityResource()->m_moduleBase);
#else
	return ModuleBase::s_pModuleInst;
#endif //RVC_OS_WIN
}

ModuleBase::ModuleBase()
:m_hInstance(NULL), m_nEntityCount(0) 
{
#ifdef RVC_OS_WIN
	getEntityResource()->m_moduleBase = this;
#else
	ModuleBase::s_pModuleInst = this;
#endif //RVC_OS_WIN
}

CClientSessionBase::~CClientSessionBase()
{
	if (m_pSessionFunction) {
		SpClientSessionFunction *pFunction = dynamic_cast<SpClientSessionFunction *>(m_pSessionFunction);
		m_pSessionFunction = NULL;
		pFunction->DecrementRef();
	}
}

CSimpleStringA uuid4_generateStr(int len)
{
	auto ret = uuid4_generate(len);
	return ret.c_str();
}