Skip to content

Commit 02c6a3b

Browse files
committed
fix: finalize was missing from the octx context
On-behalf-of: Gergely Brautigam <gergely.brautigam@sap.com> Signed-off-by: Gergely Brautigam <182850+Skarlso@users.noreply.github.com>
1 parent e32615a commit 02c6a3b

File tree

6 files changed

+15
-7
lines changed

6 files changed

+15
-7
lines changed

Dockerfile

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@ COPY main.go main.go
1414
COPY api/ api/
1515
COPY controllers/ controllers/
1616
COPY pkg/ pkg/
17-
COPY internal/ internal/
1817

1918
# Build
2019
RUN CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -a -o manager main.go

controllers/componentversion_controller.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -166,6 +166,9 @@ func (r *ComponentVersionReconciler) Reconcile(ctx context.Context, req ctrl.Req
166166

167167
return ctrl.Result{}, nil
168168
}
169+
defer func() {
170+
_ = octx.Finalize()
171+
}()
169172

170173
// reconcile the version before calling reconcile func
171174
update, version, err := r.checkVersion(ctx, octx, obj)

controllers/mutation_reconcile_looper.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -307,6 +307,9 @@ func (m *MutationReconcileLooper) fetchDataFromComponentVersion(ctx context.Cont
307307
if err != nil {
308308
return nil, fmt.Errorf("failed to create authenticated client: %w", err)
309309
}
310+
defer func() {
311+
_ = octx.Finalize()
312+
}()
310313

311314
if obj.ResourceRef == nil {
312315
return nil, fmt.Errorf("no resource ref found for %s", key)
@@ -375,6 +378,9 @@ func (m *MutationReconcileLooper) createSubstitutionRulesForLocalization(
375378
if err != nil {
376379
return nil, fmt.Errorf("failed to create authenticated client: %w", err)
377380
}
381+
defer func() {
382+
_ = octx.Finalize()
383+
}()
378384

379385
compvers, err := m.OCMClient.GetComponentVersion(ctx, octx, cv.GetRepositoryURL(), cv.Spec.Component, cv.Status.ReconciledVersion)
380386
if err != nil {

controllers/resource_controller.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -194,6 +194,9 @@ func (r *ResourceReconciler) reconcile(
194194

195195
return ctrl.Result{}, nil
196196
}
197+
defer func() {
198+
_ = octx.Finalize()
199+
}()
197200

198201
reader, digest, size, err := r.OCMClient.GetResource(ctx, octx, componentVersion, obj.Spec.SourceRef.ResourceRef)
199202
if err != nil {

main.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,6 @@ func main() {
154154
}
155155

156156
ctx := ctrl.SetupSignalHandler()
157-
158157
setupLog.Info("starting manager")
159158
if err := mgr.Start(ctx); err != nil {
160159
setupLog.Error(err, "problem running manager")

pkg/snapshot/tar.go

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -72,17 +72,15 @@ func buildTar(artifactPath, sourceDir string) error {
7272
}
7373
f, err := os.Open(p)
7474
if err != nil {
75-
f.Close()
76-
7775
return err
7876
}
79-
if _, err := io.Copy(tw, f); err != nil {
80-
f.Close()
77+
defer f.Close()
8178

79+
if _, err := io.Copy(tw, f); err != nil {
8280
return err
8381
}
8482

85-
return f.Close()
83+
return nil
8684
}); err != nil {
8785
tw.Close()
8886
tf.Close()

0 commit comments

Comments
 (0)