@@ -124,15 +124,22 @@ void peer::handle_rpc_result( ptr<peer> myself,
124
124
if (stale_resps < limit) {
125
125
p_wn ( " [EDGE CASE] got stale RPC response from %d: "
126
126
" current %p (%" PRIu64 " ), from parameter %p (%" PRIu64 " ). "
127
- " will ignore this response" ,
127
+ " will ignore this response."
128
+ " Currently, stale_resps: %d, response_limit: %d" ,
128
129
config_->get_id (),
129
130
rpc_.get (),
130
131
cur_rpc_id,
131
132
my_rpc_client.get (),
132
- given_rpc_id );
133
+ given_rpc_id,
134
+ stale_resps,
135
+ limit );
133
136
} else if (stale_resps == limit) {
134
137
p_wn ( " [EDGE CASE] too verbose stale RPC response from peer %d, "
135
- " will suppress it from now" , config_->get_id () );
138
+ " will suppress it from now."
139
+ " Currently, stale_resps: %d, response_limit: %d" ,
140
+ config_->get_id (),
141
+ stale_resps,
142
+ limit );
136
143
}
137
144
138
145
} else {
@@ -206,15 +213,22 @@ void peer::handle_rpc_result( ptr<peer> myself,
206
213
if (stale_resps < limit) {
207
214
p_wn ( " [EDGE CASE] RPC for %d has been reset before "
208
215
" returning error: current %p (%" PRIu64
209
- " ), from parameter %p (%" PRIu64 " )" ,
216
+ " ), from parameter %p (%" PRIu64 " )."
217
+ " Currently, stale_resps: %d, response_limit: %d" ,
210
218
config_->get_id (),
211
219
rpc_.get (),
212
220
cur_rpc_id,
213
221
my_rpc_client.get (),
214
- given_rpc_id );
222
+ given_rpc_id,
223
+ stale_resps,
224
+ limit );
215
225
} else if (stale_resps == limit) {
216
226
p_wn ( " [EDGE CASE] too verbose stale RPC response from peer %d, "
217
- " will suppress it from now" , config_->get_id () );
227
+ " will suppress it from now."
228
+ " Currently, stale_resps: %d, response_limit: %d" ,
229
+ config_->get_id (),
230
+ stale_resps,
231
+ limit );
218
232
}
219
233
}
220
234
}
0 commit comments