lustre/ofd/ofd_trans.c

   1 /*
   2  * GPL HEADER START
   3  *
   4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   5  *
   6  * This program is free software; you can redistribute it and/or modify
   7  * it under the terms of the GNU General Public License version 2 only,
   8  * as published by the Free Software Foundation.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License version 2 for more details (a copy is included
  14  * in the LICENSE file that accompanied this code).
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * version 2 along with this program; If not, see
  18  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
  19  *
  20  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
  21  * CA 95054 USA or visit www.sun.com if you need additional information or
  22  * have any questions.
  23  *
  24  * GPL HEADER END
  25  */
  26 /*
  27  * Copyright (c) 2009, 2010, Oracle and/or its affiliates. All rights reserved.
  28  * Use is subject to license terms.
  29  *
  30  * Copyright (c) 2012, 2013, Intel Corporation.
  31  */
  32 /*
  33  * This file is part of Lustre, http://www.lustre.org/
  34  * Lustre is a trademark of Sun Microsystems, Inc.
  35  *
  36  * lustre/ofd/ofd_recovery.c
  37  *
  38  * Author: Alex Zhuravlev <bzzz@whamcloud.com>
  39  * Author: Mikhail Pershin <tappro@whamcloud.com>
  40  */
  41
  42 #define DEBUG_SUBSYSTEM S_FILTER
  43
  44 #include "ofd_internal.h"
  45
  46 struct thandle *ofd_trans_create(const struct lu_env *env,
  47                                  struct ofd_device *ofd)
  48 {
  49         struct ofd_thread_info  *info = ofd_info(env);
  50         struct thandle          *th;
  51
  52         LASSERT(info);
  53
  54         th = dt_trans_create(env, ofd->ofd_osd);
  55         if (IS_ERR(th))
  56                 return th;
  57
  58         /* export can require sync operations */
  59         if (info->fti_exp != NULL)
  60                 th->th_sync |= info->fti_exp->exp_need_sync;
  61         return th;
  62 }
  63
  64 int ofd_trans_start(const struct lu_env *env, struct ofd_device *ofd,
  65                     struct ofd_object *obj, struct thandle *th)
  66 {
  67         struct ofd_thread_info  *info = ofd_info(env);
  68         int                      rc;
  69
  70         if (env->le_ses == NULL || info->fti_exp == NULL)
  71                 return 0;
  72
  73         /* declare last_rcvd update */
  74         rc = dt_declare_record_write(env, ofd->ofd_lut.lut_last_rcvd,
  75                                      sizeof(struct lsd_client_data),
  76                                      info->fti_exp->exp_target_data.ted_lr_off,
  77                                      th);
  78         if (rc)
  79                 RETURN(rc);
  80
  81         /* declare last_rcvd header update */
  82         rc = dt_declare_record_write(env, ofd->ofd_lut.lut_last_rcvd,
  83                                      sizeof(ofd->ofd_lut.lut_lsd), 0, th);
  84         if (rc)
  85                 RETURN(rc);
  86
  87         /* version change is required for this object */
  88         if (obj) {
  89                 ofd_info(env)->fti_obj = obj;
  90                 rc = dt_declare_version_set(env, ofd_object_child(obj), th);
  91                 if (rc)
  92                         RETURN(rc);
  93         }
  94
  95         return dt_trans_start(env, ofd->ofd_osd, th);
  96 }
  97
  98 void ofd_trans_stop(const struct lu_env *env, struct ofd_device *ofd,
  99                     struct thandle *th, int rc)
 100 {
 101         th->th_result = rc;
 102         dt_trans_stop(env, ofd->ofd_osd, th);
 103 }
 104
 105 /* Update last_rcvd records with the latest transaction data */
 106 int ofd_txn_stop_cb(const struct lu_env *env, struct thandle *txn,
 107                     void *cookie)
 108 {
 109         struct ofd_device       *ofd = cookie;
 110         struct ofd_thread_info  *info = ofd_info(env);
 111         struct dt_object        *obj;
 112         struct tgt_session_info *tsi;
 113         bool                     echo_client;
 114         int                      rc;
 115
 116         ENTRY;
 117
 118         if (env->le_ses == NULL || info->fti_exp == NULL)
 119                 RETURN(0);
 120
 121         tsi = tgt_ses_info(env);
 122
 123         echo_client = (tgt_ses_req(tsi) == NULL);
 124
 125         if (info->fti_has_trans && !echo_client) {
 126                 if (info->fti_mult_trans == 0) {
 127                         CERROR("More than one transaction "LPU64"\n",
 128                                info->fti_transno);
 129                         RETURN(0);
 130                 }
 131                 /* we need another transno to be assigned */
 132                 info->fti_transno = 0;
 133         } else if (txn->th_result == 0) {
 134                 info->fti_has_trans = 1;
 135         }
 136
 137         /** VBR: set new versions */
 138         if (info->fti_obj != NULL)
 139                 obj = ofd_object_child(info->fti_obj);
 140         else
 141                 obj = NULL;
 142
 143         if (unlikely(echo_client)) /* echo client special case */
 144                 rc = tgt_last_rcvd_update_echo(env, &ofd->ofd_lut, obj, txn,
 145                                                tsi->tsi_exp);
 146         else
 147                 rc = tgt_last_rcvd_update(env, &ofd->ofd_lut, obj, 0, txn,
 148                                           tgt_ses_req(tsi));
 149         RETURN(rc);
 150 }
 151