Lines Matching defs:lwork
2965 struct linger_work *lwork;
2967 lwork = kzalloc(sizeof(*lwork), GFP_NOIO);
2968 if (!lwork)
2971 INIT_WORK(&lwork->work, workfn);
2972 INIT_LIST_HEAD(&lwork->pending_item);
2973 lwork->lreq = linger_get(lreq);
2975 return lwork;
2978 static void lwork_free(struct linger_work *lwork)
2980 struct ceph_osd_linger_request *lreq = lwork->lreq;
2983 list_del(&lwork->pending_item);
2987 kfree(lwork);
2990 static void lwork_queue(struct linger_work *lwork)
2992 struct ceph_osd_linger_request *lreq = lwork->lreq;
2996 WARN_ON(!list_empty(&lwork->pending_item));
2998 lwork->queued_stamp = jiffies;
2999 list_add_tail(&lwork->pending_item, &lreq->pending_lworks);
3000 queue_work(osdc->notify_wq, &lwork->work);
3005 struct linger_work *lwork = container_of(w, struct linger_work, work);
3006 struct ceph_osd_linger_request *lreq = lwork->lreq;
3015 __func__, lreq, lwork->notify.notify_id, lwork->notify.notifier_id,
3016 lwork->notify.payload_len);
3017 lreq->wcb(lreq->data, lwork->notify.notify_id, lreq->linger_id,
3018 lwork->notify.notifier_id, lwork->notify.payload,
3019 lwork->notify.payload_len);
3022 ceph_msg_put(lwork->notify.msg);
3023 lwork_free(lwork);
3028 struct linger_work *lwork = container_of(w, struct linger_work, work);
3029 struct ceph_osd_linger_request *lreq = lwork->lreq;
3036 dout("%s lreq %p err %d\n", __func__, lreq, lwork->error.err);
3037 lreq->errcb(lreq->data, lreq->linger_id, lwork->error.err);
3040 lwork_free(lwork);
3045 struct linger_work *lwork;
3047 lwork = lwork_alloc(lreq, do_watch_error);
3048 if (!lwork) {
3049 pr_err("failed to allocate error-lwork\n");
3053 lwork->error.err = lreq->last_error;
3054 lwork_queue(lwork);
4579 struct linger_work *lwork;
4645 lwork = lwork_alloc(lreq, do_watch_notify);
4646 if (!lwork) {
4647 pr_err("failed to allocate notify-lwork\n");
4651 lwork->notify.notify_id = notify_id;
4652 lwork->notify.notifier_id = notifier_id;
4653 lwork->notify.payload = payload;
4654 lwork->notify.payload_len = payload_len;
4655 lwork->notify.msg = ceph_msg_get(msg);
4656 lwork_queue(lwork);
5017 struct linger_work *lwork =
5022 if (time_before(lwork->queued_stamp, stamp))
5023 stamp = lwork->queued_stamp;