Lines Matching defs:reply
586 dout("%s greq %p request %p reply %p\n", __func__, req, req->request,
587 req->reply);
590 if (req->reply)
591 ceph_msg_put(req->reply);
656 ceph_msg_revoke_incoming(req->reply);
722 dout("get_generic_reply %lld got %p\n", tid, req->reply);
724 m = ceph_msg_get(req->reply);
727 * this reply because we only have one open connection
742 struct ceph_mon_statfs_reply *reply = msg->front.iov_base;
747 if (msg->front.iov_len != sizeof(*reply))
758 *req->u.st = reply->st; /* struct */
766 pr_err("corrupt statfs reply, tid %llu\n", tid);
789 req->reply = ceph_msg_new(CEPH_MSG_STATFS_REPLY, 64, GFP_NOFS, true);
790 if (!req->reply)
848 pr_err("corrupt mon_get_version reply, tid %llu\n", tid);
868 req->reply = ceph_msg_new(CEPH_MSG_MON_GET_VERSION_REPLY, 32, GFP_NOIO,
870 if (!req->reply)
897 * Send MMonGetVersion and wait for the reply.
989 req->reply = ceph_msg_new(CEPH_MSG_MON_COMMAND_ACK, 512, GFP_NOIO,
991 if (!req->reply)
1073 ceph_msg_revoke_incoming(req->reply);
1370 void *reply, int reply_len,
1378 ret = ceph_auth_handle_reply_more(monc->auth, reply, reply_len,
1391 u64 global_id, void *reply, int reply_len,
1403 reply, reply_len,
1510 * Older OSDs don't set reply tid even if the original