From: adilger <adilger>
Date: Tue, 5 Mar 2002 23:55:38 +0000 (+0000)
Subject: Add echo_preprw() and echo_commitrw() methods to the echo OST.  They have
X-Git-Tag: v1_7_100~5940
X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=commitdiff_plain;h=48397ced0f7df6fb76c9e4c9732eada698e43e6d

Add echo_preprw() and echo_commitrw() methods to the echo OST.  They have
not been tested yet, need to add test_brw to obdctl first.
---

diff --git a/lustre/obdecho/echo.c b/lustre/obdecho/echo.c
index dad0dec..6fdf30b 100644
--- a/lustre/obdecho/echo.c
+++ b/lustre/obdecho/echo.c
@@ -38,20 +38,91 @@ static int echo_getattr(struct obd_conn *conn, struct obdo *oa)
         return 0;
 }
 
-/*
-static int echo_setattr(struct obd_conn *conn, struct obdo *oa)
+int echo_preprw(int cmd, struct obd_conn *conn, int objcount,
+                struct obd_ioobj *obj, int niocount, struct niobuf *nb, 
+                struct niobuf *res)
 {
-        memcpy(&OA, oa, sizeof(*oa));
+        int rc = 0;
+        int i;
+
+        ENTRY;
+        memset(res, 0, sizeof(*res) * niocount);
+
+        for (i = 0; i < objcount; i++, obj++) { 
+                int j;
+
+                for (j = 0 ; j < obj->ioo_bufcnt ; j++, nb++, res++) { 
+                        unsigned long address;
+
+                        address = get_zeroed_page(GFP_KERNEL);
+                        if (!address) { 
+                                /* FIXME: cleanup old pages */
+                                EXIT; 
+                                rc = -ENOMEM; 
+                        }
+                        
+                        /*
+                        if (cmd == OBD_BRW_READ) {
+                                __u64 *data = address;
+
+                                data[0] = obj->ioo_id;
+                                data[1] = j;
+                                data[2] = nb->offset;
+                                data[3] = nb->len;
+                        }
+                        */
+                        
+                        res->addr = address;
+                        res->offset = nb->offset;
+                        res->page = virt_to_page(address);
+                        res->len = PAGE_SIZE;
+                        // r->flags
+                }
+        }
+
+        return rc;
+}
 
-        return 0;
+int echo_commitrw(int cmd, struct obd_conn *conn, int objcount,
+                  struct obd_ioobj *obj, int niocount, struct niobuf *res)
+{
+        int i; 
+        int rc = 0;
+        ENTRY;
+
+        for (i = 0; i < objcount; i++, obj++) { 
+                int j;
+
+                for (j = 0 ; j < obj->ioo_bufcnt ; j++, res++) { 
+                        struct page *page;
+
+                        if (!res) {
+                                /* FIXME: cleanup remaining pages */
+                                CERROR("NULL buf, obj %Ld (%d), buf %d/%d\n",
+                                        obj->ioo_id, i, j, obj->ioo_bufcnt);
+                                rc = -EINVAL;
+                        }
+
+                        page = res->page;
+                        if (page || !VALID_PAGE(page)) {
+                                /* FIXME: cleanup remaining pages */
+                                CERROR("bad page %p, obj %Ld (%d), buf %d/%d\n",
+                                        page, obj->ioo_id, i, j, obj->ioo_bufcnt);
+                                rc = -EINVAL;
+                        }
+
+                        page_cache_release(page);
+                }
+        }
+        return rc;
 }
-*/
 
 struct obd_ops echo_obd_ops = {
         o_connect:     gen_connect,
         o_disconnect:  gen_disconnect,
         o_getattr:     echo_getattr,
-//        o_setattr:     echo_setattr,
+        o_preprw:      echo_preprw,
+        o_commitrw:    echo_commitrw,
 };