Lines Matching defs:notify
426 ceph_osd_data_release(&op->notify.request_data);
427 ceph_osd_data_release(&op->notify.response_data);
923 * prot_ver, timeout and notify payload (may be empty) should already be
932 op->notify.cookie = cookie;
934 ceph_osd_data_pagelist_init(&op->notify.request_data, request_pl);
1022 dst->notify.cookie = cpu_to_le64(src->notify.cookie);
2124 &op->notify.request_data);
2126 &op->notify.response_data);
2780 * lingering requests, watch/notify v2 infrastructure
2955 } notify;
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);
3084 osd_req_op_data(req, 0, notify, response_data);
3182 osd_req_op_data(req, 0, notify, response_data),
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);
4993 dout("lreq %p failed to initiate notify %d\n", lreq, ret);
5151 * Call all pending notify callbacks - for use after a watch is
5288 osdc->notify_wq = create_singlethread_workqueue("ceph-watch-notify");