diff --git a/consul/server.go b/consul/server.go index 26fab86fb..d05c0e529 100644 --- a/consul/server.go +++ b/consul/server.go @@ -179,14 +179,14 @@ func (s *Server) setupRaft() error { s.raftStore = store // Create the snapshot store - snapshots, err := raft.NewFileSnapshotStore(path, 3) + snapshots, err := raft.NewFileSnapshotStore(path, 3, s.config.LogOutput) if err != nil { store.Close() return err } // Create a transport layer - trans := raft.NewNetworkTransport(s.raftLayer, 3, 10*time.Second) + trans := raft.NewNetworkTransport(s.raftLayer, 3, 10*time.Second, s.config.LogOutput) s.raftTransport = trans // Setup the peer store @@ -202,6 +202,9 @@ func (s *Server) setupRaft() error { s.raftPeers.SetPeers(raft.AddUniquePeer(peers, trans.LocalAddr())) } + // Make sure we set the LogOutput + s.config.RaftConfig.LogOutput = s.config.LogOutput + // Setup the Raft store s.raft, err = raft.NewRaft(s.config.RaftConfig, s.fsm, store, store, snapshots, s.raftPeers, trans)