Whamcloud - gitweb
Branch: HEAD
[fs/lustre-release.git] / lustre / ptlbd / server.c
1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2  * vim:expandtab:shiftwidth=8:tabstop=8:
3  *
4  *  Copyright (c) 2002, 2003 Cluster File Systems, Inc.
5  *   Author: Zach Brown <zab@clusterfs.com>
6  *
7  *   This file is part of Lustre, http://www.lustre.org.
8  *
9  *   Lustre is free software; you can redistribute it and/or
10  *   modify it under the terms of version 2 of the GNU General Public
11  *   License as published by the Free Software Foundation.
12  *
13  *   Lustre is distributed in the hope that it will be useful,
14  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
15  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
16  *   GNU General Public License for more details.
17  *
18  *   You should have received a copy of the GNU General Public License
19  *   along with Lustre; if not, write to the Free Software
20  *   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
21  */
22
23 #include <linux/version.h>
24 #include <linux/module.h>
25 #include <linux/fs.h>
26
27 #define DEBUG_SUBSYSTEM S_PTLBD
28
29 #include <linux/obd_support.h>
30 #include <linux/obd_class.h>
31 #include <linux/lustre_debug.h>
32 #include <linux/lprocfs_status.h>
33 #include <linux/obd_ptlbd.h>
34
35 #define BACKING_FILE    "/tmp/ptlbd-backing-file-la-la-la"
36
37 static int ptlbd_sv_already_setup = 1;
38
39 static int ptlbd_sv_attach(struct obd_device *obd, obd_count len, void *buf)
40 {
41         struct lprocfs_static_vars lvars;
42
43         lprocfs_init_vars(ptlbd_sv, &lvars);
44         return lprocfs_obd_attach(obd, lvars.obd_vars);
45 }
46
47 static int ptlbd_sv_detach(struct obd_device *obd)
48 {
49         return lprocfs_obd_detach(obd);
50 }
51
52 static int ptlbd_sv_setup(struct obd_device *obd, obd_count len, void *buf)
53 {
54         struct ptlbd_obd *ptlbd = &obd->u.ptlbd;
55         int rc;
56         ENTRY;
57
58         ptlbd->filp = filp_open(BACKING_FILE,
59                                         O_RDWR|O_CREAT|O_LARGEFILE, 0600);
60
61         if ( IS_ERR(ptlbd->filp) )
62                 RETURN(PTR_ERR(ptlbd->filp));
63
64         ptlbd->ptlbd_service =
65                 ptlrpc_init_svc(PTLBD_NBUFS, PTLBD_BUFSIZE, PTLBD_MAXREQSIZE,
66                                 PTLBD_REQUEST_PORTAL, PTLBD_REPLY_PORTAL, 30000,
67                                 ptlbd_handle, "ptlbd_sv",
68                                 obd->obd_proc_entry);
69
70         if (ptlbd->ptlbd_service == NULL)
71                 GOTO(out_filp, rc = -ENOMEM);
72
73         rc = ptlrpc_start_n_threads(obd, ptlbd->ptlbd_service, 1, "ptldb");
74         if (rc != 0)
75                 GOTO(out_thread, rc);
76
77         ptlbd_sv_already_setup = 1;
78
79         RETURN(0);
80
81 out_thread:
82         ptlrpc_unregister_service(ptlbd->ptlbd_service);
83 out_filp:
84         filp_close(ptlbd->filp, NULL);
85         RETURN(rc);
86 }
87
88 static int ptlbd_sv_cleanup(struct obd_device *obd, int flags)
89 {
90         struct ptlbd_obd *ptlbd = &obd->u.ptlbd;
91         ENTRY;
92
93         /* XXX check for state */
94         ptlrpc_stop_all_threads(ptlbd->ptlbd_service);
95         ptlrpc_unregister_service(ptlbd->ptlbd_service);
96         if ( ! IS_ERR(ptlbd->filp) )
97                 filp_close(ptlbd->filp, NULL);
98
99         ptlbd_sv_already_setup = 0;
100         RETURN(0);
101 }
102
103 static int ptlbd_connect(struct lustre_handle *conn, struct obd_device *obd,
104                 struct obd_uuid *cluuid, unsigned long connect_flags)
105 {
106         int rc;
107
108         rc = class_connect(conn, obd, cluuid);
109         RETURN(rc);
110 }
111
112 static struct obd_ops ptlbd_sv_obd_ops = {
113         .o_owner        = THIS_MODULE,
114         .o_attach       = ptlbd_sv_attach,
115         .o_detach       = ptlbd_sv_detach,
116         .o_setup        = ptlbd_sv_setup,
117         .o_cleanup      = ptlbd_sv_cleanup,
118         .o_connect      = ptlbd_connect,
119         .o_disconnect   = class_disconnect,
120 };
121
122 static struct lprocfs_vars lprocfs_obd_vars[] = { {0} };
123 static struct lprocfs_vars lprocfs_module_vars[] = { {0} };
124 LPROCFS_INIT_VARS(ptlbd_sv, lprocfs_module_vars, lprocfs_obd_vars)
125
126 int ptlbd_sv_init(void)
127 {
128         struct lprocfs_static_vars lvars;
129
130         lprocfs_init_vars(ptlbd_sv,&lvars);
131         return class_register_type(&ptlbd_sv_obd_ops, NULL, lvars.module_vars,
132                                    OBD_PTLBD_SV_DEVICENAME);
133 }
134
135 void ptlbd_sv_exit(void)
136 {
137         class_unregister_type(OBD_PTLBD_SV_DEVICENAME);
138 }