Whamcloud - gitweb
a9f6737ecf7340b345c2edd6b8aebde8fc481262
[fs/lustre-release.git] / lustre / mgc / libmgc.c
1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2  * vim:expandtab:shiftwidth=8:tabstop=8:
3  *
4  * GPL HEADER START
5  *
6  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
7  *
8  * This program is free software; you can redistribute it and/or modify
9  * it under the terms of the GNU General Public License version 2 only,
10  * as published by the Free Software Foundation.
11  *
12  * This program is distributed in the hope that it will be useful, but
13  * WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15  * General Public License version 2 for more details (a copy is included
16  * in the LICENSE file that accompanied this code).
17  *
18  * You should have received a copy of the GNU General Public License
19  * version 2 along with this program; If not, see
20  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
21  *
22  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
23  * CA 95054 USA or visit www.sun.com if you need additional information or
24  * have any questions.
25  *
26  * GPL HEADER END
27  */
28 /*
29  * Copyright  2008 Sun Microsystems, Inc. All rights reserved
30  * Use is subject to license terms.
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/mgc/libmgc.c
37  *
38  * Lustre Management Client
39  * Author: Nathan Rutman <nathan@clusterfs.com>
40  */
41
42 /* Minimal MGC for liblustre: only used to read the config log from the MGS
43    at setup time, no updates. */
44  
45 #ifndef EXPORT_SYMTAB
46 # define EXPORT_SYMTAB
47 #endif
48 #define DEBUG_SUBSYSTEM S_MGC
49
50 #include <liblustre.h>
51
52 #include <obd_class.h>
53 #include <lustre_dlm.h>
54 #include <lustre_log.h>
55 #include <lustre_fsfilt.h>
56 #include <lustre_disk.h>
57
58
59 static int mgc_setup(struct obd_device *obd, struct lustre_cfg *lcfg)
60 {
61         int rc;
62         ENTRY;
63
64         ptlrpcd_addref();
65
66         rc = client_obd_setup(obd, lcfg);
67         if (rc)
68                 GOTO(err_decref, rc);
69
70         rc = obd_llog_init(obd, &obd->obd_olg, obd, 0, NULL, NULL);
71         if (rc) {
72                 CERROR("failed to setup llogging subsystems\n");
73                 GOTO(err_cleanup, rc);
74         }
75
76         RETURN(rc);
77
78 err_cleanup:
79         client_obd_cleanup(obd);
80 err_decref:
81         ptlrpcd_decref();
82         RETURN(rc);
83 }
84
85 static int mgc_precleanup(struct obd_device *obd, enum obd_cleanup_stage stage)
86 {
87         int rc = 0;
88         ENTRY;
89
90         switch (stage) {
91         case OBD_CLEANUP_EARLY: 
92         case OBD_CLEANUP_EXPORTS:
93                 rc = obd_llog_finish(obd, 0);
94                 if (rc != 0)
95                         CERROR("failed to cleanup llogging subsystems\n");
96                 break;
97         }
98         RETURN(rc);
99 }
100
101 static int mgc_cleanup(struct obd_device *obd)
102 {
103         struct client_obd *cli = &obd->u.cli;
104         int rc;
105         ENTRY;
106
107         LASSERT(cli->cl_mgc_vfsmnt == NULL);
108
109         ptlrpcd_decref();
110
111         rc = client_obd_cleanup(obd);
112         RETURN(rc);
113 }
114
115 static int mgc_llog_init(struct obd_device *obd, struct obd_llog_group *olg,
116                          struct obd_device *tgt, int count, 
117                          struct llog_catid *logid, struct obd_uuid *uuid)
118 {
119         struct llog_ctxt *ctxt;
120         int rc;
121         ENTRY;
122
123         LASSERT(olg == &obd->obd_olg);
124         rc = llog_setup(obd, olg, LLOG_CONFIG_REPL_CTXT, tgt, 0, NULL,
125                         &llog_client_ops);
126         if (rc == 0) {
127                 ctxt = llog_group_get_ctxt(olg, LLOG_CONFIG_REPL_CTXT);
128                 llog_initiator_connect(ctxt);
129                 llog_ctxt_put(ctxt);
130         }
131
132         RETURN(rc);
133 }
134
135 static int mgc_llog_finish(struct obd_device *obd, int count)
136 {
137         int rc;
138         ENTRY;
139
140         rc = llog_cleanup(llog_get_context(obd, LLOG_CONFIG_REPL_CTXT));
141
142         RETURN(rc);
143 }
144
145 struct obd_ops mgc_obd_ops = {
146         .o_owner        = THIS_MODULE,
147         .o_setup        = mgc_setup,
148         .o_precleanup   = mgc_precleanup,
149         .o_cleanup      = mgc_cleanup,
150         .o_add_conn     = client_import_add_conn,
151         .o_del_conn     = client_import_del_conn,
152         .o_connect      = client_connect_import,
153         .o_disconnect   = client_disconnect_export,
154         .o_llog_init    = mgc_llog_init,
155         .o_llog_finish  = mgc_llog_finish,
156 };
157
158 int __init mgc_init(void)
159 {
160         return class_register_type(&mgc_obd_ops, NULL, 
161                                    NULL, LUSTRE_MGC_NAME, NULL);
162 }