@@ -99,7 +99,7 @@ func (serv *ExchangeServer[H]) requestHandler(stream network.Stream) {
99
99
pbreq := new (p2p_pb.HeaderRequest )
100
100
_ , err = serde .Read (stream , pbreq )
101
101
if err != nil {
102
- log .Errorw ("server: reading header request from stream" , "err" , err )
102
+ log .Warnw ("server: reading header request from stream" , "err" , err )
103
103
stream .Reset () //nolint:errcheck
104
104
return
105
105
}
@@ -115,7 +115,7 @@ func (serv *ExchangeServer[H]) requestHandler(stream network.Stream) {
115
115
case * p2p_pb.HeaderRequest_Origin :
116
116
headers , err = serv .handleRequest (pbreq .GetOrigin (), pbreq .GetOrigin ()+ pbreq .Amount )
117
117
default :
118
- log .Error ("server: invalid data type received" )
118
+ log .Warn ("server: invalid data type received" )
119
119
stream .Reset () //nolint:errcheck
120
120
return
121
121
}
@@ -147,14 +147,14 @@ func (serv *ExchangeServer[H]) requestHandler(stream network.Stream) {
147
147
if ! h .IsZero () {
148
148
bin , err = h .MarshalBinary ()
149
149
if err != nil {
150
- log .Errorw ("server: marshaling header to proto" , "height" , h .Height , "err" , err )
150
+ log .Warnw ("server: marshaling header to proto" , "height" , h .Height , "err" , err )
151
151
stream .Reset () //nolint:errcheck
152
152
return
153
153
}
154
154
}
155
155
_ , err = serde .Write (stream , & p2p_pb.HeaderResponse {Body : bin , StatusCode : code })
156
156
if err != nil {
157
- log .Errorw ("server: writing header to stream" , "err" , err )
157
+ log .Warnw ("server: writing header to stream" , "err" , err )
158
158
stream .Reset () //nolint:errcheck
159
159
return
160
160
}
0 commit comments