kern/v4/lev3/mod_kctx/mod_kctx.go

// package mod_kctx -- модуль контекста ядра.
package mod_kctx

import (
	"sync"

	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/comp_spec"
	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
	"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_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"
)

// ModuleKernelCtx -- модуль контекста ядра.
type ModuleKernelCtx struct {
	kspec.IKernelModule
	kCtx      kspec.IKernelCtx
	kServHttp kspec.IKernelServerHttp
	log       comp_spec.ILogBuf
}

var (
	mod   *ModuleKernelCtx
	block sync.Mutex
)

// GetModuleKernelCtx -- возвращает новый модуль контекста ядра.
func GetModuleKernelCtx() *ModuleKernelCtx {
	block.Lock()
	defer block.Unlock()
	if mod != nil {
		return mod
	}
	modName := defs.NewModuleName("kCtx")
	sf := &ModuleKernelCtx{
		kCtx:          kctx.GetKernelCtx(),
		IKernelModule: kmodule.NewKernelModule(modName),
		kServHttp:     kserv_http.GetKernelServHttp(),
	}
	sf.log = sf.Ctx().Log()
	_ = page_monolit.GetPageMonolit()
	_ = page_module.GetPageModule()

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

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

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