修改redis recover模块

This commit is contained in:
shadow1ng 2021-03-18 16:25:31 +08:00
parent bb3222451c
commit e866d68f10
1 changed files with 14 additions and 2 deletions

View File

@ -298,18 +298,30 @@ func getconfig(conn net.Conn) (dbfilename string, dir string, err error) {
if err != nil {
return
}
dbfilename, err = readreply(conn)
text, err := readreply(conn)
if err != nil {
return
}
text1 := strings.Split(text, "\n")
if len(text1) > 2 {
dbfilename = text1[len(text1)-2]
} else {
dbfilename = text1[0]
}
_, err = conn.Write([]byte(fmt.Sprintf("CONFIG GET dir\r\n")))
if err != nil {
return
}
dir, err = readreply(conn)
text, err = readreply(conn)
if err != nil {
return
}
text1 = strings.Split(text, "\n")
if len(text1) > 2 {
dir = text1[len(text1)-2]
} else {
dir = text1[0]
}
return
}