diff --git a/input/carbon/carbon.go b/input/carbon/carbon.go index aa7fc4b4b0..b453c24e1c 100644 --- a/input/carbon/carbon.go +++ b/input/carbon/carbon.go @@ -88,7 +88,7 @@ func ConfigProcess() { var err error schemas, err = persister.ReadWhisperSchemas(schemasFile) if err != nil { - log.Fatal(4, "can't read schemas file %q: %s", schemasFile, err.Error()) + log.Fatal(4, "carbon-in: can't read schemas file %q: %s", schemasFile, err.Error()) } var defaultFound bool for _, schema := range schemas { @@ -102,7 +102,7 @@ func ConfigProcess() { if !defaultFound { // good graphite health (not sure what graphite does if there's no .*) // but we definitely need to always be able to determine which interval to use - log.Fatal(4, "storage-conf does not have a default '.*' pattern") + log.Fatal(4, "carbon-in: storage-conf does not have a default '.*' pattern") } } @@ -143,7 +143,7 @@ func (c *Carbon) accept() { return default: } - log.Error(4, "Accept Error: %s", err.Error()) + log.Error(4, "carbon-in: Accept Error: %s", err.Error()) return } c.handlerWaitGroup.Add(1) @@ -153,7 +153,7 @@ func (c *Carbon) accept() { } func (c *Carbon) Stop() { - log.Info("Carbon: shutting down.") + log.Info("carbon-in: shutting down.") close(c.quit) c.listener.Close() c.connTrack.CloseAll() @@ -179,7 +179,7 @@ func (c *Carbon) handle(conn net.Conn) { default: } if io.EOF != err { - log.Error(4, "Recv error: %s", err.Error()) + log.Error(4, "carbon-in: Recv error: %s", err.Error()) } break }