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()
1237 struct ceph_osd_linger_request *lreq = in close_osd()
1238 rb_entry(n, struct ceph_osd_linger_request, node); in close_osd()
2554 struct ceph_osd_linger_request *lreq = in linger_release()
2555 container_of(kref, struct ceph_osd_linger_request, kref); in linger_release()
2574 static void linger_put(struct ceph_osd_linger_request *lreq) in linger_put()
2580 static struct ceph_osd_linger_request *
2581 linger_get(struct ceph_osd_linger_request *lreq) in linger_get()
2587 static struct ceph_osd_linger_request *
2590 struct ceph_osd_linger_request *lreq; in linger_alloc()
2613 DEFINE_RB_INSDEL_FUNCS(linger, struct ceph_osd_linger_request, linger_id, node) in DEFINE_RB_INSDEL_FUNCS() argument
2614 DEFINE_RB_FUNCS(linger_osdc, struct ceph_osd_linger_request, linger_id, osdc_node) in DEFINE_RB_INSDEL_FUNCS()
2615 DEFINE_RB_FUNCS(linger_mc, struct ceph_osd_linger_request, linger_id, mc_node) in DEFINE_RB_INSDEL_FUNCS()
2623 struct ceph_osd_linger_request *lreq) in DEFINE_RB_INSDEL_FUNCS()
2641 struct ceph_osd_linger_request *lreq) in unlink_linger()
2658 static bool __linger_registered(struct ceph_osd_linger_request *lreq) in __linger_registered()
2665 static bool linger_registered(struct ceph_osd_linger_request *lreq) in linger_registered()
2677 static void linger_register(struct ceph_osd_linger_request *lreq) in linger_register()
2689 static void linger_unregister(struct ceph_osd_linger_request *lreq) in linger_unregister()
2701 struct ceph_osd_linger_request *lreq = req->r_priv; in cancel_linger_request()
2710 struct ceph_osd_linger_request *lreq;
2729 static struct linger_work *lwork_alloc(struct ceph_osd_linger_request *lreq, in lwork_alloc()
2747 struct ceph_osd_linger_request *lreq = lwork->lreq; in lwork_free()
2759 struct ceph_osd_linger_request *lreq = lwork->lreq; in lwork_queue()
2773 struct ceph_osd_linger_request *lreq = lwork->lreq; in do_watch_notify()
2796 struct ceph_osd_linger_request *lreq = lwork->lreq; in do_watch_error()
2810 static void queue_watch_error(struct ceph_osd_linger_request *lreq) in queue_watch_error()
2824 static void linger_reg_commit_complete(struct ceph_osd_linger_request *lreq, in linger_reg_commit_complete()
2835 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_commit_cb()
2880 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_reconnect_cb()
2896 static void send_linger(struct ceph_osd_linger_request *lreq) in send_linger()
2940 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_ping_cb()
2962 static void send_linger_ping(struct ceph_osd_linger_request *lreq) in send_linger_ping()
2999 static void linger_submit(struct ceph_osd_linger_request *lreq) in linger_submit()
3011 static void cancel_linger_map_check(struct ceph_osd_linger_request *lreq) in cancel_linger_map_check()
3014 struct ceph_osd_linger_request *lookup_lreq; in cancel_linger_map_check()
3031 static void __linger_cancel(struct ceph_osd_linger_request *lreq) in __linger_cancel()
3042 static void linger_cancel(struct ceph_osd_linger_request *lreq) in linger_cancel()
3052 static void send_linger_map_check(struct ceph_osd_linger_request *lreq);
3054 static void check_linger_pool_dne(struct ceph_osd_linger_request *lreq) in check_linger_pool_dne()
3088 struct ceph_osd_linger_request *lreq; in linger_map_check_cb()
3113 static void send_linger_map_check(struct ceph_osd_linger_request *lreq) in send_linger_map_check()
3116 struct ceph_osd_linger_request *lookup_lreq; in send_linger_map_check()
3135 static int linger_reg_commit_wait(struct ceph_osd_linger_request *lreq) in linger_reg_commit_wait()
3144 static int linger_notify_finish_wait(struct ceph_osd_linger_request *lreq) in linger_notify_finish_wait()
3200 struct ceph_osd_linger_request *lreq = in handle_timeout()
3201 rb_entry(p, struct ceph_osd_linger_request, node); in handle_timeout()
3615 recalc_linger_target(struct ceph_osd_linger_request *lreq) in recalc_linger_target()
3649 struct ceph_osd_linger_request *lreq = in scan_requests()
3650 rb_entry(n, struct ceph_osd_linger_request, node); in scan_requests()
3790 struct ceph_osd_linger_request *lreq, *nlreq; in kick_requests()
3976 struct ceph_osd_linger_request *lreq = in kick_osd_requests()
3977 rb_entry(n, struct ceph_osd_linger_request, node); in kick_osd_requests()
4270 struct ceph_osd_linger_request *lreq; in handle_watch_notify()
4469 alloc_linger_request(struct ceph_osd_linger_request *lreq) in alloc_linger_request()
4491 struct ceph_osd_linger_request *
4499 struct ceph_osd_linger_request *lreq; in ceph_osdc_watch()
4560 struct ceph_osd_linger_request *lreq) in ceph_osdc_unwatch()
4709 struct ceph_osd_linger_request *lreq; in ceph_osdc_notify()
4778 struct ceph_osd_linger_request *lreq) in ceph_osdc_watch_check()