Feature db opt (#174)

* db * db * db Co-authored-by: charizer <>
finogeeks · Sep 1, 2021 · 16b86ea · 16b86ea
1 parent 8d5e6a9
commit 16b86ea
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 5 deletions.
diff --git a/syncserver/api/lruInfo.go b/syncserver/api/lruInfo.go
@@ -121,7 +121,7 @@ func (ReqPutLRURoom) Process(consumer interface{}, msg core.Coder, device *autht
 	}
 
 	c.rmHsTimeline.LoadHistory(req.RoomID, false)
-	//c.rmHsTimeline.LoadDomainMaxStream(req.RoomID)
+	c.rmHsTimeline.LoadDomainMaxStream(req.RoomID)
 	c.rmHsTimeline.LoadRoomMinStream(req.RoomID)
 	c.rsTimeline.LoadStreamStates(req.RoomID, false)
 	c.rsTimeline.LoadStates(req.RoomID, false)

diff --git a/syncserver/syncserver.go b/syncserver/syncserver.go
@@ -82,7 +82,7 @@ func SetupSyncServerComponent(
 	roomHistory.SetMonitor(qureyHitCounter)
 	roomHistory.SetCache(cacheIn)
 	roomHistory.SetCfg(base.Cfg)
-	roomHistory.LoadAllDomainMaxStream(context.Background())
+	//roomHistory.LoadAllDomainMaxStream(context.Background())
 	rsCurState.SetPersist(syncDB)
 
 	rsTimeline.SetPersist(syncDB)

diff --git a/syncwriter/api/lruInfo.go b/syncwriter/api/lruInfo.go
@@ -121,7 +121,7 @@ func (ReqPutLRURoom) Process(consumer interface{}, msg core.Coder, device *autht
 	}
 
 	c.rmHsTimeline.LoadHistory(req.RoomID, false)
-	//c.rmHsTimeline.LoadDomainMaxStream(req.RoomID)
+	c.rmHsTimeline.LoadDomainMaxStream(req.RoomID)
 	c.rsTimeline.LoadStreamStates(req.RoomID, false)
 
 	return http.StatusOK, &external.PutLRURoomResponse{

diff --git a/syncwriter/syncwriter.go b/syncwriter/syncwriter.go
@@ -15,7 +15,6 @@
 package syncwriter
 
 import (
-	"context"
 	"github.com/finogeeks/ligase/common/basecomponent"
 	"github.com/finogeeks/ligase/model/repos"
 	rpcService "github.com/finogeeks/ligase/rpc"
@@ -45,7 +44,7 @@ func SetupSyncWriterComponent(
 	roomHistory.SetRoomPersist(roomDB)
 	roomHistory.SetPersist(syncDB)
 	roomHistory.SetMonitor(qureyHitCounter)
-	roomHistory.LoadAllDomainMaxStream(context.Background())
+	//roomHistory.LoadAllDomainMaxStream(context.Background())
 	roomHistory.SetCache(cache)
 	rsCurState.SetPersist(syncDB)