lwork            2833 net/ceph/osd_client.c 	struct linger_work *lwork;
lwork            2835 net/ceph/osd_client.c 	lwork = kzalloc(sizeof(*lwork), GFP_NOIO);
lwork            2836 net/ceph/osd_client.c 	if (!lwork)
lwork            2839 net/ceph/osd_client.c 	INIT_WORK(&lwork->work, workfn);
lwork            2840 net/ceph/osd_client.c 	INIT_LIST_HEAD(&lwork->pending_item);
lwork            2841 net/ceph/osd_client.c 	lwork->lreq = linger_get(lreq);
lwork            2843 net/ceph/osd_client.c 	return lwork;
lwork            2846 net/ceph/osd_client.c static void lwork_free(struct linger_work *lwork)
lwork            2848 net/ceph/osd_client.c 	struct ceph_osd_linger_request *lreq = lwork->lreq;
lwork            2851 net/ceph/osd_client.c 	list_del(&lwork->pending_item);
lwork            2855 net/ceph/osd_client.c 	kfree(lwork);
lwork            2858 net/ceph/osd_client.c static void lwork_queue(struct linger_work *lwork)
lwork            2860 net/ceph/osd_client.c 	struct ceph_osd_linger_request *lreq = lwork->lreq;
lwork            2864 net/ceph/osd_client.c 	WARN_ON(!list_empty(&lwork->pending_item));
lwork            2866 net/ceph/osd_client.c 	lwork->queued_stamp = jiffies;
lwork            2867 net/ceph/osd_client.c 	list_add_tail(&lwork->pending_item, &lreq->pending_lworks);
lwork            2868 net/ceph/osd_client.c 	queue_work(osdc->notify_wq, &lwork->work);
lwork            2873 net/ceph/osd_client.c 	struct linger_work *lwork = container_of(w, struct linger_work, work);
lwork            2874 net/ceph/osd_client.c 	struct ceph_osd_linger_request *lreq = lwork->lreq;
lwork            2883 net/ceph/osd_client.c 	     __func__, lreq, lwork->notify.notify_id, lwork->notify.notifier_id,
lwork            2884 net/ceph/osd_client.c 	     lwork->notify.payload_len);
lwork            2885 net/ceph/osd_client.c 	lreq->wcb(lreq->data, lwork->notify.notify_id, lreq->linger_id,
lwork            2886 net/ceph/osd_client.c 		  lwork->notify.notifier_id, lwork->notify.payload,
lwork            2887 net/ceph/osd_client.c 		  lwork->notify.payload_len);
lwork            2890 net/ceph/osd_client.c 	ceph_msg_put(lwork->notify.msg);
lwork            2891 net/ceph/osd_client.c 	lwork_free(lwork);
lwork            2896 net/ceph/osd_client.c 	struct linger_work *lwork = container_of(w, struct linger_work, work);
lwork            2897 net/ceph/osd_client.c 	struct ceph_osd_linger_request *lreq = lwork->lreq;
lwork            2904 net/ceph/osd_client.c 	dout("%s lreq %p err %d\n", __func__, lreq, lwork->error.err);
lwork            2905 net/ceph/osd_client.c 	lreq->errcb(lreq->data, lreq->linger_id, lwork->error.err);
lwork            2908 net/ceph/osd_client.c 	lwork_free(lwork);
lwork            2913 net/ceph/osd_client.c 	struct linger_work *lwork;
lwork            2915 net/ceph/osd_client.c 	lwork = lwork_alloc(lreq, do_watch_error);
lwork            2916 net/ceph/osd_client.c 	if (!lwork) {
lwork            2921 net/ceph/osd_client.c 	lwork->error.err = lreq->last_error;
lwork            2922 net/ceph/osd_client.c 	lwork_queue(lwork);
lwork            4383 net/ceph/osd_client.c 	struct linger_work *lwork;
lwork            4449 net/ceph/osd_client.c 		lwork = lwork_alloc(lreq, do_watch_notify);
lwork            4450 net/ceph/osd_client.c 		if (!lwork) {
lwork            4455 net/ceph/osd_client.c 		lwork->notify.notify_id = notify_id;
lwork            4456 net/ceph/osd_client.c 		lwork->notify.notifier_id = notifier_id;
lwork            4457 net/ceph/osd_client.c 		lwork->notify.payload = payload;
lwork            4458 net/ceph/osd_client.c 		lwork->notify.payload_len = payload_len;
lwork            4459 net/ceph/osd_client.c 		lwork->notify.msg = ceph_msg_get(msg);
lwork            4460 net/ceph/osd_client.c 		lwork_queue(lwork);
lwork            4903 net/ceph/osd_client.c 		struct linger_work *lwork =
lwork            4908 net/ceph/osd_client.c 		if (time_before(lwork->queued_stamp, stamp))
lwork            4909 net/ceph/osd_client.c 			stamp = lwork->queued_stamp;