kern/v4/lev3/mod_keeper/mod_keeper.go

// package mod_keeper -- модуль сторожа ядра.
package mod_keeper

import (
	"sync"

	"gitp78su.ipnodns.ru/svi/kern/v4/lev0"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev1"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kmodule"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kserv_http"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kspec"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_ent/module_name"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_serv_http/http_api"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_serv_http/page_module"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_serv_http/page_monolit"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_spec"
)

// ModuleKeeper -- модуль сторожа.
type ModuleKeeper struct {
	mod_spec.IKernelModule
	kCtx     *lev2.KernCtx
	kServHttp kspec.IKernelServerHttp
	log       *lev1.LogBuf
}

var (
	mod   *ModuleKeeper
	block sync.Mutex
)

// GetModuleKeeper -- возвращает новый модуль сторожа ядра.
func GetModuleKeeper() *ModuleKeeper {
	param := &lev1.LogBufParam{
		Prefix_: lev0.LetTxt("ModuleKeeper"),
		IsTerm_: lev0.MutSafeBool(true),
	}
	log := lev1.NewLogBuf(param)
	log.Debug("GetModuleKeeper()")
	block.Lock()
	defer block.Unlock()
	if mod != nil {
		return mod
	}
	kServHttp := kserv_http.GetKernelServHttp()
	modName := module_name.LetModuleName("kKeeper")
	kModKeep := kmodule.NewKernelModule(modName)
	sf := &ModuleKeeper{
		kCtx:          lev2.GetKernCtx(),
		IKernelModule: kModKeep,
		kServHttp:     kServHttp,
		log:           log,
	}
	_ = page_monolit.GetPageMonolit()
	_ = page_module.GetPageModule()

	_ = http_api.NewHttpApi()
	mod = sf
	return sf
}

// Run -- запускает модуль в работу.
func (sf *ModuleKeeper) Run() {
	sf.log.Info("ModuleKernelCtx.Run(): module=%v, is run", sf.Name())
	go sf.kServHttp.Run()
}

// IsWork -- признак работы модуля.
func (sf *ModuleKeeper) IsWork() lev0.Bool {
	return sf.kCtx.Wg().IsWork()
}