Skip to content

Commit 4d3b634

Browse files
committed
Remove Sleep & Add buffer limit
1 parent 1e376c8 commit 4d3b634

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

cloud/objstore/objutil/uploader.go

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@ import (
99
"sync"
1010
"sync/atomic"
1111

12-
"time"
1312
"github.com/couchbase/tools-common/cloud/v2/objstore/objcli"
1413
"github.com/couchbase/tools-common/cloud/v2/objstore/objcli/objaws"
1514
"github.com/couchbase/tools-common/cloud/v2/objstore/objval"
@@ -101,7 +100,8 @@ func NewMPUploader(opts MPUploaderOptions) (*MPUploader, error) {
101100
opts.defaults()
102101

103102
uploader := &MPUploader{
104-
opts: opts,
103+
opts: opts,
104+
number: 1,
105105
}
106106

107107
// Continue from where the last part was uploaded (if provided)
@@ -182,8 +182,6 @@ func (m *MPUploader) upload(ctx context.Context, number int, metadata any, body
182182
return fmt.Errorf("failed to upload part: %w", err)
183183
}
184184

185-
time.Sleep(30*time.Second)
186-
fmt.Println("Sleeping here")
187185
// Parts may be uploaded concurrently, but must be marked as completed one at a time
188186
m.lock.Lock()
189187
defer m.lock.Unlock()

0 commit comments

Comments
 (0)