diff --git a/include/linux/skmsg.h b/include/linux/skmsg.h
index f69af3de0da09e6da0aa290b1c0961300aa4d907..fdedb7a29c0e639a950e763eeb03b247b1a03775 100644
--- a/include/linux/skmsg.h
+++ b/include/linux/skmsg.h
@@ -467,10 +467,12 @@ static inline void sk_psock_put(struct sock *sk, struct sk_psock *psock)
 
 static inline void sk_psock_data_ready(struct sock *sk, struct sk_psock *psock)
 {
+	read_lock_bh(&sk->sk_callback_lock);
 	if (psock->saved_data_ready)
 		psock->saved_data_ready(sk);
 	else
 		sk->sk_data_ready(sk);
+	read_unlock_bh(&sk->sk_callback_lock);
 }
 
 static inline void psock_set_prog(struct bpf_prog **pprog,
diff --git a/net/core/skmsg.c b/net/core/skmsg.c
index 6f774de8f6b2fb468010edf2a093b7ad6894a1de..f2e7ce81fef03ea666d473dd07496ea468d55f95 100644
--- a/net/core/skmsg.c
+++ b/net/core/skmsg.c
@@ -1234,11 +1234,8 @@ static void sk_psock_verdict_data_ready(struct sock *sk)
 
 		rcu_read_lock();
 		psock = sk_psock(sk);
-		if (psock) {
-			read_lock_bh(&sk->sk_callback_lock);
+		if (psock)
 			sk_psock_data_ready(sk, psock);
-			read_unlock_bh(&sk->sk_callback_lock);
-		}
 		rcu_read_unlock();
 	}
 }