tolti msg di debug

This commit is contained in:
Miki 2015-11-24 11:38:01 +01:00
parent 15c0b5b157
commit 7ed0686953
2 changed files with 8 additions and 7 deletions

View file

@ -80,15 +80,16 @@ func consumer(id int) {
if err != nil { if err != nil {
log.Printf("Insert error: %+v\n", err) log.Printf("Insert error: %+v\n", err)
// se l'errore non e' "duplicate key error" salta al prossimo senza cancellare niente // se l'errore non e' "duplicate key error" salta al prossimo senza cancellare niente
if !strings.Contains(err.Error(), "E11000") { count.AddErr()
count.AddErr() continue
//return }
continue if retval.Updated == 1 {
}
count.AddDuplicate() count.AddDuplicate()
} }
log.Printf("%+v - %+v\n", ml, retval) if opts.Debug {
log.Printf("%+v - %+v\n", ml, retval)
}
if i < (len(prod.logins) - 1) { if i < (len(prod.logins) - 1) {
cons.logins = append(cons.logins, login) cons.logins = append(cons.logins, login)

View file

@ -11,7 +11,7 @@ import (
) )
const ( const (
_VERSION = "v2.2.2" _VERSION = "v2.2.3"
) )
var ( var (