Skip to content

Commit

Permalink
removed unneccessary logs
Browse files Browse the repository at this point in the history
  • Loading branch information
ehsan6sha committed Mar 4, 2024
1 parent 65a0fcb commit edd56e3
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 7 deletions.
8 changes: 4 additions & 4 deletions announcements/announcements.go
Original file line number Diff line number Diff line change
Expand Up @@ -163,7 +163,7 @@ func (an *FxAnnouncements) HandleAnnouncements(ctx context.Context) {
continue
}
if from == an.h.ID() {
log.Debug("Ignoring announcement from self")
//log.Debug("Ignoring announcement from self")
continue
}
a := &Announcement{}
Expand Down Expand Up @@ -228,7 +228,7 @@ func (an *FxAnnouncements) AnnounceIExistPeriodically(ctx context.Context) {
log.Errorw("Failed to publish iexist announcement", "err", err)
continue
}
log.Debugw("Announced iexist message", "from", an.h.ID(), "announcement", a, "time", t)
//log.Debugw("Announced iexist message", "from", an.h.ID(), "announcement", a, "time", t)
}
}
}
Expand Down Expand Up @@ -291,13 +291,13 @@ func (an *FxAnnouncements) AnnounceJoinPoolRequestPeriodically(ctx context.Conte
}

func (an *FxAnnouncements) ValidateAnnouncement(ctx context.Context, id peer.ID, msg *pubsub.Message, status common.MemberStatus, exists bool) bool {
log.Debugw("ValidateAnnouncement", "on peer", an.h.ID(), "from peerID", id)
//log.Debugw("ValidateAnnouncement", "on peer", an.h.ID(), "from peerID", id)
a := &Announcement{}
if err := a.UnmarshalBinary(msg.Data); err != nil {
log.Errorw("failed to unmarshal announcement data", "err", err)
return false
}
log.Debugw("ValidateAnnouncement", "on peer", an.h.ID(), "from peerID", id, "type", a.Type)
//log.Debugw("ValidateAnnouncement", "on peer", an.h.ID(), "from peerID", id, "type", a.Type)

switch a.Type {
case NewManifestAnnouncementType:
Expand Down
2 changes: 1 addition & 1 deletion blockchain/blockchain.go
Original file line number Diff line number Diff line change
Expand Up @@ -534,7 +534,7 @@ func (bl *FxBlockchain) handleReplicateInPool(method string, action string, from

if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
log.Debug("cannot parse request body: %v", err)
http.Error(w, "", http.StatusBadRequest)
http.Error(w, "cannot parse request body", http.StatusBadRequest)
return
}

Expand Down
2 changes: 1 addition & 1 deletion exchange/hub_publisher.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ func (p *hubPublisher) Start(_ context.Context) error {
maybePublish := func() {
remaining := len(unpublished)
if remaining == 0 {
log.Debug("hubPublisher: No remaining entries to publish")
//log.Debug("hubPublisher: No remaining entries to publish")
return
}
if publishing.Load() {
Expand Down
2 changes: 1 addition & 1 deletion exchange/ipni_publisher.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ func (p *ipniPublisher) Start(ctx context.Context) error {
maybePublish := func() {
remaining := len(unpublished)
if remaining == 0 {
log.Debug("No remaining entries to publish")
//log.Debug("No remaining entries to publish")
return
}
if publishing.Load() {
Expand Down

0 comments on commit edd56e3

Please sign in to comment.