X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lustre%2Flmv%2Flmv_objmgr.c;h=4c2ef10702997ea33742a6ee6c6bb44997679775;hp=c39574860ef179f40e773413a0baf1e2a0cffc57;hb=89f9a5bced24ecb7c84040a1ed88dcef4384f7c6;hpb=30f882bb273d5583aae1a41c141b52b85613ce70 diff --git a/lustre/lmv/lmv_objmgr.c b/lustre/lmv/lmv_objmgr.c index c395748..4c2ef10 100644 --- a/lustre/lmv/lmv_objmgr.c +++ b/lustre/lmv/lmv_objmgr.c @@ -48,26 +48,41 @@ #include #include "lmv_internal.h" -LIST_HEAD(lmv_obj_list); -spinlock_t lmv_obj_list_lock = SPIN_LOCK_UNLOCKED; +/* objects cache. */ +extern kmem_cache_t *obj_cache; +extern atomic_t obj_cache_count; -/* creates new obj on passed @fid and @mea. */ -static struct lmv_obj * -__lmv_alloc_obj(struct obd_device *obd, struct ll_fid *fid, - struct mea *mea) +/* object list and its guard. */ +static LIST_HEAD(obj_list); +static spinlock_t obj_list_lock = SPIN_LOCK_UNLOCKED; + +/* creates new obj on passed @id and @mea. */ +struct lmv_obj * +lmv_alloc_obj(struct obd_device *obd, + struct lustre_id *id, + struct mea *mea) { int i; struct lmv_obj *obj; unsigned int obj_size; struct lmv_obd *lmv = &obd->u.lmv; - OBD_ALLOC(obj, sizeof(*obj)); + LASSERT(mea->mea_magic == MEA_MAGIC_LAST_CHAR + || mea->mea_magic == MEA_MAGIC_ALL_CHARS); + + OBD_SLAB_ALLOC(obj, obj_cache, GFP_NOFS, + sizeof(*obj)); if (!obj) return NULL; + atomic_inc(&obj_cache_count); + + obj->id = *id; obj->obd = obd; - obj->fid = *fid; - + obj->state = 0; + obj->hashtype = mea->mea_magic; + + init_MUTEX(&obj->guard); atomic_set(&obj->count, 0); obj->objcount = mea->mea_count; @@ -80,13 +95,13 @@ __lmv_alloc_obj(struct obd_device *obd, struct ll_fid *fid, memset(obj->objs, 0, obj_size); - /* put all fids in */ + /* put all ids in */ for (i = 0; i < mea->mea_count; i++) { - CDEBUG(D_OTHER, "subobj %lu/%lu/%lu\n", - (unsigned long)mea->mea_fids[i].mds, - (unsigned long)mea->mea_fids[i].id, - (unsigned long)mea->mea_fids[i].generation); - obj->objs[i].fid = mea->mea_fids[i]; + CDEBUG(D_OTHER, "subobj "DLID4"\n", + OLID4(&mea->mea_ids[i])); + obj->objs[i].id = mea->mea_ids[i]; + LASSERT(id_ino(&obj->objs[i].id)); + LASSERT(id_fid(&obj->objs[i].id)); } return obj; @@ -96,209 +111,304 @@ err_obj: return NULL; } -/* destroys passed @obj. */ -static void -__lmv_free_obj(struct lmv_obj *obj) +/* destroy passed @obj. */ +void +lmv_free_obj(struct lmv_obj *obj) { unsigned int obj_size; struct lmv_obd *lmv = &obj->obd->u.lmv; + LASSERT(!atomic_read(&obj->count)); + obj_size = sizeof(struct lmv_inode) * lmv->desc.ld_tgt_count; OBD_FREE(obj->objs, obj_size); - OBD_FREE(obj, sizeof(*obj)); + OBD_SLAB_FREE(obj, obj_cache, sizeof(*obj)); + atomic_dec(&obj_cache_count); +} + +static void +__add_obj(struct lmv_obj *obj) +{ + atomic_inc(&obj->count); + list_add(&obj->list, &obj_list); +} + +void +lmv_add_obj(struct lmv_obj *obj) +{ + spin_lock(&obj_list_lock); + __add_obj(obj); + spin_unlock(&obj_list_lock); +} + +static void +__del_obj(struct lmv_obj *obj) +{ + list_del(&obj->list); + lmv_free_obj(obj); +} + +void +lmv_del_obj(struct lmv_obj *obj) +{ + spin_lock(&obj_list_lock); + __del_obj(obj); + spin_unlock(&obj_list_lock); +} + +static struct lmv_obj * +__get_obj(struct lmv_obj *obj) +{ + LASSERT(obj != NULL); + atomic_inc(&obj->count); + return obj; } struct lmv_obj * lmv_get_obj(struct lmv_obj *obj) { - LASSERT(obj); - atomic_inc(&obj->count); + spin_lock(&obj_list_lock); + __get_obj(obj); + spin_unlock(&obj_list_lock); return obj; } -void -lmv_put_obj(struct lmv_obj *obj) +static void +__put_obj(struct lmv_obj *obj) { LASSERT(obj); if (atomic_dec_and_test(&obj->count)) { - struct ll_fid *fid = &obj->fid; - CDEBUG(D_OTHER, "last reference to %lu/%lu/%lu - destroying\n", - (unsigned long)fid->mds, (unsigned long)fid->id, - (unsigned long)fid->generation); - __lmv_free_obj(obj); + struct lustre_id *id = &obj->id; + CDEBUG(D_OTHER, "last reference to "DLID4" - " + "destroying\n", OLID4(id)); + __del_obj(obj); } } +void +lmv_put_obj(struct lmv_obj *obj) +{ + spin_lock(&obj_list_lock); + __put_obj(obj); + spin_unlock(&obj_list_lock); +} + static struct lmv_obj * -__lmv_grab_obj(struct obd_device *obd, struct ll_fid *fid) +__grab_obj(struct obd_device *obd, struct lustre_id *id) { struct lmv_obj *obj; struct list_head *cur; - list_for_each(cur, &lmv_obj_list) { + list_for_each(cur, &obj_list) { obj = list_entry(cur, struct lmv_obj, list); - if (fid_equal(&obj->fid, fid)) - return lmv_get_obj(obj); + + /* check if object is in progress of destroying. If so - skip + * it. */ + if (obj->state & O_FREEING) + continue; + + /* + * we should make sure, that we have found object belong to + * passed obd. It is possible that, object manager will have two + * objects with the same fid belong to different obds, if client + * and mds runs on the same host. May be it is good idea to have + * objects list assosiated with obd. + */ + if (obj->obd != obd) + continue; + + /* check if this is what we're looking for. */ + if (id_equal_fid(&obj->id, id)) + return __get_obj(obj); } + return NULL; } struct lmv_obj * -lmv_grab_obj(struct obd_device *obd, struct ll_fid *fid) +lmv_grab_obj(struct obd_device *obd, struct lustre_id *id) { struct lmv_obj *obj; ENTRY; - spin_lock(&lmv_obj_list_lock); - obj = __lmv_grab_obj(obd, fid); - spin_unlock(&lmv_obj_list_lock); + spin_lock(&obj_list_lock); + obj = __grab_obj(obd, id); + spin_unlock(&obj_list_lock); RETURN(obj); } -/* looks in objects list for an object that matches passed @fid. If it is not - * found -- creates it using passed @mea and puts to list. */ +/* looks in objects list for an object that matches passed @id. If it is not + * found -- creates it using passed @mea and puts onto list. */ static struct lmv_obj * -__lmv_create_obj(struct obd_device *obd, struct ll_fid *fid, - struct mea *mea) +__create_obj(struct obd_device *obd, struct lustre_id *id, struct mea *mea) { - struct lmv_obj *obj, *cobj; + struct lmv_obj *new, *obj; ENTRY; - obj = lmv_grab_obj(obd, fid); + obj = lmv_grab_obj(obd, id); if (obj) RETURN(obj); - /* no such object yet, allocate and initialize them. */ - obj = __lmv_alloc_obj(obd, fid, mea); - if (!obj) + /* no such object yet, allocate and initialize it. */ + new = lmv_alloc_obj(obd, id, mea); + if (!new) RETURN(NULL); /* check if someone create it already while we were dealing with * allocating @obj. */ - spin_lock(&lmv_obj_list_lock); - cobj = __lmv_grab_obj(obd, fid); - if (cobj) { + spin_lock(&obj_list_lock); + obj = __grab_obj(obd, id); + if (obj) { /* someone created it already - put @obj and getting out. */ - __lmv_free_obj(obj); - spin_unlock(&lmv_obj_list_lock); - RETURN(cobj); + lmv_free_obj(new); + spin_unlock(&obj_list_lock); + RETURN(obj); } - /* object is referenced by list and thus should have additional - * reference counted. */ - lmv_get_obj(obj); - list_add(&obj->list, &lmv_obj_list); - spin_unlock(&lmv_obj_list_lock); + __add_obj(new); + __get_obj(new); + + spin_unlock(&obj_list_lock); - CDEBUG(D_OTHER, "new obj in lmv cache: %lu/%lu/%lu\n", - (unsigned long)fid->mds, (unsigned long)fid->id, - (unsigned long)fid->generation); + CDEBUG(D_OTHER, "new obj in lmv cache: "DLID4"\n", + OLID4(id)); - RETURN(lmv_get_obj(obj)); + RETURN(new); } -int -lmv_create_obj(struct obd_export *exp, - struct ll_fid *fid, struct mea *mea) +/* creates object from passed @id and @mea. If @mea is NULL, it will be + * obtained from correct MDT and used for constructing the object. */ +struct lmv_obj * +lmv_create_obj(struct obd_export *exp, struct lustre_id *id, struct mea *mea) { struct obd_device *obd = exp->exp_obd; struct lmv_obd *lmv = &obd->u.lmv; struct ptlrpc_request *req = NULL; struct lmv_obj *obj; struct lustre_md md; - int mealen, i, rc = 0; + int mealen, rc; ENTRY; - CDEBUG(D_OTHER, "get mea for %lu/%lu/%lu and create lmv obj\n", - (unsigned long)fid->mds, (unsigned long)fid->id, - (unsigned long)fid->generation); + CDEBUG(D_OTHER, "get mea for "DLID4" and create lmv obj\n", + OLID4(id)); - if (!mea) { - unsigned long valid; + md.mea = NULL; + + if (mea == NULL) { + __u64 valid; CDEBUG(D_OTHER, "mea isn't passed in, get it now\n"); mealen = MEA_SIZE_LMV(lmv); - /* time to update mea of parent fid */ - i = fid->mds; + /* time to update mea of parent id */ md.mea = NULL; - valid = OBD_MD_FLEASIZE | OBD_MD_FLDIREA; - rc = md_getattr(lmv->tgts[fid->mds].ltd_exp, fid, - valid, mealen, &req); + + rc = md_getattr(lmv->tgts[id_group(id)].ltd_exp, + id, valid, NULL, 0, mealen, &req); if (rc) { CERROR("md_getattr() failed, error %d\n", rc); - GOTO(cleanup, rc); + GOTO(cleanup, obj = ERR_PTR(rc)); } rc = mdc_req2lustre_md(exp, req, 0, NULL, &md); if (rc) { CERROR("mdc_req2lustre_md() failed, error %d\n", rc); - GOTO(cleanup, rc); + GOTO(cleanup, obj = ERR_PTR(rc)); } - if (!md.mea) - GOTO(cleanup, rc = -ENODATA); + if (md.mea == NULL) + GOTO(cleanup, obj = ERR_PTR(-ENODATA)); mea = md.mea; } /* got mea, now create obj for it. */ - obj = __lmv_create_obj(obd, fid, mea); + obj = __create_obj(obd, id, mea); if (!obj) { - CERROR("Can't create new object %lu/%lu/%lu\n", - (unsigned long)fid->mds, (unsigned long)fid->id, - (unsigned long)fid->generation); - GOTO(cleanup, rc = -ENOMEM); - } else - lmv_put_obj(obj); + CERROR("Can't create new object "DLID4"\n", + OLID4(id)); + GOTO(cleanup, obj = ERR_PTR(-ENOMEM)); + } + + if (md.mea != NULL) + obd_free_memmd(exp, (struct lov_stripe_md **)&md.mea); + + EXIT; cleanup: - if (req) + if (req) ptlrpc_req_finished(req); - RETURN(rc); + return obj; +} + +/* + * looks for object with @id and orders to destroy it. It is possible the object + * will not be destroyed right now, because it is still using by someone. In + * this case it will be marked as "freeing" and will not be accessible anymore + * for subsequent callers of lmv_grab_obj(). + */ +int +lmv_delete_obj(struct obd_export *exp, struct lustre_id *id) +{ + struct obd_device *obd = exp->exp_obd; + struct lmv_obj *obj; + int rc = 0; + ENTRY; + + spin_lock(&obj_list_lock); + obj = __grab_obj(obd, id); + if (obj) { + obj->state |= O_FREEING; + __put_obj(obj); + __put_obj(obj); + rc = 1; + } + spin_unlock(&obj_list_lock); + + RETURN(rc); } int lmv_setup_mgr(struct obd_device *obd) { - CWARN("LMV object manager setup\n"); - return 0; + ENTRY; + LASSERT(obd != NULL); + + CDEBUG(D_INFO, "LMV object manager setup (%s)\n", + obd->obd_uuid.uuid); + + RETURN(0); } void lmv_cleanup_mgr(struct obd_device *obd) { - struct lmv_obj *obj; struct list_head *cur, *tmp; + struct lmv_obj *obj; + ENTRY; - CWARN("LMV object manager cleanup\n"); + CDEBUG(D_INFO, "LMV object manager cleanup (%s)\n", + obd->obd_uuid.uuid); - spin_lock(&lmv_obj_list_lock); - list_for_each_safe(cur, tmp, &lmv_obj_list) { + spin_lock(&obj_list_lock); + list_for_each_safe(cur, tmp, &obj_list) { obj = list_entry(cur, struct lmv_obj, list); if (obj->obd != obd) continue; - list_del(&obj->list); - + obj->state |= O_FREEING; if (atomic_read(&obj->count) > 1) { - struct ll_fid *fid = &obj->fid; - - CERROR("Object %lu/%lu/%lu has invalid ref count %d\n", - (unsigned long)fid->mds, (unsigned long)fid->id, - (unsigned long)fid->generation, - atomic_read(&obj->count)); + CERROR("obj "DLID4" has count > 1 (%d)\n", + OLID4(&obj->id), atomic_read(&obj->count)); } - - /* list does not use object anymore, ref counter should be - * descreased. */ - lmv_put_obj(obj); + __put_obj(obj); } - spin_unlock(&lmv_obj_list_lock); + spin_unlock(&obj_list_lock); + EXIT; }