Method LockContainer

pkg/funclet/container.go:44–62

(id string, event api.Event, ctx *funcletCtx.Context)

}

func (m *ContainerManager) LockContainer(id string, event api.Event, ctx *funcletCtx.Context) (res bool, err error) {
	info, err := m.ContainerMap.GetContainer(id)
	if err != nil {
		ctx.Logger.Errorf("get container %s status err %s", id, err)
		return
	}
	res = info.EventLock.Lock()
	if res {
		ctx.Logger.V(9).Infof("get lock success, container %s event %s", id, event)
		info.CurrentEvent = event
	} else {
		err = &ContainerIsBusy{
			ID:           id,
			CurrentEvent: info.CurrentEvent,
			TriggerEvent: event,
		}
	}
	return
}

func (m *ContainerManager) UnLockContainer(id string, ctx *funcletCtx.Context) (err error) {
	info, err := m.ContainerMap.GetContainer(id)