Remove debug and send task without pointer because its an interface

BBVA · Mar 6, 2019 · 49fca49 · 49fca49
1 parent 0caf105
commit 49fca49
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/gossip/publisher/publisher.go b/gossip/publisher/publisher.go
@@ -110,14 +110,13 @@ func (p *Publisher) Process(b protocol.BatchSnapshots) {
 		taskCh: p.taskCh,
 		batch:  b,
 	}
-	p.taskCh <- *task
+	p.taskCh <- task
 }
 
 func (p Publisher) runTaskDispatcher() {
 	for {
 		select {
 		case <-p.executionTicker.C:
-			log.Debug("Dispatching tasks...")
 			go p.dispatchTasks()
 		case <-p.quitCh:
 			p.executionTicker.Stop()
@@ -145,7 +144,7 @@ func (p *Publisher) Shutdown() {
 func (p Publisher) dispatchTasks() {
 	count := 0
 	var task Task
-	defer log.Debugf("%d tasks dispatched", count)
+
 	for {
 		select {
 		case task = <-p.taskCh: