diff --git a/chunk.go b/chunk.go index 2d097a8..261d3ac 100644 --- a/chunk.go +++ b/chunk.go @@ -42,6 +42,8 @@ func (cc *commPCallback) OnSuccess(buf *Buffer, graphName, payloadCid, fsDetail carFilePath := filepath.Join(cc.carDir, cpRes.Root.String()) carFileNameWithSuffix := carFilePath + ".car" + log.Infof("start write car to tile") + writeStart := time.Now() carFile, err := os.OpenFile(carFileNameWithSuffix, os.O_RDWR|os.O_CREATE, 0o644) if err != nil { log.Fatalf("failed to create car file: %s", err) @@ -52,6 +54,7 @@ func (cc *commPCallback) OnSuccess(buf *Buffer, graphName, payloadCid, fsDetail } buf.Reset() carFile.Close() + log.Infof("end write car to file: %v", time.Since(writeStart)) if cc.rename { if err := os.Rename(carFileNameWithSuffix, carFilePath); err != nil { diff --git a/utils.go b/utils.go index 6508579..6d0ef57 100644 --- a/utils.go +++ b/utils.go @@ -143,6 +143,10 @@ func BuildIpldGraph(ctx context.Context, graphName string, params *ChunkParams, ) { + start := time.Now() + defer func() { + log.Infof("BuildIpldGraph took: %v", time.Since(start)) + }() buf, payloadCid, fsDetail, err := buildIpldGraph(ctx, fileList, params.ParentPath, params.Parallel, params.ExpectSliceSize, params.Ef, params.SkipFilename) if err != nil {