Merge tag 'nfs-for-3.12-1' of git://git.linux-nfs.org/projects/trondmy/linux-nfs

Pull NFS client updates from Trond Myklebust:
 "Highlights include:

   - Fix NFSv4 recovery so that it doesn't recover lost locks in cases
     such as lease loss due to a network partition, where doing so may
     result in data corruption.  Add a kernel parameter to control
     choice of legacy behaviour or not.
   - Performance improvements when 2 processes are writing to the same
     file.
   - Flush data to disk when an RPCSEC_GSS session timeout is imminent.
   - Implement NFSv4.1 SP4_MACH_CRED state protection to prevent other
     NFS clients from being able to manipulate our lease and file
     locking state.
   - Allow sharing of RPCSEC_GSS caches between different rpc clients.
   - Fix the broken NFSv4 security auto-negotiation between client and
     server.
   - Fix rmdir() to wait for outstanding sillyrename unlinks to complete
   - Add a tracepoint framework for debugging NFSv4 state recovery
     issues.
   - Add tracing to the generic NFS layer.
   - Add tracing for the SUNRPC socket connection state.
   - Clean up the rpc_pipefs mount/umount event management.
   - Merge more patches from Chuck in preparation for NFSv4 migration
     support"

* tag 'nfs-for-3.12-1' of git://git.linux-nfs.org/projects/trondmy/linux-nfs: (107 commits)
  NFSv4: use mach cred for SECINFO_NO_NAME w/ integrity
  NFS: nfs_compare_super shouldn't check the auth flavour unless 'sec=' was set
  NFSv4: Allow security autonegotiation for submounts
  NFSv4: Disallow security negotiation for lookups when 'sec=' is specified
  NFSv4: Fix security auto-negotiation
  NFS: Clean up nfs_parse_security_flavors()
  NFS: Clean up the auth flavour array mess
  NFSv4.1 Use MDS auth flavor for data server connection
  NFS: Don't check lock owner compatability unless file is locked (part 2)
  NFS: Don't check lock owner compatibility in writes unless file is locked
  nfs4: Map NFS4ERR_WRONG_CRED to EPERM
  nfs4.1: Add SP4_MACH_CRED write and commit support
  nfs4.1: Add SP4_MACH_CRED stateid support
  nfs4.1: Add SP4_MACH_CRED secinfo support
  nfs4.1: Add SP4_MACH_CRED cleanup support
  nfs4.1: Add state protection handler
  nfs4.1: Minimal SP4_MACH_CRED implementation
  SUNRPC: Replace pointer values with task->tk_pid and rpc_clnt->cl_clid
  SUNRPC: Add an identifier for struct rpc_clnt
  SUNRPC: Ensure rpc_task->tk_pid is available for tracepoints
  ...

1 files changed, 157 insertions, 24 deletions

diff --git a/include/trace/events/sunrpc.h b/include/trace/events/sunrpc.h
index 43be87d5dd58..d51d16c7afd8 100644
--- a/include/trace/events/sunrpc.h
+++ b/include/trace/events/sunrpc.h
@@ -6,6 +6,8 @@
 
 #include <linux/sunrpc/sched.h>
 #include <linux/sunrpc/clnt.h>
+#include <net/tcp_states.h>
+#include <linux/net.h>
 #include <linux/tracepoint.h>
 
 DECLARE_EVENT_CLASS(rpc_task_status,
@@ -15,18 +17,20 @@ DECLARE_EVENT_CLASS(rpc_task_status,
         TP_ARGS(task),
 
         TP_STRUCT__entry(
-                __field(const struct rpc_task *, task)
-                __field(const struct rpc_clnt *, clnt)
+                __field(unsigned int, task_id)
+                __field(unsigned int, client_id)
                 __field(int, status)
         ),
 
         TP_fast_assign(
-                __entry->task = task;
-                __entry->clnt = task->tk_client;
+                __entry->task_id = task->tk_pid;
+                __entry->client_id = task->tk_client->cl_clid;
                 __entry->status = task->tk_status;
         ),
 
-        TP_printk("task:%p@%p, status %d",__entry->task, __entry->clnt, __entry->status)
+        TP_printk("task:%u@%u, status %d",
+                __entry->task_id, __entry->client_id,
+                __entry->status)
 );
 
 DEFINE_EVENT(rpc_task_status, rpc_call_status,
@@ -47,18 +51,20 @@ TRACE_EVENT(rpc_connect_status,
         TP_ARGS(task, status),
 
         TP_STRUCT__entry(
-                __field(const struct rpc_task *, task)
-                __field(const struct rpc_clnt *, clnt)
+                __field(unsigned int, task_id)
+                __field(unsigned int, client_id)
                 __field(int, status)
         ),
 
         TP_fast_assign(
-                __entry->task = task;
-                __entry->clnt = task->tk_client;
+                __entry->task_id = task->tk_pid;
+                __entry->client_id = task->tk_client->cl_clid;
                 __entry->status = status;
         ),
 
-        TP_printk("task:%p@%p, status %d",__entry->task, __entry->clnt, __entry->status)
+        TP_printk("task:%u@%u, status %d",
+                __entry->task_id, __entry->client_id,
+                __entry->status)
 );
 
 DECLARE_EVENT_CLASS(rpc_task_running,
@@ -68,8 +74,8 @@ DECLARE_EVENT_CLASS(rpc_task_running,
         TP_ARGS(clnt, task, action),
 
         TP_STRUCT__entry(
-                __field(const struct rpc_clnt *, clnt)
-                __field(const struct rpc_task *, task)
+                __field(unsigned int, task_id)
+                __field(unsigned int, client_id)
                 __field(const void *, action)
                 __field(unsigned long, runstate)
                 __field(int, status)
@@ -77,17 +83,16 @@ DECLARE_EVENT_CLASS(rpc_task_running,
                 ),
 
         TP_fast_assign(
-                __entry->clnt = clnt;
-                __entry->task = task;
+                __entry->client_id = clnt->cl_clid;
+                __entry->task_id = task->tk_pid;
                 __entry->action = action;
                 __entry->runstate = task->tk_runstate;
                 __entry->status = task->tk_status;
                 __entry->flags = task->tk_flags;
                 ),
 
-        TP_printk("task:%p@%p flags=%4.4x state=%4.4lx status=%d action=%pf",
-                __entry->task,
-                __entry->clnt,
+        TP_printk("task:%u@%u flags=%4.4x state=%4.4lx status=%d action=%pf",
+                __entry->task_id, __entry->client_id,
                 __entry->flags,
                 __entry->runstate,
                 __entry->status,
@@ -126,8 +131,8 @@ DECLARE_EVENT_CLASS(rpc_task_queued,
         TP_ARGS(clnt, task, q),
 
         TP_STRUCT__entry(
-                __field(const struct rpc_clnt *, clnt)
-                __field(const struct rpc_task *, task)
+                __field(unsigned int, task_id)
+                __field(unsigned int, client_id)
                 __field(unsigned long, timeout)
                 __field(unsigned long, runstate)
                 __field(int, status)
@@ -136,8 +141,8 @@ DECLARE_EVENT_CLASS(rpc_task_queued,
                 ),
 
         TP_fast_assign(
-                __entry->clnt = clnt;
-                __entry->task = task;
+                __entry->client_id = clnt->cl_clid;
+                __entry->task_id = task->tk_pid;
                 __entry->timeout = task->tk_timeout;
                 __entry->runstate = task->tk_runstate;
                 __entry->status = task->tk_status;
@@ -145,9 +150,8 @@ DECLARE_EVENT_CLASS(rpc_task_queued,
                 __assign_str(q_name, rpc_qname(q));
                 ),
 
-        TP_printk("task:%p@%p flags=%4.4x state=%4.4lx status=%d timeout=%lu queue=%s",
-                __entry->task,
-                __entry->clnt,
+        TP_printk("task:%u@%u flags=%4.4x state=%4.4lx status=%d timeout=%lu queue=%s",
+                __entry->task_id, __entry->client_id,
                 __entry->flags,
                 __entry->runstate,
                 __entry->status,
@@ -172,6 +176,135 @@ DEFINE_EVENT(rpc_task_queued, rpc_task_wakeup,
 
 );
 
+#define rpc_show_socket_state(state) \
+        __print_symbolic(state, \
+                { SS_FREE, "FREE" }, \
+                { SS_UNCONNECTED, "UNCONNECTED" }, \
+                { SS_CONNECTING, "CONNECTING," }, \
+                { SS_CONNECTED, "CONNECTED," }, \
+                { SS_DISCONNECTING, "DISCONNECTING" })
+
+#define rpc_show_sock_state(state) \
+        __print_symbolic(state, \
+                { TCP_ESTABLISHED, "ESTABLISHED" }, \
+                { TCP_SYN_SENT, "SYN_SENT" }, \
+                { TCP_SYN_RECV, "SYN_RECV" }, \
+                { TCP_FIN_WAIT1, "FIN_WAIT1" }, \
+                { TCP_FIN_WAIT2, "FIN_WAIT2" }, \
+                { TCP_TIME_WAIT, "TIME_WAIT" }, \
+                { TCP_CLOSE, "CLOSE" }, \
+                { TCP_CLOSE_WAIT, "CLOSE_WAIT" }, \
+                { TCP_LAST_ACK, "LAST_ACK" }, \
+                { TCP_LISTEN, "LISTEN" }, \
+                { TCP_CLOSING, "CLOSING" })
+
+DECLARE_EVENT_CLASS(xs_socket_event,
+
+                TP_PROTO(
+                        struct rpc_xprt *xprt,
+                        struct socket *socket
+                ),
+
+                TP_ARGS(xprt, socket),
+
+                TP_STRUCT__entry(
+                        __field(unsigned int, socket_state)
+                        __field(unsigned int, sock_state)
+                        __field(unsigned long long, ino)
+                        __string(dstaddr,
+                                xprt->address_strings[RPC_DISPLAY_ADDR])
+                        __string(dstport,
+                                xprt->address_strings[RPC_DISPLAY_PORT])
+                ),
+
+                TP_fast_assign(
+                        struct inode *inode = SOCK_INODE(socket);
+                        __entry->socket_state = socket->state;
+                        __entry->sock_state = socket->sk->sk_state;
+                        __entry->ino = (unsigned long long)inode->i_ino;
+                        __assign_str(dstaddr,
+                                xprt->address_strings[RPC_DISPLAY_ADDR]);
+                        __assign_str(dstport,
+                                xprt->address_strings[RPC_DISPLAY_PORT]);
+                ),
+
+                TP_printk(
+                        "socket:[%llu] dstaddr=%s/%s "
+                        "state=%u (%s) sk_state=%u (%s)",
+                        __entry->ino, __get_str(dstaddr), __get_str(dstport),
+                        __entry->socket_state,
+                        rpc_show_socket_state(__entry->socket_state),
+                        __entry->sock_state,
+                        rpc_show_sock_state(__entry->sock_state)
+                )
+);
+#define DEFINE_RPC_SOCKET_EVENT(name) \
+        DEFINE_EVENT(xs_socket_event, name, \
+                        TP_PROTO( \
+                                struct rpc_xprt *xprt, \
+                                struct socket *socket \
+                        ), \
+                        TP_ARGS(xprt, socket))
+
+DECLARE_EVENT_CLASS(xs_socket_event_done,
+
+                TP_PROTO(
+                        struct rpc_xprt *xprt,
+                        struct socket *socket,
+                        int error
+                ),
+
+                TP_ARGS(xprt, socket, error),
+
+                TP_STRUCT__entry(
+                        __field(int, error)
+                        __field(unsigned int, socket_state)
+                        __field(unsigned int, sock_state)
+                        __field(unsigned long long, ino)
+                        __string(dstaddr,
+                                xprt->address_strings[RPC_DISPLAY_ADDR])
+                        __string(dstport,
+                                xprt->address_strings[RPC_DISPLAY_PORT])
+                ),
+
+                TP_fast_assign(
+                        struct inode *inode = SOCK_INODE(socket);
+                        __entry->socket_state = socket->state;
+                        __entry->sock_state = socket->sk->sk_state;
+                        __entry->ino = (unsigned long long)inode->i_ino;
+                        __entry->error = error;
+                        __assign_str(dstaddr,
+                                xprt->address_strings[RPC_DISPLAY_ADDR]);
+                        __assign_str(dstport,
+                                xprt->address_strings[RPC_DISPLAY_PORT]);
+                ),
+
+                TP_printk(
+                        "error=%d socket:[%llu] dstaddr=%s/%s "
+                        "state=%u (%s) sk_state=%u (%s)",
+                        __entry->error,
+                        __entry->ino, __get_str(dstaddr), __get_str(dstport),
+                        __entry->socket_state,
+                        rpc_show_socket_state(__entry->socket_state),
+                        __entry->sock_state,
+                        rpc_show_sock_state(__entry->sock_state)
+                )
+);
+#define DEFINE_RPC_SOCKET_EVENT_DONE(name) \
+        DEFINE_EVENT(xs_socket_event_done, name, \
+                        TP_PROTO( \
+                                struct rpc_xprt *xprt, \
+                                struct socket *socket, \
+                                int error \
+                        ), \
+                        TP_ARGS(xprt, socket, error))
+
+DEFINE_RPC_SOCKET_EVENT(rpc_socket_state_change);
+DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_connect);
+DEFINE_RPC_SOCKET_EVENT_DONE(rpc_socket_reset_connection);
+DEFINE_RPC_SOCKET_EVENT(rpc_socket_close);
+DEFINE_RPC_SOCKET_EVENT(rpc_socket_shutdown);
+
 #endif /* _TRACE_SUNRPC_H */
 
 #include <trace/define_trace.h>