fix bugs after refactoring

database/database.go

@@ -105,7 +105,7 @@ func (db *DB) worker() {
 		}
 
 		// write batch now?
-		if bp != nil && (writeNow || closed) || len(bp.Points()) >= batchMaxSize {
+		if bp != nil && (writeNow || closed || len(bp.Points()) >= batchMaxSize) {
 			log.Println("saving", len(bp.Points()), "points")
 
 			if err = db.client.Write(bp); err != nil {

respond/collector.go

@@ -45,6 +45,7 @@ func NewCollector(db *database.DB, nodes *models.Nodes, interval time.Duration,
 
 	collector := &Collector{
 		connection:    conn,
+		db:            db,
 		nodes:         nodes,
 		multicastAddr: net.JoinHostPort(multiCastGroup+"%"+iface, port),
 		queue:         make(chan *Response, 400),