1 files changed, 41 insertions, 36 deletions

diff --git a/net/9p/client.c b/net/9p/client.c
index b1c02187f862..854ca7a911c4 100644
--- a/net/9p/client.c
+++ b/net/9p/client.c
@@ -38,6 +38,9 @@
 #include <net/9p/transport.h>
 #include "protocol.h"
 
+#define CREATE_TRACE_POINTS
+#include <trace/events/9p.h>
+
 /*
   * Client Option Parsing (code inspired by NFS code)
   *  - a little lazy - parse all client options
@@ -464,11 +467,15 @@ static int p9_check_errors(struct p9_client *c, struct p9_req_t *req)
         int ecode;
 
         err = p9_parse_header(req->rc, NULL, &type, NULL, 0);
+        /*
+         * dump the response from server
+         * This should be after check errors which poplulate pdu_fcall.
+         */
+        trace_9p_protocol_dump(c, req->rc);
         if (err) {
                 P9_DPRINTK(P9_DEBUG_ERROR, "couldn't parse header %d\n", err);
                 return err;
         }
-
         if (type != P9_RERROR && type != P9_RLERROR)
                 return 0;
 
@@ -525,6 +532,11 @@ static int p9_check_zc_errors(struct p9_client *c, struct p9_req_t *req,
         char *ename = NULL;
 
         err = p9_parse_header(req->rc, NULL, &type, NULL, 0);
+        /*
+         * dump the response from server
+         * This should be after parse_header which poplulate pdu_fcall.
+         */
+        trace_9p_protocol_dump(c, req->rc);
         if (err) {
                 P9_DPRINTK(P9_DEBUG_ERROR, "couldn't parse header %d\n", err);
                 return err;
@@ -684,7 +696,8 @@ static struct p9_req_t *p9_client_prepare_req(struct p9_client *c,
         err = p9pdu_vwritef(req->tc, c->proto_version, fmt, ap);
         if (err)
                 goto reterr;
-        p9pdu_finalize(req->tc);
+        p9pdu_finalize(c, req->tc);
+        trace_9p_client_req(c, type, tag);
         return req;
 reterr:
         p9_free_req(c, req);
@@ -755,13 +768,10 @@ p9_client_rpc(struct p9_client *c, int8_t type, const char *fmt, ...)
                 goto reterr;
 
         err = p9_check_errors(c, req);
-        if (!err) {
-                P9_DPRINTK(P9_DEBUG_MUX, "exit: client %p op %d\n", c, type);
+        trace_9p_client_res(c, type, req->rc->tag, err);
+        if (!err)
                 return req;
-        }
 reterr:
-        P9_DPRINTK(P9_DEBUG_MUX,
-                   "exit: client %p op %d error: %d\n", c, type, err);
         p9_free_req(c, req);
         return ERR_PTR(err);
 }
@@ -841,13 +851,10 @@ static struct p9_req_t *p9_client_zc_rpc(struct p9_client *c, int8_t type,
                 goto reterr;
 
         err = p9_check_zc_errors(c, req, uidata, in_hdrlen, kern_buf);
-        if (!err) {
-                P9_DPRINTK(P9_DEBUG_MUX, "exit: client %p op %d\n", c, type);
+        trace_9p_client_res(c, type, req->rc->tag, err);
+        if (!err)
                 return req;
-        }
 reterr:
-        P9_DPRINTK(P9_DEBUG_MUX, "exit: client %p op %d error: %d\n", c, type,
-                                                                        err);
         p9_free_req(c, req);
         return ERR_PTR(err);
 }
@@ -935,7 +942,7 @@ static int p9_client_version(struct p9_client *c)
         err = p9pdu_readf(req->rc, c->proto_version, "ds", &msize, &version);
         if (err) {
                 P9_DPRINTK(P9_DEBUG_9P, "version error %d\n", err);
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(c, req->rc);
                 goto error;
         }
 
@@ -1072,15 +1079,14 @@ EXPORT_SYMBOL(p9_client_begin_disconnect);
 struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid,
         char *uname, u32 n_uname, char *aname)
 {
-        int err;
+        int err = 0;
         struct p9_req_t *req;
         struct p9_fid *fid;
         struct p9_qid qid;
 
-        P9_DPRINTK(P9_DEBUG_9P, ">>> TATTACH afid %d uname %s aname %s\n",
-                                        afid ? afid->fid : -1, uname, aname);
-        err = 0;
 
+        P9_DPRINTK(P9_DEBUG_9P, ">>> TATTACH afid %d uname %s aname %s\n",
+                   afid ? afid->fid : -1, uname, aname);
         fid = p9_fid_create(clnt);
         if (IS_ERR(fid)) {
                 err = PTR_ERR(fid);
@@ -1097,7 +1103,7 @@ struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid,
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "Q", &qid);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 p9_free_req(clnt, req);
                 goto error;
         }
@@ -1157,7 +1163,7 @@ struct p9_fid *p9_client_walk(struct p9_fid *oldfid, uint16_t nwname,
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "R", &nwqids, &wqids);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 p9_free_req(clnt, req);
                 goto clunk_fid;
         }
@@ -1224,7 +1230,7 @@ int p9_client_open(struct p9_fid *fid, int mode)
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "Qd", &qid, &iounit);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto free_and_error;
         }
 
@@ -1267,7 +1273,7 @@ int p9_client_create_dotl(struct p9_fid *ofid, char *name, u32 flags, u32 mode,
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "Qd", qid, &iounit);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto free_and_error;
         }
 
@@ -1312,7 +1318,7 @@ int p9_client_fcreate(struct p9_fid *fid, char *name, u32 perm, int mode,
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "Qd", &qid, &iounit);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto free_and_error;
         }
 
@@ -1351,7 +1357,7 @@ int p9_client_symlink(struct p9_fid *dfid, char *name, char *symtgt, gid_t gid,
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "Q", qid);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto free_and_error;
         }
 
@@ -1542,12 +1548,11 @@ p9_client_read(struct p9_fid *fid, char *data, char __user *udata, u64 offset,
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "D", &count, &dataptr);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto free_and_error;
         }
 
         P9_DPRINTK(P9_DEBUG_9P, "<<< RREAD count %d\n", count);
-        P9_DUMP_PKT(1, req->rc);
 
         if (non_zc) {
                 if (data) {
@@ -1617,7 +1622,7 @@ p9_client_write(struct p9_fid *fid, char *data, const char __user *udata,
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "d", &count);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto free_and_error;
         }
 
@@ -1657,7 +1662,7 @@ struct p9_wstat *p9_client_stat(struct p9_fid *fid)
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "wS", &ignored, ret);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 p9_free_req(clnt, req);
                 goto error;
         }
@@ -1708,7 +1713,7 @@ struct p9_stat_dotl *p9_client_getattr_dotl(struct p9_fid *fid,
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "A", ret);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 p9_free_req(clnt, req);
                 goto error;
         }
@@ -1856,7 +1861,7 @@ int p9_client_statfs(struct p9_fid *fid, struct p9_rstatfs *sb)
                 &sb->bsize, &sb->blocks, &sb->bfree, &sb->bavail,
                 &sb->files, &sb->ffree, &sb->fsid, &sb->namelen);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 p9_free_req(clnt, req);
                 goto error;
         }
@@ -1963,7 +1968,7 @@ struct p9_fid *p9_client_xattrwalk(struct p9_fid *file_fid,
         }
         err = p9pdu_readf(req->rc, clnt->proto_version, "q", attr_size);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 p9_free_req(clnt, req);
                 goto clunk_fid;
         }
@@ -2047,7 +2052,7 @@ int p9_client_readdir(struct p9_fid *fid, char *data, u32 count, u64 offset)
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "D", &count, &dataptr);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto free_and_error;
         }
 
@@ -2084,7 +2089,7 @@ int p9_client_mknod_dotl(struct p9_fid *fid, char *name, int mode,
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "Q", qid);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto error;
         }
         P9_DPRINTK(P9_DEBUG_9P, "<<< RMKNOD qid %x.%llx.%x\n", qid->type,
@@ -2115,7 +2120,7 @@ int p9_client_mkdir_dotl(struct p9_fid *fid, char *name, int mode,
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "Q", qid);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto error;
         }
         P9_DPRINTK(P9_DEBUG_9P, "<<< RMKDIR qid %x.%llx.%x\n", qid->type,
@@ -2150,7 +2155,7 @@ int p9_client_lock_dotl(struct p9_fid *fid, struct p9_flock *flock, u8 *status)
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "b", status);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto error;
         }
         P9_DPRINTK(P9_DEBUG_9P, "<<< RLOCK status %i\n", *status);
@@ -2183,7 +2188,7 @@ int p9_client_getlock_dotl(struct p9_fid *fid, struct p9_getlock *glock)
                         &glock->start, &glock->length, &glock->proc_id,
                         &glock->client_id);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto error;
         }
         P9_DPRINTK(P9_DEBUG_9P, "<<< RGETLOCK type %i start %lld length %lld "
@@ -2211,7 +2216,7 @@ int p9_client_readlink(struct p9_fid *fid, char **target)
 
         err = p9pdu_readf(req->rc, clnt->proto_version, "s", target);
         if (err) {
-                P9_DUMP_PKT(1, req->rc);
+                trace_9p_protocol_dump(clnt, req->rc);
                 goto error;
         }
         P9_DPRINTK(P9_DEBUG_9P, "<<< RREADLINK target %s\n", *target);