github/kubevela
1
0
Fork 0
mirror of https://github.com/kubevela/kubevela.git synced 2026-08-20 13:06:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix: concurrent write to controller revision (#3520)

Browse Source 
Signed-off-by: Somefive <yd219913@alibaba-inc.com>
This commit is contained in:
Somefive
2022-03-27 19:56:25 +08:00
committed by GitHub
parent c2f5175fd1
commit 9fc992ea3e
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/resourcekeeper/componentrevision.go
+4
View File
@@ -31,6 +31,8 @@ import (
// DispatchComponentRevision create component revision (also add record in resourcetracker)
func (h *resourceKeeper) DispatchComponentRevision(ctx context.Context, cr *v1.ControllerRevision) error {
h.mu.Lock()
defer h.mu.Unlock()
rt, err := h.getComponentRevisionRT(ctx)
if err != nil {
return errors.Wrapf(err, "failed to get resourcetracker")
@@ -50,6 +52,8 @@ func (h *resourceKeeper) DispatchComponentRevision(ctx context.Context, cr *v1.C
// DeleteComponentRevision delete component revision (also remove record in resourcetracker)
func (h *resourceKeeper) DeleteComponentRevision(ctx context.Context, cr *v1.ControllerRevision) error {
h.mu.Lock()
defer h.mu.Unlock()
rt, err := h.getComponentRevisionRT(ctx)
if err != nil {
return errors.Wrapf(err, "failed to get resourcetracker")