Lines Matching +refs:get +refs:reply
587 req->reply); in DEFINE_RB_FUNCS()
590 if (req->reply) in DEFINE_RB_FUNCS()
591 ceph_msg_put(req->reply); in DEFINE_RB_FUNCS()
656 ceph_msg_revoke_incoming(req->reply); in __finish_generic_request()
722 dout("get_generic_reply %lld got %p\n", tid, req->reply); in get_generic_reply()
724 m = ceph_msg_get(req->reply); in get_generic_reply()
742 struct ceph_mon_statfs_reply *reply = msg->front.iov_base; in handle_statfs_reply() local
747 if (msg->front.iov_len != sizeof(*reply)) in handle_statfs_reply()
758 *req->u.st = reply->st; /* struct */ in handle_statfs_reply()
789 req->reply = ceph_msg_new(CEPH_MSG_STATFS_REPLY, 64, GFP_NOFS, true); in ceph_monc_do_statfs()
790 if (!req->reply) in ceph_monc_do_statfs()
868 req->reply = ceph_msg_new(CEPH_MSG_MON_GET_VERSION_REPLY, 32, GFP_NOIO, in __ceph_monc_get_version()
870 if (!req->reply) in __ceph_monc_get_version()
989 req->reply = ceph_msg_new(CEPH_MSG_MON_COMMAND_ACK, 512, GFP_NOIO, in do_mon_command_vargs()
991 if (!req->reply) in do_mon_command_vargs()
1073 ceph_msg_revoke_incoming(req->reply); in __resend_generic_request()
1370 void *reply, int reply_len, in mon_handle_auth_reply_more() argument
1378 ret = ceph_auth_handle_reply_more(monc->auth, reply, reply_len, in mon_handle_auth_reply_more()
1391 u64 global_id, void *reply, int reply_len, in mon_handle_auth_done() argument
1403 reply, reply_len, in mon_handle_auth_done()
1577 .get = mon_get_con,