Method cacheAndReturn

roomserver/internal/input/input_missing.go:366–374

(ev *gomatrixserverlib.Event)

}

func (t *missingStateReq) cacheAndReturn(ev *gomatrixserverlib.Event) *gomatrixserverlib.Event {
	t.haveEventsMutex.Lock()
	defer t.haveEventsMutex.Unlock()
	if cached, exists := t.haveEvents[ev.EventID()]; exists {
		return cached
	}
	t.haveEvents[ev.EventID()] = ev
	return ev
}

func (t *missingStateReq) lookupStateAfterEventLocally(ctx context.Context, roomID, eventID string) *parsedRespState {
	span, ctx := opentracing.StartSpanFromContext(ctx, "lookupStateAfterEventLocally")