removed all timings

code/go/0chain.net/blobbercore/allocation/file_changer_base.go

@@ -2,12 +2,9 @@ package allocation
 
 import (
 	"context"
-	"time"
 
 	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/filestore"
 	"github.com/0chain/blobber/code/go/0chain.net/core/common"
-	"github.com/0chain/blobber/code/go/0chain.net/core/logging"
-	"go.uber.org/zap"
 )
 
 // BaseFileChanger base file change processor
@@ -95,12 +92,9 @@ func (fc *BaseFileChanger) CommitToFileStore(ctx context.Context) error {
 	fileInputData.ValidationRoot = fc.ValidationRoot
 	fileInputData.FixedMerkleRoot = fc.FixedMerkleRoot
 	fileInputData.ChunkSize = fc.ChunkSize
-	start := time.Now()
 	_, err := filestore.GetFileStore().CommitWrite(fc.AllocationID, fc.ConnectionID, fileInputData)
 	if err != nil {
 		return common.NewError("file_store_error", "Error committing to file store. "+err.Error())
 	}
-	elapsed := time.Since(start)
-	logging.Logger.Info("CommitToFileStore", zap.String("path", fc.Path), zap.Duration("elapsed", elapsed))
 	return nil
 }

code/go/0chain.net/blobbercore/filestore/storage.go

@@ -40,7 +40,6 @@ import (
 	"strings"
 	"sync"
 	"syscall"
-	"time"
 
 	"github.com/0chain/blobber/code/go/0chain.net/core/common"
 	"github.com/0chain/blobber/code/go/0chain.net/core/encryption"
@@ -244,7 +243,6 @@ func (fs *FileStore) CommitWrite(allocID, conID string, fileData *FileInputData)
 	}
 
 	fileSize := rStat.Size()
-	start := time.Now()
 	hasher := GetNewCommitHasher(fileSize)
 	bufSize := BufferSize
 	if fileSize < BufferSize {
@@ -260,18 +258,15 @@ func (fs *FileStore) CommitWrite(allocID, conID string, fileData *FileInputData)
 	if err != nil {
 		return false, common.NewError("finalize_error", err.Error())
 	}
-	elapsedHash := time.Since(start)
 	fmtRootBytes, err := hasher.fmt.CalculateRootAndStoreNodes(f)
 	if err != nil {
 		return false, common.NewError("fmt_hash_calculation_error", err.Error())
 	}
-	elapsedMerkle := time.Since(start) - elapsedHash
 
 	validationRootBytes, err := hasher.vt.CalculateRootAndStoreNodes(f)
 	if err != nil {
 		return false, common.NewError("validation_hash_calculation_error", err.Error())
 	}
-	elapsedValidation := time.Since(start) - elapsedMerkle - elapsedHash
 	fmtRoot := hex.EncodeToString(fmtRootBytes)
 	validationRoot := hex.EncodeToString(validationRootBytes)
 
@@ -305,7 +300,6 @@ func (fs *FileStore) CommitWrite(allocID, conID string, fileData *FileInputData)
 	// 5. Move: It is Copy + Delete. Delete will not delete file if ref exists in database. i.e. copy would create
 	// ref that refers to this file therefore it will be skipped
 	fs.incrDecrAllocFileSizeAndNumber(allocID, fileSize, 1)
-	logging.Logger.Info("CommitWrite", zap.Duration("elapsedHash", elapsedHash), zap.Duration("elapsedMerkle", elapsedMerkle), zap.Duration("elapsedValidation", elapsedValidation), zap.Duration("elapsedTotal", time.Since(start)))
 	return true, nil
 }
 

code/go/0chain.net/blobbercore/handler/file_command_upload.go

@@ -6,7 +6,6 @@ import (
 	"fmt"
 	"net/http"
 	"path/filepath"
-	"time"
 
 	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/reference"
 
@@ -46,21 +45,18 @@ func (cmd *UploadFileCommand) GetPath() string {
 
 // IsValidated validate request.
 func (cmd *UploadFileCommand) IsValidated(ctx context.Context, req *http.Request, allocationObj *allocation.Allocation, clientID string) error {
-	start := time.Now()
 	if allocationObj.OwnerID != clientID && allocationObj.RepairerID != clientID {
 		return common.NewError("invalid_operation", "Operation needs to be performed by the owner or the payer of the allocation")
 	}
 
 	fileChanger := &allocation.UploadFileChanger{}
 
 	uploadMetaString := req.FormValue(UploadMeta)
-	elapsedReadForm := time.Since(start)
 	err := json.Unmarshal([]byte(uploadMetaString), fileChanger)
 	if err != nil {
 		return common.NewError("invalid_parameters",
 			"Invalid parameters. Error parsing the meta data for upload."+err.Error())
 	}
-	elapsedUnmarshal := time.Since(start) - elapsedReadForm
 
 	if fileChanger.Path == "/" {
 		return common.NewError("invalid_path", "Invalid path. Cannot upload to root directory")
@@ -76,7 +72,7 @@ func (cmd *UploadFileCommand) IsValidated(ctx context.Context, req *http.Request
 		logging.Logger.Error(err.Error())
 		return common.NewError("database_error", "Got db error while getting ref")
 	}
-	elapsedRefExist := time.Since(start) - elapsedUnmarshal - elapsedReadForm
+
 	if isExist {
 		msg := fmt.Sprintf("File at path :%s: already exists", fileChanger.Path)
 		return common.NewError("duplicate_file", msg)
@@ -100,7 +96,6 @@ func (cmd *UploadFileCommand) IsValidated(ctx context.Context, req *http.Request
 	}
 
 	cmd.fileChanger = fileChanger
-	logging.Logger.Info("isValidated", zap.Duration("elapsedReamForm", elapsedReadForm), zap.Duration("elapsedUnmarshal", elapsedUnmarshal), zap.Duration("elapsedRefExist", elapsedRefExist), zap.Duration("elapsed", time.Since(start)))
 	return nil
 }