dcavalca / rpms / linuxptp

Forked from rpms/linuxptp 2 years ago
Clone

Blame SOURCES/linuxptp-ipoib.patch

43ff50
commit 7546434030d456b13b2eda6138f183ac3bf29751
43ff50
Author: Feras Daoud <ferasda@mellanox.com>
43ff50
Date:   Wed Aug 9 18:27:32 2017 +0300
43ff50
43ff50
    ptp4l: Add IPoIB interface support for ptp4l
43ff50
    
43ff50
    The current implementation of ptp4l always assumes 6 octets MAC
43ff50
    address, which is correct for Ethernet interfaces but not for IPoIB
43ff50
    interfaces (that have 20 octets MAC), therefore running ptp4l over
43ff50
    IPoIB interface does not function correctly.
43ff50
    
43ff50
    In Infiniband, every interface has three identifiers:
43ff50
    GUID, GID, and LID.
43ff50
    The GUID is similar in concept to a MAC address. From RFC4392:
43ff50
    The EUI-64 portion of a GID is referred to as the Global Unique
43ff50
    Identifier (GUID) and is the only persistent identifier of a port.
43ff50
    
43ff50
    Therefore, to support IPoIB interfaces, the GUID of the port should
43ff50
    be used instead of the MAC.
43ff50
    This patch checks the interface type before creating the clock identity,
43ff50
    for Infiniband ports, it retrieves the GUID of the port using sysfs
43ff50
    and use it to create the clock identity.
43ff50
    
43ff50
    sysfs method was chosen since the GUID is the 6 lsb bytes of
43ff50
    the 20 byte device address, and SIOCGIFHWADDR ioctl call returns
43ff50
    the 14 msb bytes of the device address, so it is not possible to
43ff50
    get the GUID using SIOCGIFHWADDR ioctl call.
43ff50
    
43ff50
    [ RC: fixed trivial coding style error, space after switch keyword. ]
43ff50
    
43ff50
    Signed-off-by: Feras Daoud <ferasda@mellanox.com>
43ff50
    Reviewed-by: Alex Vesker <valex@mellanox.com>
43ff50
43ff50
diff --git a/address.h b/address.h
43ff50
index 7578f91..35ef05f 100644
43ff50
--- a/address.h
43ff50
+++ b/address.h
43ff50
@@ -24,6 +24,7 @@
43ff50
 #include <netpacket/packet.h>
43ff50
 #include <sys/socket.h>
43ff50
 #include <sys/un.h>
43ff50
+#include <net/if_arp.h>
43ff50
 
43ff50
 struct address {
43ff50
 	socklen_t len;
43ff50
diff --git a/ether.h b/ether.h
43ff50
index ce3d663..8ec9669 100644
43ff50
--- a/ether.h
43ff50
+++ b/ether.h
43ff50
@@ -22,7 +22,13 @@
43ff50
 
43ff50
 #include <stdint.h>
43ff50
 
43ff50
-#define MAC_LEN 6
43ff50
+#define EUI48 6
43ff50
+#define EUI64 8
43ff50
+
43ff50
+#define MAC_LEN  EUI48
43ff50
+#define GUID_LEN EUI64
43ff50
+
43ff50
+#define GUID_OFFSET 36
43ff50
 
43ff50
 typedef uint8_t eth_addr[MAC_LEN];
43ff50
 
43ff50
diff --git a/sk.c b/sk.c
43ff50
index 63ec206..0cf55c5 100644
43ff50
--- a/sk.c
43ff50
+++ b/sk.c
43ff50
@@ -159,10 +159,55 @@ failed:
43ff50
 	return -1;
43ff50
 }
43ff50
 
43ff50
+static int sk_interface_guidaddr(const char *name, unsigned char *guid)
43ff50
+{
43ff50
+	char file_name[64], buf[64], addr[8];
43ff50
+	FILE *f;
43ff50
+	char *err;
43ff50
+	int res;
43ff50
+
43ff50
+	snprintf(file_name, sizeof buf, "/sys/class/net/%s/address", name);
43ff50
+	f = fopen(file_name, "r");
43ff50
+	if (!f) {
43ff50
+		pr_err("failed to open %s: %m", buf);
43ff50
+		return -1;
43ff50
+	}
43ff50
+
43ff50
+	/* Set the file position to the beginning of the GUID */
43ff50
+	res = fseek(f, GUID_OFFSET, SEEK_SET);
43ff50
+	if (res) {
43ff50
+		pr_err("fseek failed: %m");
43ff50
+		goto error;
43ff50
+	}
43ff50
+
43ff50
+	err = fgets(buf, sizeof buf, f);
43ff50
+	if (err == NULL) {
43ff50
+		pr_err("fseek failed: %m");
43ff50
+		goto error;
43ff50
+	}
43ff50
+
43ff50
+	res = sscanf(buf, "%hhx:%hhx:%hhx:%hhx:%hhx:%hhx:%hhx:%hhx",
43ff50
+			   &addr[0], &addr[1], &addr[2], &addr[3],
43ff50
+			   &addr[4], &addr[5], &addr[6], &addr[7]);
43ff50
+	if (res != GUID_LEN) {
43ff50
+		pr_err("sscanf failed: %m");
43ff50
+		goto error;
43ff50
+	}
43ff50
+
43ff50
+	memcpy(guid, addr, GUID_LEN);
43ff50
+	fclose(f);
43ff50
+
43ff50
+	return 0;
43ff50
+
43ff50
+error:
43ff50
+	fclose(f);
43ff50
+	return -1;
43ff50
+}
43ff50
+
43ff50
 int sk_interface_macaddr(const char *name, struct address *mac)
43ff50
 {
43ff50
 	struct ifreq ifreq;
43ff50
-	int err, fd;
43ff50
+	int err, fd, type;
43ff50
 
43ff50
 	memset(&ifreq, 0, sizeof(ifreq));
43ff50
 	strncpy(ifreq.ifr_name, name, sizeof(ifreq.ifr_name) - 1);
43ff50
@@ -180,9 +225,23 @@ int sk_interface_macaddr(const char *name, struct address *mac)
43ff50
 		return -1;
43ff50
 	}
43ff50
 
43ff50
+	/* Get interface type */
43ff50
+	type = ifreq.ifr_hwaddr.sa_family;
43ff50
+	switch (type) {
43ff50
+		case ARPHRD_INFINIBAND:
43ff50
+			err = sk_interface_guidaddr(name, mac->sll.sll_addr);
43ff50
+			if (err) {
43ff50
+				pr_err("fail to get address using sysfs: %m");
43ff50
+				return -1;
43ff50
+			}
43ff50
+			mac->sll.sll_halen = EUI64;
43ff50
+			break;
43ff50
+		default:
43ff50
+			memcpy(mac->sll.sll_addr, &ifreq.ifr_hwaddr.sa_data, MAC_LEN);
43ff50
+			mac->sll.sll_halen = EUI48;
43ff50
+	}
43ff50
+
43ff50
 	mac->sll.sll_family = AF_PACKET;
43ff50
-	mac->sll.sll_halen = MAC_LEN;
43ff50
-	memcpy(mac->sll.sll_addr, &ifreq.ifr_hwaddr.sa_data, MAC_LEN);
43ff50
 	mac->len = sizeof(mac->sll);
43ff50
 	close(fd);
43ff50
 	return 0;
43ff50
diff --git a/util.c b/util.c
43ff50
index 2b880ff..62f2638 100644
43ff50
--- a/util.c
43ff50
+++ b/util.c
43ff50
@@ -135,14 +135,32 @@ int generate_clock_identity(struct ClockIdentity *ci, const char *name)
43ff50
 
43ff50
 	if (sk_interface_macaddr(name, &addr))
43ff50
 		return -1;
43ff50
-	ci->id[0] = addr.sll.sll_addr[0];
43ff50
-	ci->id[1] = addr.sll.sll_addr[1];
43ff50
-	ci->id[2] = addr.sll.sll_addr[2];
43ff50
-	ci->id[3] = 0xFF;
43ff50
-	ci->id[4] = 0xFE;
43ff50
-	ci->id[5] = addr.sll.sll_addr[3];
43ff50
-	ci->id[6] = addr.sll.sll_addr[4];
43ff50
-	ci->id[7] = addr.sll.sll_addr[5];
43ff50
+
43ff50
+	switch (addr.sll.sll_halen) {
43ff50
+		case EUI48:
43ff50
+			ci->id[0] = addr.sll.sll_addr[0];
43ff50
+			ci->id[1] = addr.sll.sll_addr[1];
43ff50
+			ci->id[2] = addr.sll.sll_addr[2];
43ff50
+			ci->id[3] = 0xFF;
43ff50
+			ci->id[4] = 0xFE;
43ff50
+			ci->id[5] = addr.sll.sll_addr[3];
43ff50
+			ci->id[6] = addr.sll.sll_addr[4];
43ff50
+			ci->id[7] = addr.sll.sll_addr[5];
43ff50
+			break;
43ff50
+		case EUI64:
43ff50
+			ci->id[0] = addr.sll.sll_addr[0];
43ff50
+			ci->id[1] = addr.sll.sll_addr[1];
43ff50
+			ci->id[2] = addr.sll.sll_addr[2];
43ff50
+			ci->id[3] = addr.sll.sll_addr[3];
43ff50
+			ci->id[4] = addr.sll.sll_addr[4];
43ff50
+			ci->id[5] = addr.sll.sll_addr[5];
43ff50
+			ci->id[6] = addr.sll.sll_addr[6];
43ff50
+			ci->id[7] = addr.sll.sll_addr[7];
43ff50
+			break;
43ff50
+		default:
43ff50
+			return -1;
43ff50
+	}
43ff50
+
43ff50
 	return 0;
43ff50
 }
43ff50
 
43ff50
commit fd2646263f0fb1a31dde53e67ac24971ab1f90f4
43ff50
Author: Miroslav Lichvar <mlichvar@redhat.com>
43ff50
Date:   Mon Oct 16 11:29:48 2017 +0200
43ff50
43ff50
    sk: don't leak socket when reading of IB GUID fails.
43ff50
    
43ff50
    Signed-off-by: Miroslav Lichvar <mlichvar@redhat.com>
43ff50
43ff50
diff --git a/sk.c b/sk.c
43ff50
index 0cf55c5..2c7593b 100644
43ff50
--- a/sk.c
43ff50
+++ b/sk.c
43ff50
@@ -225,6 +225,8 @@ int sk_interface_macaddr(const char *name, struct address *mac)
43ff50
 		return -1;
43ff50
 	}
43ff50
 
43ff50
+	close(fd);
43ff50
+
43ff50
 	/* Get interface type */
43ff50
 	type = ifreq.ifr_hwaddr.sa_family;
43ff50
 	switch (type) {
43ff50
@@ -243,7 +245,6 @@ int sk_interface_macaddr(const char *name, struct address *mac)
43ff50
 
43ff50
 	mac->sll.sll_family = AF_PACKET;
43ff50
 	mac->len = sizeof(mac->sll);
43ff50
-	close(fd);
43ff50
 	return 0;
43ff50
 }
43ff50