fw/rt2/frame/std/sf.go

package std

import (
	"container/list"
	"fw/rt2/context"
	"fw/rt2/frame"
	"fw/rt2/scope"
	"fw/utils"
	"reflect"
	"ypk/assert"
	"ypk/halt"
)

type FlowFrame interface {
}

type RootFrame struct {
	inner  list.List
	domain context.Domain
	queue  []frame.Frame
}

func (f *RootFrame) init() *RootFrame {
	f.inner = *list.New()
	return f
}

func NewRoot() *RootFrame {
	return new(RootFrame).init()
}

func (r *RootFrame) Queue(f ...frame.Frame) (ret frame.Frame) {
	if len(f) == 0 {
		if len(r.queue) > 0 {
			ret = r.queue[0]
			old := r.queue
			r.queue = nil
			for i := 1; i < len(old); i++ {
				r.queue = append(r.queue, old[i])
			}
		}
		return ret
	} else {
		for i := range f {
			assert.For(f[i].Domain() != nil, 20)
		}
		r.queue = append(r.queue, f...)
		return nil
	}
}

func (f *RootFrame) PushFor(fr, parent frame.Frame) {
	_, ok := fr.(*RootFrame)
	if ok {
		panic("impossibru")
	}
	f.inner.PushFront(fr)
	if fr.Domain() == nil {
		if parent == nil {
			domain := f.Domain().(context.Factory).New()
			domain.Attach(context.SCOPE, scope.New(context.SCOPE))
			fr.Init(domain)
		} else {
			fr.Init(parent.Domain())
		}
	}
	fr.OnPush(f, parent)
}

func (f *RootFrame) Pop() {
	if f.inner.Front() != nil {
		elem := f.inner.Front()
		frame := elem.Value.(frame.Frame)
		frame.OnPop()
		f.inner.Remove(elem)
	} else {
		panic("it's empty stack")
	}
}

func (f *RootFrame) Top() (fr frame.Frame) {
	elem := f.inner.Front()
	if elem != nil {
		fr = elem.Value.(frame.Frame)
	}
	return fr
}

func (f *RootFrame) Drop() (fr frame.Frame) {
	elem := f.inner.Front()
	if elem != nil {
		fr = elem.Value.(frame.Frame)
		f.inner.Remove(elem)
	}
	return fr
}

func (f *RootFrame) Do() (res frame.WAIT) {
	var (
		trapped bool
	)
	if f.Top() != nil {
		x := f.Top()
		//цикл дейкстры
		for {
			wait := x.Do()
			//fmt.Println(wait)
			if wait == frame.LATER || wait == frame.BEGIN || wait == frame.END {
				break
			} else if wait == frame.NOW {
			} else if wait == frame.WRONG {
				trapped = true
				utils.PrintTrap("it's a trap")
				break
				//panic("something wrong") do nothing, it's a trap
			} else if wait == frame.STOP {
				if x == f.Top() {
					f.Pop()
				} else {
					halt.As(100, reflect.TypeOf(x), reflect.TypeOf(f.Top()), "do not stop if not top on stack")
				}
				break
			} else {
				panic("wrong wait code")
			}
		}
	}
	if f.Top() != nil && !trapped {
		res = frame.NOW
	} else {
		res = frame.STOP
	}
	return res
}

func (f *RootFrame) ForEach(run func(x frame.Frame) bool) {
	e := f.inner.Front()
	ok := true
	for (e != nil) && ok {
		if e.Value != nil {
			ok = run(e.Value.(frame.Frame))
		}
		e = e.Next()
	}
}

func (f *RootFrame) OnPush(a frame.Stack, b frame.Frame) {}
func (f *RootFrame) OnPop()                              {}
func (f *RootFrame) Parent() frame.Frame                 { return nil }
func (f *RootFrame) Root() frame.Stack                   { return nil }
func (f *RootFrame) Domain() context.Domain              { return f.domain }
func (f *RootFrame) Init(d context.Domain) {
	assert.For(f.domain == nil, 20)
	assert.For(d != nil, 21)
	f.domain = d
}

func (f *RootFrame) Handle(msg interface{}) {}