X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fmdd%2Fmdd_lock.c;h=0db27f364178d4d0e1e08a60a356f0054aa05a2b;hb=d05051c34077c74e3c08f3723bf6084554c0daf8;hp=4f1427dafc0735734501b43382c45964b13e8ea2;hpb=6e3ec5812ebd1b5ecf7cae584f429b013ffe7431;p=fs%2Flustre-release.git diff --git a/lustre/mdd/mdd_lock.c b/lustre/mdd/mdd_lock.c index 4f1427d..0db27f3 100644 --- a/lustre/mdd/mdd_lock.c +++ b/lustre/mdd/mdd_lock.c @@ -1,6 +1,4 @@ -/* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*- - * vim:expandtab:shiftwidth=8:tabstop=8: - * +/* * GPL HEADER START * * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. @@ -26,8 +24,10 @@ * GPL HEADER END */ /* - * Copyright 2008 Sun Microsystems, Inc. All rights reserved + * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved. * Use is subject to license terms. + * + * Copyright (c) 2012, 2014, Intel Corporation. */ /* * This file is part of Lustre, http://www.lustre.org/ @@ -40,136 +40,45 @@ * Author: Mike Pershin */ -#ifndef EXPORT_SYMTAB -# define EXPORT_SYMTAB -#endif #define DEBUG_SUBSYSTEM S_MDS #include #include #include "mdd_internal.h" - -#ifdef CONFIG_LOCKDEP -static cfs_lock_class_key_t mdd_pdirop_key; - -#define RETIP ((unsigned long)__builtin_return_address(0)) - -static void mdd_lockdep_init(struct mdd_object *obj) -{ - lockdep_set_class_and_name(obj, &mdd_pdirop_key, "pdir"); -} - -static void mdd_lockdep_pd_acquire(struct mdd_object *obj, - enum mdd_object_role role) -{ - lock_acquire(&obj->dep_map, role, 0, 1, 2, RETIP); -} - -static void mdd_lockdep_pd_release(struct mdd_object *obj) -{ - lock_release(&obj->dep_map, 0, RETIP); -} - -#else /* !CONFIG_LOCKDEP */ - -static void mdd_lockdep_init(struct mdd_object *obj) -{} -static void mdd_lockdep_pd_acquire(struct mdd_object *obj, - enum mdd_object_role role) -{} -static void mdd_lockdep_pd_release(struct mdd_object *obj) -{} - -#endif /* !CONFIG_LOCKDEP */ - void mdd_write_lock(const struct lu_env *env, struct mdd_object *obj, - enum mdd_object_role role) + enum mdd_object_role role) { - struct dt_object *next = mdd_object_child(obj); + struct dt_object *next = mdd_object_child(obj); - next->do_ops->do_write_lock(env, next, role); + dt_write_lock(env, next, role); } void mdd_read_lock(const struct lu_env *env, struct mdd_object *obj, - enum mdd_object_role role) + enum mdd_object_role role) { - struct dt_object *next = mdd_object_child(obj); + struct dt_object *next = mdd_object_child(obj); - next->do_ops->do_read_lock(env, next, role); + dt_read_lock(env, next, role); } void mdd_write_unlock(const struct lu_env *env, struct mdd_object *obj) { - struct dt_object *next = mdd_object_child(obj); + struct dt_object *next = mdd_object_child(obj); - next->do_ops->do_write_unlock(env, next); + dt_write_unlock(env, next); } void mdd_read_unlock(const struct lu_env *env, struct mdd_object *obj) { - struct dt_object *next = mdd_object_child(obj); + struct dt_object *next = mdd_object_child(obj); - next->do_ops->do_read_unlock(env, next); + dt_read_unlock(env, next); } int mdd_write_locked(const struct lu_env *env, struct mdd_object *obj) { - struct dt_object *next = mdd_object_child(obj); - - return next->do_ops->do_write_locked(env, next); -} - -/* Methods for parallel directory locking */ - -void mdd_pdlock_init(struct mdd_object *obj) -{ - dynlock_init(&obj->mod_pdlock); - mdd_lockdep_init(obj); -} - -unsigned long mdd_name2hash(const char *name) -{ - return full_name_hash((unsigned char*)name, strlen(name)); -} - -struct dynlock_handle *mdd_pdo_write_lock(const struct lu_env *env, - struct mdd_object *obj, - const char *name, - enum mdd_object_role role) -{ - struct dynlock_handle *handle; - unsigned long value = mdd_name2hash(name); + struct dt_object *next = mdd_object_child(obj); - handle = dynlock_lock(&obj->mod_pdlock, value, DLT_WRITE, GFP_NOFS); - if (handle != NULL) - mdd_lockdep_pd_acquire(obj, role); - return handle; -} - -struct dynlock_handle *mdd_pdo_read_lock(const struct lu_env *env, - struct mdd_object *obj, - const char *name, - enum mdd_object_role role) -{ - struct dynlock_handle *handle; - unsigned long value = mdd_name2hash(name); - handle = dynlock_lock(&obj->mod_pdlock, value, DLT_READ, GFP_NOFS); - if (handle != NULL) - mdd_lockdep_pd_acquire(obj, role); - return handle; -} - -void mdd_pdo_write_unlock(const struct lu_env *env, struct mdd_object *obj, - struct dynlock_handle *dlh) -{ - mdd_lockdep_pd_release(obj); - return dynlock_unlock(&obj->mod_pdlock, dlh); -} - -void mdd_pdo_read_unlock(const struct lu_env *env, struct mdd_object *obj, - struct dynlock_handle *dlh) -{ - mdd_lockdep_pd_release(obj); - return dynlock_unlock(&obj->mod_pdlock, dlh); + return dt_write_locked(env, next); }