diff --git a/protocols/executor.go b/protocols/executor.go index a73671e..9be796c 100644 --- a/protocols/executor.go +++ b/protocols/executor.go @@ -238,7 +238,6 @@ func (s *Executor) Run(ctx context.Context, trans Transport) error { // TODO: ca //s.Logf("closed signature queue") return nil } - s.Logf("picked up signature from queue: %s", qsig.sig) err := s.runSignature(qsig.ctx, qsig.sig, qsig.rec) if err != nil { s.Logf("error: %s", err) diff --git a/protocols/protocols.go b/protocols/protocols.go index 4123536..c83240f 100644 --- a/protocols/protocols.go +++ b/protocols/protocols.go @@ -268,7 +268,7 @@ func (p *Protocol) Aggregate(ctx context.Context, incoming <-chan Share) <-chan aggOut.Share.ProtocolType = p.pd.Type if err == nil { aggOut.Share = p.agg.getAggregatedShare() - p.Logf("aggregation done") + //p.Logf("aggregation done") } else { aggOut.Error = err p.Logf("aggregation error: %s", err) @@ -277,7 +277,7 @@ func (p *Protocol) Aggregate(ctx context.Context, incoming <-chan Share) <-chan close(aggOutChan) }() - p.Logf("[%s] aggregating shares", p.HID()) + //p.Logf("[%s] aggregating shares", p.HID()) return aggOutChan }