Show last holder PID, inode in client_locks

Add last_user_pid[mode] and last_user_ino[mode] arrays to scoutfs_lock,
filled in at the granted-mode path alongside the existing counts.
The inode is passed by callers for all per-inode cases, and set to 0
for others. PID is from the current task.

The client_locks line is expanded with "ino: rd I wr I wo I pid: rd P
wr P wo P".  Existing users:/waiters: field positions are unchanged.

A simple test case demonstrates the functionality for the two simple
inode/non-inode case, and for a contended lock case (multiple rd/wr
lock holders).

Signed-off-by: Auke Kok <auke.kok@versity.com>

kmod/src/client.c

@@ -479,7 +479,7 @@ static void scoutfs_client_connect_worker(struct work_struct *work)
 	struct scoutfs_sb_info *sbi = SCOUTFS_SB(sb);
 	struct scoutfs_mount_options opts;
 	struct scoutfs_net_greeting greet;
-	struct sockaddr_storage sin;
+	struct sockaddr_in sin;
 	bool am_quorum;
 	int ret;
 

kmod/src/fence.c

@@ -25,7 +25,6 @@
 #include "sysfs.h"
 #include "server.h"
 #include "fence.h"
-#include "net.h"
 
 /*
  * Fencing ensures that a given mount can no longer write to the
@@ -80,7 +79,7 @@ struct pending_fence {
 	struct timer_list timer;
 
 	ktime_t start_kt;
-	union scoutfs_inet_addr addr;
+	__be32 ipv4_addr;
 	bool fenced;
 	bool error;
 	int reason;
@@ -172,19 +171,14 @@ static ssize_t error_store(struct kobject *kobj, struct kobj_attribute *attr, co
 }
 SCOUTFS_ATTR_RW(error);
 
-static ssize_t inet_addr_show(struct kobject *kobj,
+static ssize_t ipv4_addr_show(struct kobject *kobj,
 			      struct kobj_attribute *attr, char *buf)
 {
 	DECLARE_FENCE_FROM_KOBJ(fence, kobj);
-	struct sockaddr_storage sin;
 
-	memset(&sin, 0, sizeof(struct sockaddr_storage));
-
-	scoutfs_addr_to_sin(&sin, &fence->addr);
-
-	return snprintf(buf, PAGE_SIZE, "%pISc", SIN_ARG(&sin));
+	return snprintf(buf, PAGE_SIZE, "%pI4", &fence->ipv4_addr);
 }
-SCOUTFS_ATTR_RO(inet_addr);
+SCOUTFS_ATTR_RO(ipv4_addr);
 
 static ssize_t reason_show(struct kobject *kobj, struct kobj_attribute *attr,
 			   char *buf)
@@ -218,7 +212,7 @@ static struct attribute *fence_attrs[] = {
 	SCOUTFS_ATTR_PTR(elapsed_secs),
 	SCOUTFS_ATTR_PTR(fenced),
 	SCOUTFS_ATTR_PTR(error),
-	SCOUTFS_ATTR_PTR(inet_addr),
+	SCOUTFS_ATTR_PTR(ipv4_addr),
 	SCOUTFS_ATTR_PTR(reason),
 	SCOUTFS_ATTR_PTR(rid),
 	NULL,
@@ -238,7 +232,7 @@ static void fence_timeout(struct timer_list *timer)
 	wake_up(&fi->waitq);
 }
 
-int scoutfs_fence_start(struct super_block *sb, u64 rid, union scoutfs_inet_addr *addr, int reason)
+int scoutfs_fence_start(struct super_block *sb, u64 rid, __be32 ipv4_addr, int reason)
 {
 	DECLARE_FENCE_INFO(sb, fi);
 	struct pending_fence *fence;
@@ -254,7 +248,7 @@ int scoutfs_fence_start(struct super_block *sb, u64 rid, union scoutfs_inet_addr
 	scoutfs_sysfs_init_attrs(sb, &fence->ssa);
 
 	fence->start_kt = ktime_get();
-	memcpy(&fence->addr, addr, sizeof(union scoutfs_inet_addr));
+	fence->ipv4_addr = ipv4_addr;
 	fence->fenced = false;
 	fence->error = false;
 	fence->reason = reason;

kmod/src/fence.h

@@ -7,7 +7,7 @@ enum {
 	SCOUTFS_FENCE_QUORUM_BLOCK_LEADER,
 };
 
-int scoutfs_fence_start(struct super_block *sb, u64 rid, union scoutfs_inet_addr *addr, int reason);
+int scoutfs_fence_start(struct super_block *sb, u64 rid, __be32 ipv4_addr, int reason);
 int scoutfs_fence_next(struct super_block *sb, u64 *rid, int *reason, bool *error);
 int scoutfs_fence_reason_pending(struct super_block *sb, int reason);
 int scoutfs_fence_free(struct super_block *sb, u64 rid);

kmod/src/kernelcompat.h

@@ -195,11 +195,9 @@ struct kc_shrinker_wrapper {
 #include <linux/inet.h>
 static inline int kc_kernel_getsockname(struct socket *sock, struct sockaddr *addr)
 {
-	int addrlen = sizeof(struct sockaddr_storage);
+	int addrlen = sizeof(struct sockaddr_in);
 	int ret = kernel_getsockname(sock, addr, &addrlen);
-	if (ret == 0 && (!(
-	    (addrlen == sizeof(struct sockaddr_in)) ||
-	    (addrlen == sizeof(struct sockaddr_in6)))))
+	if (ret == 0 && addrlen != sizeof(struct sockaddr_in))
 		return -EAFNOSUPPORT;
 	else if (ret < 0)
 		return ret;
@@ -208,11 +206,9 @@ static inline int kc_kernel_getsockname(struct socket *sock, struct sockaddr *ad
 }
 static inline int kc_kernel_getpeername(struct socket *sock, struct sockaddr *addr)
 {
-	int addrlen = sizeof(struct sockaddr_storage);
+	int addrlen = sizeof(struct sockaddr_in);
 	int ret = kernel_getpeername(sock, addr, &addrlen);
-	if (ret == 0 && (!(
-	    (addrlen == sizeof(struct sockaddr_in)) ||
-	    (addrlen == sizeof(struct sockaddr_in6)))))
+	if (ret == 0 && addrlen != sizeof(struct sockaddr_in))
 		return -EAFNOSUPPORT;
 	else if (ret < 0)
 		return ret;

kmod/src/lock.c

@@ -980,7 +980,7 @@ static bool lock_flags_invalid(int flags)
  */
 static int lock_key_range(struct super_block *sb, enum scoutfs_lock_mode mode, int flags,
 			  struct scoutfs_key *start, struct scoutfs_key *end,
-			  struct scoutfs_lock **ret_lock)
+			  u64 ino, struct scoutfs_lock **ret_lock)
 {
 	DECLARE_LOCK_INFO(sb, linfo);
 	struct scoutfs_lock *lock;
@@ -1028,6 +1028,8 @@ static int lock_key_range(struct super_block *sb, enum scoutfs_lock_mode mode, i
 		/* the fast path where we can use the granted mode */
 		if (lock_modes_match(lock->mode, mode)) {
 			lock_inc_count(lock->users, mode);
+			lock->last_user_pid[mode] = task_pid_nr(current);
+			lock->last_user_ino[mode] = ino;
 			*ret_lock = lock;
 			ret = 0;
 			break;
@@ -1108,7 +1110,7 @@ int scoutfs_lock_ino(struct super_block *sb, enum scoutfs_lock_mode mode, int fl
 	end.sk_zone = SCOUTFS_FS_ZONE;
 	end.ski_ino = cpu_to_le64(ino | SCOUTFS_LOCK_INODE_GROUP_MASK);
 
-	return lock_key_range(sb, mode, flags, &start, &end, ret_lock);
+	return lock_key_range(sb, mode, flags, &start, &end, ino, ret_lock);
 }
 
 /*
@@ -1238,7 +1240,7 @@ int scoutfs_lock_rename(struct super_block *sb, enum scoutfs_lock_mode mode, int
 		.sk_type = SCOUTFS_RENAME_TYPE,
 	};
 
-	return lock_key_range(sb, mode, flags, &key, &key, lock);
+	return lock_key_range(sb, mode, flags, &key, &key, 0, lock);
 }
 
 /*
@@ -1286,7 +1288,7 @@ int scoutfs_lock_inode_index(struct super_block *sb, enum scoutfs_lock_mode mode
 
 	scoutfs_lock_get_index_item_range(type, major, ino, &start, &end);
 
-	return lock_key_range(sb, mode, 0, &start, &end, ret_lock);
+	return lock_key_range(sb, mode, 0, &start, &end, ino, ret_lock);
 }
 
 /*
@@ -1313,7 +1315,7 @@ int scoutfs_lock_orphan(struct super_block *sb, enum scoutfs_lock_mode mode, int
 	end.sko_ino = cpu_to_le64(U64_MAX);
 	end.sk_type = SCOUTFS_ORPHAN_TYPE;
 
-	return lock_key_range(sb, mode, flags, &start, &end, lock);
+	return lock_key_range(sb, mode, flags, &start, &end, ino, lock);
 }
 
 int scoutfs_lock_xattr_totl(struct super_block *sb, enum scoutfs_lock_mode mode, int flags,
@@ -1324,7 +1326,7 @@ int scoutfs_lock_xattr_totl(struct super_block *sb, enum scoutfs_lock_mode mode,
 
 	scoutfs_totl_set_range(&start, &end);
 
-	return lock_key_range(sb, mode, flags, &start, &end, lock);
+	return lock_key_range(sb, mode, flags, &start, &end, 0, lock);
 }
 
 int scoutfs_lock_xattr_indx(struct super_block *sb, enum scoutfs_lock_mode mode, int flags,
@@ -1335,7 +1337,7 @@ int scoutfs_lock_xattr_indx(struct super_block *sb, enum scoutfs_lock_mode mode,
 
 	scoutfs_xattr_indx_get_range(&start, &end);
 
-	return lock_key_range(sb, mode, flags, &start, &end, lock);
+	return lock_key_range(sb, mode, flags, &start, &end, 0, lock);
 }
 
 int scoutfs_lock_quota(struct super_block *sb, enum scoutfs_lock_mode mode, int flags,
@@ -1346,7 +1348,7 @@ int scoutfs_lock_quota(struct super_block *sb, enum scoutfs_lock_mode mode, int
 
 	scoutfs_quota_get_lock_range(&start, &end);
 
-	return lock_key_range(sb, mode, flags, &start, &end, lock);
+	return lock_key_range(sb, mode, flags, &start, &end, 0, lock);
 }
 
 void scoutfs_unlock(struct super_block *sb, struct scoutfs_lock *lock, enum scoutfs_lock_mode mode)
@@ -1463,7 +1465,7 @@ static void lock_tseq_show(struct seq_file *m, struct scoutfs_tseq_entry *ent)
 	struct scoutfs_lock *lock =
 		container_of(ent, struct scoutfs_lock, tseq_entry);
 
-	seq_printf(m, "start "SK_FMT" end "SK_FMT" refresh_gen %llu mode %d waiters: rd %u wr %u wo %u users: rd %u wr %u wo %u\n",
+	seq_printf(m, "start "SK_FMT" end "SK_FMT" refresh_gen %llu mode %d waiters: rd %u wr %u wo %u users: rd %u wr %u wo %u ino: rd %llu wr %llu wo %llu pid: rd %d wr %d wo %d\n",
 			   SK_ARG(&lock->start), SK_ARG(&lock->end),
 			   lock->refresh_gen, lock->mode,
 			   lock->waiters[SCOUTFS_LOCK_READ],
@@ -1471,7 +1473,13 @@ static void lock_tseq_show(struct seq_file *m, struct scoutfs_tseq_entry *ent)
 			   lock->waiters[SCOUTFS_LOCK_WRITE_ONLY],
 			   lock->users[SCOUTFS_LOCK_READ],
 			   lock->users[SCOUTFS_LOCK_WRITE],
-			   lock->users[SCOUTFS_LOCK_WRITE_ONLY]);
+			   lock->users[SCOUTFS_LOCK_WRITE_ONLY],
+			   lock->last_user_ino[SCOUTFS_LOCK_READ],
+			   lock->last_user_ino[SCOUTFS_LOCK_WRITE],
+			   lock->last_user_ino[SCOUTFS_LOCK_WRITE_ONLY],
+			   lock->last_user_pid[SCOUTFS_LOCK_READ],
+			   lock->last_user_pid[SCOUTFS_LOCK_WRITE],
+			   lock->last_user_pid[SCOUTFS_LOCK_WRITE_ONLY]);
 }
 
 /*

kmod/src/lock.h

@@ -42,6 +42,8 @@ struct scoutfs_lock {
 	enum scoutfs_lock_mode invalidating_mode;
 	unsigned int waiters[SCOUTFS_LOCK_NR_MODES];
 	unsigned int users[SCOUTFS_LOCK_NR_MODES];
+	pid_t last_user_pid[SCOUTFS_LOCK_NR_MODES];
+	u64 last_user_ino[SCOUTFS_LOCK_NR_MODES];
 
 	struct scoutfs_tseq_entry tseq_entry;
 

kmod/src/net.c

@@ -1218,8 +1218,7 @@ static void scoutfs_net_connect_worker(struct work_struct *work)
 
 	trace_scoutfs_net_connect_work_enter(sb, 0, 0);
 
-	ret = kc_sock_create_kern(conn->connect_sin.ss_family,
-				  SOCK_STREAM, IPPROTO_TCP, &sock);
+	ret = kc_sock_create_kern(AF_INET, SOCK_STREAM, IPPROTO_TCP, &sock);
 	if (ret)
 		goto out;
 
@@ -1240,9 +1239,7 @@ static void scoutfs_net_connect_worker(struct work_struct *work)
 	trace_scoutfs_conn_connect_start(conn);
 
 	ret = kernel_connect(sock, (struct sockaddr *)&conn->connect_sin,
-			     conn->connect_sin.ss_family == AF_INET ?
-				sizeof(struct sockaddr_in) : sizeof(struct sockaddr_in6),
-			     0);
+			     sizeof(struct sockaddr_in), 0);
 	if (ret)
 		goto out;
 
@@ -1284,13 +1281,6 @@ static bool empty_accepted_list(struct scoutfs_net_connection *conn)
 	return empty;
 }
 
-/*
- * sockaddr_storage wraps both _in and _in6, which have _port always
- * __be16 at the same offset, and we only need to test whether it's
- * zero.
- */
-#define sockaddr_port_is_nonzero(sin) ((sin).__data[0] || (sin).__data[1])
-
 /*
  * Safely shut down an active connection.  This can be triggered by
  * errors in workers or by an external call to free the connection.  The
@@ -1314,7 +1304,7 @@ static void scoutfs_net_shutdown_worker(struct work_struct *work)
 	trace_scoutfs_conn_shutdown_start(conn);
 
 	/* connected and accepted conns print a message */
-	if (sockaddr_port_is_nonzero(conn->peername))
+	if (conn->peername.sin_port != 0)
 		scoutfs_info(sb, "%s "SIN_FMT" -> "SIN_FMT,
 			     conn->listening_conn ? "server closing" :
 			                            "client disconnected",
@@ -1444,7 +1434,6 @@ static void scoutfs_net_reconn_free_worker(struct work_struct *work)
 	DEFINE_CONN_FROM_WORK(conn, work, reconn_free_dwork.work);
 	struct super_block *sb = conn->sb;
 	struct scoutfs_net_connection *acc;
-	union scoutfs_inet_addr addr;
 	unsigned long now = jiffies;
 	unsigned long deadline = 0;
 	bool requeue = false;
@@ -1465,9 +1454,8 @@ restart:
 			if (!test_conn_fl(conn, shutting_down)) {
 				scoutfs_info(sb, "client "SIN_FMT" reconnect timed out, fencing",
 					     SIN_ARG(&acc->last_peername));
-				scoutfs_sin_to_addr(&addr, &acc->last_peername);
 				ret = scoutfs_fence_start(sb, acc->rid,
-						&addr,
+						acc->last_peername.sin_addr.s_addr,
 						SCOUTFS_FENCE_CLIENT_RECONNECT);
 				if (ret) {
 					scoutfs_err(sb, "client fence returned err %d, shutting down server",
@@ -1550,9 +1538,9 @@ scoutfs_net_alloc_conn(struct super_block *sb,
 	conn->req_funcs = req_funcs;
 	spin_lock_init(&conn->lock);
 	init_waitqueue_head(&conn->waitq);
-	conn->sockname.ss_family = AF_UNSPEC;
-	conn->peername.ss_family = AF_UNSPEC;
-	conn->last_peername.ss_family = AF_UNSPEC;
+	conn->sockname.sin_family = AF_INET;
+	conn->peername.sin_family = AF_INET;
+	conn->last_peername.sin_family = AF_INET;
 	INIT_LIST_HEAD(&conn->accepted_head);
 	INIT_LIST_HEAD(&conn->accepted_list);
 	conn->next_send_seq = 1;
@@ -1631,7 +1619,7 @@ void scoutfs_net_free_conn(struct super_block *sb,
  */
 int scoutfs_net_bind(struct super_block *sb,
 		     struct scoutfs_net_connection *conn,
-		     struct sockaddr_storage *sin)
+		     struct sockaddr_in *sin)
 {
 	struct socket *sock = NULL;
 	int addrlen;
@@ -1642,7 +1630,7 @@ int scoutfs_net_bind(struct super_block *sb,
 	if (WARN_ON_ONCE(conn->sock))
 		return -EINVAL;
 
-	ret = kc_sock_create_kern(sin->ss_family, SOCK_STREAM, IPPROTO_TCP, &sock);
+	ret = kc_sock_create_kern(AF_INET, SOCK_STREAM, IPPROTO_TCP, &sock);
 	if (ret)
 		goto out;
 
@@ -1654,7 +1642,7 @@ int scoutfs_net_bind(struct super_block *sb,
 	if (ret)
 		goto out;
 
-	addrlen = sin->ss_family == AF_INET ? sizeof(struct sockaddr_in) : sizeof(struct sockaddr_in6);
+	addrlen = sizeof(struct sockaddr_in);
 	ret = kernel_bind(sock, (struct sockaddr *)sin, addrlen);
 	if (ret)
 		goto out;
@@ -1670,7 +1658,7 @@ int scoutfs_net_bind(struct super_block *sb,
 	ret = 0;
 
 	conn->sock = sock;
-	sin = (struct sockaddr_storage *)&conn->sockname;
+	*sin = conn->sockname;
 
 out:
 	if (ret < 0 && sock)
@@ -1705,7 +1693,7 @@ static bool connect_result(struct scoutfs_net_connection *conn, int *error)
 		done = true;
 		*error = 0;
 	} else if (test_conn_fl(conn, shutting_down) ||
-		   conn->connect_sin.ss_family == AF_UNSPEC) {
+		   conn->connect_sin.sin_family == 0) {
 		done = true;
 		*error = -ESHUTDOWN;
 	}
@@ -1726,7 +1714,7 @@ static bool connect_result(struct scoutfs_net_connection *conn, int *error)
  */
 int scoutfs_net_connect(struct super_block *sb,
 			struct scoutfs_net_connection *conn,
-			struct sockaddr_storage *sin, unsigned long timeout_ms)
+			struct sockaddr_in *sin, unsigned long timeout_ms)
 {
 	int ret = 0;
 

kmod/src/net.h

@@ -49,15 +49,15 @@ struct scoutfs_net_connection {
 	unsigned long flags; /* CONN_FL_* bitmask */
 	unsigned long reconn_deadline;
 
-	struct sockaddr_storage connect_sin;
+	struct sockaddr_in connect_sin;
 	unsigned long connect_timeout_ms;
 
 	struct socket *sock;
 	u64 rid;
 	u64 greeting_id;
-	struct sockaddr_storage sockname;
-	struct sockaddr_storage peername;
-	struct sockaddr_storage last_peername;
+	struct sockaddr_in sockname;
+	struct sockaddr_in peername;
+	struct sockaddr_in last_peername;
 
 	struct list_head accepted_head;
 	struct scoutfs_net_connection *listening_conn;
@@ -99,44 +99,27 @@ enum conn_flags {
 	CONN_FL_reconn_freeing = (1UL << 6), /* waiting done, setter frees */
 };
 
-#define SIN_FMT		"%pISpc"
-#define SIN_ARG(sin)	sin
+#define SIN_FMT		"%pIS:%u"
+#define SIN_ARG(sin)	sin, be16_to_cpu((sin)->sin_port)
 
-static inline void scoutfs_addr_to_sin(struct sockaddr_storage *sin,
+static inline void scoutfs_addr_to_sin(struct sockaddr_in *sin,
 				       union scoutfs_inet_addr *addr)
 {
-	if (addr->v4.family == cpu_to_le16(SCOUTFS_AF_IPV4)) {
-		struct sockaddr_in *sin4 = (struct sockaddr_in *)sin;
-		memset(sin, 0, sizeof(struct sockaddr_storage));
-		sin4->sin_family = AF_INET;
-		sin4->sin_addr.s_addr = cpu_to_be32(le32_to_cpu(addr->v4.addr));
-		sin4->sin_port = cpu_to_be16(le16_to_cpu(addr->v4.port));
-	} else if (addr->v6.family == cpu_to_le16(SCOUTFS_AF_IPV6)) {
-		struct sockaddr_in6 *sin6 = (struct sockaddr_in6 *)sin;
-		memset(sin, 0, sizeof(struct sockaddr_storage));
-		sin6->sin6_family = AF_INET6;
-		memcpy(&sin6->sin6_addr.in6_u.u6_addr8, &addr->v6.addr, 16);
-		sin6->sin6_port = cpu_to_be16(le16_to_cpu(addr->v6.port));
-	} else
-		BUG();
+	BUG_ON(addr->v4.family != cpu_to_le16(SCOUTFS_AF_IPV4));
+
+	sin->sin_family = AF_INET;
+	sin->sin_addr.s_addr = cpu_to_be32(le32_to_cpu(addr->v4.addr));
+	sin->sin_port = cpu_to_be16(le16_to_cpu(addr->v4.port));
 }
 
-static inline void scoutfs_sin_to_addr(union scoutfs_inet_addr *addr, struct sockaddr_storage *sin)
+static inline void scoutfs_sin_to_addr(union scoutfs_inet_addr *addr, struct sockaddr_in *sin)
 {
-	if (sin->ss_family == AF_INET) {
-		struct sockaddr_in *sin4 = (struct sockaddr_in *)sin;
-		memset(addr, 0, sizeof(union scoutfs_inet_addr));
-		addr->v4.family = cpu_to_le16(SCOUTFS_AF_IPV4);
-		addr->v4.addr = be32_to_le32(sin4->sin_addr.s_addr);
-		addr->v4.port = be16_to_le16(sin4->sin_port);
-	} else if (sin->ss_family == AF_INET6) {
-		struct sockaddr_in6 *sin6 = (struct sockaddr_in6 *)sin;
-		memset(addr, 0, sizeof(union scoutfs_inet_addr));
-		addr->v6.family = cpu_to_le16(SCOUTFS_AF_IPV6);
-		memcpy(&addr->v6.addr, &sin6->sin6_addr.in6_u.u6_addr8, 16);
-		addr->v6.port = be16_to_le16(sin6->sin6_port);
-	} else
-		BUG();
+	BUG_ON(sin->sin_family != AF_INET);
+
+	memset(addr, 0, sizeof(union scoutfs_inet_addr));
+	addr->v4.family = cpu_to_le16(SCOUTFS_AF_IPV4);
+	addr->v4.addr = be32_to_le32(sin->sin_addr.s_addr);
+	addr->v4.port = be16_to_le16(sin->sin_port);
 }
 
 struct scoutfs_net_connection *
@@ -147,10 +130,10 @@ scoutfs_net_alloc_conn(struct super_block *sb,
 u64 scoutfs_net_client_rid(struct scoutfs_net_connection *conn);
 int scoutfs_net_connect(struct super_block *sb,
 			struct scoutfs_net_connection *conn,
-			struct sockaddr_storage *sin, unsigned long timeout_ms);
+			struct sockaddr_in *sin, unsigned long timeout_ms);
 int scoutfs_net_bind(struct super_block *sb,
 		     struct scoutfs_net_connection *conn,
-		     struct sockaddr_storage *sin);
+		     struct sockaddr_in *sin);
 void scoutfs_net_listen(struct super_block *sb,
 			struct scoutfs_net_connection *conn);
 int scoutfs_net_submit_request(struct super_block *sb,

kmod/src/quorum.c

@@ -145,26 +145,14 @@ struct quorum_info {
 #define DECLARE_QUORUM_INFO_KOBJ(kobj, name) \
 	DECLARE_QUORUM_INFO(SCOUTFS_SYSFS_ATTRS_SB(kobj), name)
 
-static bool quorum_slot_ipv4(struct scoutfs_quorum_config *qconf, int i)
+static bool quorum_slot_present(struct scoutfs_quorum_config *qconf, int i)
 {
 	BUG_ON(i < 0 || i > SCOUTFS_QUORUM_MAX_SLOTS);
 
 	return qconf->slots[i].addr.v4.family == cpu_to_le16(SCOUTFS_AF_IPV4);
 }
 
-static bool quorum_slot_ipv6(struct scoutfs_quorum_config *qconf, int i)
-{
-	BUG_ON(i < 0 || i > SCOUTFS_QUORUM_MAX_SLOTS);
-
-	return qconf->slots[i].addr.v6.family == cpu_to_le16(SCOUTFS_AF_IPV6);
-}
-
-static bool quorum_slot_present(struct scoutfs_quorum_config *qconf, int i)
-{
-	return quorum_slot_ipv4(qconf, i) || quorum_slot_ipv6(qconf, i);
-}
-
-static void quorum_slot_sin(struct scoutfs_quorum_config *qconf, int i, struct sockaddr_storage *sin)
+static void quorum_slot_sin(struct scoutfs_quorum_config *qconf, int i, struct sockaddr_in *sin)
 {
 	BUG_ON(i < 0 || i >= SCOUTFS_QUORUM_MAX_SLOTS);
 
@@ -191,18 +179,11 @@ static int create_socket(struct super_block *sb)
 {
 	DECLARE_QUORUM_INFO(sb, qinf);
 	struct socket *sock = NULL;
-	struct sockaddr_storage sin;
-	struct scoutfs_quorum_slot slot = qinf->qconf.slots[qinf->our_quorum_slot_nr];
+	struct sockaddr_in sin;
 	int addrlen;
 	int ret;
 
-	if (le16_to_cpu(slot.addr.v4.family) == SCOUTFS_AF_IPV4)
-		ret = kc_sock_create_kern(PF_INET, SOCK_DGRAM, IPPROTO_UDP, &sock);
-	else if (le16_to_cpu(slot.addr.v6.family) == SCOUTFS_AF_IPV6)
-		ret = kc_sock_create_kern(PF_INET6, SOCK_DGRAM, IPPROTO_UDP, &sock);
-	else
-		BUG();
-
+	ret = kc_sock_create_kern(PF_INET, SOCK_DGRAM, IPPROTO_UDP, &sock);
 	if (ret) {
 		scoutfs_err(sb, "quorum couldn't create udp socket: %d", ret);
 		goto out;
@@ -211,9 +192,9 @@ static int create_socket(struct super_block *sb)
 	/* rather fail and retry than block waiting for free */
 	sock->sk->sk_allocation = GFP_ATOMIC;
 
-	addrlen = (le16_to_cpu(slot.addr.v4.family) == SCOUTFS_AF_IPV4) ?
-		  sizeof(struct sockaddr_in) : sizeof(struct sockaddr_in6);
 	quorum_slot_sin(&qinf->qconf, qinf->our_quorum_slot_nr, &sin);
+
+	addrlen = sizeof(sin);
 	ret = kernel_bind(sock, (struct sockaddr *)&sin, addrlen);
 	if (ret) {
 		scoutfs_err(sb, "quorum failed to bind udp socket to "SIN_FMT": %d",
@@ -260,7 +241,7 @@ static int send_msg_members(struct super_block *sb, int type, u64 term, int only
 		.iov_base = &qmes,
 		.iov_len = sizeof(qmes),
 	};
-	struct sockaddr_storage sin;
+	struct sockaddr_in sin;
 	struct msghdr mh = {
 		.msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL,
 		.msg_name = &sin,
@@ -561,11 +542,10 @@ int scoutfs_quorum_fence_leaders(struct super_block *sb, struct scoutfs_quorum_c
 				 u64 term)
 {
 #define NR_OLD 2
-	struct scoutfs_quorum_block_event (*old)[NR_OLD];
+	struct scoutfs_quorum_block_event old[SCOUTFS_QUORUM_MAX_SLOTS][NR_OLD] = {{{0,}}};
 	struct scoutfs_sb_info *sbi = SCOUTFS_SB(sb);
 	struct scoutfs_quorum_block blk;
-	struct sockaddr_storage sin;
-	union scoutfs_inet_addr addr;
+	struct sockaddr_in sin;
 	const __le64 lefsid = cpu_to_le64(sbi->fsid);
 	const u64 rid = sbi->rid;
 	bool fence_started = false;
@@ -578,20 +558,13 @@ int scoutfs_quorum_fence_leaders(struct super_block *sb, struct scoutfs_quorum_c
 
 	BUILD_BUG_ON(SCOUTFS_QUORUM_BLOCKS < SCOUTFS_QUORUM_MAX_SLOTS);
 
-	old = kmalloc(NR_OLD * SCOUTFS_QUORUM_MAX_SLOTS * sizeof(struct scoutfs_quorum_block_event), GFP_KERNEL);
-	if (!old) {
-		ret = -ENOMEM;
-		goto out;
-	}
-	memset(old, 0, NR_OLD * SCOUTFS_QUORUM_MAX_SLOTS * sizeof(struct scoutfs_quorum_block_event));
-
 	for (i = 0; i < SCOUTFS_QUORUM_MAX_SLOTS; i++) {
 		if (!quorum_slot_present(qconf, i))
 			continue;
 
 		ret = read_quorum_block(sb, SCOUTFS_QUORUM_BLKNO + i, &blk, false);
 		if (ret < 0)
-			goto out_free;
+			goto out;
 
 		/* elected leader still running */
 		if (le64_to_cpu(blk.events[SCOUTFS_QUORUM_EVENT_ELECT].term) >
@@ -625,17 +598,14 @@ int scoutfs_quorum_fence_leaders(struct super_block *sb, struct scoutfs_quorum_c
 			scoutfs_info(sb, "fencing previous leader "SCSBF" at term %llu in slot %u with address "SIN_FMT,
 				     SCSB_LEFR_ARGS(lefsid, fence_rid),
 				     le64_to_cpu(old[i][j].term), i, SIN_ARG(&sin));
-			scoutfs_sin_to_addr(&addr, &sin);
-			ret = scoutfs_fence_start(sb, le64_to_cpu(fence_rid), &addr,
+			ret = scoutfs_fence_start(sb, le64_to_cpu(fence_rid), sin.sin_addr.s_addr,
 						  SCOUTFS_FENCE_QUORUM_BLOCK_LEADER);
 			if (ret < 0)
-				goto out_free;
+				goto out;
 			fence_started = true;
 		}
 	}
 
-out_free:
-	kfree(old);
 out:
 	err = scoutfs_fence_wait_fenced(sb, msecs_to_jiffies(SCOUTFS_QUORUM_FENCE_TO_MS));
 	if (ret == 0)
@@ -738,7 +708,7 @@ static void scoutfs_quorum_worker(struct work_struct *work)
 	struct quorum_info *qinf = container_of(work, struct quorum_info, work);
 	struct scoutfs_mount_options opts;
 	struct super_block *sb = qinf->sb;
-	struct sockaddr_storage unused;
+	struct sockaddr_in unused;
 	struct quorum_host_msg msg;
 	struct quorum_status qst = {0,};
 	struct hb_recording hbr;
@@ -1020,7 +990,7 @@ out:
  * leader with the greatest elected term.  If we get it wrong the
  * connection will timeout and the client will try again.
  */
-int scoutfs_quorum_server_sin(struct super_block *sb, struct sockaddr_storage *sin)
+int scoutfs_quorum_server_sin(struct super_block *sb, struct sockaddr_in *sin)
 {
 	struct scoutfs_super_block *super = NULL;
 	struct scoutfs_quorum_block blk;
@@ -1079,7 +1049,7 @@ u8 scoutfs_quorum_votes_needed(struct super_block *sb)
 	return qinf->votes_needed;
 }
 
-void scoutfs_quorum_slot_sin(struct scoutfs_quorum_config *qconf, int i, struct sockaddr_storage *sin)
+void scoutfs_quorum_slot_sin(struct scoutfs_quorum_config *qconf, int i, struct sockaddr_in *sin)
 {
 	return quorum_slot_sin(qconf, i, sin);
 }
@@ -1238,12 +1208,8 @@ static int verify_quorum_slots(struct super_block *sb, struct quorum_info *qinf,
 			       struct scoutfs_quorum_config *qconf)
 {
 	char slots[(SCOUTFS_QUORUM_MAX_SLOTS * 3) + 1];
-	struct sockaddr_storage other;
-	struct sockaddr_storage sin;
-	struct sockaddr_in *sin4;
-	struct sockaddr_in *other4;
-	struct sockaddr_in6 *sin6;
-	struct sockaddr_in6 *other6;
+	struct sockaddr_in other;
+	struct sockaddr_in sin;
 	int found = 0;
 	int ret;
 	int i;
@@ -1254,78 +1220,35 @@ static int verify_quorum_slots(struct super_block *sb, struct quorum_info *qinf,
 		if (!quorum_slot_present(qconf, i))
 			continue;
 
-		if (quorum_slot_ipv4(qconf, i)) {
-			scoutfs_quorum_slot_sin(qconf, i, &sin);
-			sin4 = (struct sockaddr_in *)&sin;
+		scoutfs_quorum_slot_sin(qconf, i, &sin);
 
-			if (!valid_ipv4_unicast(sin4->sin_addr.s_addr)) {
-				scoutfs_err(sb, "quorum slot #%d has invalid ipv4 unicast address: "SIN_FMT,
-					    i, SIN_ARG(&sin));
-				return -EINVAL;
-			}
-
-			if (!valid_ipv4_port(sin4->sin_port)) {
-				scoutfs_err(sb, "quorum slot #%d has invalid ipv4 port number:"SIN_FMT,
-					    i, SIN_ARG(&sin));
-				return -EINVAL;
-			}
-
-			for (j = i + 1; j < SCOUTFS_QUORUM_MAX_SLOTS; j++) {
-				if (!quorum_slot_ipv4(qconf, j))
-					continue;
-
-				scoutfs_quorum_slot_sin(qconf, j, &other);
-				other4 = (struct sockaddr_in *)&other;
-
-				if (sin4->sin_addr.s_addr == other4->sin_addr.s_addr &&
-				    sin4->sin_port == other4->sin_port) {
-					scoutfs_err(sb, "quorum slots #%u and #%u have the same address: "SIN_FMT,
-						    i, j, SIN_ARG(&sin));
-					return -EINVAL;
-				}
-			}
-
-			found++;
-		} else if (quorum_slot_ipv6(qconf, i)) {
-			quorum_slot_sin(qconf, i, &sin);
-			sin6 = (struct sockaddr_in6 *)&sin;
-
-			if ((sin6->sin6_addr.in6_u.u6_addr32[0] == 0) && (sin6->sin6_addr.in6_u.u6_addr32[1] == 0) &&
-			    (sin6->sin6_addr.in6_u.u6_addr32[2] == 0) && (sin6->sin6_addr.in6_u.u6_addr32[3] == 0)) {
-				scoutfs_err(sb, "quorum slot #%d has unspecified ipv6 address:"SIN_FMT,
-					    i, SIN_ARG(&sin));
-				return -EINVAL;
-			}
-
-			if (sin6->sin6_addr.in6_u.u6_addr8[0] == 0xff) {
-				scoutfs_err(sb, "quorum slot #%d has multicast ipv6 address:"SIN_FMT,
-					    i, SIN_ARG(&sin));
-				return -EINVAL;
-			}
-
-			if (!valid_ipv4_port(sin6->sin6_port)) {
-				scoutfs_err(sb, "quorum slot #%d has invalid ipv6 port number:"SIN_FMT,
-					    i,  SIN_ARG(&sin));
-				return -EINVAL;
-			}
-
-			for (j = i + 1; j < SCOUTFS_QUORUM_MAX_SLOTS; j++) {
-				if (!quorum_slot_ipv6(qconf, j))
-					continue;
-
-				quorum_slot_sin(qconf, j, &other);
-				other6 = (struct sockaddr_in6 *)&other;
-
-				if ((ipv6_addr_equal(&sin6->sin6_addr, &other6->sin6_addr)) &&
-				    (sin6->sin6_port == other6->sin6_port)) {
-					scoutfs_err(sb, "quorum slots #%u and #%u have the same address: "SIN_FMT,
-						    i, j, SIN_ARG(&sin));
-					return -EINVAL;
-				}
-			}
-
-			found++;
+		if (!valid_ipv4_unicast(sin.sin_addr.s_addr)) {
+			scoutfs_err(sb, "quorum slot #%d has invalid ipv4 unicast address: "SIN_FMT,
+				    i,  SIN_ARG(&sin));
+			return -EINVAL;
 		}
+
+		if (!valid_ipv4_port(sin.sin_port)) {
+			scoutfs_err(sb, "quorum slot #%d has invalid ipv4 port number:"SIN_FMT,
+				    i,  SIN_ARG(&sin));
+			return -EINVAL;
+		}
+
+		for (j = i + 1; j < SCOUTFS_QUORUM_MAX_SLOTS; j++) {
+			if (!quorum_slot_present(qconf, j))
+				continue;
+
+			scoutfs_quorum_slot_sin(qconf, j, &other);
+
+			if (sin.sin_addr.s_addr == other.sin_addr.s_addr &&
+			    sin.sin_port == other.sin_port) {
+				scoutfs_err(sb, "quorum slots #%u and #%u have the same address: "SIN_FMT,
+					    i, j, SIN_ARG(&sin));
+				return -EINVAL;
+			}
+		}
+
+		found++;
 	}
 
 	if (found == 0)  {

kmod/src/quorum.h

@@ -1,11 +1,11 @@
 #ifndef _SCOUTFS_QUORUM_H_
 #define _SCOUTFS_QUORUM_H_
 
-int scoutfs_quorum_server_sin(struct super_block *sb, struct sockaddr_storage *sin);
+int scoutfs_quorum_server_sin(struct super_block *sb, struct sockaddr_in *sin);
 
 u8 scoutfs_quorum_votes_needed(struct super_block *sb);
 void scoutfs_quorum_slot_sin(struct scoutfs_quorum_config *qconf, int i,
-			     struct sockaddr_storage *sin);
+			     struct sockaddr_in *sin);
 
 int scoutfs_quorum_fence_leaders(struct super_block *sb, struct scoutfs_quorum_config *qconf,
 				 u64 term);

kmod/src/scoutfs_trace.h

@@ -1355,37 +1355,35 @@ DEFINE_EVENT(scoutfs_lock_class, scoutfs_lock_shrink,
 );
 
 DECLARE_EVENT_CLASS(scoutfs_net_class,
-        TP_PROTO(struct super_block *sb, struct sockaddr_storage *name,
-		 struct sockaddr_storage *peer, struct scoutfs_net_header *nh),
+        TP_PROTO(struct super_block *sb, struct sockaddr_in *name,
+		 struct sockaddr_in *peer, struct scoutfs_net_header *nh),
         TP_ARGS(sb, name, peer, nh),
         TP_STRUCT__entry(
 		SCSB_TRACE_FIELDS
-		__field_struct(struct sockaddr_storage, name)
-		__field_struct(struct sockaddr_storage, peer)
+		si4_trace_define(name)
+		si4_trace_define(peer)
 		snh_trace_define(nh)
         ),
         TP_fast_assign(
 		SCSB_TRACE_ASSIGN(sb);
-		memcpy(&__entry->name, name, sizeof(struct sockaddr_storage));
-		memcpy(&__entry->peer, peer, sizeof(struct sockaddr_storage));
+		si4_trace_assign(name, name);
+		si4_trace_assign(peer, peer);
 		snh_trace_assign(nh, nh);
         ),
-        TP_printk(SCSBF" name "SIN_FMT" peer "SIN_FMT" nh "SNH_FMT,
-		  SCSB_TRACE_ARGS,
-		  &__entry->name,
-		  &__entry->peer,
+        TP_printk(SCSBF" name "SI4_FMT" peer "SI4_FMT" nh "SNH_FMT,
+		  SCSB_TRACE_ARGS, si4_trace_args(name), si4_trace_args(peer),
 		  snh_trace_args(nh))
 );
 
 DEFINE_EVENT(scoutfs_net_class, scoutfs_net_send_message,
-        TP_PROTO(struct super_block *sb, struct sockaddr_storage *name,
-		 struct sockaddr_storage *peer, struct scoutfs_net_header *nh),
+        TP_PROTO(struct super_block *sb, struct sockaddr_in *name,
+		 struct sockaddr_in *peer, struct scoutfs_net_header *nh),
         TP_ARGS(sb, name, peer, nh)
 );
 
 DEFINE_EVENT(scoutfs_net_class, scoutfs_net_recv_message,
-        TP_PROTO(struct super_block *sb, struct sockaddr_storage *name,
-		 struct sockaddr_storage *peer, struct scoutfs_net_header *nh),
+        TP_PROTO(struct super_block *sb, struct sockaddr_in *name,
+		 struct sockaddr_in *peer, struct scoutfs_net_header *nh),
         TP_ARGS(sb, name, peer, nh)
 );
 
@@ -1418,8 +1416,8 @@ DECLARE_EVENT_CLASS(scoutfs_net_conn_class,
 		__field(void *, sock)
 		__field(__u64, c_rid)
 		__field(__u64, greeting_id)
-		__field_struct(struct sockaddr_storage, sockname)
-		__field_struct(struct sockaddr_storage, peername)
+		si4_trace_define(sockname)
+		si4_trace_define(peername)
 		__field(unsigned char, e_accepted_head)
 		__field(void *, listening_conn)
 		__field(unsigned char, e_accepted_list)
@@ -1437,8 +1435,8 @@ DECLARE_EVENT_CLASS(scoutfs_net_conn_class,
 		__entry->sock = conn->sock;
 		__entry->c_rid = conn->rid;
 		__entry->greeting_id = conn->greeting_id;
-		memcpy(&__entry->sockname, &conn->sockname, sizeof(struct sockaddr_storage));
-		memcpy(&__entry->peername, &conn->peername, sizeof(struct sockaddr_storage));
+		si4_trace_assign(sockname, &conn->sockname);
+		si4_trace_assign(peername, &conn->peername);
 		__entry->e_accepted_head = !!list_empty(&conn->accepted_head);
 		__entry->listening_conn = conn->listening_conn;
 		__entry->e_accepted_list = !!list_empty(&conn->accepted_list);
@@ -1448,7 +1446,7 @@ DECLARE_EVENT_CLASS(scoutfs_net_conn_class,
 		__entry->e_resend_queue = !!list_empty(&conn->resend_queue);
 		__entry->recv_seq = atomic64_read(&conn->recv_seq);
         ),
-        TP_printk(SCSBF" flags %s rc_dl %lu cto %lu sk %p rid %llu grid %llu sn "SIN_FMT" pn "SIN_FMT" eah %u lc %p eal %u nss %llu nsi %llu esq %u erq %u rs %llu",
+        TP_printk(SCSBF" flags %s rc_dl %lu cto %lu sk %p rid %llu grid %llu sn "SI4_FMT" pn "SI4_FMT" eah %u lc %p eal %u nss %llu nsi %llu esq %u erq %u rs %llu",
 		  SCSB_TRACE_ARGS,
 		  print_conn_flags(__entry->flags),
 		  __entry->reconn_deadline,
@@ -1456,8 +1454,8 @@ DECLARE_EVENT_CLASS(scoutfs_net_conn_class,
 		  __entry->sock,
 		  __entry->c_rid,
 		  __entry->greeting_id,
-		  &__entry->sockname,
-		  &__entry->peername,
+		  si4_trace_args(sockname),
+		  si4_trace_args(peername),
 		  __entry->e_accepted_head,
 		  __entry->listening_conn,
 		  __entry->e_accepted_list,

kmod/src/server.c

@@ -3639,7 +3639,7 @@ static bool invalid_mounted_client_item(struct scoutfs_btree_item_ref *iref)
  * it's acceptable to see -EEXIST.
  */
 static int insert_mounted_client(struct super_block *sb, u64 rid, u64 gr_flags,
-				 struct sockaddr_storage *sin)
+				 struct sockaddr_in *sin)
 {
 	DECLARE_SERVER_INFO(sb, server);
 	struct scoutfs_super_block *super = DIRTY_SUPER_SB(sb);
@@ -4392,7 +4392,7 @@ static void fence_pending_recov_worker(struct work_struct *work)
 			break;
 		}
 
-		ret = scoutfs_fence_start(sb, rid, &addr,
+		ret = scoutfs_fence_start(sb, rid, le32_to_be32(addr.v4.addr),
 					  SCOUTFS_FENCE_CLIENT_RECOVERY);
 		if (ret < 0) {
 			scoutfs_err(sb, "fence returned err %d, shutting down server", ret);
@@ -4543,7 +4543,7 @@ static void scoutfs_server_worker(struct work_struct *work)
 	struct scoutfs_net_connection *conn = NULL;
 	struct scoutfs_mount_options opts;
 	DECLARE_WAIT_QUEUE_HEAD(waitq);
-	struct sockaddr_storage sin;
+	struct sockaddr_in sin;
 	bool alloc_init = false;
 	u64 max_seq;
 	int ret;
@@ -4552,7 +4552,7 @@ static void scoutfs_server_worker(struct work_struct *work)
 
 	scoutfs_options_read(sb, &opts);
 	scoutfs_quorum_slot_sin(&server->qconf, opts.quorum_slot_nr, &sin);
-	scoutfs_info(sb, "server starting at "SIN_FMT, &sin);
+	scoutfs_info(sb, "server starting at "SIN_FMT, SIN_ARG(&sin));
 
 	scoutfs_block_writer_init(sb, &server->wri);
 	server->finalize_sent_seq = 0;

kmod/src/server.h

@@ -1,6 +1,27 @@
 #ifndef _SCOUTFS_SERVER_H_
 #define _SCOUTFS_SERVER_H_
 
+#define SI4_FMT		"%u.%u.%u.%u:%u"
+
+#define si4_trace_define(name)		\
+	__field(__u32, name##_addr)	\
+	__field(__u16, name##_port)
+
+#define si4_trace_assign(name, sin)					\
+do {									\
+	__typeof__(sin) _sin = (sin);					\
+									\
+	__entry->name##_addr = be32_to_cpu(_sin->sin_addr.s_addr);	\
+	__entry->name##_port = be16_to_cpu(_sin->sin_port);		\
+} while(0)
+
+#define si4_trace_args(name)			\
+	(__entry->name##_addr >> 24),		\
+	(__entry->name##_addr >> 16) & 255,	\
+	(__entry->name##_addr >> 8) & 255,	\
+	__entry->name##_addr & 255,		\
+	__entry->name##_port
+
 #define SNH_FMT \
 	"seq %llu recv_seq %llu id %llu data_len %u cmd %u flags 0x%x error %u"
 #define SNH_ARG(nh)							\

tests/golden/lock-pid-ino

@@ -0,0 +1,6 @@
+== set up file
+== exercise read, write, and write-only modes
+== verify FS-zone lock recorded read and write ino+pid
+== verify orphan-zone lock recorded write-only ino+pid
+== contend on a single inode with concurrent read and write loops
+== verify both rd and wr slots populated by concurrent contention

tests/run-tests.sh

@@ -383,7 +383,7 @@ fi
 quo=""
 if [ -n "$T_MKFS" ]; then
 	for i in $(seq -0 $((T_QUORUM - 1))); do
-		quo="$quo -Q $i,::1,$((T_TEST_PORT + i))"
+		quo="$quo -Q $i,127.0.0.1,$((T_TEST_PORT + i))"
 	done
 
 	msg "making new filesystem with $T_QUORUM quorum members"

tests/sequence

@@ -32,6 +32,7 @@ totl-merge-read.sh
 quota-invalidate-race.sh
 totl-delta-inject.sh
 lock-refleak.sh
+lock-pid-ino.sh
 lock-shrink-consistency.sh
 lock-shrink-read-race.sh
 lock-pr-cw-conflict.sh

tests/tests/lock-pid-ino.sh

@@ -0,0 +1,68 @@
+#
+# verify debugfs client_locks reports per-mode last-user PID and inode.
+#
+
+t_require_commands stat touch awk rm
+
+FILE="$T_D0/file"
+
+echo "== set up file"
+touch "$FILE"
+INO=$(stat -c %i "$FILE")
+GROUP_START=$(( INO & ~1023 ))
+
+echo "== exercise read, write, and write-only modes"
+t_quiet stat "$FILE"
+echo data > "$FILE"
+rm -f "$FILE"
+
+echo "== verify FS-zone lock recorded read and write ino+pid"
+ERR=$(awk -v group="$GROUP_START" -v ino="$INO" '
+	$2 == "16." group ".0.0.0.0" {
+		if ($25 != ino || $32 <= 0)
+			print "read mode: ino=" $25 " pid=" $32 " want ino=" ino " pid>0"
+		if ($27 != ino || $34 <= 0)
+			print "write mode: ino=" $27 " pid=" $34 " want ino=" ino " pid>0"
+		found = 1
+	}
+	END { if (!found) print "no FS-zone client_locks line for group " group }
+' < "$(t_debugfs_path)/client_locks")
+[ -n "$ERR" ] && t_fail "$ERR"
+
+echo "== verify orphan-zone lock recorded write-only ino+pid"
+ERR=$(awk -v ino="$INO" '
+	$2 == "8.0.4.0.0.0" {
+		if ($29 != ino || $36 <= 0)
+			print "write-only mode: ino=" $29 " pid=" $36 " want ino=" ino " pid>0"
+		found = 1
+	}
+	END { if (!found) print "no orphan-zone client_locks line" }
+' < "$(t_debugfs_path)/client_locks")
+[ -n "$ERR" ] && t_fail "$ERR"
+
+echo "== contend on a single inode with concurrent read and write loops"
+FILE2="$T_D0/file2"
+touch "$FILE2"
+INO2=$(stat -c %i "$FILE2")
+GROUP2=$(( INO2 & ~1023 ))
+
+for i in $(seq 1 5); do t_quiet stat "$FILE2"; done &
+RPID=$!
+for i in $(seq 1 5); do echo $i > "$FILE2"; done &
+WPID=$!
+wait $RPID $WPID
+
+echo "== verify both rd and wr slots populated by concurrent contention"
+ERR=$(awk -v group="$GROUP2" -v ino="$INO2" '
+	$2 == "16." group ".0.0.0.0" {
+		if ($25 != ino || $32 <= 0)
+			print "concurrent read: ino=" $25 " pid=" $32 " want ino=" ino " pid>0"
+		if ($27 != ino || $34 <= 0)
+			print "concurrent write: ino=" $27 " pid=" $34 " want ino=" ino " pid>0"
+		found = 1
+	}
+	END { if (!found) print "no FS-zone client_locks line for group " group }
+' < "$(t_debugfs_path)/client_locks")
+[ -n "$ERR" ] && t_fail "$ERR"
+
+t_pass

utils/src/parse.c

@@ -160,16 +160,15 @@ int parse_timespec(char *str, struct timespec *ts)
  * Parse a quorum slot specification string "NR,ADDR,PORT" into its
  * component parts.  We use sscanf to both parse the leading NR and
  * trailing PORT integers, and to pull out the inner ADDR string which
- * is then parsed to make sure that it's a valid unicast ip address.
+ * is then parsed to make sure that it's a valid unicast ipv4 address.
  * We require that all components be specified, and sccanf will check
  * this by the number of matches it returns.
  */
 int parse_quorum_slot(struct scoutfs_quorum_slot *slot, char *arg)
 {
-#define ADDR_CHARS 45 /* (INET6_ADDRSTRLEN - 1) */
-	char addr[INET6_ADDRSTRLEN] = {'\0',};
+#define ADDR_CHARS 45 /* max ipv6 */
+	char addr[ADDR_CHARS + 1] = {'\0',};
 	struct in_addr in;
-	struct in6_addr in6;
 	int port;
 	int parsed;
 	int nr;
@@ -207,25 +206,15 @@ int parse_quorum_slot(struct scoutfs_quorum_slot *slot, char *arg)
 		return -EINVAL;
 	}
 
-	if (inet_pton(AF_INET, addr, &in) == 1) {
-		if (htonl(in.s_addr) == 0 || htonl(in.s_addr) == UINT_MAX) {
-			printf("invalid ipv4 address '%s' in quorum slot '%s'\n",
-			       addr, arg);
-			return -EINVAL;
-		}
-		slot->addr.v4.family = cpu_to_le16(SCOUTFS_AF_IPV4);
-		slot->addr.v4.addr = cpu_to_le32(htonl(in.s_addr));
-		slot->addr.v4.port = cpu_to_le16(port);
-	} else if (inet_pton(AF_INET6, addr, &in6) == 1) {
-		if (IN6_IS_ADDR_UNSPECIFIED(&in6) || IN6_IS_ADDR_MULTICAST(&in6)) {
-			printf("invalid ipv6 address '%s' in quorum slot '%s'\n",
-			       addr, arg);
-			return -EINVAL;
-		}
-		slot->addr.v6.family = cpu_to_le16(SCOUTFS_AF_IPV6);
-		memcpy(slot->addr.v6.addr, &in6, 16);
-		slot->addr.v6.port = cpu_to_le16(port);
+	if (inet_aton(addr, &in) == 0 || htonl(in.s_addr) == 0 ||
+	    htonl(in.s_addr) == UINT_MAX) {
+		printf("invalid ipv4 address '%s' in quorum slot '%s'\n",
+		       addr, arg);
+		return -EINVAL;
 	}
 
+	slot->addr.v4.family = cpu_to_le16(SCOUTFS_AF_IPV4);
+	slot->addr.v4.addr = cpu_to_le32(htonl(in.s_addr));
+	slot->addr.v4.port = cpu_to_le16(port);
 	return nr;
 }

utils/src/print.c

@@ -28,7 +28,6 @@
 #include "srch.h"
 #include "leaf_item_hash.h"
 #include "dev.h"
-#include "quorum.h"
 
 static void print_block_header(struct scoutfs_block_header *hdr, int size)
 {
@@ -401,20 +400,12 @@ static int print_mounted_client_entry(struct scoutfs_key *key, u64 seq, u8 flags
 {
 	struct scoutfs_mounted_client_btree_val *mcv = val;
 	struct in_addr in;
-	char ip6addr[INET6_ADDRSTRLEN];
 
 	memset(&in, 0, sizeof(in));
-	if (mcv->addr.v4.family == cpu_to_le16(SCOUTFS_AF_IPV4)) {
-		in.s_addr = htonl(le32_to_cpu(mcv->addr.v4.addr));
+	in.s_addr = htonl(le32_to_cpu(mcv->addr.v4.addr));
 
-		printf("    rid %016llx ipv4_addr %s flags 0x%x\n",
-		       le64_to_cpu(key->skmc_rid), inet_ntoa(in), mcv->flags);
-	} else if (mcv->addr.v6.family == cpu_to_le16(SCOUTFS_AF_IPV6)) {
-		printf("    rid %016llx ipv6_addr %s flags 0x%x\n",
-		       le64_to_cpu(key->skmc_rid),
-		       inet_ntop(AF_INET, mcv->addr.v6.addr, ip6addr, INET6_ADDRSTRLEN),
-		       mcv->flags);
-	}
+	printf("    rid %016llx ipv4_addr %s flags 0x%x\n",
+	       le64_to_cpu(key->skmc_rid), inet_ntoa(in), mcv->flags);
 
 	return 0;
 }
@@ -900,40 +891,26 @@ static int print_btree_leaf_items(int fd, struct scoutfs_super_block *super,
 static char *alloc_addr_str(union scoutfs_inet_addr *ia)
 {
 	struct in_addr addr;
-	char ip6addr[INET6_ADDRSTRLEN];
 	char *quad;
 	char *str;
 	int len;
 
-	if (le16_to_cpu(ia->v4.family) == SCOUTFS_AF_IPV4) {
-		memset(&addr, 0, sizeof(addr));
-		addr.s_addr = htonl(le32_to_cpu(ia->v4.addr));
-		quad = inet_ntoa(addr);
-		if (quad == NULL)
-			return NULL;
-
-		len = snprintf(NULL, 0, "%s:%u", quad, le16_to_cpu(ia->v4.port));
-		if (len < 1 || len > 22)
-			return NULL;
-
-		len++; /* null */
-		str = malloc(len);
-		if (!str)
-			return NULL;
-
-		snprintf(str, len, "%s:%u", quad, le16_to_cpu(ia->v4.port));
-	} else if (le16_to_cpu(ia->v6.family) == SCOUTFS_AF_IPV6) {
-		if (inet_ntop(AF_INET6, ia->v6.addr, ip6addr, INET6_ADDRSTRLEN) == NULL)
-			return NULL;
-
-		len = strlen(ip6addr) + 9; /* "[]:\0" (4) plus max strlen(u16) (5) */
-		str = malloc(len);
-		if (!str)
-			return NULL;
-
-		snprintf(str, len, "[%s]:%u", ip6addr, le16_to_cpu(ia->v6.port));
-	} else
+	memset(&addr, 0, sizeof(addr));
+	addr.s_addr = htonl(le32_to_cpu(ia->v4.addr));
+	quad = inet_ntoa(addr);
+	if (quad == NULL)
 		return NULL;
+
+	len = snprintf(NULL, 0, "%s:%u", quad, le16_to_cpu(ia->v4.port));
+	if (len < 1 || len > 22)
+		return NULL;
+
+	len++; /* null */
+	str = malloc(len);
+	if (!str)
+		return NULL;
+
+	snprintf(str, len, "%s:%u", quad, le16_to_cpu(ia->v4.port));
 	return str;
 }
 
@@ -1049,7 +1026,7 @@ static void print_super_block(struct scoutfs_super_block *super, u64 blkno)
 	printf("  quorum config version %llu\n",
 		le64_to_cpu(super->qconf.version));
 	for (i = 0; i < array_size(super->qconf.slots); i++) {
-		if (!quorum_slot_present(super, i))
+		if (super->qconf.slots[i].addr.v4.family != cpu_to_le16(SCOUTFS_AF_IPV4))
 			continue;
 
 		addr = alloc_addr_str(&super->qconf.slots[i].addr);

utils/src/quorum.c

@@ -10,8 +10,7 @@
 
 bool quorum_slot_present(struct scoutfs_super_block *super, int i)
 {
-	return ((super->qconf.slots[i].addr.v4.family == cpu_to_le16(SCOUTFS_AF_IPV4)) ||
-		(super->qconf.slots[i].addr.v6.family == cpu_to_le16(SCOUTFS_AF_IPV6)));
+	return super->qconf.slots[i].addr.v4.family == cpu_to_le16(SCOUTFS_AF_IPV4);
 }
 
 bool valid_quorum_slots(struct scoutfs_quorum_slot *slots)
@@ -19,40 +18,35 @@ bool valid_quorum_slots(struct scoutfs_quorum_slot *slots)
 	struct in_addr in;
 	bool valid = true;
 	char *addr;
-	char ip6addr[INET6_ADDRSTRLEN];
 	int i;
 	int j;
 
 	for (i = 0; i < SCOUTFS_QUORUM_MAX_SLOTS; i++) {
-		if (slots[i].addr.v4.family == cpu_to_le16(SCOUTFS_AF_IPV4)) {
-			for (j = i + 1; j < SCOUTFS_QUORUM_MAX_SLOTS; j++) {
-				if (slots[i].addr.v4.addr == slots[j].addr.v4.addr &&
-				    slots[i].addr.v4.port == slots[j].addr.v4.port) {
-					in.s_addr =
-						htonl(le32_to_cpu(slots[i].addr.v4.addr));
-					addr = inet_ntoa(in);
-					fprintf(stderr, "quorum slot nr %u and %u have the same address %s:%u\n",
-						i, j, addr,
-						le16_to_cpu(slots[i].addr.v4.port));
-					valid = false;
-				}
-			}
-		} else if (slots[i].addr.v6.family == cpu_to_le16(SCOUTFS_AF_IPV6)) {
-			for (j = i + 1; j < SCOUTFS_QUORUM_MAX_SLOTS; j++) {
-				if ((IN6_ARE_ADDR_EQUAL(slots[i].addr.v6.addr, slots[j].addr.v6.addr)) &&
-				    (slots[i].addr.v6.port == slots[j].addr.v6.port)) {
-					fprintf(stderr, "quorum slot nr %u and %u have the same address [%s]:%u\n",
-						i, j,
-						inet_ntop(AF_INET6, slots[i].addr.v6.addr, ip6addr, INET6_ADDRSTRLEN),
-						le16_to_cpu(slots[i].addr.v6.port));
-					valid = false;
-				}
-			}
-		} else if (slots[i].addr.v6.family != cpu_to_le16(SCOUTFS_AF_NONE)) {
+		if (slots[i].addr.v4.family == cpu_to_le16(SCOUTFS_AF_NONE))
+			continue;
+
+		if (slots[i].addr.v4.family != cpu_to_le16(SCOUTFS_AF_IPV4)) {
 			fprintf(stderr, "quorum slot nr %u has invalid family %u\n",
 				i, le16_to_cpu(slots[i].addr.v4.family));
 			valid = false;
 		}
+
+		for (j = i + 1; j < SCOUTFS_QUORUM_MAX_SLOTS; j++) {
+			if (slots[i].addr.v4.family != cpu_to_le16(SCOUTFS_AF_IPV4))
+				continue;
+
+			if (slots[i].addr.v4.addr == slots[j].addr.v4.addr &&
+			    slots[i].addr.v4.port == slots[j].addr.v4.port) {
+
+				in.s_addr =
+					htonl(le32_to_cpu(slots[i].addr.v4.addr));
+				addr = inet_ntoa(in);
+				fprintf(stderr, "quorum slot nr %u and %u have the same address %s:%u\n",
+					i, j, addr,
+					le16_to_cpu(slots[i].addr.v4.port));
+				valid = false;
+			}
+		}
 	}
 
 	return valid;
@@ -67,23 +61,19 @@ void print_quorum_slots(struct scoutfs_quorum_slot *slots, int nr, char *indent)
 {
 	struct scoutfs_quorum_slot *sl;
 	struct in_addr in;
-	char ip6addr[INET6_ADDRSTRLEN];
 	bool first = true;
 	int i;
 
 	for (i = 0, sl = slots; i < SCOUTFS_QUORUM_MAX_SLOTS; i++, sl++) {
-		if (sl->addr.v4.family == cpu_to_le16(SCOUTFS_AF_IPV4)) {
-			in.s_addr = htonl(le32_to_cpu(sl->addr.v4.addr));
-			printf("%s%u: %s:%u\n", first ? "" : indent,
-			       i, inet_ntoa(in), le16_to_cpu(sl->addr.v4.port));
 
-			first = false;
-		} else if (sl->addr.v6.family == cpu_to_le16(SCOUTFS_AF_IPV6)) {
-			printf("%s%u: [%s]:%u\n", first ? "" : indent, i,
-				inet_ntop(AF_INET6, sl->addr.v6.addr, ip6addr, INET6_ADDRSTRLEN),
-				le16_to_cpu(sl->addr.v6.port));
-			first = false;
-		}
+		if (sl->addr.v4.family != cpu_to_le16(SCOUTFS_AF_IPV4))
+			continue;
+
+		in.s_addr = htonl(le32_to_cpu(sl->addr.v4.addr));
+		printf("%s%u: %s:%u\n", first ? "" : indent,
+		       i, inet_ntoa(in), le16_to_cpu(sl->addr.v4.port));
+
+		first = false;
 	}
 }