@@ -201,8 +201,6 @@ func (pc *PyramidChunker) decrementWorkerCount() {
201
201
}
202
202
203
203
func (pc * PyramidChunker ) Split (ctx context.Context ) (k Address , wait func (context.Context ) error , err error ) {
204
- log .Debug ("pyramid.chunker: Split()" )
205
-
206
204
pc .wg .Add (1 )
207
205
pc .prepareChunks (ctx , false )
208
206
@@ -235,7 +233,6 @@ func (pc *PyramidChunker) Split(ctx context.Context) (k Address, wait func(conte
235
233
}
236
234
237
235
func (pc * PyramidChunker ) Append (ctx context.Context ) (k Address , wait func (context.Context ) error , err error ) {
238
- log .Debug ("pyramid.chunker: Append()" )
239
236
// Load the right most unfinished tree chunks in every level
240
237
pc .loadTree (ctx )
241
238
@@ -283,8 +280,6 @@ func (pc *PyramidChunker) processor(ctx context.Context, id int64) {
283
280
}
284
281
285
282
func (pc * PyramidChunker ) processChunk (ctx context.Context , id int64 , job * chunkJob ) {
286
- log .Debug ("pyramid.chunker: processChunk()" , "id" , id )
287
-
288
283
ref , err := pc .putter .Put (ctx , job .chunk )
289
284
if err != nil {
290
285
select {
@@ -301,7 +296,6 @@ func (pc *PyramidChunker) processChunk(ctx context.Context, id int64, job *chunk
301
296
}
302
297
303
298
func (pc * PyramidChunker ) loadTree (ctx context.Context ) error {
304
- log .Debug ("pyramid.chunker: loadTree()" )
305
299
// Get the root chunk to get the total size
306
300
chunkData , err := pc .getter .Get (ctx , Reference (pc .key ))
307
301
if err != nil {
@@ -386,7 +380,6 @@ func (pc *PyramidChunker) loadTree(ctx context.Context) error {
386
380
}
387
381
388
382
func (pc * PyramidChunker ) prepareChunks (ctx context.Context , isAppend bool ) {
389
- log .Debug ("pyramid.chunker: prepareChunks" , "isAppend" , isAppend )
390
383
defer pc .wg .Done ()
391
384
392
385
chunkWG := & sync.WaitGroup {}
0 commit comments