diff --git a/src/add-ons/kernel/network/protocols/unix/UnixDatagramEndpoint.cpp b/src/add-ons/kernel/network/protocols/unix/UnixDatagramEndpoint.cpp
index 30a3d08c96..ba63736450 100644
--- a/src/add-ons/kernel/network/protocols/unix/UnixDatagramEndpoint.cpp
+++ b/src/add-ons/kernel/network/protocols/unix/UnixDatagramEndpoint.cpp
@@ -185,6 +185,7 @@ UnixDatagramEndpoint::Connect(const struct sockaddr* _address)
 
 	// Required by the socket layer.
 	PeerAddress().SetTo(&fTargetEndpoint->socket->address);
+	gSocketModule->set_connected(Socket());
 
 	RETURN_ERROR(B_OK);
 }
diff --git a/src/add-ons/kernel/network/protocols/unix/UnixStreamEndpoint.cpp b/src/add-ons/kernel/network/protocols/unix/UnixStreamEndpoint.cpp
index 6a2302bbfe..e327456cf5 100644
--- a/src/add-ons/kernel/network/protocols/unix/UnixStreamEndpoint.cpp
+++ b/src/add-ons/kernel/network/protocols/unix/UnixStreamEndpoint.cpp
@@ -323,7 +323,7 @@ UnixStreamEndpoint::Connect(const struct sockaddr* _address)
 	fState = unix_stream_endpoint_state::Connected;
 	fWasConnected = true;
 
-	gSocketModule->set_connected(newSocket);
+	gSocketModule->set_connected(Socket());
 
 	release_sem(listeningEndpoint->fAcceptSemaphore);
 
@@ -709,6 +709,8 @@ UnixStreamEndpoint::_Spawn(UnixStreamEndpoint* connectingEndpoint,
 	fCredentials = listeningEndpoint->fCredentials;
 
 	fState = unix_stream_endpoint_state::Connected;
+
+	gSocketModule->set_connected(Socket());
 }