- unland b_fid to HEAD

[fs/lustre-release.git] / lustre / cmobd / cmobd_reint.c

diff --git a/lustre/cmobd/cmobd_reint.c b/lustre/cmobd/cmobd_reint.c
new file mode 100644 (file)
index 0000000..f68132f
--- /dev/null
+++ b/lustre/cmobd/cmobd_reint.c
@@ -0,0 +1,119 @@
+/* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
+ * vim:expandtab:shiftwidth=8:tabstop=8:
+ *
+ *  Copyright (c) 2002 Cluster File Systems, Inc. <info@clusterfs.com>
+ *
+ *   This file is part of Lustre, http://www.lustre.org.
+ *
+ *   Lustre is free software; you can redistribute it and/or
+ *   modify it under the terms of version 2 of the GNU General Public
+ *   License as published by the Free Software Foundation.
+ *
+ *   Lustre is distributed in the hope that it will be useful,
+ *   but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *   GNU General Public License for more details.
+ *
+ *   You should have received a copy of the GNU General Public License
+ *   along with Lustre; if not, write to the Free Software
+ *   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ */
+
+#define DEBUG_SUBSYSTEM S_CMOBD
+
+#include <linux/version.h>
+#include <linux/init.h>
+#include <linux/obd_support.h>
+#include <linux/lustre_lib.h>
+#include <linux/lustre_net.h>
+#include <linux/lustre_idl.h>
+#include <linux/obd_class.h>
+#include <linux/lustre_log.h>
+#include <linux/lustre_cmobd.h>
+#include <linux/lustre_fsfilt.h>
+#include <linux/lustre_smfs.h>
+
+#include "cmobd_internal.h"
+
+static int cmobd_reint_record(int opcode, struct obd_device *obd, char *record)
+{
+        int rc = 0;
+        
+        switch (opcode) {
+        case OST_CREATE:
+                rc = cmobd_reint_create(obd, record);
+                break;                       
+        case OST_SETATTR:
+                rc = cmobd_reint_setattr(obd, record);
+                break;                       
+        case OST_WRITE:
+                rc = cmobd_reint_write(obd, record);
+                break;                       
+        case MDS_REINT:
+                rc = cmobd_reint_mds(obd, record);
+                break;                       
+        default:
+                CERROR("unrecognized format %d\n", opcode);
+                rc = -EINVAL;
+                break; 
+        }
+        return rc;
+}  
+static int cmobd_reint_cb(struct llog_handle *llh, struct llog_rec_hdr *rec,
+                          void *data)
+{
+        struct obd_device *obd = (struct obd_device*)data;
+        char *buf, *pbuf;
+        int rc = 0, opcode;
+        
+        ENTRY;
+
+        if (!(llh->lgh_hdr->llh_flags & LLOG_F_IS_PLAIN)) {
+                CERROR("log is not plain log\n");
+                RETURN(-EINVAL);
+        }
+        if (rec->lrh_type != SMFS_UPDATE_REC)
+               RETURN(-EINVAL);
+
+        buf = (char *)(rec + 1);
+        rc = smfs_rec_unpack(NULL, buf, &pbuf, &opcode);
+        if (rc)
+                GOTO(out, rc);
+        rc = cmobd_reint_record(opcode, obd, pbuf); 
+        if (rc)
+                GOTO(out, rc);
+        /*delete this record*/
+        rc = LLOG_DEL_RECORD; 
+out:
+        RETURN(rc);
+}
+
+int cmobd_reintegrate(struct obd_device *obd)
+{
+        struct cache_manager_obd *cmobd = &obd->u.cmobd;
+        struct llog_ctxt *ctxt = NULL;
+        struct llog_handle *llh;
+        int val_size, rc = 0;
+        ENTRY;
+
+        /* XXX just fetch the reintegration log context from
+         * cache ost directly, use logid later ?? */
+        val_size = sizeof(ctxt);
+        rc = obd_get_info(cmobd->cm_cache_exp, strlen("reint_log") + 1,
+                          "reint_log", &val_size, &ctxt);
+        if (rc)
+                RETURN(rc);
+
+        /* use the already opened log handle instead of 
+         * reopen a new log handle */
+        llh = ctxt ? ctxt->loc_handle : NULL;
+        if (llh == NULL)
+                RETURN(-EFAULT);
+
+        /* FIXME should we insert a LLOG_GEN_REC before process log ? */
+        rc = llog_cat_process(llh, (llog_cb_t)cmobd_reint_cb, obd);
+
+        RETURN(rc);
+}
+
+