kern/v4/lev2/kbus_local/kbus_local.go

// package kbus_local -- реализация локальной шины сообщений.
package kbus_local

import (
	"sync"

	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kbus_base"
)

// Локальная шина данных.
type kernelBusLocal struct {
	*kbus_base.KBusBase
}

var (
	bus   *kernelBusLocal
	block sync.Mutex
)

// GetKernelBusLocal -- возвращает локальную шину сообщений.
func GetKernelBusLocal() *kernelBusLocal {
	block.Lock()
	defer block.Unlock()
	if bus != nil {
		return bus
	}
	bus = &kernelBusLocal{
		KBusBase: kbus_base.GetKernelBusBase(),
	}
	return bus
}