Lines Matching refs:linger_id

1389 		     lreq->linger_id);  in close_osd()
2846 DEFINE_RB_INSDEL_FUNCS(linger, struct ceph_osd_linger_request, linger_id, node) in DEFINE_RB_INSDEL_FUNCS() argument
2847 DEFINE_RB_FUNCS(linger_osdc, struct ceph_osd_linger_request, linger_id, osdc_node) in DEFINE_RB_INSDEL_FUNCS()
2848 DEFINE_RB_FUNCS(linger_mc, struct ceph_osd_linger_request, linger_id, mc_node) in DEFINE_RB_INSDEL_FUNCS()
2859 WARN_ON(!lreq->linger_id || lreq->osd); in DEFINE_RB_INSDEL_FUNCS()
2861 osd->o_osd, lreq, lreq->linger_id); in DEFINE_RB_INSDEL_FUNCS()
2879 osd->o_osd, lreq, lreq->linger_id); in unlink_linger()
2915 WARN_ON(lreq->linger_id); in linger_register()
2918 lreq->linger_id = ++osdc->last_linger_id; in linger_register()
3017 lreq->wcb(lreq->data, lwork->notify.notify_id, lreq->linger_id, in do_watch_notify()
3037 lreq->errcb(lreq->data, lreq->linger_id, lwork->error.err); in do_watch_error()
3073 __func__, lreq, lreq->linger_id, req, lreq->reg_req); in linger_commit_cb()
3078 lreq->linger_id, req->r_result); in linger_commit_cb()
3125 __func__, lreq, lreq->linger_id, req, lreq->reg_req); in linger_reconnect_cb()
3130 lreq, lreq->linger_id, req->r_result, lreq->last_error); in linger_reconnect_cb()
3151 dout("%s lreq %p linger_id %llu\n", __func__, lreq, lreq->linger_id); in send_linger()
3167 lreq->linger_id, ++lreq->register_gen); in send_linger()
3174 lreq->linger_id, 0); in send_linger()
3179 osd_req_op_notify_init(req, 0, lreq->linger_id, in send_linger()
3207 __func__, lreq, lreq->linger_id, req, lreq->ping_req); in linger_ping_cb()
3212 __func__, lreq, lreq->linger_id, req->r_result, lreq->ping_sent, in linger_ping_cb()
3244 __func__, lreq, lreq->linger_id, lreq->ping_sent, in send_linger_ping()
3257 osd_req_op_watch_init(req, 0, CEPH_OSD_WATCH_OP_PING, lreq->linger_id, in send_linger_ping()
3299 lreq->linger_id); in cancel_linger_map_check()
3345 lreq, lreq->linger_id); in check_linger_pool_dne()
3348 __func__, lreq, lreq->linger_id, lreq->map_dne_bound, in check_linger_pool_dne()
3356 lreq->linger_id); in check_linger_pool_dne()
3369 u64 linger_id = greq->private_data; in linger_map_check_cb() local
3374 lreq = lookup_linger_mc(&osdc->linger_map_checks, linger_id); in linger_map_check_cb()
3376 dout("%s linger_id %llu dne\n", __func__, linger_id); in linger_map_check_cb()
3381 __func__, lreq, lreq->linger_id, lreq->map_dne_bound, in linger_map_check_cb()
3402 lreq->linger_id); in send_linger_map_check()
3411 linger_map_check_cb, lreq->linger_id); in send_linger_map_check()
3419 dout("%s lreq %p linger_id %llu\n", __func__, lreq, lreq->linger_id); in linger_reg_commit_wait()
3429 dout("%s lreq %p linger_id %llu\n", __func__, lreq, lreq->linger_id); in linger_notify_finish_wait()
3491 lreq, lreq->linger_id, osd->o_osd); in handle_timeout()
3963 lreq->linger_id); in scan_requests()
4841 lreq->linger_id, 0); in ceph_osdc_unwatch()
5027 lreq, lreq->linger_id, age, lreq->last_error); in ceph_osdc_watch_check()