Ensure *_wal_dir exists

consensus/state.go

@@ -304,8 +304,15 @@ func (cs *ConsensusState) SetPrivValidator(priv *types.PrivValidator) {
 func (cs *ConsensusState) OnStart() error {
 	cs.BaseService.OnStart()
 
-	err := cs.OpenWAL(cs.config.GetString("cs_wal_dir"))
+	walDir := cs.config.GetString("cs_wal_dir")
+	err := EnsureDir(walDir, 0700)
 	if err != nil {
+		log.Error("Error ensuring ConsensusState wal dir", "error", err.Error())
+		return err
+	}
+	err = cs.OpenWAL(walDir)
+	if err != nil {
+		log.Error("Error loading ConsensusState wal", "error", err.Error())
 		return err
 	}
 

mempool/mempool.go

@@ -87,8 +87,14 @@ func NewMempool(config cfg.Config, proxyAppConn proxy.AppConnMempool) *Mempool {
 func (mem *Mempool) initWAL() {
 	walDir := mem.config.GetString("mempool_wal_dir")
 	if walDir != "" {
+		err := EnsureDir(walDir, 0700)
+		if err != nil {
+			log.Error("Error ensuring Mempool wal dir", "error", err)
+			PanicSanity(err)
+		}
 		af, err := auto.OpenAutoFile(walDir + "/wal")
 		if err != nil {
+			log.Error("Error opening Mempool wal file", "error", err)
 			PanicSanity(err)
 		}
 		mem.wal = af