diff options
| author | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-05-21 16:05:59 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <lebedev_k@tochka.com> | 2021-05-21 16:05:59 +0500 |
| commit | 3325b850ccf220f9a1f72909037100badf9b4a3b (patch) | |
| tree | 6d8265a05ace7cc692bf3a956ad7d2369f429b56 | |
| parent | 26a4f34a5794fd220dee3edf04564dfd04a01e20 (diff) | |
| download | seaweedfs-3325b850ccf220f9a1f72909037100badf9b4a3b.tar.xz seaweedfs-3325b850ccf220f9a1f72909037100badf9b4a3b.zip | |
rm func CheckAllChunkViews
| -rw-r--r-- | weed/filer/stream.go | 15 |
1 files changed, 0 insertions, 15 deletions
diff --git a/weed/filer/stream.go b/weed/filer/stream.go index 3fac0895e..70a278ca5 100644 --- a/weed/filer/stream.go +++ b/weed/filer/stream.go @@ -3,7 +3,6 @@ package filer import ( "bytes" "fmt" - "golang.org/x/sync/errgroup" "io" "math" "strings" @@ -59,20 +58,6 @@ func StreamContent(masterClient wdclient.HasLookupFileIdFunction, w io.Writer, c } -func CheckAllChunkViews(chunkViews []*ChunkView, fileId2Url *map[string][]string, gErr *errgroup.Group) { - for _, chunkView := range chunkViews { - urlStrings := (*fileId2Url)[chunkView.FileId] - glog.V(9).Infof("Check chunk: %+v\n url: %+v", chunkView, urlStrings) - if !chunkView.IsFullChunk() { - continue - } - gErr.Go(func() error { - _, err := retriedFetchChunkData(urlStrings, chunkView.CipherKey, chunkView.IsGzipped, false, 0, 2) - return err - }) - } -} - // ---------------- ReadAllReader ---------------------------------- func ReadAll(masterClient *wdclient.MasterClient, chunks []*filer_pb.FileChunk) ([]byte, error) { |