Skip to content

Commit

Permalink
modify log and activeMediatorsUpdatedEventRecvLoop
Browse files Browse the repository at this point in the history
  • Loading branch information
etying committed Dec 5, 2018
1 parent bf47fe5 commit a56d5b1
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 2 deletions.
2 changes: 1 addition & 1 deletion ptn/downloader/downloader.go
Original file line number Diff line number Diff line change
Expand Up @@ -423,7 +423,7 @@ func (d *Downloader) syncWithPeer(p *peerConnection, hash common.Hash, index uin
// Look up the sync boundaries: the common ancestor and the target block
latest, err := d.fetchHeight(p, assetId)
if err != nil {
//log.Info("fetchHeight", "err:", err)
log.Info("fetchHeight", "err:", err)
return err
}

Expand Down
1 change: 1 addition & 0 deletions ptn/mediator_connection.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ type producer interface {
}

func (pm *ProtocolManager) activeMediatorsUpdatedEventRecvLoop() {
return
for {
select {
case <-pm.activeMediatorsUpdatedCh:
Expand Down
2 changes: 1 addition & 1 deletion ptn/message.go
Original file line number Diff line number Diff line change
Expand Up @@ -207,7 +207,7 @@ func (pm *ProtocolManager) GetBlockBodiesMsg(msg p2p.Msg, p *peer) error {
log.Debug("msgStream.Decode", "err", err)
return errResp(ErrDecode, "msg %v: %v", msg, err)
}
//log.Debug("GetBlockBodiesMsg", "hash", hash)
log.Debug("GetBlockBodiesMsg", "hash", hash)
// Retrieve the requested block body, stopping if enough was found
txs, err := pm.dag.GetUnitTransactions(hash)
if err != nil {
Expand Down

0 comments on commit a56d5b1

Please sign in to comment.