diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-12-06 20:12:52 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-12-06 20:12:52 -0800 |
| commit | 9acda432fe65ad3b136f5ebff48c29de36c3f97c (patch) | |
| tree | cf49d8aadb6574effc067eb76d19e4a449ea6b4a /weed/pb/filer_pb/filer_pb_helper.go | |
| parent | ae5eb85a0692c46fb6a66818b3cc08bb26ed8cdb (diff) | |
| download | seaweedfs-9acda432fe65ad3b136f5ebff48c29de36c3f97c.tar.xz seaweedfs-9acda432fe65ad3b136f5ebff48c29de36c3f97c.zip | |
fix import cycle
Diffstat (limited to 'weed/pb/filer_pb/filer_pb_helper.go')
| -rw-r--r-- | weed/pb/filer_pb/filer_pb_helper.go | 23 |
1 files changed, 0 insertions, 23 deletions
diff --git a/weed/pb/filer_pb/filer_pb_helper.go b/weed/pb/filer_pb/filer_pb_helper.go index 76a8c973e..b46385c8f 100644 --- a/weed/pb/filer_pb/filer_pb_helper.go +++ b/weed/pb/filer_pb/filer_pb_helper.go @@ -1,13 +1,9 @@ package filer_pb import ( - "bytes" "context" "errors" "fmt" - "github.com/chrislusf/seaweedfs/weed/filer" - "github.com/chrislusf/seaweedfs/weed/wdclient" - "math" "strings" "github.com/chrislusf/seaweedfs/weed/glog" @@ -126,25 +122,6 @@ func LookupEntry(client SeaweedFilerClient, request *LookupDirectoryEntryRequest return resp, nil } -func ReadEntry(masterClient *wdclient.MasterClient, filerClient SeaweedFilerClient, dir, name string, byteBuffer *bytes.Buffer) error { - - request := &LookupDirectoryEntryRequest{ - Directory: filer.DirectoryEtc, - Name: filer.FilerConfName, - } - respLookupEntry, err := LookupEntry(filerClient, request) - if err != nil { - return err - } - if len(respLookupEntry.Entry.Content) > 0 { - _, err = byteBuffer.Write(respLookupEntry.Entry.Content) - return err - } - - return filer.StreamContent(masterClient, byteBuffer, respLookupEntry.Entry.Chunks, 0, math.MaxInt64) - -} - var ErrNotFound = errors.New("filer: no entry is found in filer store") func IsCreate(event *SubscribeMetadataResponse) bool { |
