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,
  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 }