automerge
This commit is contained in:
@ -168,15 +168,7 @@ impl RepairService {
|
|||||||
})
|
})
|
||||||
.collect();
|
.collect();
|
||||||
|
|
||||||
for ((to, req), repair_request) in reqs {
|
for ((to, req), _) in reqs {
|
||||||
if let Ok(local_addr) = repair_socket.local_addr() {
|
|
||||||
datapoint_debug!(
|
|
||||||
"repair_service",
|
|
||||||
("repair_request", format!("{:?}", repair_request), String),
|
|
||||||
("to", to.to_string(), String),
|
|
||||||
("from", local_addr.to_string(), String),
|
|
||||||
);
|
|
||||||
}
|
|
||||||
repair_socket.send_to(&req, to).unwrap_or_else(|e| {
|
repair_socket.send_to(&req, to).unwrap_or_else(|e| {
|
||||||
info!("{} repair req send_to({}) error {:?}", id, to, e);
|
info!("{} repair req send_to({}) error {:?}", id, to, e);
|
||||||
0
|
0
|
||||||
|
Reference in New Issue
Block a user