strparser: Queue work when being unpaused
When the upper layer unpauses a stream parser connection we need to queue rx_work to make sure no events are missed. Signed-off-by: Tom Herbert <tom@herbertland.com> Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
parent
3c90a941ed
commit
cff6a334e6
2 changed files with 12 additions and 4 deletions
|
@ -88,10 +88,7 @@ static inline void strp_pause(struct strparser *strp)
|
||||||
}
|
}
|
||||||
|
|
||||||
/* May be called without holding lock for attached socket */
|
/* May be called without holding lock for attached socket */
|
||||||
static inline void strp_unpause(struct strparser *strp)
|
void strp_unpause(struct strparser *strp);
|
||||||
{
|
|
||||||
strp->rx_paused = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
static inline void save_strp_stats(struct strparser *strp,
|
static inline void save_strp_stats(struct strparser *strp,
|
||||||
struct strp_aggr_stats *agg_stats)
|
struct strp_aggr_stats *agg_stats)
|
||||||
|
|
|
@ -445,6 +445,17 @@ int strp_init(struct strparser *strp, struct sock *csk,
|
||||||
}
|
}
|
||||||
EXPORT_SYMBOL_GPL(strp_init);
|
EXPORT_SYMBOL_GPL(strp_init);
|
||||||
|
|
||||||
|
void strp_unpause(struct strparser *strp)
|
||||||
|
{
|
||||||
|
strp->rx_paused = 0;
|
||||||
|
|
||||||
|
/* Sync setting rx_paused with RX work */
|
||||||
|
smp_mb();
|
||||||
|
|
||||||
|
queue_work(strp_wq, &strp->rx_work);
|
||||||
|
}
|
||||||
|
EXPORT_SYMBOL_GPL(strp_unpause);
|
||||||
|
|
||||||
/* strp must already be stopped so that strp_tcp_recv will no longer be called.
|
/* strp must already be stopped so that strp_tcp_recv will no longer be called.
|
||||||
* Note that strp_done is not called with the lower socket held.
|
* Note that strp_done is not called with the lower socket held.
|
||||||
*/
|
*/
|
||||||
|
|
Loading…
Reference in a new issue