desc_dma);
                swdata = cppi5_hdesc_get_swdata(desc_tx);
 
+               /* was this command's TX complete? */
+               if (emac->is_sr1 && *(swdata) == emac->cmd_data) {
+                       prueth_xmit_free(tx_chn, desc_tx);
+                       continue;
+               }
+
                skb = *(swdata);
                prueth_xmit_free(tx_chn, desc_tx);
 
        struct net_device *ndev = emac->ndev;
        u32 fdqring_id, hdesc_size;
        int i, ret = 0, slice;
+       int flow_id_base;
 
        slice = prueth_emac_slice(emac);
        if (slice < 0)
                goto fail;
        }
 
-       emac->rx_flow_id_base = k3_udma_glue_rx_get_flow_id_base(rx_chn->rx_chn);
-       netdev_dbg(ndev, "flow id base = %d\n", emac->rx_flow_id_base);
+       flow_id_base = k3_udma_glue_rx_get_flow_id_base(rx_chn->rx_chn);
+       if (emac->is_sr1 && !strcmp(name, "rxmgm")) {
+               emac->rx_mgm_flow_id_base = flow_id_base;
+               netdev_dbg(ndev, "mgm flow id base = %d\n", flow_id_base);
+       } else {
+               emac->rx_flow_id_base = flow_id_base;
+               netdev_dbg(ndev, "flow id base = %d\n", flow_id_base);
+       }
 
        fdqring_id = K3_RINGACC_RING_ID_ANY;
        for (i = 0; i < rx_cfg.flow_id_num; i++) {
        struct skb_shared_hwtstamps *ssh;
        u64 ns;
 
-       u32 hi_sw = readl(emac->prueth->shram.va +
-                         TIMESYNC_FW_WC_COUNT_HI_SW_OFFSET_OFFSET);
-       ns = icssg_ts_to_ns(hi_sw, psdata[1], psdata[0],
-                           IEP_DEFAULT_CYCLE_TIME_NS);
+       if (emac->is_sr1) {
+               ns = (u64)psdata[1] << 32 | psdata[0];
+       } else {
+               u32 hi_sw = readl(emac->prueth->shram.va +
+                                 TIMESYNC_FW_WC_COUNT_HI_SW_OFFSET_OFFSET);
+               ns = icssg_ts_to_ns(hi_sw, psdata[1], psdata[0],
+                                   IEP_DEFAULT_CYCLE_TIME_NS);
+       }
 
        ssh = skb_hwtstamps(skb);
        memset(ssh, 0, sizeof(*ssh));
        }
 
        emac->fw_running = 0;
-       rproc_shutdown(prueth->txpru[slice]);
+       if (!emac->is_sr1)
+               rproc_shutdown(prueth->txpru[slice]);
        rproc_shutdown(prueth->rtu[slice]);
        rproc_shutdown(prueth->pru[slice]);
 }
 int emac_napi_rx_poll(struct napi_struct *napi_rx, int budget)
 {
        struct prueth_emac *emac = prueth_napi_to_emac(napi_rx);
-       int rx_flow = PRUETH_RX_FLOW_DATA;
-       int flow = PRUETH_MAX_RX_FLOWS;
+       int rx_flow = emac->is_sr1 ?
+               PRUETH_RX_FLOW_DATA_SR1 : PRUETH_RX_FLOW_DATA;
+       int flow = emac->is_sr1 ?
+               PRUETH_MAX_RX_FLOWS_SR1 : PRUETH_MAX_RX_FLOWS;
        int num_rx = 0;
        int cur_budget;
        int ret;
        prueth->emac[mac] = NULL;
 }
 
-int prueth_get_cores(struct prueth *prueth, int slice)
+int prueth_get_cores(struct prueth *prueth, int slice, bool is_sr1)
 {
        struct device *dev = prueth->dev;
        enum pruss_pru_id pruss_id;
                idx = 0;
                break;
        case ICSS_SLICE1:
-               idx = 3;
+               idx = is_sr1 ? 2 : 3;
                break;
        default:
                return -EINVAL;
                return dev_err_probe(dev, ret, "unable to get RTU%d\n", slice);
        }
 
+       if (is_sr1)
+               return 0;
+
        idx++;
        prueth->txpru[slice] = pru_rproc_get(np, idx, NULL);
        if (IS_ERR(prueth->txpru[slice])) {