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()
1307 struct ceph_osd_linger_request *lreq = in close_osd()
1308 rb_entry(n, struct ceph_osd_linger_request, node); in close_osd()
2701 struct ceph_osd_linger_request *lreq = in linger_release()
2702 container_of(kref, struct ceph_osd_linger_request, kref); in linger_release()
2724 static void linger_put(struct ceph_osd_linger_request *lreq) in linger_put()
2730 static struct ceph_osd_linger_request *
2731 linger_get(struct ceph_osd_linger_request *lreq) in linger_get()
2737 static struct ceph_osd_linger_request *
2740 struct ceph_osd_linger_request *lreq; in linger_alloc()
2763 DEFINE_RB_INSDEL_FUNCS(linger, struct ceph_osd_linger_request, linger_id, node) in DEFINE_RB_INSDEL_FUNCS() argument
2764 DEFINE_RB_FUNCS(linger_osdc, struct ceph_osd_linger_request, linger_id, osdc_node) in DEFINE_RB_INSDEL_FUNCS()
2765 DEFINE_RB_FUNCS(linger_mc, struct ceph_osd_linger_request, linger_id, mc_node) in DEFINE_RB_INSDEL_FUNCS()
2773 struct ceph_osd_linger_request *lreq) in DEFINE_RB_INSDEL_FUNCS()
2791 struct ceph_osd_linger_request *lreq) in unlink_linger()
2808 static bool __linger_registered(struct ceph_osd_linger_request *lreq) in __linger_registered()
2815 static bool linger_registered(struct ceph_osd_linger_request *lreq) in linger_registered()
2827 static void linger_register(struct ceph_osd_linger_request *lreq) in linger_register()
2839 static void linger_unregister(struct ceph_osd_linger_request *lreq) in linger_unregister()
2851 struct ceph_osd_linger_request *lreq = req->r_priv; in cancel_linger_request()
2860 struct ceph_osd_linger_request *lreq;
2879 static struct linger_work *lwork_alloc(struct ceph_osd_linger_request *lreq, in lwork_alloc()
2897 struct ceph_osd_linger_request *lreq = lwork->lreq; in lwork_free()
2909 struct ceph_osd_linger_request *lreq = lwork->lreq; in lwork_queue()
2923 struct ceph_osd_linger_request *lreq = lwork->lreq; in do_watch_notify()
2946 struct ceph_osd_linger_request *lreq = lwork->lreq; in do_watch_error()
2960 static void queue_watch_error(struct ceph_osd_linger_request *lreq) in queue_watch_error()
2974 static void linger_reg_commit_complete(struct ceph_osd_linger_request *lreq, in linger_reg_commit_complete()
2985 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_commit_cb()
3037 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_reconnect_cb()
3060 static void send_linger(struct ceph_osd_linger_request *lreq) in send_linger()
3119 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_ping_cb()
3148 static void send_linger_ping(struct ceph_osd_linger_request *lreq) in send_linger_ping()
3192 static void linger_submit(struct ceph_osd_linger_request *lreq) in linger_submit()
3208 static void cancel_linger_map_check(struct ceph_osd_linger_request *lreq) in cancel_linger_map_check()
3211 struct ceph_osd_linger_request *lookup_lreq; in cancel_linger_map_check()
3228 static void __linger_cancel(struct ceph_osd_linger_request *lreq) in __linger_cancel()
3239 static void linger_cancel(struct ceph_osd_linger_request *lreq) in linger_cancel()
3249 static void send_linger_map_check(struct ceph_osd_linger_request *lreq);
3251 static void check_linger_pool_dne(struct ceph_osd_linger_request *lreq) in check_linger_pool_dne()
3285 struct ceph_osd_linger_request *lreq; in linger_map_check_cb()
3310 static void send_linger_map_check(struct ceph_osd_linger_request *lreq) in send_linger_map_check()
3313 struct ceph_osd_linger_request *lookup_lreq; in send_linger_map_check()
3332 static int linger_reg_commit_wait(struct ceph_osd_linger_request *lreq) in linger_reg_commit_wait()
3341 static int linger_notify_finish_wait(struct ceph_osd_linger_request *lreq) in linger_notify_finish_wait()
3397 struct ceph_osd_linger_request *lreq = in handle_timeout()
3398 rb_entry(p, struct ceph_osd_linger_request, node); in handle_timeout()
3831 recalc_linger_target(struct ceph_osd_linger_request *lreq) in recalc_linger_target()
3865 struct ceph_osd_linger_request *lreq = in scan_requests()
3866 rb_entry(n, struct ceph_osd_linger_request, node); in scan_requests()
4007 struct ceph_osd_linger_request *lreq, *nlreq; in kick_requests()
4193 struct ceph_osd_linger_request *lreq = in kick_osd_requests()
4194 rb_entry(n, struct ceph_osd_linger_request, node); in kick_osd_requests()
4487 struct ceph_osd_linger_request *lreq; in handle_watch_notify()
4686 struct ceph_osd_linger_request *
4694 struct ceph_osd_linger_request *lreq; in ceph_osdc_watch()
4735 struct ceph_osd_linger_request *lreq) in ceph_osdc_unwatch()
4853 struct ceph_osd_linger_request *lreq; in ceph_osdc_notify()
4916 struct ceph_osd_linger_request *lreq) in ceph_osdc_watch_check()