X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fobdclass%2Fllog_ioctl.c;h=ca1877e3257a511ddcefd9a2f67fa8e2dd06dc71;hb=c5e8e49281ac04feca9ddbc13dc87acb5b20e57d;hp=3a6fb7d6be72c83a8a76d356e7ad7d176a3b477b;hpb=4d1f235006cb22689473472f1267fb36a9edb721;p=fs%2Flustre-release.git diff --git a/lustre/obdclass/llog_ioctl.c b/lustre/obdclass/llog_ioctl.c index 3a6fb7d..ca1877e 100644 --- a/lustre/obdclass/llog_ioctl.c +++ b/lustre/obdclass/llog_ioctl.c @@ -1,9 +1,37 @@ /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*- * vim:expandtab:shiftwidth=8:tabstop=8: * - * 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. + * GPL HEADER START + * + * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2 only, + * as published by the Free Software Foundation. + * + * This program 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 version 2 for more details (a copy is included + * in the LICENSE file that accompanied this code). + * + * You should have received a copy of the GNU General Public License + * version 2 along with this program; If not, see + * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf + * + * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara, + * CA 95054 USA or visit www.sun.com if you need additional information or + * have any questions. + * + * GPL HEADER END + */ +/* + * Copyright 2008 Sun Microsystems, Inc. All rights reserved + * Use is subject to license terms. + */ +/* + * This file is part of Lustre, http://www.lustre.org/ + * Lustre is a trademark of Sun Microsystems, Inc. */ #define DEBUG_SUBSYSTEM S_LOG @@ -12,20 +40,20 @@ #define EXPORT_SYMTAB #endif -#include -#include -#include -#include +#include +#include +#include #include "llog_internal.h" static int str2logid(struct llog_logid *logid, char *str, int len) { char *start, *end, *endp; - + + ENTRY; start = str; if (*start != '#') RETURN(-EINVAL); - + start++; if (start - str >= len - 1) RETURN(-EINVAL); @@ -34,7 +62,7 @@ static int str2logid(struct llog_logid *logid, char *str, int len) RETURN(-EINVAL); *end = '\0'; - logid->lgl_oid = simple_strtoull(start, &endp, 16); + logid->lgl_oid = simple_strtoull(start, &endp, 0); if (endp != end) RETURN(-EINVAL); @@ -46,7 +74,7 @@ static int str2logid(struct llog_logid *logid, char *str, int len) RETURN(-EINVAL); *end = '\0'; - logid->lgl_ogr = simple_strtoull(start, &endp, 16); + logid->lgl_ogr = simple_strtoull(start, &endp, 0); if (endp != end) RETURN(-EINVAL); @@ -60,7 +88,7 @@ static int str2logid(struct llog_logid *logid, char *str, int len) RETURN(0); } -static int llog_check_cb(struct llog_handle *handle, struct llog_rec_hdr *rec, +static int llog_check_cb(struct llog_handle *handle, struct llog_rec_hdr *rec, void *data) { struct obd_ioctl_data *ioc_data = (struct obd_ioctl_data *)data; @@ -68,12 +96,13 @@ static int llog_check_cb(struct llog_handle *handle, struct llog_rec_hdr *rec, static char *out; char *endp; int cur_index, rc = 0; - - cur_index = le32_to_cpu(rec->lrh_index); - + + ENTRY; + cur_index = rec->lrh_index; + if (ioc_data && (ioc_data->ioc_inllen1)) { l = 0; - remains = ioc_data->ioc_inllen4 + + remains = ioc_data->ioc_inllen4 + size_round(ioc_data->ioc_inllen1) + size_round(ioc_data->ioc_inllen2) + size_round(ioc_data->ioc_inllen3); @@ -90,60 +119,68 @@ static int llog_check_cb(struct llog_handle *handle, struct llog_rec_hdr *rec, if (to > 0 && cur_index > to) RETURN(-LLOG_EEMPTY); } - if (handle->lgh_hdr->llh_flags & cpu_to_le32(LLOG_F_IS_CAT)) { + if (handle->lgh_hdr->llh_flags & LLOG_F_IS_CAT) { struct llog_logid_rec *lir = (struct llog_logid_rec *)rec; - struct llog_handle *log_handle; - - if (rec->lrh_type != cpu_to_le32(LLOG_LOGID_MAGIC)) { - l = snprintf(out, remains, - "[index]: %05d [type]: %02x [len]: %04d failed\n", - cur_index, le32_to_cpu(rec->lrh_type), - le32_to_cpu(rec->lrh_len)); + struct llog_handle *log_handle; + + if (rec->lrh_type != LLOG_LOGID_MAGIC) { + l = snprintf(out, remains, "[index]: %05d [type]: " + "%02x [len]: %04d failed\n", + cur_index, rec->lrh_type, + rec->lrh_len); } if (handle->lgh_ctxt == NULL) RETURN(-EOPNOTSUPP); - llog_cat_id2handle(handle, &log_handle, &lir->lid_id); - rc = llog_process(log_handle, llog_check_cb, NULL); + rc = llog_cat_id2handle(handle, &log_handle, &lir->lid_id); + if (rc) { + CDEBUG(D_IOCTL, + "cannot find log #"LPX64"#"LPX64"#%08x\n", + lir->lid_id.lgl_oid, lir->lid_id.lgl_ogr, + lir->lid_id.lgl_ogen); + RETURN(rc); + } + rc = llog_process(log_handle, llog_check_cb, NULL, NULL); llog_close(log_handle); } else { - switch (le32_to_cpu(rec->lrh_type)) { + switch (rec->lrh_type) { case OST_SZ_REC: - case OST_RAID1_REC: + case OST_RAID1_REC: case MDS_UNLINK_REC: - case OBD_CFG_REC: - case PTL_CFG_REC: - case LLOG_HDR_MAGIC: { - l = snprintf(out, remains, - "[index]: %05d [type]: %02x [len]: %04d ok\n", - cur_index, le32_to_cpu(rec->lrh_type), - le32_to_cpu(rec->lrh_len)); + case MDS_SETATTR_REC: + case MDS_SETATTR64_REC: + case OBD_CFG_REC: + case LLOG_HDR_MAGIC: { + l = snprintf(out, remains, "[index]: %05d [type]: " + "%02x [len]: %04d ok\n", + cur_index, rec->lrh_type, + rec->lrh_len); out += l; remains -= l; if (remains <= 0) { - CERROR("not enough space for print log records\n"); + CERROR("no space to print log records\n"); RETURN(-LLOG_EEMPTY); } RETURN(0); } default: { - l = snprintf(out, remains, - "[index]: %05d [type]: %02x [len]: %04d failed\n", - cur_index, le32_to_cpu(rec->lrh_type), - le32_to_cpu(rec->lrh_len)); + l = snprintf(out, remains, "[index]: %05d [type]: " + "%02x [len]: %04d failed\n", + cur_index, rec->lrh_type, + rec->lrh_len); out += l; remains -= l; if (remains <= 0) { - CERROR("not enough space for print log records\n"); + CERROR("no space to print log records\n"); RETURN(-LLOG_EEMPTY); } RETURN(0); - } + } } } RETURN(rc); } -static int llog_print_cb(struct llog_handle *handle, struct llog_rec_hdr *rec, +static int llog_print_cb(struct llog_handle *handle, struct llog_rec_hdr *rec, void *data) { struct obd_ioctl_data *ioc_data = (struct obd_ioctl_data *)data; @@ -151,10 +188,11 @@ static int llog_print_cb(struct llog_handle *handle, struct llog_rec_hdr *rec, static char *out; char *endp; int cur_index; - + + ENTRY; if (ioc_data->ioc_inllen1) { l = 0; - remains = ioc_data->ioc_inllen4 + + remains = ioc_data->ioc_inllen4 + size_round(ioc_data->ioc_inllen1) + size_round(ioc_data->ioc_inllen2) + size_round(ioc_data->ioc_inllen3); @@ -168,28 +206,28 @@ static int llog_print_cb(struct llog_handle *handle, struct llog_rec_hdr *rec, ioc_data->ioc_inllen1 = 0; } - cur_index = le32_to_cpu(rec->lrh_index); + cur_index = rec->lrh_index; if (cur_index < from) RETURN(0); if (to > 0 && cur_index > to) RETURN(-LLOG_EEMPTY); - if (handle->lgh_hdr->llh_flags & cpu_to_le32(LLOG_F_IS_CAT)) { + if (handle->lgh_hdr->llh_flags & LLOG_F_IS_CAT) { struct llog_logid_rec *lir = (struct llog_logid_rec *)rec; - if (rec->lrh_type != cpu_to_le32(LLOG_LOGID_MAGIC)) { + if (rec->lrh_type != LLOG_LOGID_MAGIC) { CERROR("invalid record in catalog\n"); RETURN(-EINVAL); } l = snprintf(out, remains, - "[index]: %05d [logid]: #%llx#%llx#%08x\n", - cur_index, lir->lid_id.lgl_oid, + "[index]: %05d [logid]: #"LPX64"#"LPX64"#%08x\n", + cur_index, lir->lid_id.lgl_oid, lir->lid_id.lgl_ogr, lir->lid_id.lgl_ogen); } else { l = snprintf(out, remains, - "[index]: %05d [type]: %02x [len]: %04d\n", - cur_index, le32_to_cpu(rec->lrh_type), - le32_to_cpu(rec->lrh_len)); + "[index]: %05d [type]: %02x [len]: %04d\n", + cur_index, rec->lrh_type, + rec->lrh_len); } out += l; remains -= l; @@ -204,15 +242,16 @@ static int llog_remove_log(struct llog_handle *cat, struct llog_logid *logid) { struct llog_handle *log; int rc, index = 0; - + + ENTRY; down_write(&cat->lgh_lock); rc = llog_cat_id2handle(cat, &log, logid); if (rc) { - CDEBUG(D_IOCTL, "cannot find log #%0llx#%0llx#%08x\n", + CDEBUG(D_IOCTL, "cannot find log #"LPX64"#"LPX64"#%08x\n", logid->lgl_oid, logid->lgl_ogr, logid->lgl_ogen); GOTO(out, rc = -ENOENT); } - + index = log->u.phd.phd_cookie.lgc_index; LASSERT(index); rc = llog_destroy(log); @@ -220,6 +259,7 @@ static int llog_remove_log(struct llog_handle *cat, struct llog_logid *logid) CDEBUG(D_IOCTL, "cannot destroy log\n"); GOTO(out, rc); } + llog_cat_set_first_idx(cat, index); rc = llog_cancel_rec(cat, index); out: llog_free_handle(log); @@ -227,16 +267,18 @@ out: RETURN(rc); } -static int llog_delete_cb(struct llog_handle *handle, struct llog_rec_hdr *rec, - void *data) + +static int llog_delete_cb(struct llog_handle *handle, struct llog_rec_hdr *rec, + void *data) { struct llog_logid_rec *lir = (struct llog_logid_rec*)rec; int rc; - - if (rec->lrh_type != cpu_to_le32(LLOG_LOGID_MAGIC)) - return (-EINVAL); + + ENTRY; + if (rec->lrh_type != LLOG_LOGID_MAGIC) + RETURN (-EINVAL); rc = llog_remove_log(handle, &lir->lid_id); - + RETURN(rc); } @@ -246,14 +288,15 @@ int llog_ioctl(struct llog_ctxt *ctxt, int cmd, struct obd_ioctl_data *data) struct llog_logid logid; int err = 0; struct llog_handle *handle = NULL; - + + ENTRY; if (*data->ioc_inlbuf1 == '#') { err = str2logid(&logid, data->ioc_inlbuf1, data->ioc_inllen1); if (err) GOTO(out, err); err = llog_create(ctxt, &handle, &logid, NULL); if (err) - GOTO(out, err); + GOTO(out, err); } else if (*data->ioc_inlbuf1 == '$') { char *name = data->ioc_inlbuf1 + 1; err = llog_create(ctxt, &handle, NULL, name); @@ -264,38 +307,38 @@ int llog_ioctl(struct llog_ctxt *ctxt, int cmd, struct obd_ioctl_data *data) } err = llog_init_handle(handle, 0, NULL); - if (err) + if (err) GOTO(out_close, err = -ENOENT); - + switch (cmd) { case OBD_IOC_LLOG_INFO: { int l; - int remains = data->ioc_inllen2 + + int remains = data->ioc_inllen2 + size_round(data->ioc_inllen1); char *out = data->ioc_bulk; - l = snprintf(out, remains, - "logid: #%llx#%llx#%08x\n" + l = snprintf(out, remains, + "logid: #"LPX64"#"LPX64"#%08x\n" "flags: %x (%s)\n" "records count: %d\n" "last index: %d\n", handle->lgh_id.lgl_oid, handle->lgh_id.lgl_ogr, handle->lgh_id.lgl_ogen, - le32_to_cpu(handle->lgh_hdr->llh_flags), - le32_to_cpu(handle->lgh_hdr->llh_flags) & + handle->lgh_hdr->llh_flags, + handle->lgh_hdr->llh_flags & LLOG_F_IS_CAT ? "cat" : "plain", - le32_to_cpu(handle->lgh_hdr->llh_count), + handle->lgh_hdr->llh_count, handle->lgh_last_idx); out += l; remains -= l; - if (remains <= 0) + if (remains <= 0) CERROR("not enough space for log header info\n"); GOTO(out_close, err); } case OBD_IOC_LLOG_CHECK: { LASSERT(data->ioc_inllen1); - err = llog_process(handle, llog_check_cb, data); + err = llog_process(handle, llog_check_cb, data, NULL); if (err == -LLOG_EEMPTY) err = 0; GOTO(out_close, err); @@ -303,9 +346,11 @@ int llog_ioctl(struct llog_ctxt *ctxt, int cmd, struct obd_ioctl_data *data) case OBD_IOC_LLOG_PRINT: { LASSERT(data->ioc_inllen1); - err = llog_process(handle, llog_print_cb, data); + err = llog_process(handle, class_config_dump_handler,data,NULL); if (err == -LLOG_EEMPTY) err = 0; + else + err = llog_process(handle, llog_print_cb, data, NULL); GOTO(out_close, err); } @@ -313,17 +358,24 @@ int llog_ioctl(struct llog_ctxt *ctxt, int cmd, struct obd_ioctl_data *data) struct llog_cookie cookie; struct llog_logid plain; char *endp; - - if (!(handle->lgh_hdr->llh_flags & cpu_to_le32(LLOG_F_IS_CAT))) + + cookie.lgc_index = simple_strtoul(data->ioc_inlbuf3, &endp, 0); + if (*endp != '\0') GOTO(out_close, err = -EINVAL); - + + if (handle->lgh_hdr->llh_flags & LLOG_F_IS_CAT) { + down_write(&handle->lgh_lock); + err = llog_cancel_rec(handle, cookie.lgc_index); + up_write(&handle->lgh_lock); + GOTO(out_close, err); + } + err = str2logid(&plain, data->ioc_inlbuf2, data->ioc_inllen2); if (err) GOTO(out_close, err); cookie.lgc_lgl = plain; - cookie.lgc_index = simple_strtoul(data->ioc_inlbuf3, - &endp, 0); - if (*endp != '\0') + + if (!(handle->lgh_hdr->llh_flags & LLOG_F_IS_CAT)) GOTO(out_close, err = -EINVAL); err = llog_cat_cancel_records(handle, 1, &cookie); @@ -331,27 +383,35 @@ int llog_ioctl(struct llog_ctxt *ctxt, int cmd, struct obd_ioctl_data *data) } case OBD_IOC_LLOG_REMOVE: { struct llog_logid plain; - - if (!(handle->lgh_hdr->llh_flags & cpu_to_le32(LLOG_F_IS_CAT))) + + if (handle->lgh_hdr->llh_flags & LLOG_F_IS_PLAIN) { + err = llog_destroy(handle); + if (!err) + llog_free_handle(handle); + GOTO(out, err); + } + + if (!(handle->lgh_hdr->llh_flags & LLOG_F_IS_CAT)) GOTO(out_close, err = -EINVAL); - + if (data->ioc_inlbuf2) { /*remove indicate log from the catalog*/ - err = str2logid(&plain, data->ioc_inlbuf2, data->ioc_inllen2); + err = str2logid(&plain, data->ioc_inlbuf2, + data->ioc_inllen2); if (err) GOTO(out_close, err); err = llog_remove_log(handle, &plain); } else { /*remove all the log of the catalog*/ - llog_process(handle, llog_delete_cb, NULL); + llog_process(handle, llog_delete_cb, NULL, NULL); } GOTO(out_close, err); } } - + out_close: - if (handle->lgh_hdr && - handle->lgh_hdr->llh_flags & cpu_to_le32(LLOG_F_IS_CAT)) + if (handle->lgh_hdr && + handle->lgh_hdr->llh_flags & LLOG_F_IS_CAT) llog_cat_put(handle); else llog_close(handle); @@ -360,36 +420,35 @@ out: } EXPORT_SYMBOL(llog_ioctl); -int llog_catlog_list(struct obd_device *obd, int count, - struct obd_ioctl_data *data) +int llog_catalog_list(struct obd_device *obd, int count, + struct obd_ioctl_data *data) { int size, i; - struct llog_logid *idarray, *id; - char name[32] = "CATLIST"; + struct llog_catid *idarray; + struct llog_logid *id; + char name[32] = CATLIST; char *out; int l, remains, rc = 0; - + + ENTRY; size = sizeof(*idarray) * count; - - OBD_ALLOC(idarray, size); + + OBD_VMALLOC(idarray, size); if (!idarray) RETURN(-ENOMEM); - memset(idarray, 0, size); - - rc = llog_get_cat_list(obd, obd, name, count, idarray); - if (rc) { - OBD_FREE(idarray, size); - RETURN(rc); - } - + + mutex_down(&obd->obd_olg.olg_cat_processing); + rc = llog_get_cat_list(obd, name, 0, count, idarray); + if (rc) + GOTO(out, rc); + out = data->ioc_bulk; remains = data->ioc_inllen1; - id = idarray; for (i = 0; i < count; i++) { - l = snprintf(out, remains, - "catalog log: #%llx#%llx#%08x\n", + id = &idarray[i].lci_logid; + l = snprintf(out, remains, + "catalog log: #"LPX64"#"LPX64"#%08x\n", id->lgl_oid, id->lgl_ogr, id->lgl_ogen); - id++; out += l; remains -= l; if (remains <= 0) { @@ -397,8 +456,12 @@ int llog_catlog_list(struct obd_device *obd, int count, break; } } - OBD_FREE(idarray, size); - RETURN(0); +out: + /* release semaphore */ + mutex_up(&obd->obd_olg.olg_cat_processing); + + OBD_VFREE(idarray, size); + RETURN(rc); } -EXPORT_SYMBOL(llog_catlog_list); +EXPORT_SYMBOL(llog_catalog_list);