perf: optimize listpack insert perf

README.md

@@ -79,9 +79,14 @@ Ensure your local Go environment is >= `1.22`. In the project directory, run `go
 
 ```
 $ go run .
-2024-07-18 23:37:13 INF current version buildTime=240718_233649+0800
-2024-07-18 23:37:13 INF read cmd arguments config=/etc/rotom/config.json debug=false
-2024-07-18 23:37:13 INF running on port=6379
+2024-07-18 23:37:13 DBG 
+ ________      _____                  
+ ___  __ \_______  /_____________ ___   Rotom 64 bit (amd64/linux)
+ __  /_/ /  __ \  __/  __ \_  __ '__ \  Port: 6379, Pid: 15817
+ _  _, _// /_/ / /_ / /_/ /  / / / / /  Build: 
+ /_/ |_| \____/\__/ \____//_/ /_/ /_/
+
+2024-07-18 23:37:13 INF read config file config=config.json
 2024-07-18 23:37:13 INF rotom server is ready to accept.
 ```
 

README_CN.md

@@ -79,9 +79,14 @@ git clone https://github.com/xgzlucario/rotom
 
 ```
 $ go run .
-2024-07-18 23:37:13 INF current version buildTime=240718_233649+0800
-2024-07-18 23:37:13 INF read cmd arguments config=/etc/rotom/config.json debug=false
-2024-07-18 23:37:13 INF running on port=6379
+2024-07-18 23:37:13 DBG 
+ ________      _____                  
+ ___  __ \_______  /_____________ ___   Rotom 64 bit (amd64/linux)
+ __  /_/ /  __ \  __/  __ \_  __ '__ \  Port: 6379, Pid: 15817
+ _  _, _// /_/ / /_ / /_/ /  / / / / /  Build: 
+ /_/ |_| \____/\__/ \____//_/ /_/ /_/
+
+2024-07-18 23:37:13 INF read config file config=config.json
 2024-07-18 23:37:13 INF rotom server is ready to accept.
 ```
 

command_test.go

@@ -21,6 +21,7 @@ func startup() {
 	}
 	os.Remove(config.AppendFileName)
 	config4Server(config)
+	printBanner(config)
 	server.aeLoop.AddRead(server.fd, AcceptHandler, nil)
 	server.aeLoop.AddTimeEvent(AE_NORMAL, 500, CheckOutOfMemory, nil)
 	server.aeLoop.AddTimeEvent(AE_NORMAL, 1000, SysMonitor, nil)

internal/list/listpack.go

@@ -142,6 +142,15 @@ func (it *LpIterator) Prev() []byte {
 }
 
 func (it *LpIterator) Insert(datas ...string) {
+	// fast insert to tail
+	if it.IsLast() {
+		for _, data := range datas {
+			it.data = appendEntry(it.data, data)
+			it.size++
+		}
+		return
+	}
+
 	var alloc []byte
 	for _, data := range datas {
 		alloc = appendEntry(alloc, data)
@@ -186,7 +195,8 @@ func (it *LpIterator) ReplaceNext(key string) {
 
 func appendEntry(dst []byte, data string) []byte {
 	if dst == nil {
-		dst = bpool.Get(len(data) + 10)[:0]
+		sz := len(data) + 2*SizeUvarint(uint64(len(data)))
+		dst = bpool.Get(sz)[:0]
 	}
 	before := len(dst)
 	dst = appendUvarint(dst, len(data), false)

main.go

@@ -5,6 +5,8 @@ import (
 	"net/http"
 	_ "net/http/pprof"
 	"os"
+	"runtime"
+	"strconv"
 	"time"
 
 	"github.com/rs/zerolog"
@@ -33,6 +35,19 @@ func config4Server(config *Config) {
 	}
 }
 
+func printBanner(config *Config) {
+	log.Printf(`
+	________      _____                  
+	___  __ \_______  /_____________ ___   Rotom %d bit (%s/%s)
+	__  /_/ /  __ \  __/  __ \_  __ '__ \  Port: %d, Pid: %d
+	_  _, _// /_/ / /_ / /_/ /  / / / / /  Build: %s
+	/_/ |_| \____/\__/ \____//_/ /_/ /_/
+	   `,
+		strconv.IntSize, runtime.GOARCH, runtime.GOOS,
+		config.Port, os.Getpid(),
+		buildTime)
+}
+
 func main() {
 	var path string
 	var debug bool
@@ -41,19 +56,19 @@ func main() {
 	flag.BoolVar(&debug, "debug", false, "run with debug mode.")
 	flag.Parse()
 
-	log.Info().Str("buildTime", buildTime).Msg("current version")
-	log.Info().Str("config", path).Bool("debug", debug).Msg("read cmd arguments")
-
 	config, err := LoadConfig(path)
 	if err != nil {
 		log.Fatal().Msgf("load config error: %v", err)
 	}
-	config4Server(config)
+	printBanner(config)
+
 	if debug {
 		go http.ListenAndServe(":6060", nil)
 	}
 
-	log.Info().Int("port", config.Port).Msg("running on")
+	log.Info().Str("config", path).Msg("read config file")
+	config4Server(config)
+
 	log.Info().Msg("rotom server is ready to accept.")
 
 	// register main aeLoop event