2 files changed, 30 insertions, 0 deletions
diff --git a/source3/lib/msghdr.c b/source3/lib/msghdr.c
index 9d5f28bbb3..3449579b43 100644
--- a/source3/lib/msghdr.c
+++ b/source3/lib/msghdr.c
@@ -125,3 +125,31 @@ struct msghdr *msghdr_buf_msghdr(struct msghdr_buf *msg)
 {
 	return &msg->msg;
 }
+
+size_t msghdr_extract_fds(struct msghdr *msg, int *fds, size_t fds_size)
+{
+	struct cmsghdr *cmsg;
+	size_t num_fds;
+
+	for(cmsg = CMSG_FIRSTHDR(msg);
+	    cmsg != NULL;
+	    cmsg = CMSG_NXTHDR(msg, cmsg))
+	{
+		if ((cmsg->cmsg_type == SCM_RIGHTS) &&
+		    (cmsg->cmsg_level == SOL_SOCKET)) {
+			break;
+		}
+	}
+
+	if (cmsg == NULL) {
+		return 0;
+	}
+
+	num_fds = (cmsg->cmsg_len - CMSG_LEN(0)) / sizeof(int);
+
+	if ((num_fds != 0) && (fds_size >= num_fds)) {
+		memcpy(fds, CMSG_DATA(cmsg), num_fds * sizeof(int));
+	}
+
+	return num_fds;
+}
diff --git a/source3/lib/msghdr.h b/source3/lib/msghdr.h
index af9506c625..88829238a2 100644
--- a/source3/lib/msghdr.h
+++ b/source3/lib/msghdr.h
@@ -35,4 +35,6 @@ ssize_t msghdr_copy(struct msghdr_buf *msg, size_t msgsize,
 		    const int *fds, size_t num_fds);
 struct msghdr *msghdr_buf_msghdr(struct msghdr_buf *msg);
 
+size_t msghdr_extract_fds(struct msghdr *msg, int *fds, size_t num_fds);
+
 #endif