mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2026-02-09 09:17:28 +08:00
Merge branch 'master' of https://github.com/chrislusf/seaweedfs
This commit is contained in:
@@ -85,6 +85,7 @@ func ResolveOneChunkManifest(lookupFileIdFn wdclient.LookupFileIdFunctionType, c
|
|||||||
|
|
||||||
// IsChunkManifest
|
// IsChunkManifest
|
||||||
bytesBuffer := bytesBufferPool.Get().(*bytes.Buffer)
|
bytesBuffer := bytesBufferPool.Get().(*bytes.Buffer)
|
||||||
|
bytesBuffer.Reset()
|
||||||
defer bytesBufferPool.Put(bytesBuffer)
|
defer bytesBufferPool.Put(bytesBuffer)
|
||||||
err := fetchWholeChunk(bytesBuffer, lookupFileIdFn, chunk.GetFileIdString(), chunk.CipherKey, chunk.IsCompressed)
|
err := fetchWholeChunk(bytesBuffer, lookupFileIdFn, chunk.GetFileIdString(), chunk.CipherKey, chunk.IsCompressed)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -130,8 +130,8 @@ func NewFilerServer(defaultMux, readonlyMux *http.ServeMux, option *FilerOption)
|
|||||||
go fs.filer.KeepMasterClientConnected()
|
go fs.filer.KeepMasterClientConnected()
|
||||||
|
|
||||||
if !util.LoadConfiguration("filer", false) {
|
if !util.LoadConfiguration("filer", false) {
|
||||||
v.Set("leveldb2.enabled", true)
|
v.SetDefault("leveldb2.enabled", true)
|
||||||
v.Set("leveldb2.dir", option.DefaultLevelDbDir)
|
v.SetDefault("leveldb2.dir", option.DefaultLevelDbDir)
|
||||||
_, err := os.Stat(option.DefaultLevelDbDir)
|
_, err := os.Stat(option.DefaultLevelDbDir)
|
||||||
if os.IsNotExist(err) {
|
if os.IsNotExist(err) {
|
||||||
os.MkdirAll(option.DefaultLevelDbDir, 0755)
|
os.MkdirAll(option.DefaultLevelDbDir, 0755)
|
||||||
|
|||||||
Reference in New Issue
Block a user