a liitle change

cmd/ledis-server/main.go

@@ -9,7 +9,7 @@ import (
 	"syscall"
 )
 
-var configFile = flag.String("config", "", "ledisdb config file")
+var configFile = flag.String("config", "/etc/ledis.json", "ledisdb config file")
 
 func main() {
 	runtime.GOMAXPROCS(runtime.NumCPU())

ledis/replication.go

@@ -123,7 +123,9 @@ func (l *Ledis) ReplicateFromBinLog(filePath string) error {
 
 	rb := bufio.NewReaderSize(f, 4096)
 
+	l.Lock()
 	err = l.ReplicateFromReader(rb)
+	l.Unlock()
 
 	f.Close()
 

server/app.go

@@ -90,3 +90,7 @@ func (app *App) Run() {
 		newClient(conn, app)
 	}
 }
+
+func (app *App) Ledis() *ledis.DB {
+	return app.ldb
+}