Lines Matching refs:reply
69 * mds reply parsing
285 * parse a normal reply, which may contain a (dir+)dentry and/or a
523 /* Malformed reply? */
574 * parse entire mds reply
2009 * after dropping auth caps. It doesn't hurt because reply
3049 /* only abort if we didn't race with a real reply */
3117 * Handle mds reply.
3119 * We take the session mutex and parse and process the reply immediately.
3128 struct ceph_mds_reply_info_parsed *rinfo; /* parsed reply info */
3135 pr_err("mdsc_handle_reply got corrupt (short) reply\n");
3163 pr_warn("got a dup %s reply on %llu from mds%d\n",
3222 dout("got safe reply %llu, mds%d\n", tid, mds);
3242 pr_err("mdsc_handle_reply got corrupt reply mds%d(tid:%lld)\n", mds, tid);
3299 dout("reply arrived after request %lld was aborted\n", tid);
3340 goto out; /* dup reply? */
3615 struct ceph_msg *reply;
3632 reply = ceph_msg_new2(CEPH_MSG_CLIENT_RECONNECT, 0, 1, GFP_NOFS, false);
3633 if (!reply)
3668 reply->hdr.version = cpu_to_le16(5);
3669 reply->hdr.compat_version = cpu_to_le16(4);
3671 reply->hdr.data_len = cpu_to_le32(recon_state->pagelist->length);
3672 ceph_msg_data_add_pagelist(reply, recon_state->pagelist);
3674 ceph_con_send(&recon_state->session->s_con, reply);
3683 ceph_msg_put(reply);
3977 struct ceph_msg *reply;
3991 reply = ceph_msg_new2(CEPH_MSG_CLIENT_RECONNECT, 0, 1, GFP_NOFS, false);
3992 if (!reply)
4112 reply->hdr.version = cpu_to_le16(recon_state.msg_version);
4114 reply->hdr.compat_version = cpu_to_le16(4);
4116 reply->hdr.data_len = cpu_to_le32(recon_state.pagelist->length);
4117 ceph_msg_data_add_pagelist(reply, recon_state.pagelist);
4119 ceph_con_send(&session->s_con, reply);
4132 ceph_msg_put(reply);
4467 * If the sequence is incremented while we're waiting on a REQUEST_CLOSE reply,
4712 * wait for reply handlers to drop their request refs and