|
@@ -1675,13 +1675,13 @@ static void kick_requests(struct ceph_osd_client *osdc, int force_resend)
|
|
__register_request(osdc, req);
|
|
__register_request(osdc, req);
|
|
__unregister_linger_request(osdc, req);
|
|
__unregister_linger_request(osdc, req);
|
|
}
|
|
}
|
|
|
|
+ reset_changed_osds(osdc);
|
|
mutex_unlock(&osdc->request_mutex);
|
|
mutex_unlock(&osdc->request_mutex);
|
|
|
|
|
|
if (needmap) {
|
|
if (needmap) {
|
|
dout("%d requests for down osds, need new map\n", needmap);
|
|
dout("%d requests for down osds, need new map\n", needmap);
|
|
ceph_monc_request_next_osdmap(&osdc->client->monc);
|
|
ceph_monc_request_next_osdmap(&osdc->client->monc);
|
|
}
|
|
}
|
|
- reset_changed_osds(osdc);
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|