fix: add lock

search-elasticsearch/es.go

@@ -26,6 +26,7 @@ import (
 	"fmt"
 	"github.com/apache/incubator-answer-plugins/util"
 	"strings"
+	"sync"
 
 	"github.com/apache/incubator-answer-plugins/search-elasticsearch/i18n"
 	"github.com/apache/incubator-answer/plugin"
@@ -40,6 +41,8 @@ type SearchEngine struct {
 	Config   *SearchEngineConfig
 	Operator *Operator
 	syncer   plugin.SearchSyncer
+	syncing  bool
+	lock     sync.Mutex
 }
 
 type SearchEngineConfig struct {
@@ -51,6 +54,7 @@ type SearchEngineConfig struct {
 func init() {
 	plugin.Register(&SearchEngine{
 		Config: &SearchEngineConfig{},
+		lock:   sync.Mutex{},
 	})
 }
 

search-elasticsearch/sync.go

@@ -27,7 +27,20 @@ import (
 
 func (s *SearchEngine) sync() {
 	var page, pageSize = 1, 100
+	if s.syncing {
+		log.Warnf("es: syncing is running, skip")
+		return
+	}
+
 	go func() {
+		s.lock.Lock()
+		defer s.lock.Unlock()
+		if s.syncing {
+			log.Warnf("es: syncing is running, skip")
+			return
+		}
+
+		s.syncing = true
 		log.Info("es: start sync questions...")
 		page = 1
 		for {
@@ -68,6 +81,7 @@ func (s *SearchEngine) sync() {
 
 			page += 1
 		}
+		s.syncing = false
 		log.Info("es: sync done")
 	}()
 }