From 8ae9773aed9d843312c6435ab44662b4132efd4e Mon Sep 17 00:00:00 2001
From: Daniel Langesten <daniel.langest@gmail.com>
Date: Thu, 19 Mar 2015 14:22:42 +0100
Subject: added better logging

---
 cleaner.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/cleaner.go b/cleaner.go
index 001542f..f7f697e 100644
--- a/cleaner.go
+++ b/cleaner.go
@@ -19,6 +19,7 @@ func init() {
 }
 
 func cleanFromDB(cfg *Config) (rowsLeft int, err error) {
+	cllogger.Println("Starting to clean from db...")
 
 	db, err := sql.Open("mysql", cfg.DBUser+":"+cfg.DBPass+"@"+cfg.DBConn+"/"+cfg.DBName)
 	if err != nil {
@@ -82,10 +83,12 @@ func cleanFromDB(cfg *Config) (rowsLeft int, err error) {
 	}
 
 	tx.Commit()
+	cllogger.Println("Finished cleaning from db!")
 	return
 }
 
 func cleanFromStdin(rDatChan <-chan []RawData, cfg *Config) error {
+	cllogger.Println("Starting to clean from stdin")
 	for rDat := range rDatChan {
 		cDat, err := clean(rDat, cfg)
 		if err != nil {
@@ -98,6 +101,7 @@ func cleanFromStdin(rDatChan <-chan []RawData, cfg *Config) error {
 			return err
 		}
 	}
+	cllogger.Println("Finished cleaning from stdin!")
 	return nil
 }
 
-- 
cgit v1.1