|
|
@ -3,7 +3,6 @@ package filer |
|
|
|
import ( |
|
|
|
"bytes" |
|
|
|
"fmt" |
|
|
|
"github.com/chrislusf/seaweedfs/weed/wdclient" |
|
|
|
"io" |
|
|
|
"math" |
|
|
|
"net/url" |
|
|
@ -11,6 +10,8 @@ import ( |
|
|
|
"sync" |
|
|
|
"time" |
|
|
|
|
|
|
|
"github.com/chrislusf/seaweedfs/weed/wdclient" |
|
|
|
|
|
|
|
"github.com/golang/protobuf/proto" |
|
|
|
|
|
|
|
"github.com/chrislusf/seaweedfs/weed/glog" |
|
|
@ -63,14 +64,14 @@ func ResolveChunkManifest(lookupFileIdFn wdclient.LookupFileIdFunctionType, chun |
|
|
|
|
|
|
|
resolvedChunks, err := ResolveOneChunkManifest(lookupFileIdFn, chunk) |
|
|
|
if err != nil { |
|
|
|
return chunks, nil, err |
|
|
|
return dataChunks, nil, err |
|
|
|
} |
|
|
|
|
|
|
|
manifestChunks = append(manifestChunks, chunk) |
|
|
|
// recursive
|
|
|
|
subDataChunks, subManifestChunks, subErr := ResolveChunkManifest(lookupFileIdFn, resolvedChunks, startOffset, stopOffset) |
|
|
|
if subErr != nil { |
|
|
|
return chunks, nil, subErr |
|
|
|
return dataChunks, nil, subErr |
|
|
|
} |
|
|
|
dataChunks = append(dataChunks, subDataChunks...) |
|
|
|
manifestChunks = append(manifestChunks, subManifestChunks...) |
|
|
|