apps/redis-go
0
0
Fork 0
mirror of https://github.com/HDT3213/godis.git synced 2025-10-09 02:30:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

rename dump rdb

Browse Source
This commit is contained in:
finley
2022-11-05 21:18:58 +08:00
parent b93d74d5a7
commit 635c9dd740
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
database/rdb.go
View File

@@ -22,14 +22,14 @@ func loadRdbFile(mdb *MultiDB) {
_ = rdbFile.Close()
}()
decoder := rdb.NewDecoder(rdbFile)
err = dumpRDB(decoder, mdb)
err = importRDB(decoder, mdb)
if err != nil {
logger.Error("dump rdb file failed " + err.Error())
return
}
}
func dumpRDB(dec *core.Decoder, mdb *MultiDB) error {
func importRDB(dec *core.Decoder, mdb *MultiDB) error {
return dec.Parse(func(o rdb.RedisObject) bool {
db := mdb.mustSelectDB(o.GetDBIndex())
switch o.GetType() {

2
database/replication.go
View File

@@ -285,7 +285,7 @@ func (mdb *MultiDB) doPsync() error {
logger.Info(fmt.Sprintf("receive %d bytes of rdb from master", len(psyncData.Arg)))
rdbDec := rdb.NewDecoder(bytes.NewReader(psyncData.Arg))
rdbHolder := MakeBasicMultiDB()
err = dumpRDB(rdbDec, rdbHolder)
err = importRDB(rdbDec, rdbHolder)
if err != nil {
return errors.New("dump rdb failed: " + err.Error())
}