Lines Matching defs: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() local
2697 struct ceph_osd_linger_request *lreq = in linger_release() local
2720 static void linger_put(struct ceph_osd_linger_request *lreq) in linger_put()
2727 linger_get(struct ceph_osd_linger_request *lreq) in linger_get()
2736 struct ceph_osd_linger_request *lreq; in linger_alloc() local
2787 struct ceph_osd_linger_request *lreq) in unlink_linger()
2804 static bool __linger_registered(struct ceph_osd_linger_request *lreq) in __linger_registered()
2811 static bool linger_registered(struct ceph_osd_linger_request *lreq) in linger_registered()
2823 static void linger_register(struct ceph_osd_linger_request *lreq) in linger_register()
2835 static void linger_unregister(struct ceph_osd_linger_request *lreq) in linger_unregister()
2847 struct ceph_osd_linger_request *lreq = req->r_priv; in cancel_linger_request() local
2856 struct ceph_osd_linger_request *lreq; member
2875 static struct linger_work *lwork_alloc(struct ceph_osd_linger_request *lreq, in lwork_alloc()
2893 struct ceph_osd_linger_request *lreq = lwork->lreq; in lwork_free() local
2905 struct ceph_osd_linger_request *lreq = lwork->lreq; in lwork_queue() local
2919 struct ceph_osd_linger_request *lreq = lwork->lreq; in do_watch_notify() local
2942 struct ceph_osd_linger_request *lreq = lwork->lreq; in do_watch_error() local
2956 static void queue_watch_error(struct ceph_osd_linger_request *lreq) in queue_watch_error()
2970 static void linger_reg_commit_complete(struct ceph_osd_linger_request *lreq, in linger_reg_commit_complete()
2981 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_commit_cb() local
3033 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_reconnect_cb() local
3056 static void send_linger(struct ceph_osd_linger_request *lreq) in send_linger()
3115 struct ceph_osd_linger_request *lreq = req->r_priv; in linger_ping_cb() local
3144 static void send_linger_ping(struct ceph_osd_linger_request *lreq) in send_linger_ping()
3188 static void linger_submit(struct ceph_osd_linger_request *lreq) in linger_submit()
3204 static void cancel_linger_map_check(struct ceph_osd_linger_request *lreq) in cancel_linger_map_check()
3224 static void __linger_cancel(struct ceph_osd_linger_request *lreq) in __linger_cancel()
3235 static void linger_cancel(struct ceph_osd_linger_request *lreq) in linger_cancel()
3247 static void check_linger_pool_dne(struct ceph_osd_linger_request *lreq) in check_linger_pool_dne()
3281 struct ceph_osd_linger_request *lreq; in linger_map_check_cb() local
3306 static void send_linger_map_check(struct ceph_osd_linger_request *lreq) in send_linger_map_check()
3328 static int linger_reg_commit_wait(struct ceph_osd_linger_request *lreq) in linger_reg_commit_wait()
3337 static int linger_notify_finish_wait(struct ceph_osd_linger_request *lreq, in linger_notify_finish_wait()
3400 struct ceph_osd_linger_request *lreq = in handle_timeout() local
3834 recalc_linger_target(struct ceph_osd_linger_request *lreq) in recalc_linger_target()
3868 struct ceph_osd_linger_request *lreq = in scan_requests() local
4008 struct ceph_osd_linger_request *lreq, *nlreq; in kick_requests() local
4194 struct ceph_osd_linger_request *lreq = in kick_osd_requests() local
4488 struct ceph_osd_linger_request *lreq; in handle_watch_notify() local
4693 struct ceph_osd_linger_request *lreq; in ceph_osdc_watch() local
4734 struct ceph_osd_linger_request *lreq) in ceph_osdc_unwatch()
4852 struct ceph_osd_linger_request *lreq; in ceph_osdc_notify() local
4916 struct ceph_osd_linger_request *lreq) in ceph_osdc_watch_check()