Whamcloud - gitweb
land b_eq on HEAD
[fs/lustre-release.git] / lustre / mds / mds_log.c
1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2  * vim:expandtab:shiftwidth=8:tabstop=8:
3  *
4  *  lustre/mds/mds_log.c
5  *
6  *  Copyright (c) 2001-2003 Cluster File Systems, Inc.
7  *   Author: Peter Braam <braam@clusterfs.com>
8  *   Author: Andreas Dilger <adilger@clusterfs.com>
9  *   Author: Phil Schwan <phil@clusterfs.com>
10  *
11  *   This file is part of Lustre, http://www.lustre.org.
12  *
13  *   Lustre is free software; you can redistribute it and/or
14  *   modify it under the terms of version 2 of the GNU General Public
15  *   License as published by the Free Software Foundation.
16  *
17  *   Lustre is distributed in the hope that it will be useful,
18  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
19  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
20  *   GNU General Public License for more details.
21  *
22  *   You should have received a copy of the GNU General Public License
23  *   along with Lustre; if not, write to the Free Software
24  *   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
25  */
26
27 #define DEBUG_SUBSYSTEM S_MDS
28
29 #include <linux/config.h>
30 #include <linux/module.h>
31 #include <linux/version.h>
32
33 #include <portals/list.h>
34 #include <linux/obd_class.h>
35 #include <linux/lustre_fsfilt.h>
36 #include <linux/lustre_commit_confd.h>
37
38 #include "mds_internal.h"
39
40 static int mds_llog_origin_add(struct llog_ctxt *ctxt,
41                         struct llog_rec_hdr *rec, struct lov_stripe_md *lsm,
42                         struct llog_cookie *logcookies, int numcookies)
43 {
44         struct obd_device *obd = ctxt->loc_obd;
45         struct obd_device *lov_obd = obd->u.mds.mds_osc_obd;
46         struct llog_ctxt *lctxt;
47         int rc;
48         ENTRY;
49
50         lctxt = llog_get_context(lov_obd, ctxt->loc_idx);
51         rc = llog_add(lctxt, rec, lsm, logcookies, numcookies);
52         RETURN(rc);
53 }
54
55 static int mds_llog_origin_connect(struct llog_ctxt *ctxt, int count,
56                                    struct llog_logid *logid,
57                                    struct llog_gen *gen)
58 {
59         struct obd_device *obd = ctxt->loc_obd;
60         struct obd_device *lov_obd = obd->u.mds.mds_osc_obd;
61         struct llog_ctxt *lctxt;
62         int rc;
63         ENTRY;
64
65         lctxt = llog_get_context(lov_obd, ctxt->loc_idx);
66         rc = llog_connect(lctxt, count, logid, gen);
67         RETURN(rc);
68 }
69
70 static int mds_llog_repl_cancel(struct llog_ctxt *ctxt, struct lov_stripe_md *lsm,
71                           int count, struct llog_cookie *cookies, int flags)
72 {
73         struct obd_device *obd = ctxt->loc_obd;
74         struct obd_device *lov_obd = obd->u.mds.mds_osc_obd;
75         struct llog_ctxt *lctxt;
76         int rc;
77         ENTRY;
78
79         lctxt = llog_get_context(lov_obd, ctxt->loc_idx);
80         rc = llog_cancel(lctxt, lsm, count, cookies,flags);
81         RETURN(rc);
82 }
83
84 int mds_log_op_unlink(struct obd_device *obd, struct inode *inode,
85                       struct lov_mds_md *lmm, int lmm_size,
86                       struct llog_cookie *logcookies, int cookies_size)
87 {
88         struct mds_obd *mds = &obd->u.mds;
89         struct lov_stripe_md *lsm = NULL;
90         struct llog_ctxt *ctxt;
91         int rc;
92         ENTRY;
93
94         if (IS_ERR(mds->mds_osc_obd))
95                 RETURN(PTR_ERR(mds->mds_osc_obd));
96
97         rc = obd_unpackmd(mds->mds_osc_exp, &lsm,
98                           lmm, lmm_size);
99         if (rc < 0)
100                 RETURN(rc);
101
102         ctxt = llog_get_context(obd, LLOG_UNLINK_ORIG_CTXT);
103         rc = llog_add(ctxt, NULL, lsm, logcookies,
104                       cookies_size / sizeof(struct llog_cookie));
105
106         obd_free_memmd(mds->mds_osc_exp, &lsm);
107
108         RETURN(rc);
109 }
110
111 static struct llog_operations mds_unlink_orig_logops = {
112         lop_add:        mds_llog_origin_add,
113         lop_connect:    mds_llog_origin_connect,
114 };
115
116 static struct llog_operations mds_size_repl_logops = {
117         lop_cancel:     mds_llog_repl_cancel
118 };
119
120 int mds_llog_init(struct obd_device *obd, struct obd_device *tgt,
121                   int count, struct llog_logid *logid)
122 {
123         struct obd_device *lov_obd = obd->u.mds.mds_osc_obd;
124         int rc;
125         ENTRY;
126
127         rc = llog_setup(obd, LLOG_UNLINK_ORIG_CTXT, tgt, 0, NULL,
128                         &mds_unlink_orig_logops);
129         if (rc)
130                 RETURN(rc);
131
132         rc = llog_setup(obd, LLOG_SIZE_REPL_CTXT, tgt, 0, NULL,
133                         &mds_size_repl_logops);
134         if (rc)
135                 RETURN(rc);
136
137         rc = obd_llog_init(lov_obd, tgt, count, logid);
138         if (rc)
139                 CERROR("error lov_llog_init\n");
140
141         RETURN(rc);
142 }
143
144 int mds_llog_finish(struct obd_device *obd, int count)
145 {
146         struct obd_device *lov_obd = obd->u.mds.mds_osc_obd;
147         int rc;
148         ENTRY;
149
150         rc = llog_cleanup(llog_get_context(obd, LLOG_UNLINK_ORIG_CTXT));
151         if (rc)
152                 RETURN(rc);
153
154         rc = llog_cleanup(llog_get_context(obd, LLOG_SIZE_REPL_CTXT));
155         if (rc)
156                 RETURN(rc);
157
158         rc = obd_llog_finish(lov_obd, count);
159         if (rc)
160                 CERROR("error lov_llog_finish\n");
161
162         RETURN(rc);
163 }