diff --git a/changelog/unreleased/no-need-to-unmark-postprocessing-when-it-was-not-started.md b/changelog/unreleased/no-need-to-unmark-postprocessing-when-it-was-not-started.md new file mode 100644 index 0000000000..1f416ffa76 --- /dev/null +++ b/changelog/unreleased/no-need-to-unmark-postprocessing-when-it-was-not-started.md @@ -0,0 +1,3 @@ +Bugfix: no need to unmark postprocessing when it was not started + +https://github.com/cs3org/reva/pull/4476 diff --git a/pkg/storage/utils/decomposedfs/upload/session.go b/pkg/storage/utils/decomposedfs/upload/session.go index c6fed249e7..f438d684f9 100644 --- a/pkg/storage/utils/decomposedfs/upload/session.go +++ b/pkg/storage/utils/decomposedfs/upload/session.go @@ -295,7 +295,7 @@ func (s *OcisSession) MTime() time.Time { return t } -// IsProcessing returns true if all bytes have been received. The node then has entered postprocessing state. +// IsProcessing returns true if all bytes have been received. The session then has entered postprocessing state. func (s *OcisSession) IsProcessing() bool { return s.info.Size == s.info.Offset } diff --git a/pkg/storage/utils/decomposedfs/upload/upload.go b/pkg/storage/utils/decomposedfs/upload/upload.go index 64c3cb047c..2f2713b454 100644 --- a/pkg/storage/utils/decomposedfs/upload/upload.go +++ b/pkg/storage/utils/decomposedfs/upload/upload.go @@ -191,7 +191,7 @@ func (session *OcisSession) FinishUpload(ctx context.Context) error { n, err := session.store.CreateNodeForUpload(session, attrs) if err != nil { - session.store.Cleanup(ctx, session, true, false, true) + session.store.Cleanup(ctx, session, true, false, false) return err }