kern/v4/d2/kern_ctx/kern_ctx_test.go

package kern_ctx

import (
	"testing"

	"gitp78su.ipnodns.ru/svi/kern/v4/d0"
)

type tester struct {
	t     *testing.T
	owner *d0.LOwner
}

func TestKernelCtx(t *testing.T) {
	sf := &tester{
		t:     t,
		owner: d0.LetOwner(1, "test_kernel_ctx"),
	}
	sf.new()
}

var counter *d0.LTxt

// Создание контекста ядра.
func (sf *tester) new() {
	sf.t.Log("new")
	counter = d0.LetTxt(sf.owner, "counter")
	kCtx := GetKernCtx()
	if kCtx == nil {
		sf.t.Fatalf("new(): KernelCtx==nil")
	}
	if ctx := kCtx.CtxBg(); ctx != kernCtx.ctxBg {
		sf.t.Fatalf("new(): ctx!=ctxBg")
	}
	if ctx := kCtx.SelfCtx(); ctx == nil {
		sf.t.Fatalf("new(): ctx==nil")
	}
	kCtx.Set(counter, 5, "test_counter")
	if kCtx.Get(counter) == nil {
		sf.t.Fatalf("new(): counter==nil")
	}
	res := kCtx.Get(counter)
	ctxVal := res.Hassert("new()")
	val := ctxVal.Val().(d0.Num)
	if val != 5 {
		sf.t.Fatalf("new(): counter(%v)!=5", val)
	}
	kCtx.Del(counter)
	kCtx.Cancel()
	kCtx.Wait()
	kCtx = GetKernCtx()
	if kCtx == nil {
		sf.t.Fatalf("new(): KernelCtx==nil")
	}
	if wg := kCtx.Wg(); wg == nil {
		sf.t.Fatalf("new(): IKernelWg==nil")
	}
	if keep := kCtx.Keeper(); keep == nil {
		sf.t.Fatalf("new(): IKernelKeeper==nil")
	}

}