summaryrefslogtreecommitdiffstats
path: root/commands
diff options
context:
space:
mode:
authorBjørn Erik Pedersen <bjorn.erik.pedersen@gmail.com>2018-08-16 12:30:03 +0200
committerBjørn Erik Pedersen <bjorn.erik.pedersen@gmail.com>2018-08-16 12:54:59 +0200
commita655e00d702dbc20b3961b131b33ab21841b043d (patch)
treeb4f1c3e347af0fb05f836b84fe6663dc4b71417b /commands
parent9d973004f5379cff2adda489566fe40683553c4c (diff)
commands: Gracefully handle typos in server config when running the server
Fixes #5081
Diffstat (limited to 'commands')
-rw-r--r--commands/commandeer.go1
-rw-r--r--commands/hugo.go45
2 files changed, 32 insertions, 14 deletions
diff --git a/commands/commandeer.go b/commands/commandeer.go
index 0a024f047..c55806980 100644
--- a/commands/commandeer.go
+++ b/commands/commandeer.go
@@ -71,6 +71,7 @@ type commandeer struct {
languages langs.Languages
configured bool
+ paused bool
}
func (c *commandeer) Set(key string, value interface{}) {
diff --git a/commands/hugo.go b/commands/hugo.go
index c80080c49..fc8dced74 100644
--- a/commands/hugo.go
+++ b/commands/hugo.go
@@ -646,12 +646,21 @@ func (c *commandeer) rebuildSites(events []fsnotify.Event) error {
func (c *commandeer) fullRebuild() {
c.commandeerHugoState = &commandeerHugoState{}
- if err := c.loadConfig(true, true); err != nil {
+ err := c.loadConfig(true, true)
+ if err != nil {
jww.ERROR.Println("Failed to reload config:", err)
- } else if err := c.buildSites(); err != nil {
- jww.ERROR.Println(err)
- } else if !c.h.buildWatch && !c.Cfg.GetBool("disableLiveReload") {
- livereload.ForceRefresh()
+ // Set the processing on pause until the state is recovered.
+ c.paused = true
+ } else {
+ c.paused = false
+ }
+
+ if !c.paused {
+ if err := c.buildSites(); err != nil {
+ jww.ERROR.Println(err)
+ } else if !c.h.buildWatch && !c.Cfg.GetBool("disableLiveReload") {
+ livereload.ForceRefresh()
+ }
}
}
@@ -691,6 +700,23 @@ func (c *commandeer) newWatcher(dirList ...string) (*watcher.Batcher, error) {
for {
select {
case evs := <-watcher.Events:
+ for _, ev := range evs {
+ if configSet[ev.Name] {
+ if ev.Op&fsnotify.Chmod == fsnotify.Chmod {
+ continue
+ }
+ // Config file changed. Need full rebuild.
+ c.fullRebuild()
+ break
+ }
+ }
+
+ if c.paused {
+ // Wait for the server to get into a consistent state before
+ // we continue with processing.
+ continue
+ }
+
if len(evs) > 50 {
// This is probably a mass edit of the content dir.
// Schedule a full rebuild for when it slows down.
@@ -706,15 +732,6 @@ func (c *commandeer) newWatcher(dirList ...string) (*watcher.Batcher, error) {
// Special handling for symbolic links inside /content.
filtered := []fsnotify.Event{}
for _, ev := range evs {
- if configSet[ev.Name] {
- if ev.Op&fsnotify.Chmod == fsnotify.Chmod {
- continue
- }
- // Config file changed. Need full rebuild.
- c.fullRebuild()
- break
- }
-
// Check the most specific first, i.e. files.
contentMapped := c.hugo.ContentChanges.GetSymbolicLinkMappings(ev.Name)
if len(contentMapped) > 0 {