Skip to content

Commit c498c27

Browse files
committed
1. add some explain of func
1 parent 8d771a8 commit c498c27

File tree

3 files changed

+5
-1
lines changed

3 files changed

+5
-1
lines changed

database/persistence.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ func (server *Server) loadRdbFile() error {
2525
defer func() {
2626
_ = rdbFile.Close()
2727
}()
28-
decoder := rdb.NewDecoder(rdbFile)
28+
decoder := rdb.NewDecoder(rdbFile) // 创建一个新的RDB解码器
2929
err = server.LoadRDB(decoder)
3030
if err != nil {
3131
return fmt.Errorf("load rdb file failed " + err.Error())

database/server.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,12 +62,14 @@ func NewStandaloneServer() *Server {
6262
singleDB := makeDB()
6363
singleDB.index = i
6464
holder := &atomic.Value{}
65+
// set init value
6566
holder.Store(singleDB)
6667
server.dbSet[i] = holder
6768
}
6869
server.hub = pubsub.MakeHub()
6970
// record aof
7071
validAof := false
72+
// default value is false
7173
if config.Properties.AppendOnly {
7274
validAof = fileExists(config.Properties.AppendFilename)
7375
aofHandler, err := NewPersister(server,
@@ -77,6 +79,7 @@ func NewStandaloneServer() *Server {
7779
}
7880
server.bindPersister(aofHandler)
7981
}
82+
// dbfilename value is test.rdb
8083
if config.Properties.RDBFilename != "" && !validAof {
8184
// load rdb
8285
err := server.loadRdbFile()

redis/server/server.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ func (h *Handler) Handle(ctx context.Context, conn net.Conn) {
6060
return
6161
}
6262

63+
// reuse link object in sync.Pool
6364
client := connection.NewConn(conn)
6465
h.activeConn.Store(client, struct{}{})
6566

0 commit comments

Comments
 (0)