diff options
| author | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-05-24 12:08:12 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-05-24 12:08:12 +0500 |
| commit | bb4263352251fb7ad02cfeb7f340b5b961d0d55a (patch) | |
| tree | c445f5f6cbd522467c002c268251c8bc6e402097 | |
| parent | 3325b850ccf220f9a1f72909037100badf9b4a3b (diff) | |
| download | seaweedfs-bb4263352251fb7ad02cfeb7f340b5b961d0d55a.tar.xz seaweedfs-bb4263352251fb7ad02cfeb7f340b5b961d0d55a.zip | |
rm chunk Download stats
| -rw-r--r-- | weed/filer/stream.go | 14 |
1 files changed, 3 insertions, 11 deletions
diff --git a/weed/filer/stream.go b/weed/filer/stream.go index 70a278ca5..880cb100e 100644 --- a/weed/filer/stream.go +++ b/weed/filer/stream.go @@ -3,16 +3,13 @@ package filer import ( "bytes" "fmt" - "io" - "math" - "strings" - "time" - "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" - "github.com/chrislusf/seaweedfs/weed/stats" "github.com/chrislusf/seaweedfs/weed/util" "github.com/chrislusf/seaweedfs/weed/wdclient" + "io" + "math" + "strings" ) func StreamContent(masterClient wdclient.HasLookupFileIdFunction, w io.Writer, chunks []*filer_pb.FileChunk, offset int64, size int64) error { @@ -38,20 +35,15 @@ func StreamContent(masterClient wdclient.HasLookupFileIdFunction, w io.Writer, c for _, chunkView := range chunkViews { urlStrings := fileId2Url[chunkView.FileId] - start := time.Now() data, err := retriedFetchChunkData(urlStrings, chunkView.CipherKey, chunkView.IsGzipped, chunkView.IsFullChunk(), chunkView.Offset, int(chunkView.Size)) - stats.FilerRequestHistogram.WithLabelValues("chunkDownload").Observe(time.Since(start).Seconds()) if err != nil { - stats.FilerRequestCounter.WithLabelValues("chunkDownloadError").Inc() return fmt.Errorf("read chunk: %v", err) } _, err = w.Write(data) if err != nil { - stats.FilerRequestCounter.WithLabelValues("chunkDownloadedError").Inc() return fmt.Errorf("write chunk: %v", err) } - stats.FilerRequestCounter.WithLabelValues("chunkDownload").Inc() } return nil |