diff --git a/pkg/tcpip/network/ipv4/ipv4.go b/pkg/tcpip/network/ipv4/ipv4.go index 3c5e79df8..fbbbb1272 100644 --- a/pkg/tcpip/network/ipv4/ipv4.go +++ b/pkg/tcpip/network/ipv4/ipv4.go @@ -253,9 +253,6 @@ func (e *endpoint) MulticastForwarding() bool { // SetMulticastForwarding implements stack.MulticastForwardingNetworkEndpoint. func (e *endpoint) SetMulticastForwarding(forwarding bool) bool { - e.mu.Lock() - defer e.mu.Unlock() - updatedForwarding := uint32(forwardingDisabled) if forwarding { updatedForwarding = forwardingEnabled diff --git a/pkg/tcpip/network/ipv6/ipv6.go b/pkg/tcpip/network/ipv6/ipv6.go index ca7e7ddd3..0813a9ceb 100644 --- a/pkg/tcpip/network/ipv6/ipv6.go +++ b/pkg/tcpip/network/ipv6/ipv6.go @@ -522,9 +522,6 @@ func (e *endpoint) MulticastForwarding() bool { // SetMulticastForwarding implements stack.MulticastForwardingNetworkEndpoint. func (e *endpoint) SetMulticastForwarding(forwarding bool) bool { - e.mu.Lock() - defer e.mu.Unlock() - updatedForwarding := uint32(forwardingDisabled) if forwarding { updatedForwarding = forwardingEnabled