Whamcloud - gitweb
a14afe2c4ad8d94a8630c45c1c29b51ad08cef13
[fs/lustre-release.git] / 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