Lines Matching refs:notify
399 ceph_osd_data_release(&op->notify.request_data); in osd_req_op_data_release()
400 ceph_osd_data_release(&op->notify.response_data); in osd_req_op_data_release()
1012 dst->notify.cookie = cpu_to_le64(src->notify.cookie); in osd_req_encode_op()
2004 &op->notify.request_data); in setup_request_data()
2006 &op->notify.response_data); in setup_request_data()
2823 } notify; member
2883 __func__, lreq, lwork->notify.notify_id, lwork->notify.notifier_id, in do_watch_notify()
2884 lwork->notify.payload_len); in do_watch_notify()
2885 lreq->wcb(lreq->data, lwork->notify.notify_id, lreq->linger_id, in do_watch_notify()
2886 lwork->notify.notifier_id, lwork->notify.payload, in do_watch_notify()
2887 lwork->notify.payload_len); in do_watch_notify()
2890 ceph_msg_put(lwork->notify.msg); in do_watch_notify()
2946 osd_req_op_data(req, 0, notify, response_data); in linger_commit_cb()
3111 lreq->reg_req->r_ops[0].notify.cookie = lreq->linger_id; in linger_submit()
4455 lwork->notify.notify_id = notify_id; in handle_watch_notify()
4456 lwork->notify.notifier_id = notifier_id; in handle_watch_notify()
4457 lwork->notify.payload = payload; in handle_watch_notify()
4458 lwork->notify.payload_len = payload_len; in handle_watch_notify()
4459 lwork->notify.msg = ceph_msg_get(msg); in handle_watch_notify()
4787 op->notify.cookie = cookie; in osd_req_op_notify_init()
4802 ceph_osd_data_pagelist_init(&op->notify.request_data, pl); in osd_req_op_notify_init()
4866 ceph_osd_data_pages_init(osd_req_op_data(lreq->reg_req, 0, notify, in ceph_osdc_notify()