| -rw-r--r-- | internal/client/input/s3.go | 1 | ||||
| -rw-r--r-- | internal/client/output/s3.go | 13 | ||||
| -rw-r--r-- | main.go | 4 |
3 files changed, 8 insertions, 10 deletions
diff --git a/internal/client/input/s3.go b/internal/client/input/s3.go index 00684c2..4f84788 100644 --- a/internal/client/input/s3.go +++ b/internal/client/input/s3.go @@ -150,7 +150,6 @@ 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 f0527fb..9d54a5e 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,7 +163,6 @@ 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 @@ -165,11 +165,11 @@ func main() { var inputMetadata *input.MetadataStruct id := inputClient.ID(file) - cacheMapMutex.Lock() if _, ok := cacheMap[id]; !ok { + cacheMapMutex.Lock() cacheMap[id] = make(map[uint32]struct{}) + cacheMapMutex.Unlock() } - cacheMapMutex.Unlock() convertersToLaunch := []int{} for j, conv := range converters { |