JJens Langhammerimprove race conditions
954f537f创建于 2022年10月4日历史提交
package instance

import "beryju.io/gravity/pkg/roles"

func (i *Instance) DispatchEvent(topic string, ev *roles.Event) {
	i.eventHandlersM.RLock()
	handlers, ok := i.eventHandlers[topic]
	i.eventHandlersM.RUnlock()
	if !ok {
		return
	}
	for _, handlers := range handlers {
		for _, handler := range handlers {
			handler(ev)
		}
	}
}