summaryrefslogtreecommitdiffhomepage
path: root/pkg/tcpip/transport/unix/unix.go
diff options
context:
space:
mode:
authorIan Gudger <igudger@google.com>2018-08-08 19:23:02 -0700
committerShentubot <shentubot@google.com>2018-08-08 19:23:48 -0700
commit2a44362c0b99c6ab800e1b0d26e4f368a5e7f9f1 (patch)
treea58248a196d348bcc612f27f7282d0181893a7b9 /pkg/tcpip/transport/unix/unix.go
parent9144ddda09c0a370bfc7391b0d7382836e296b5d (diff)
Fix data race in unix.BoundEndpoint.UnidirectionalConnect.
Data race is: Read: (*connectionlessEndpoint).UnidirectionalConnect: writeQueue: e.receiver.(*queueReceiver).readQueue, Write: (*connectionlessEndpoint).Close: e.receiver = nil The problem is that (*connectionlessEndpoint).UnidirectionalConnect assumed that baseEndpoint.receiver is immutable which is explicitly not the case. Fixing this required two changes: 1. Add synchronization around access of baseEndpoint.receiver in (*connectionlessEndpoint).UnidirectionalConnect. 2. Check for baseEndpoint.receiver being nil in (*connectionlessEndpoint).UnidirectionalConnect. PiperOrigin-RevId: 207984402 Change-Id: Icddeeb43805e777fa3ef874329fa704891d14181
Diffstat (limited to 'pkg/tcpip/transport/unix/unix.go')
-rw-r--r--pkg/tcpip/transport/unix/unix.go6
1 files changed, 5 insertions, 1 deletions
diff --git a/pkg/tcpip/transport/unix/unix.go b/pkg/tcpip/transport/unix/unix.go
index 8e4af3139..0bb00df42 100644
--- a/pkg/tcpip/transport/unix/unix.go
+++ b/pkg/tcpip/transport/unix/unix.go
@@ -224,7 +224,11 @@ type BoundEndpoint interface {
// type that isn't SockStream or SockSeqpacket.
BidirectionalConnect(ep ConnectingEndpoint, returnConnect func(Receiver, ConnectedEndpoint)) *tcpip.Error
- // UnidirectionalConnect establishes a write-only connection to a unix endpoint.
+ // UnidirectionalConnect establishes a write-only connection to a unix
+ // endpoint.
+ //
+ // An endpoint which calls UnidirectionalConnect and supports it itself must
+ // not hold its own lock when calling UnidirectionalConnect.
//
// This method will return tcpip.ErrConnectionRefused on a non-SockDgram
// endpoint.