mirror of
https://github.com/torvalds/linux.git
synced 2026-07-29 18:51:21 +02:00
Merge branch 'sfc-couple-more-ARFS-tidy-ups'
Edward Cree says: ==================== couple more ARFS tidy-ups Tie up some loose ends from the recent ARFS work. ==================== Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
commit
5f1475b171
|
|
@ -150,24 +150,6 @@ static inline s32 efx_filter_get_rx_ids(struct efx_nic *efx,
|
|||
int efx_filter_rfs(struct net_device *net_dev, const struct sk_buff *skb,
|
||||
u16 rxq_index, u32 flow_id);
|
||||
bool __efx_filter_rfs_expire(struct efx_channel *channel, unsigned int quota);
|
||||
static inline void efx_filter_rfs_expire(struct work_struct *data)
|
||||
{
|
||||
struct delayed_work *dwork = to_delayed_work(data);
|
||||
struct efx_channel *channel;
|
||||
unsigned int time, quota;
|
||||
|
||||
channel = container_of(dwork, struct efx_channel, filter_work);
|
||||
time = jiffies - channel->rfs_last_expiry;
|
||||
quota = channel->rfs_filter_count * time / (30 * HZ);
|
||||
if (quota > 20 && __efx_filter_rfs_expire(channel, min(channel->rfs_filter_count, quota)))
|
||||
channel->rfs_last_expiry += time;
|
||||
/* Ensure we do more work eventually even if NAPI poll is not happening */
|
||||
schedule_delayed_work(dwork, 30 * HZ);
|
||||
}
|
||||
#define efx_filter_rfs_enabled() 1
|
||||
#else
|
||||
static inline void efx_filter_rfs_expire(struct work_struct *data) {}
|
||||
#define efx_filter_rfs_enabled() 0
|
||||
#endif
|
||||
|
||||
/* RSS contexts */
|
||||
|
|
|
|||
|
|
@ -485,6 +485,23 @@ void efx_remove_eventq(struct efx_channel *channel)
|
|||
*
|
||||
*************************************************************************/
|
||||
|
||||
#ifdef CONFIG_RFS_ACCEL
|
||||
static void efx_filter_rfs_expire(struct work_struct *data)
|
||||
{
|
||||
struct delayed_work *dwork = to_delayed_work(data);
|
||||
struct efx_channel *channel;
|
||||
unsigned int time, quota;
|
||||
|
||||
channel = container_of(dwork, struct efx_channel, filter_work);
|
||||
time = jiffies - channel->rfs_last_expiry;
|
||||
quota = channel->rfs_filter_count * time / (30 * HZ);
|
||||
if (quota >= 20 && __efx_filter_rfs_expire(channel, min(channel->rfs_filter_count, quota)))
|
||||
channel->rfs_last_expiry += time;
|
||||
/* Ensure we do more work eventually even if NAPI poll is not happening */
|
||||
schedule_delayed_work(dwork, 30 * HZ);
|
||||
}
|
||||
#endif
|
||||
|
||||
/* Allocate and initialise a channel structure. */
|
||||
struct efx_channel *
|
||||
efx_alloc_channel(struct efx_nic *efx, int i, struct efx_channel *old_channel)
|
||||
|
|
@ -1166,6 +1183,9 @@ static int efx_poll(struct napi_struct *napi, int budget)
|
|||
struct efx_channel *channel =
|
||||
container_of(napi, struct efx_channel, napi_str);
|
||||
struct efx_nic *efx = channel->efx;
|
||||
#ifdef CONFIG_RFS_ACCEL
|
||||
unsigned int time;
|
||||
#endif
|
||||
int spent;
|
||||
|
||||
netif_vdbg(efx, intr, efx->net_dev,
|
||||
|
|
@ -1185,7 +1205,10 @@ static int efx_poll(struct napi_struct *napi, int budget)
|
|||
|
||||
#ifdef CONFIG_RFS_ACCEL
|
||||
/* Perhaps expire some ARFS filters */
|
||||
mod_delayed_work(system_wq, &channel->filter_work, 0);
|
||||
time = jiffies - channel->rfs_last_expiry;
|
||||
/* Would our quota be >= 20? */
|
||||
if (channel->rfs_filter_count * time >= 600 * HZ)
|
||||
mod_delayed_work(system_wq, &channel->filter_work, 0);
|
||||
#endif
|
||||
|
||||
/* There is no race here; although napi_disable() will
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user