fix for potential race condition

xmidt-org · Aug 20, 2024 · d2b5ccc · d2b5ccc
1 parent d0ea5fd
commit d2b5ccc
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/pkg/tablemgr/routing_table_manager.go b/internal/pkg/tablemgr/routing_table_manager.go
@@ -217,7 +217,9 @@ func (r *DefaultRoutingTableManager) RemoveRoute(ctx context.Context, tid tenant
 }
 
 func (r *DefaultRoutingTableManager) RouteEvent(ctx context.Context, tid tenant.Id, routeId string, payload interface{}) (*event.Event, string, error) {
+	r.Lock()
 	lrw, ok := r.liveRouteMap[tid.KeyWithRoute(routeId)]
+	r.Unlock()
 	if !ok {
 		return nil, "", errors.New("no route " + routeId)
 	}