Lines Matching refs:ceph_osd_linger_request
52 struct ceph_osd_linger_request *lreq);
54 struct ceph_osd_linger_request *lreq);
85 static inline void verify_lreq_locked(struct ceph_osd_linger_request *lreq) in verify_lreq_locked()
93 static inline void verify_lreq_locked(struct ceph_osd_linger_request *lreq) { } in verify_lreq_locked()
1327 struct ceph_osd_linger_request *lreq = in close_osd()
1328 rb_entry(n, struct ceph_osd_linger_request, node); in close_osd()
2655 struct ceph_osd_linger_request *lreq = in linger_release()
2656 container_of(kref, struct ceph_osd_linger_request, kref); in linger_release()
2675 static void linger_put(struct ceph_osd_linger_request *lreq) in linger_put()
2681 static struct ceph_osd_linger_request *
2682 linger_get(struct ceph_osd_linger_request *lreq) in linger_get()
2688 static struct ceph_osd_linger_request *
2691 struct ceph_osd_linger_request *lreq; in linger_alloc()
2714 DEFINE_RB_INSDEL_FUNCS(linger, struct ceph_osd_linger_request, linger_id, node) in DEFINE_RB_INSDEL_FUNCS() argument
2715 DEFINE_RB_FUNCS(linger_osdc, struct ceph_osd_linger_request, linger_id, osdc_node) in DEFINE_RB_INSDEL_FUNCS()
2716 DEFINE_RB_FUNCS(linger_mc, struct ceph_osd_linger_request, linger_id, mc_node) in DEFINE_RB_INSDEL_FUNCS()
2724 struct ceph_osd_linger_request *lreq) in DEFINE_RB_INSDEL_FUNCS()
2742 struct ceph_osd_linger_request *lreq) in unlink_linger()
2759 static bool __linger_registered(struct ceph_osd_linger_request *lreq) in __linger_registered()
2766 static bool linger_registered(struct ceph_osd_linger_request *lreq) in linger_registered()
2778 static void linger_register(struct ceph_osd_linger_request *lreq) in linger_register()
2790 static void linger_unregister(struct ceph_osd_linger_request *lreq) in linger_unregister()
2802 struct ceph_osd_linger_request *lreq = req->r_priv; in cancel_linger_request()
2811 struct ceph_osd_linger_request *lreq;
2830 static struct linger_work *lwork_alloc(struct ceph_osd_linger_request *lreq, in lwork_alloc()
2848 struct ceph_osd_linger_request *lreq = lwork->lreq; in lwork_free()
2860 struct ceph_osd_linger_request *lreq = lwork->lreq; in lwork_queue()
2874 struct ceph_osd_linger_request *lreq = lwork->lreq; in do_watch_notify()
2897 struct ceph_osd_linger_request *lreq = lwork->lreq; in do_watch_error()
2911 static void queue_watch_error(struct ceph_osd_linger_request *lreq) in queue_watch_error()
2925 static void linger_reg_commit_complete(struct ceph_osd_linger_request *lreq, in linger_reg_commit_complete()
2936 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_commit_cb()
2981 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_reconnect_cb()
2997 static void send_linger(struct ceph_osd_linger_request *lreq) in send_linger()
3041 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_ping_cb()
3063 static void send_linger_ping(struct ceph_osd_linger_request *lreq) in send_linger_ping()
3100 static void linger_submit(struct ceph_osd_linger_request *lreq) in linger_submit()
3122 static void cancel_linger_map_check(struct ceph_osd_linger_request *lreq) in cancel_linger_map_check()
3125 struct ceph_osd_linger_request *lookup_lreq; in cancel_linger_map_check()
3142 static void __linger_cancel(struct ceph_osd_linger_request *lreq) in __linger_cancel()
3153 static void linger_cancel(struct ceph_osd_linger_request *lreq) in linger_cancel()
3163 static void send_linger_map_check(struct ceph_osd_linger_request *lreq);
3165 static void check_linger_pool_dne(struct ceph_osd_linger_request *lreq) in check_linger_pool_dne()
3199 struct ceph_osd_linger_request *lreq; in linger_map_check_cb()
3224 static void send_linger_map_check(struct ceph_osd_linger_request *lreq) in send_linger_map_check()
3227 struct ceph_osd_linger_request *lookup_lreq; in send_linger_map_check()
3246 static int linger_reg_commit_wait(struct ceph_osd_linger_request *lreq) in linger_reg_commit_wait()
3255 static int linger_notify_finish_wait(struct ceph_osd_linger_request *lreq) in linger_notify_finish_wait()
3311 struct ceph_osd_linger_request *lreq = in handle_timeout()
3312 rb_entry(p, struct ceph_osd_linger_request, node); in handle_timeout()
3726 recalc_linger_target(struct ceph_osd_linger_request *lreq) in recalc_linger_target()
3760 struct ceph_osd_linger_request *lreq = in scan_requests()
3761 rb_entry(n, struct ceph_osd_linger_request, node); in scan_requests()
3900 struct ceph_osd_linger_request *lreq, *nlreq; in kick_requests()
4086 struct ceph_osd_linger_request *lreq = in kick_osd_requests()
4087 rb_entry(n, struct ceph_osd_linger_request, node); in kick_osd_requests()
4380 struct ceph_osd_linger_request *lreq; in handle_watch_notify()
4577 alloc_linger_request(struct ceph_osd_linger_request *lreq) in alloc_linger_request()
4591 alloc_watch_request(struct ceph_osd_linger_request *lreq, u8 watch_opcode) in alloc_watch_request()
4616 struct ceph_osd_linger_request *
4624 struct ceph_osd_linger_request *lreq; in ceph_osdc_watch()
4677 struct ceph_osd_linger_request *lreq) in ceph_osdc_unwatch()
4824 struct ceph_osd_linger_request *lreq; in ceph_osdc_notify()
4894 struct ceph_osd_linger_request *lreq) in ceph_osdc_watch_check()