Lines Matching refs:r_osd
528 if (req->r_osd) {
530 ceph_con_revoke(&req->r_osd->o_con, req->r_request);
533 if (list_empty(&req->r_osd->o_requests))
534 __move_osd_to_lru(osdc, req->r_osd);
535 req->r_osd = NULL;
552 if (req->r_sent && req->r_osd) {
553 ceph_con_revoke(&req->r_osd->o_con, req->r_request);
561 * (as needed), and set the request r_osd appropriately. If there is
562 * no up osd, set r_osd to NULL.
591 if ((req->r_osd && req->r_osd->o_osd == o &&
592 req->r_sent >= req->r_osd->o_incarnation &&
595 (req->r_osd == NULL && o == -1))
600 req->r_osd ? req->r_osd->o_osd : -1);
606 if (req->r_osd) {
609 req->r_osd = NULL;
612 req->r_osd = __lookup_osd(osdc, o);
613 if (!req->r_osd && o >= 0) {
615 req->r_osd = create_osd(osdc);
616 if (!req->r_osd)
619 dout("map_osds osd %p is osd%d\n", req->r_osd, o);
620 req->r_osd->o_osd = o;
621 req->r_osd->o_con.peer_name.num = cpu_to_le64(o);
622 __insert_osd(osdc, req->r_osd);
624 ceph_con_open(&req->r_osd->o_con, &osdc->osdmap->osd_addr[o]);
627 if (req->r_osd) {
628 __remove_osd_from_lru(req->r_osd);
629 list_add(&req->r_osd_item, &req->r_osd->o_requests);
649 if (req->r_osd == NULL) {
656 req, req->r_tid, req->r_osd->o_osd, req->r_flags);
667 ceph_con_send(&req->r_osd->o_con, req->r_request);
668 req->r_sent = req->r_osd->o_incarnation;
734 osd = req->r_osd;
751 osd = req->r_osd;
921 if (req->r_osd && kickosd == req->r_osd) {
934 if (req->r_osd == NULL) {
942 req->r_osd ? req->r_osd->o_osd : -1);