prefix log messages properly

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
 		}