+
+int tgt_mk_reply_data(const struct lu_env *env,
+ struct lu_target *tgt,
+ struct tg_export_data *ted,
+ struct ptlrpc_request *req,
+ __u64 opdata,
+ struct thandle *th,
+ bool write_update,
+ __u64 transno)
+{
+ struct tg_reply_data *trd;
+ struct lsd_reply_data *lrd;
+ __u64 *pre_versions = NULL;
+ int rc;
+ struct tgt_session_info *tsi = NULL;
+
+ OBD_ALLOC_PTR(trd);
+ if (unlikely(trd == NULL))
+ RETURN(-ENOMEM);
+
+ if (env != NULL)
+ tsi = tgt_ses_info(env);
+
+ /* fill reply data information */
+ lrd = &trd->trd_reply;
+ lrd->lrd_transno = transno;
+ if (req != NULL) {
+ lrd->lrd_xid = req->rq_xid;
+ trd->trd_tag = lustre_msg_get_tag(req->rq_reqmsg);
+ lrd->lrd_client_gen = ted->ted_lcd->lcd_generation;
+ if (write_update) {
+ pre_versions = lustre_msg_get_versions(req->rq_repmsg);
+ lrd->lrd_result = th->th_result;
+ }
+ } else {
+ LASSERT(env != NULL);
+ LASSERT(tsi->tsi_xid != 0);
+
+ lrd->lrd_xid = tsi->tsi_xid;
+ lrd->lrd_result = tsi->tsi_result;
+ lrd->lrd_client_gen = tsi->tsi_client_gen;
+ }
+
+ lrd->lrd_data = opdata;
+ if (pre_versions) {
+ trd->trd_pre_versions[0] = pre_versions[0];
+ trd->trd_pre_versions[1] = pre_versions[1];
+ trd->trd_pre_versions[2] = pre_versions[2];
+ trd->trd_pre_versions[3] = pre_versions[3];
+ }
+
+ if (tsi && tsi->tsi_open_obj)
+ trd->trd_object = *lu_object_fid(&tsi->tsi_open_obj->do_lu);
+
+ rc = tgt_add_reply_data(env, tgt, ted, trd, req,
+ th, write_update);
+ if (rc < 0) {
+ OBD_FREE_PTR(trd);
+ if (rc == -EBADR)
+ rc = 0;
+ }
+ return rc;
+
+}
+EXPORT_SYMBOL(tgt_mk_reply_data);