Whamcloud - gitweb
class/obdcontrol: fixed read, write, create to work with obdos
[fs/lustre-release.git] / lustre / include / linux / obd_class.h
index 5ba16a8..8ef35a7 100644 (file)
@@ -30,8 +30,8 @@ typedef uint32_t      obd_gid;
 typedef uint32_t       obd_flag;
 typedef uint32_t       obd_count;
 
-#define OBD_FL_INLINEDATA      (1UL)  
-#define OBD_FL_OBDMDEXISTS     (1UL << 1)
+#define OBD_FL_INLINEDATA      (0x00000001UL)  
+#define OBD_FL_OBDMDEXISTS     (0x00000002UL)
 
 #define OBD_INLINESZ   60
 #define OBD_OBDMDSZ    60
@@ -60,22 +60,23 @@ struct obdo {
 };
 
 #define OBD_MD_FLALL   (~0UL)
-#define OBD_MD_FLID    (0x0001UL)
-#define OBD_MD_FLATIME (0x0002UL)
-#define OBD_MD_FLMTIME (0x0004UL)
-#define OBD_MD_FLCTIME (0x0008UL)
-#define OBD_MD_FLSIZE  (0x0010UL)
-#define OBD_MD_FLBLOCKS        (0x0020UL)
-#define OBD_MD_FLBLKSZ (0x0040UL)
-#define OBD_MD_FLMODE  (0x0080UL)
-#define OBD_MD_FLUID   (0x0100UL)
-#define OBD_MD_FLGID   (0x0200UL)
-#define OBD_MD_FLFLAGS (0x0400UL)
-#define OBD_MD_FLOBDFLG        (0x0800UL)
-#define OBD_MD_FLNLINK (0x1000UL)
-#define OBD_MD_FLGENER (0x2000UL)
-#define OBD_MD_FLINLINE        (0x4000UL)
-#define OBD_MD_FLOBDMD (0x8000UL)
+#define OBD_MD_FLID    (0x00000001UL)
+#define OBD_MD_FLATIME (0x00000002UL)
+#define OBD_MD_FLMTIME (0x00000004UL)
+#define OBD_MD_FLCTIME (0x00000008UL)
+#define OBD_MD_FLSIZE  (0x00000010UL)
+#define OBD_MD_FLBLOCKS        (0x00000020UL)
+#define OBD_MD_FLBLKSZ (0x00000040UL)
+#define OBD_MD_FLMODE  (0x00000080UL)
+#define OBD_MD_FLUID   (0x00000100UL)
+#define OBD_MD_FLGID   (0x00000200UL)
+#define OBD_MD_FLFLAGS (0x00000400UL)
+#define OBD_MD_FLOBDFLG        (0x00000800UL)
+#define OBD_MD_FLNLINK (0x00001000UL)
+#define OBD_MD_FLGENER (0x00002000UL)
+#define OBD_MD_FLINLINE        (0x00004000UL)
+#define OBD_MD_FLOBDMD (0x00008000UL)
+#define OBD_MD_FLNOTOBD        (~(OBD_MD_FLOBDMD | OBD_MD_FLOBDFLG))
 
 /*
  *  ======== OBD Device Declarations ===========
@@ -122,6 +123,10 @@ struct obd_device {
  *  ======== OBD Operations Declarations ===========
  */
 
+#define OBD_BRW_READ   (READ)
+#define OBD_BRW_WRITE  (WRITE)
+#define OBD_BRW_RWMASK (READ | WRITE)
+#define OBD_BRW_CREATE (0x00000010UL)
 
 struct obd_ops {
        int (*o_iocontrol)(int cmd, struct obd_conn *, int len, void *karg,
@@ -146,8 +151,9 @@ struct obd_ops {
                      obd_size *count, obd_off offset);
        int (*o_write)(struct obd_conn *conn, struct obdo *oa, char *buf,
                       obd_size *count, obd_off offset);
-       int (*o_brw)(int rw, struct obd_conn *conn, struct obdo *oa,
-                    char *buf, obd_size count, obd_off offset, obd_flag flags);
+       int (*o_brw)(int rw, struct obd_conn *conn, obd_count *num_io,
+                    struct obdo **oa, char **buf, obd_size **count,
+                    obd_off *offset, obd_flag *flags);
        int (*o_punch)(struct obd_conn *conn, struct obdo *tgt, obd_size count,
                       obd_off offset);
        int (*o_sync)(struct obd_conn *conn, struct obdo *tgt, obd_size count,
@@ -175,12 +181,14 @@ extern void obd_cleanup_obdo_cache(void);
 
 static inline int obdo_has_inline(struct obdo *obdo)
 {
-       return obdo->o_obdflags & OBD_FL_INLINEDATA;
+       return (obdo->o_valid & OBD_MD_FLINLINE &&
+               obdo->o_obdflags & OBD_FL_INLINEDATA);
 };
 
 static inline int obdo_has_obdmd(struct obdo *obdo)
 {
-       return obdo->o_obdflags & OBD_FL_OBDMDEXISTS;
+       return (obdo->o_valid & OBD_MD_FLOBDMD &&
+               obdo->o_obdflags & OBD_FL_OBDMDEXISTS);
 };
 
 /* support routines */
@@ -188,12 +196,12 @@ extern kmem_cache_t *obdo_cachep;
 
 static __inline__ struct obdo *obdo_alloc(void)
 {
-       struct obdo *res = NULL;
+       struct obdo *oa = NULL;
 
-       res = kmem_cache_alloc(obdo_cachep, SLAB_KERNEL);
-       memset(res, 0, sizeof (*res));
+       oa = kmem_cache_alloc(obdo_cachep, SLAB_KERNEL);
+       memset(oa, 0, sizeof (*oa));
 
-       return res;
+       return oa;
 }
 
 static __inline__ void obdo_free(struct obdo *oa)
@@ -205,24 +213,28 @@ static __inline__ void obdo_free(struct obdo *oa)
 
 
 
-static __inline__ struct obdo *obdo_fromid(struct obd_conn *conn, obd_id id)
+static __inline__ struct obdo *obdo_fromid(struct obd_conn *conn, obd_id id,
+                                          obd_flag valid)
 {
-       struct obdo *res = NULL;
+       struct obdo *oa;
+       int err;
 
-       res = kmem_cache_alloc(obdo_cachep, SLAB_KERNEL);
-       if ( !res ) {
+       ENTRY;
+       oa = obdo_alloc();
+       if ( !oa ) {
                EXIT;
-               return NULL;
+               return ERR_PTR(-ENOMEM);
        }
-       memset(res, 0, sizeof(*res));
-       res->o_id = id;
-       if (OBP(conn->oc_dev, getattr)(conn, res)) {
-               OBD_FREE(res, sizeof(*res));
+       memset(oa, 0, sizeof(*oa));
+       oa->o_id = id;
+       oa->o_valid = valid;
+       if ((err = OBP(conn->oc_dev, getattr)(conn, oa))) {
+               obdo_free(oa);
                EXIT;
-               return NULL;
+               return ERR_PTR(err);
        }
        EXIT;
-       return res;
+       return oa;
 }
 
 static inline void obdo_from_iattr(struct obdo *oa, struct iattr *attr)
@@ -265,7 +277,8 @@ static inline void obdo_from_iattr(struct obdo *oa, struct iattr *attr)
 
 static __inline__ void obdo_cpy_md(struct obdo *dst, struct obdo *src)
 {
-       CDEBUG(D_INODE, "flags 0x%x\n", src->o_valid);
+       CDEBUG(D_INODE, "src obdo %Ld valid 0x%x, dst obdo %Ld\n",
+              src->o_id, src->o_valid, dst->o_id);
        if ( src->o_valid & OBD_MD_FLATIME ) 
                dst->o_atime = src->o_atime;
        if ( src->o_valid & OBD_MD_FLMTIME ) 
@@ -286,23 +299,32 @@ static __inline__ void obdo_cpy_md(struct obdo *dst, struct obdo *src)
                dst->o_gid = src->o_gid;
        if ( src->o_valid & OBD_MD_FLFLAGS ) 
                dst->o_flags = src->o_flags;
+       /*
        if ( src->o_valid & OBD_MD_FLOBDFLG ) 
                dst->o_obdflags = src->o_obdflags;
+       */
        if ( src->o_valid & OBD_MD_FLNLINK ) 
                dst->o_nlink = src->o_nlink;
        if ( src->o_valid & OBD_MD_FLGENER ) 
                dst->o_generation = src->o_generation;
-       if ( src->o_valid & OBD_MD_FLINLINE ) 
+       if ( src->o_valid & OBD_MD_FLINLINE &&
+            src->o_obdflags & OBD_FL_INLINEDATA) {
                memcpy(dst->o_inline, src->o_inline, sizeof(src->o_inline));
-       if ( src->o_valid & OBD_MD_FLOBDMD ) 
+               dst->o_obdflags |= OBD_FL_INLINEDATA;
+       }
+       if ( src->o_valid & OBD_MD_FLOBDMD &&
+            src->o_obdflags & OBD_FL_OBDMDEXISTS) {
                memcpy(dst->o_obdmd, src->o_obdmd, sizeof(src->o_obdmd));
+               dst->o_obdflags |= OBD_FL_OBDMDEXISTS;
+       }
 
        dst->o_valid |= src->o_valid;
 }
 
 static __inline__ void obdo_from_inode(struct obdo *dst, struct inode *src)
 {
-       CDEBUG(D_INODE, "flags %x\n", dst->o_valid);
+       CDEBUG(D_INODE, "src inode %ld, dst obdo %Ld valid 0x%08x\n",
+              src->i_ino, dst->o_id, dst->o_valid);
        if ( dst->o_valid & OBD_MD_FLID )
                dst->o_id = src->i_ino;
        if ( dst->o_valid & OBD_MD_FLATIME )
@@ -334,7 +356,8 @@ static __inline__ void obdo_from_inode(struct obdo *dst, struct inode *src)
 static __inline__ void obdo_to_inode(struct inode *dst, struct obdo *src)
 {
 
-       CDEBUG(D_INODE, "flags %x\n", src->o_valid);
+       CDEBUG(D_INODE, "src obdo %Ld valid 0x%08x, dst inode %ld\n",
+              src->o_id, src->o_valid, dst->i_ino);
        if ( src->o_valid & OBD_MD_FLID )
                dst->i_ino = src->o_id;
        if ( src->o_valid & OBD_MD_FLATIME ) 
@@ -363,29 +386,42 @@ static __inline__ void obdo_to_inode(struct inode *dst, struct obdo *src)
                dst->i_generation = src->o_generation;
 }
 
-static __inline__ int obdo_cmp_md(struct obdo *dst, struct obdo *src)
+/* returns FALSE if comparison (by flags) is same, TRUE if changed */
+static __inline__ int obdo_cmp_md(struct obdo *dst, struct obdo *src,
+                                 obd_flag compare)
 {
-       int res = 1;
-
-       if ( src->o_valid & OBD_MD_FLMODE )
-               res = (res && (dst->o_mode == src->o_mode));
-       if ( src->o_valid & OBD_MD_FLUID )
-               res = (res && (dst->o_uid == src->o_uid));
-       if ( src->o_valid & OBD_MD_FLGID )
-               res = (res && (dst->o_gid == src->o_gid));
-       if ( src->o_valid & OBD_MD_FLSIZE )
-               res = (res && (dst->o_size == src->o_size));
-       if ( src->o_valid & OBD_MD_FLATIME )
-               res = (res && (dst->o_atime == src->o_atime));
-       if ( src->o_valid & OBD_MD_FLMTIME )
-               res = (res && (dst->o_mtime == src->o_mtime));
-       if ( src->o_valid & OBD_MD_FLCTIME )
-               res = (res && (dst->o_ctime == src->o_ctime));
-       if ( src->o_valid & OBD_MD_FLFLAGS )
-               res = (res && (dst->o_flags == src->o_flags));
-       /* allocation of space */
-       if ( src->o_valid & OBD_MD_FLBLOCKS )
-               res = (res && (dst->o_blocks == src->o_blocks));
+       int res = 0;
+
+       if ( compare & OBD_MD_FLATIME )
+               res = (res || (dst->o_atime != src->o_atime));
+       if ( compare & OBD_MD_FLMTIME )
+               res = (res || (dst->o_mtime != src->o_mtime));
+       if ( compare & OBD_MD_FLCTIME )
+               res = (res || (dst->o_ctime != src->o_ctime));
+       if ( compare & OBD_MD_FLSIZE )
+               res = (res || (dst->o_size != src->o_size));
+       if ( compare & OBD_MD_FLBLOCKS ) /* allocation of space */
+               res = (res || (dst->o_blocks != src->o_blocks));
+       if ( compare & OBD_MD_FLBLKSZ )
+               res = (res || (dst->o_blksize != src->o_blksize));
+       if ( compare & OBD_MD_FLMODE )
+               res = (res || (dst->o_mode != src->o_mode));
+       if ( compare & OBD_MD_FLUID )
+               res = (res || (dst->o_uid != src->o_uid));
+       if ( compare & OBD_MD_FLGID )
+               res = (res || (dst->o_gid != src->o_gid));
+       if ( compare & OBD_MD_FLFLAGS ) 
+               res = (res || (dst->o_flags != src->o_flags));
+       if ( compare & OBD_MD_FLNLINK )
+               res = (res || (dst->o_nlink != src->o_nlink));
+       if ( compare & OBD_MD_FLGENER )
+               res = (res || (dst->o_generation != src->o_generation));
+       /* XXX Don't know if thses should be included here - wasn't previously
+       if ( compare & OBD_MD_FLINLINE )
+               res = (res || memcmp(dst->o_inline, src->o_inline));
+       if ( compare & OBD_MD_FLOBDMD )
+               res = (res || memcmp(dst->o_obdmd, src->o_obdmd));
+       */
        return res;
 }
 
@@ -427,53 +463,53 @@ int gen_copy_data(struct obd_conn *dst_conn, struct obdo *dst,
  *  ======== OBD IOCL Declarations ===========
  */
 struct oic_generic {
-       int  att_connid;
-       int  att_typelen;
-       void *att_type;
-       int  att_datalen;
-       void *att_data;
+       uint32_t att_connid;
+       int      att_typelen;
+       void    *att_type;
+       int      att_datalen;
+       void    *att_data;
 };
 
 
 /* for preallocation */
 struct oic_prealloc_s {
-       uint32_t cli_id;
-       uint32_t alloc; /* user sets it to the number of inodes
-                        * requesting to be preallocated.  kernel
-                        * sets it to the actual number of
-                        * succesfully preallocated inodes */
-       obd_id  ids[32]; /* actual inode numbers */
+       uint32_t         conn_id;
+       uint32_t         alloc; /* user sets it to the number of inodes
+                                * requesting to be preallocated.  kernel
+                                * sets it to the actual number of
+                                * succesfully preallocated inodes */
+       obd_id           ids[32]; /* actual inode numbers */
 };
 
 /* for getattr, setattr, create, destroy */
 struct oic_attr_s {
-       uint32_t conn_id;
-       struct obdo  obdo;
+       uint32_t         conn_id;
+       struct obdo      obdo;
 };
 
 /* for copy, migrate */
 struct ioc_mv_s {
-       unsigned int src_conn_id;
-       struct obdo  src;
-       unsigned int dst_conn_id;
-       struct obdo  dst;
+       uint32_t         src_conn_id;
+       struct obdo      src;
+       uint32_t         dst_conn_id;
+       struct obdo      dst;
 };
 
 /* for read/write */
 struct oic_rw_s {
-       uint32_t conn_id;
-       struct obdo obdo;
-       char buf;
-       obd_size count;
-       obd_off offset;
+       uint32_t         conn_id;
+       struct obdo      obdo;
+       char            *buf;
+       obd_size         count;
+       obd_off          offset;
 };
 
 /* for punch, sync */
 struct oic_range_s {
-       uint32_t conn_id;
-       struct obdo obdo;
-       obd_size count;
-       obd_off offset;
+       uint32_t         conn_id;
+       struct obdo      obdo;
+       obd_size         count;
+       obd_off          offset;
 };