fix: lock the cache map mutex before checking itmain

feat: disable log output checksum validation skipped spam

2 files changed, 8 insertions, 6 deletions

diff --git a/internal/client/input/s3.go b/internal/client/input/s3.go
index 4f84788..00684c2 100644
--- a/internal/client/input/s3.go
+++ b/internal/client/input/s3.go
@@ -150,6 +150,7 @@ func newS3Client(cfg *config.S3Config) (*s3.Client, error) {
 	}
 	s3Opts = append(s3Opts, func(o *s3.Options) {
 		o.UsePathStyle = cfg.UsePathStyle
+		o.DisableLogOutputChecksumValidationSkipped = true
 	})
 
 	return s3.NewFromConfig(awsCfg, s3Opts...), nil
diff --git a/internal/client/output/s3.go b/internal/client/output/s3.go
index 9d54a5e..f0527fb 100644
--- a/internal/client/output/s3.go
+++ b/internal/client/output/s3.go
@@ -48,12 +48,12 @@ func (c *S3OutputClient) GetWriter(path string, inputMetadata *input.MetadataStr
 	key := c.prefix + path
 
 	return &s3WriteCloser{
-		key:               key,
-		bucketName:        c.bucketName,
-		s3cl:              c.s3cl,
-		contentType:       outputContentType,
-		hashOriginal:      inputMetadata.Hash,
-		buf:               &bytes.Buffer{},
+		key:          key,
+		bucketName:   c.bucketName,
+		s3cl:         c.s3cl,
+		contentType:  outputContentType,
+		hashOriginal: inputMetadata.Hash,
+		buf:          &bytes.Buffer{},
 	}, nil
 }
 
@@ -163,6 +163,7 @@ func newS3Client(cfg *config.S3Config) (*s3.Client, error) {
 	}
 	s3Opts = append(s3Opts, func(o *s3.Options) {
 		o.UsePathStyle = cfg.UsePathStyle
+		o.DisableLogOutputChecksumValidationSkipped = true
 	})
 
 	return s3.NewFromConfig(awsCfg, s3Opts...), nil