Commit 3310aad2 authored by Larysa Zaremba's avatar Larysa Zaremba Committed by Alexei Starovoitov

ice: make RX HW timestamp reading code more reusable

Previously, we only needed RX HW timestamp in skb path,
hence all related code was written with skb in mind.
But with the addition of XDP hints via kfuncs to the ice driver,
the same logic will be needed in .xmo_() callbacks.

Put generic process of reading RX HW timestamp from a descriptor
into a separate function.
Move skb-related code into another source file.
Reviewed-by: default avatarMaciej Fijalkowski <maciej.fijalkowski@intel.com>
Signed-off-by: default avatarLarysa Zaremba <larysa.zaremba@intel.com>
Link: https://lore.kernel.org/r/20231205210847.28460-3-larysa.zaremba@intel.comSigned-off-by: default avatarAlexei Starovoitov <ast@kernel.org>
parent 9244384e
...@@ -2127,30 +2127,26 @@ int ice_ptp_set_ts_config(struct ice_pf *pf, struct ifreq *ifr) ...@@ -2127,30 +2127,26 @@ int ice_ptp_set_ts_config(struct ice_pf *pf, struct ifreq *ifr)
} }
/** /**
* ice_ptp_rx_hwtstamp - Check for an Rx timestamp * ice_ptp_get_rx_hwts - Get packet Rx timestamp in ns
* @rx_ring: Ring to get the VSI info
* @rx_desc: Receive descriptor * @rx_desc: Receive descriptor
* @skb: Particular skb to send timestamp with * @rx_ring: Ring to get the cached time
* *
* The driver receives a notification in the receive descriptor with timestamp. * The driver receives a notification in the receive descriptor with timestamp.
* The timestamp is in ns, so we must convert the result first.
*/ */
void u64 ice_ptp_get_rx_hwts(const union ice_32b_rx_flex_desc *rx_desc,
ice_ptp_rx_hwtstamp(struct ice_rx_ring *rx_ring, struct ice_rx_ring *rx_ring)
union ice_32b_rx_flex_desc *rx_desc, struct sk_buff *skb)
{ {
struct skb_shared_hwtstamps *hwtstamps;
u64 ts_ns, cached_time; u64 ts_ns, cached_time;
u32 ts_high; u32 ts_high;
if (!(rx_desc->wb.time_stamp_low & ICE_PTP_TS_VALID)) if (!(rx_desc->wb.time_stamp_low & ICE_PTP_TS_VALID))
return; return 0;
cached_time = READ_ONCE(rx_ring->cached_phctime); cached_time = READ_ONCE(rx_ring->cached_phctime);
/* Do not report a timestamp if we don't have a cached PHC time */ /* Do not report a timestamp if we don't have a cached PHC time */
if (!cached_time) if (!cached_time)
return; return 0;
/* Use ice_ptp_extend_32b_ts directly, using the ring-specific cached /* Use ice_ptp_extend_32b_ts directly, using the ring-specific cached
* PHC value, rather than accessing the PF. This also allows us to * PHC value, rather than accessing the PF. This also allows us to
...@@ -2161,9 +2157,7 @@ ice_ptp_rx_hwtstamp(struct ice_rx_ring *rx_ring, ...@@ -2161,9 +2157,7 @@ ice_ptp_rx_hwtstamp(struct ice_rx_ring *rx_ring,
ts_high = le32_to_cpu(rx_desc->wb.flex_ts.ts_high); ts_high = le32_to_cpu(rx_desc->wb.flex_ts.ts_high);
ts_ns = ice_ptp_extend_32b_ts(cached_time, ts_high); ts_ns = ice_ptp_extend_32b_ts(cached_time, ts_high);
hwtstamps = skb_hwtstamps(skb); return ts_ns;
memset(hwtstamps, 0, sizeof(*hwtstamps));
hwtstamps->hwtstamp = ns_to_ktime(ts_ns);
} }
/** /**
......
...@@ -298,9 +298,8 @@ void ice_ptp_extts_event(struct ice_pf *pf); ...@@ -298,9 +298,8 @@ void ice_ptp_extts_event(struct ice_pf *pf);
s8 ice_ptp_request_ts(struct ice_ptp_tx *tx, struct sk_buff *skb); s8 ice_ptp_request_ts(struct ice_ptp_tx *tx, struct sk_buff *skb);
enum ice_tx_tstamp_work ice_ptp_process_ts(struct ice_pf *pf); enum ice_tx_tstamp_work ice_ptp_process_ts(struct ice_pf *pf);
void u64 ice_ptp_get_rx_hwts(const union ice_32b_rx_flex_desc *rx_desc,
ice_ptp_rx_hwtstamp(struct ice_rx_ring *rx_ring, struct ice_rx_ring *rx_ring);
union ice_32b_rx_flex_desc *rx_desc, struct sk_buff *skb);
void ice_ptp_reset(struct ice_pf *pf); void ice_ptp_reset(struct ice_pf *pf);
void ice_ptp_prepare_for_reset(struct ice_pf *pf); void ice_ptp_prepare_for_reset(struct ice_pf *pf);
void ice_ptp_init(struct ice_pf *pf); void ice_ptp_init(struct ice_pf *pf);
...@@ -329,9 +328,14 @@ static inline bool ice_ptp_process_ts(struct ice_pf *pf) ...@@ -329,9 +328,14 @@ static inline bool ice_ptp_process_ts(struct ice_pf *pf)
{ {
return true; return true;
} }
static inline void
ice_ptp_rx_hwtstamp(struct ice_rx_ring *rx_ring, static inline u64
union ice_32b_rx_flex_desc *rx_desc, struct sk_buff *skb) { } ice_ptp_get_rx_hwts(const union ice_32b_rx_flex_desc *rx_desc,
struct ice_rx_ring *rx_ring)
{
return 0;
}
static inline void ice_ptp_reset(struct ice_pf *pf) { } static inline void ice_ptp_reset(struct ice_pf *pf) { }
static inline void ice_ptp_prepare_for_reset(struct ice_pf *pf) { } static inline void ice_ptp_prepare_for_reset(struct ice_pf *pf) { }
static inline void ice_ptp_init(struct ice_pf *pf) { } static inline void ice_ptp_init(struct ice_pf *pf) { }
......
...@@ -184,6 +184,24 @@ ice_rx_csum(struct ice_rx_ring *ring, struct sk_buff *skb, ...@@ -184,6 +184,24 @@ ice_rx_csum(struct ice_rx_ring *ring, struct sk_buff *skb,
ring->vsi->back->hw_csum_rx_error++; ring->vsi->back->hw_csum_rx_error++;
} }
/**
* ice_ptp_rx_hwts_to_skb - Put RX timestamp into skb
* @rx_ring: Ring to get the VSI info
* @rx_desc: Receive descriptor
* @skb: Particular skb to send timestamp with
*
* The timestamp is in ns, so we must convert the result first.
*/
static void
ice_ptp_rx_hwts_to_skb(struct ice_rx_ring *rx_ring,
const union ice_32b_rx_flex_desc *rx_desc,
struct sk_buff *skb)
{
u64 ts_ns = ice_ptp_get_rx_hwts(rx_desc, rx_ring);
skb_hwtstamps(skb)->hwtstamp = ns_to_ktime(ts_ns);
}
/** /**
* ice_process_skb_fields - Populate skb header fields from Rx descriptor * ice_process_skb_fields - Populate skb header fields from Rx descriptor
* @rx_ring: Rx descriptor ring packet is being transacted on * @rx_ring: Rx descriptor ring packet is being transacted on
...@@ -208,7 +226,7 @@ ice_process_skb_fields(struct ice_rx_ring *rx_ring, ...@@ -208,7 +226,7 @@ ice_process_skb_fields(struct ice_rx_ring *rx_ring,
ice_rx_csum(rx_ring, skb, rx_desc, ptype); ice_rx_csum(rx_ring, skb, rx_desc, ptype);
if (rx_ring->ptp_rx) if (rx_ring->ptp_rx)
ice_ptp_rx_hwtstamp(rx_ring, rx_desc, skb); ice_ptp_rx_hwts_to_skb(rx_ring, rx_desc, skb);
} }
/** /**
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment