2896 	struct linger_work *lwork;  in lwork_alloc()  local
2898 	lwork = kzalloc(sizeof(*lwork), GFP_NOIO);  in lwork_alloc()
2899 	if (!lwork)  in lwork_alloc()
2902 	INIT_WORK(&lwork->work, workfn);  in lwork_alloc()
2903 	INIT_LIST_HEAD(&lwork->pending_item);  in lwork_alloc()
2904 	lwork->lreq = linger_get(lreq);  in lwork_alloc()
2906 	return lwork;  in lwork_alloc()
2909 static void lwork_free(struct linger_work *lwork)  in lwork_free()  argument
2911 	struct ceph_osd_linger_request *lreq = lwork->lreq;  in lwork_free()
2914 	list_del(&lwork->pending_item);  in lwork_free()
2918 	kfree(lwork);  in lwork_free()
2921 static void lwork_queue(struct linger_work *lwork)  in lwork_queue()  argument
2923 	struct ceph_osd_linger_request *lreq = lwork->lreq;  in lwork_queue()
2927 	WARN_ON(!list_empty(&lwork->pending_item));  in lwork_queue()
2929 	lwork->queued_stamp = jiffies;  in lwork_queue()
2930 	list_add_tail(&lwork->pending_item, &lreq->pending_lworks);  in lwork_queue()
2931 	queue_work(osdc->notify_wq, &lwork->work);  in lwork_queue()
2936 	struct linger_work *lwork = container_of(w, struct linger_work, work);  in do_watch_notify()  local
2937 	struct ceph_osd_linger_request *lreq = lwork->lreq;  in do_watch_notify()
2946 	     __func__, lreq, lwork->notify.notify_id, lwork->notify.notifier_id,  in do_watch_notify()
2947 	     lwork->notify.payload_len);  in do_watch_notify()
2948 	lreq->wcb(lreq->data, lwork->notify.notify_id, lreq->linger_id,  in do_watch_notify()
2949 		  lwork->notify.notifier_id, lwork->notify.payload,  in do_watch_notify()
2950 		  lwork->notify.payload_len);  in do_watch_notify()
2953 	ceph_msg_put(lwork->notify.msg);  in do_watch_notify()
2954 	lwork_free(lwork);  in do_watch_notify()
2959 	struct linger_work *lwork = container_of(w, struct linger_work, work);  in do_watch_error()  local
2960 	struct ceph_osd_linger_request *lreq = lwork->lreq;  in do_watch_error()
2967 	dout("%s lreq %p err %d\n", __func__, lreq, lwork->error.err);  in do_watch_error()
2968 	lreq->errcb(lreq->data, lreq->linger_id, lwork->error.err);  in do_watch_error()
2971 	lwork_free(lwork);  in do_watch_error()
2976 	struct linger_work *lwork;  in queue_watch_error()  local
2978 	lwork = lwork_alloc(lreq, do_watch_error);  in queue_watch_error()
2979 	if (!lwork) {  in queue_watch_error()
2984 	lwork->error.err = lreq->last_error;  in queue_watch_error()
2985 	lwork_queue(lwork);  in queue_watch_error()
4461 	struct linger_work *lwork;  in handle_watch_notify()  local
4527 		lwork = lwork_alloc(lreq, do_watch_notify);  in handle_watch_notify()
4528 		if (!lwork) {  in handle_watch_notify()
4533 		lwork->notify.notify_id = notify_id;  in handle_watch_notify()
4534 		lwork->notify.notifier_id = notifier_id;  in handle_watch_notify()
4535 		lwork->notify.payload = payload;  in handle_watch_notify()
4536 		lwork->notify.payload_len = payload_len;  in handle_watch_notify()
4537 		lwork->notify.msg = ceph_msg_get(msg);  in handle_watch_notify()
4538 		lwork_queue(lwork);  in handle_watch_notify()
4981 		struct linger_work *lwork =  in ceph_osdc_watch_check()  local
4986 		if (time_before(lwork->queued_stamp, stamp))  in ceph_osdc_watch_check()
4987 			stamp = lwork->queued_stamp;  in ceph_osdc_watch_check()