]> www.infradead.org Git - users/willy/xarray.git/commitdiff
firewire: ohci: use helper inline functions to serialize/deserialize self ID packet
authorTakashi Sakamoto <o-takashi@sakamocchi.jp>
Wed, 5 Jun 2024 23:51:53 +0000 (08:51 +0900)
committerTakashi Sakamoto <o-takashi@sakamocchi.jp>
Sun, 16 Jun 2024 23:37:03 +0000 (08:37 +0900)
This commit replaces the existing implementation with the helper
functions for self ID packet.

Link: https://lore.kernel.org/r/20240605235155.116468-10-o-takashi@sakamocchi.jp
Signed-off-by: Takashi Sakamoto <o-takashi@sakamocchi.jp>
drivers/firewire/ohci.c

index 342407d8bc9b2d95241b6edb31a56a002c2ade20..1f6097a6366cf90392e5677dbe5459332b99a33c 100644 (file)
@@ -477,7 +477,7 @@ static void log_selfids(struct fw_ohci *ohci, int generation, int self_id_count)
                ohci_notice(ohci,
                    "selfID 0: %08x, phy %d [%c%c%c] %s gc=%d %s %s%s%s\n",
                    *s,
-                   *s >> 24 & 63,
+                   phy_packet_self_id_get_phy_id(*s),
                    port[self_id_sequence_get_port_status(s, quadlet_count, 0)],
                    port[self_id_sequence_get_port_status(s, quadlet_count, 1)],
                    port[self_id_sequence_get_port_status(s, quadlet_count, 2)],
@@ -490,7 +490,7 @@ static void log_selfids(struct fw_ohci *ohci, int generation, int self_id_count)
                        ohci_notice(ohci,
                            "selfID n: %08x, phy %d [%c%c%c%c%c%c%c%c]\n",
                            s[i],
-                           s[i] >> 24 & 63,
+                           phy_packet_self_id_get_phy_id(s[i]),
                            port[self_id_sequence_get_port_status(s, quadlet_count, port_index)],
                            port[self_id_sequence_get_port_status(s, quadlet_count, port_index + 1)],
                            port[self_id_sequence_get_port_status(s, quadlet_count, port_index + 2)],
@@ -1846,7 +1846,8 @@ static u32 update_bus_time(struct fw_ohci *ohci)
        return ohci->bus_time | cycle_time_seconds;
 }
 
-static int get_status_for_port(struct fw_ohci *ohci, int port_index)
+static int get_status_for_port(struct fw_ohci *ohci, int port_index,
+                              enum phy_packet_self_id_port_status *status)
 {
        int reg;
 
@@ -1860,33 +1861,44 @@ static int get_status_for_port(struct fw_ohci *ohci, int port_index)
 
        switch (reg & 0x0f) {
        case 0x06:
-               return 2;       /* is child node (connected to parent node) */
+               // is child node (connected to parent node)
+               *status = PHY_PACKET_SELF_ID_PORT_STATUS_PARENT;
+               break;
        case 0x0e:
-               return 3;       /* is parent node (connected to child node) */
+               // is parent node (connected to child node)
+               *status = PHY_PACKET_SELF_ID_PORT_STATUS_CHILD;
+               break;
+       default:
+               // not connected
+               *status = PHY_PACKET_SELF_ID_PORT_STATUS_NCONN;
+               break;
        }
-       return 1;               /* not connected */
+
+       return 0;
 }
 
 static int get_self_id_pos(struct fw_ohci *ohci, u32 self_id,
        int self_id_count)
 {
+       unsigned int left_phy_id = phy_packet_self_id_get_phy_id(self_id);
        int i;
-       u32 entry;
 
        for (i = 0; i < self_id_count; i++) {
-               entry = ohci->self_id_buffer[i];
-               if ((self_id & 0xff000000) == (entry & 0xff000000))
+               u32 entry = ohci->self_id_buffer[i];
+               unsigned int right_phy_id = phy_packet_self_id_get_phy_id(entry);
+
+               if (left_phy_id == right_phy_id)
                        return -1;
-               if ((self_id & 0xff000000) < (entry & 0xff000000))
+               if (left_phy_id < right_phy_id)
                        return i;
        }
        return i;
 }
 
-static int initiated_reset(struct fw_ohci *ohci)
+static bool initiated_reset(struct fw_ohci *ohci)
 {
        int reg;
-       int ret = 0;
+       int ret = false;
 
        mutex_lock(&ohci->phy_reg_mutex);
        reg = write_phy_reg(ohci, 7, 0xe0); /* Select page 7 */
@@ -1899,7 +1911,7 @@ static int initiated_reset(struct fw_ohci *ohci)
                        if (reg >= 0) {
                                if ((reg & 0x08) == 0x08) {
                                        /* bit 3 indicates "initiated reset" */
-                                       ret = 0x2;
+                                       ret = true;
                                }
                        }
                }
@@ -1915,9 +1927,14 @@ static int initiated_reset(struct fw_ohci *ohci)
  */
 static int find_and_insert_self_id(struct fw_ohci *ohci, int self_id_count)
 {
-       int reg, i, pos, status;
-       /* link active 1, speed 3, bridge 0, contender 1, more packets 0 */
-       u32 self_id = 0x8040c800;
+       int reg, i, pos;
+       u32 self_id = 0;
+
+       // link active 1, speed 3, bridge 0, contender 1, more packets 0.
+       phy_packet_set_packet_identifier(&self_id, PHY_PACKET_PACKET_IDENTIFIER_SELF_ID);
+       phy_packet_self_id_zero_set_link_active(&self_id, true);
+       phy_packet_self_id_zero_set_scode(&self_id, SCODE_800);
+       phy_packet_self_id_zero_set_contender(&self_id, true);
 
        reg = reg_read(ohci, OHCI1394_NodeID);
        if (!(reg & OHCI1394_NodeID_idValid)) {
@@ -1925,26 +1942,30 @@ static int find_and_insert_self_id(struct fw_ohci *ohci, int self_id_count)
                            "node ID not valid, new bus reset in progress\n");
                return -EBUSY;
        }
-       self_id |= ((reg & 0x3f) << 24); /* phy ID */
+       phy_packet_self_id_set_phy_id(&self_id, reg & 0x3f);
 
        reg = ohci_read_phy_reg(&ohci->card, 4);
        if (reg < 0)
                return reg;
-       self_id |= ((reg & 0x07) << 8); /* power class */
+       phy_packet_self_id_zero_set_power_class(&self_id, reg & 0x07);
 
        reg = ohci_read_phy_reg(&ohci->card, 1);
        if (reg < 0)
                return reg;
-       self_id |= ((reg & 0x3f) << 16); /* gap count */
+       phy_packet_self_id_zero_set_gap_count(&self_id, reg & 0x3f);
 
        for (i = 0; i < 3; i++) {
-               status = get_status_for_port(ohci, i);
-               if (status < 0)
-                       return status;
-               self_id |= ((status & 0x3) << (6 - (i * 2)));
+               enum phy_packet_self_id_port_status status;
+               int err;
+
+               err = get_status_for_port(ohci, i, &status);
+               if (err < 0)
+                       return err;
+
+               self_id_sequence_set_port_status(&self_id, 1, i, status);
        }
 
-       self_id |= initiated_reset(ohci);
+       phy_packet_self_id_zero_set_initiated_reset(&self_id, initiated_reset(ohci));
 
        pos = get_self_id_pos(ohci, self_id, self_id_count);
        if (pos >= 0) {