/* fid_be_to_cpu() */
#include <lustre_fid.h>
+struct dt_find_hint {
+ struct lu_fid *dfh_fid;
+ struct dt_device *dfh_dt;
+ struct dt_object *dfh_o;
+};
+
+struct dt_thread_info {
+ char dti_buf[DT_MAX_PATH];
+ struct lu_fid_pack dti_pack;
+ struct dt_find_hint dti_dfh;
+};
+
+/* context key constructor/destructor: dt_global_key_init, dt_global_key_fini */
+LU_KEY_INIT(dt_global, struct dt_thread_info);
+LU_KEY_FINI(dt_global, struct dt_thread_info);
+
+static struct lu_context_key dt_key = {
+ .lct_tags = LCT_MD_THREAD|LCT_DT_THREAD,
+ .lct_init = dt_global_key_init,
+ .lct_fini = dt_global_key_fini
+};
+
/* no lock is necessary to protect the list, because call-backs
* are added during system startup. Please refer to "struct dt_device".
*/
}
EXPORT_SYMBOL(dt_try_as_dir);
-extern struct lu_context_key lu_global_key;
+enum dt_format_type dt_mode_to_dft(__u32 mode)
+{
+ enum dt_format_type result;
+
+ switch (mode & S_IFMT) {
+ case S_IFDIR:
+ result = DFT_DIR;
+ break;
+ case S_IFREG:
+ result = DFT_REGULAR;
+ break;
+ case S_IFLNK:
+ result = DFT_SYM;
+ break;
+ case S_IFCHR:
+ case S_IFBLK:
+ case S_IFIFO:
+ case S_IFSOCK:
+ result = DFT_NODE;
+ break;
+ default:
+ LBUG();
+ break;
+ }
+ return result;
+}
+
+EXPORT_SYMBOL(dt_mode_to_dft);
+/**
+ * lookup fid for object named \a name in directory \a dir.
+ */
static int dt_lookup(const struct lu_env *env, struct dt_object *dir,
const char *name, struct lu_fid *fid)
{
- struct lu_fid_pack *pack = lu_context_key_get(&env->le_ctx,
- &lu_global_key);
+ struct dt_thread_info *info = lu_context_key_get(&env->le_ctx,
+ &dt_key);
+ struct lu_fid_pack *pack = &info->dti_pack;
struct dt_rec *rec = (struct dt_rec *)pack;
const struct dt_key *key = (const struct dt_key *)name;
int result;
if (dt_try_as_dir(env, dir)) {
result = dir->do_index_ops->dio_lookup(env, dir, rec, key,
BYPASS_CAPA);
- if (result == 0)
+ if (result > 0)
result = fid_unpack(pack, fid);
+ else if (result == 0)
+ result = -ENOENT;
} else
result = -ENOTDIR;
return result;
}
-static struct dt_object *dt_locate(const struct lu_env *env,
- struct dt_device *dev,
- const struct lu_fid *fid)
+/**
+ * get object for given \a fid.
+ */
+struct dt_object *dt_locate(const struct lu_env *env,
+ struct dt_device *dev,
+ const struct lu_fid *fid)
{
struct lu_object *obj;
struct dt_object *dt;
LASSERT(obj != NULL);
dt = container_of(obj, struct dt_object, do_lu);
} else
- dt = (void *)obj;
+ dt = (struct dt_object *)obj;
return dt;
}
+EXPORT_SYMBOL(dt_locate);
-struct dt_object *dt_store_open(const struct lu_env *env,
- struct dt_device *dt, const char *name,
- struct lu_fid *fid)
+/**
+ * find a object named \a entry in given \a dfh->dfh_o directory.
+ */
+static int dt_find_entry(const struct lu_env *env, const char *entry, void *data)
{
+ struct dt_find_hint *dfh = data;
+ struct dt_device *dt = dfh->dfh_dt;
+ struct lu_fid *fid = dfh->dfh_fid;
+ struct dt_object *obj = dfh->dfh_o;
+ int result;
+
+ result = dt_lookup(env, obj, entry, fid);
+ lu_object_put(env, &obj->do_lu);
+ if (result == 0) {
+ obj = dt_locate(env, dt, fid);
+ if (IS_ERR(obj))
+ result = PTR_ERR(obj);
+ }
+ dfh->dfh_o = obj;
+ return result;
+}
+
+/**
+ * Abstract function which parses path name. This function feeds
+ * path component to \a entry_func.
+ */
+int dt_path_parser(const struct lu_env *env,
+ char *path, dt_entry_func_t entry_func,
+ void *data)
+{
+ char *e;
+ int rc = 0;
+
+ while (1) {
+ e = strsep(&path, "/");
+ if (e == NULL)
+ break;
+
+ if (e[0] == 0) {
+ if (!path || path[0] == '\0')
+ break;
+ continue;
+ }
+ rc = entry_func(env, e, data);
+ if (rc)
+ break;
+ }
+
+ return rc;
+}
+
+static struct dt_object *dt_store_resolve(const struct lu_env *env,
+ struct dt_device *dt,
+ const char *path,
+ struct lu_fid *fid)
+{
+ struct dt_thread_info *info = lu_context_key_get(&env->le_ctx,
+ &dt_key);
+ struct dt_find_hint *dfh = &info->dti_dfh;
+ struct dt_object *obj = dfh->dfh_o;
+ char *local = info->dti_buf;
int result;
- struct dt_object *root;
- struct dt_object *child;
+ dfh->dfh_dt = dt;
+ dfh->dfh_fid = fid;
+
+ strncpy(local, path, DT_MAX_PATH);
+ local[DT_MAX_PATH - 1] = '\0';
result = dt->dd_ops->dt_root_get(env, dt, fid);
if (result == 0) {
- root = dt_locate(env, dt, fid);
- if (!IS_ERR(root)) {
- result = dt_lookup(env, root, name, fid);
- if (result == 0)
- child = dt_locate(env, dt, fid);
- else
- child = ERR_PTR(result);
- lu_object_put(env, &root->do_lu);
- } else {
- CERROR("No root\n");
- child = (void *)root;
+ obj = dt_locate(env, dt, fid);
+ if (!IS_ERR(obj)) {
+ dfh->dfh_o = obj;
+ result = dt_path_parser(env, local, dt_find_entry, dfh);
+ if (result != 0)
+ obj = ERR_PTR(result);
}
- } else
- child = ERR_PTR(result);
- return child;
+ } else {
+ obj = ERR_PTR(result);
+ }
+ return obj;
+}
+
+static struct dt_object *dt_reg_open(const struct lu_env *env,
+ struct dt_device *dt,
+ struct dt_object *p,
+ const char *name,
+ struct lu_fid *fid)
+{
+ struct dt_object *o;
+ int result;
+
+ result = dt_lookup(env, p, name, fid);
+ if (result == 0){
+ o = dt_locate(env, dt, fid);
+ }
+ else
+ o = ERR_PTR(result);
+
+ return o;
+}
+
+/**
+ * Open dt object named \a filename from \a dirname directory.
+ * \param dt dt device
+ * \param fid on success, object fid is stored in *fid
+ */
+struct dt_object *dt_store_open(const struct lu_env *env,
+ struct dt_device *dt,
+ const char *dirname,
+ const char *filename,
+ struct lu_fid *fid)
+{
+ struct dt_object *file;
+ struct dt_object *dir;
+
+ dir = dt_store_resolve(env, dt, dirname, fid);
+ if (!IS_ERR(dir)) {
+ file = dt_reg_open(env, dt, dir,
+ filename, fid);
+ lu_object_put(env, &dir->do_lu);
+ } else {
+ file = dir;
+ }
+ return file;
}
EXPORT_SYMBOL(dt_store_open);
+/* dt class init function. */
+int dt_global_init(void)
+{
+ int result;
+
+ LU_CONTEXT_KEY_INIT(&dt_key);
+ result = lu_context_key_register(&dt_key);
+ return result;
+}
+
+void dt_global_fini(void)
+{
+ lu_context_key_degister(&dt_key);
+}
+
const struct dt_index_features dt_directory_features;
EXPORT_SYMBOL(dt_directory_features);
git://git.whamcloud.com / fs / lustre-release.git / blobdiff