status-im/consul
2
0
Fork 0
mirror of https://github.com/status-im/consul.git synced 2025-01-11 22:34:55 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #604 from hashicorp/f-log-cache

Browse Source 
consul: Use new LogCache to improve write throughput
This commit is contained in:
Armon Dadgar 2015-01-14 15:50:54 -08:00
commit e9216fa47d
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
consul/server.go
View File

@ -49,6 +49,10 @@ const (
// Maximum number of cached ACL entries // Maximum number of cached ACL entries
aclCacheSize = 256 aclCacheSize = 256
// raftLogCacheSize is the maximum number of logs to cache in-memory.
// This is used to reduce disk I/O for the recently commited entries.
raftLogCacheSize = 512
) )
// Server is Consul server which manages the service discovery, // Server is Consul server which manages the service discovery,
@ -362,6 +366,13 @@ func (s *Server) setupRaft() error {
} }
s.raftStore = store s.raftStore = store
// Wrap the store in a LogCache to improve performance
cacheStore, err := raft.NewLogCache(raftLogCacheSize, store)
if err != nil {
store.Close()
return err
}
// Create the snapshot store // Create the snapshot store
snapshots, err := raft.NewFileSnapshotStore(path, snapshotsRetained, s.config.LogOutput) snapshots, err := raft.NewFileSnapshotStore(path, snapshotsRetained, s.config.LogOutput)
if err != nil { if err != nil {
@ -392,7 +403,7 @@ func (s *Server) setupRaft() error {
s.config.RaftConfig.LogOutput = s.config.LogOutput s.config.RaftConfig.LogOutput = s.config.LogOutput
// Setup the Raft store // Setup the Raft store
s.raft, err = raft.NewRaft(s.config.RaftConfig, s.fsm, store, store, s.raft, err = raft.NewRaft(s.config.RaftConfig, s.fsm, cacheStore, store,
snapshots, s.raftPeers, trans) snapshots, s.raftPeers, trans)
if err != nil { if err != nil {
store.Close() store.Close()