TheArchive/restic
1
0
Fork 0
mirror of https://github.com/restic/restic.git synced 2025-05-07 20:16:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

s3: Reorder debug messages

Browse Source 
This way the semaphore token acquisition can be observed in the debug
log.
This commit is contained in:
Alexander Neumann 2017-06-11 14:30:56 +02:00
parent 907c201693
commit 73b296918b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/restic/backend/s3/s3.go
View File

@ -174,8 +174,8 @@ func (be *Backend) Save(ctx context.Context, h restic.Handle, rd io.Reader) (err
return errors.New("key already exists") return errors.New("key already exists")
} }
debug.Log("PutObject(%v, %v)", be.bucketname, objName)
be.sem.GetToken() be.sem.GetToken()
debug.Log("PutObject(%v, %v)", be.bucketname, objName)
n, err := be.client.PutObject(be.bucketname, objName, rd, "application/octet-stream") n, err := be.client.PutObject(be.bucketname, objName, rd, "application/octet-stream")
be.sem.ReleaseToken() be.sem.ReleaseToken()
@ -215,14 +215,14 @@ func (be *Backend) Load(ctx context.Context, h restic.Handle, length int, offset
objName := be.Filename(h) objName := be.Filename(h)
be.sem.GetToken()
byteRange := fmt.Sprintf("bytes=%d-", offset) byteRange := fmt.Sprintf("bytes=%d-", offset)
if length > 0 { if length > 0 {
byteRange = fmt.Sprintf("bytes=%d-%d", offset, offset+int64(length)-1) byteRange = fmt.Sprintf("bytes=%d-%d", offset, offset+int64(length)-1)
} }
headers := minio.NewGetReqHeaders() headers := minio.NewGetReqHeaders()
headers.Add("Range", byteRange) headers.Add("Range", byteRange)
be.sem.GetToken()
debug.Log("Load(%v) send range %v", h, byteRange) debug.Log("Load(%v) send range %v", h, byteRange)
coreClient := minio.Core{Client: be.client} coreClient := minio.Core{Client: be.client}