@@ -220,9 +220,9 @@ func (c *defaultSingleNodeClient) readResponseInto(reader *bytes.Buffer, m proto
220
220
responseHeader := & ybApi.ResponseHeader {}
221
221
protoErr := utils .DeserializeProto (responseHeaderBuf , responseHeader )
222
222
if protoErr != nil {
223
- opLogger .Error ("failed unmarshalling response header" , "reason" , err )
223
+ opLogger .Error ("failed unmarshalling response header" , "reason" , protoErr )
224
224
return & errors.ReceiveError {
225
- Cause : fmt .Errorf ("response header unprocessable: %s" , err .Error ()),
225
+ Cause : fmt .Errorf ("response header unprocessable: %s" , protoErr .Error ()),
226
226
}
227
227
}
228
228
@@ -271,12 +271,13 @@ func (c *defaultSingleNodeClient) readResponseInto(reader *bytes.Buffer, m proto
271
271
for {
272
272
buf , err := c .recv ()
273
273
if err != nil {
274
- opLogger .Error ("response payload read bytes count != expected count " ,
274
+ opLogger .Error ("response payload read error " ,
275
275
"expected-payload-length" , responsePayloadLength ,
276
- "read-payload-length" , n )
276
+ "read-payload-length" , n ,
277
+ "reason" , err )
277
278
return & errors.ReceiveError {
278
- Cause : fmt .Errorf ("response payload incomplete : read %d bytes vs expected %d" ,
279
- n , responsePayloadLength ),
279
+ Cause : fmt .Errorf ("response payload read error : read %d bytes vs expected %d, reason: %s " ,
280
+ n , responsePayloadLength , err . Error () ),
280
281
}
281
282
}
282
283
0 commit comments