[SoftCSA] Fix 100% CPU usage and missing CWs on softcam restart

CPU bug: When the softcam restarts, the old socket gets closed but
read() returning 0 (EOF) was never handled in the CWHandler poll loop.
Additionally, POLLHUP was gated behind !(revents & POLLIN) which fails
when both flags are set on a closed socket. This caused an infinite
busy-loop: poll() -> read() -> 0 -> ignored -> poll() -> ...

Fix: Handle EOF (read==0) for both softcam_fd and proxy_fd paths, and
remove the POLLIN gate from POLLHUP/POLLERR handling.

CW bug: After softcam reconnect, the running channel never received
new CW keys. On reconnect (m_protocol3_established), distributeCAPMT()
was called before the Protocol-3 handshake, sending CAPMTs in legacy
format. The softcam processed these and started descrambling. The
subsequent Protocol-3 CAPMTs after SERVER_INFO were treated as
duplicates - no CW keys were sent.

Fix: On Protocol-3 reconnect, complete the handshake first before
distributing CAPMTs. processServerInfoPacket() already calls
distributeCAPMT() after the handshake completes.

Author: WXbet

lib/dvb/cahandler.cpp

@@ -381,23 +381,24 @@ void eDVBCAHandler::newConnection(int socket)
 	ePMTClient *client = new ePMTClient(this, client_fd);
 	clients.push_back(client);
 
-	/* Always distribute current CAPMTs first (legacy format, works for all clients) */
-	distributeCAPMT();
-
-	/* Send CLIENT_INFO only when appropriate:
-	 * - Protocol-3 already established (OSCam reconnect): always send
-	 * - First connection ever: send to probe for Protocol-3 support
-	 * - Legacy client detected (no SERVER_INFO after first attempt): skip
-	 *   to avoid unnecessary errors in legacy softcam logs */
 	if (m_protocol3_established)
 	{
+		/* Protocol-3 reconnect: complete handshake first, distributeCAPMT()
+		 * will be called from processServerInfoPacket() */
 		client->sendClientInfo();
 	}
 	else if (!m_handshake_attempted)
 	{
+		/* First connection: send legacy CAPMTs, then probe for Protocol-3 */
+		distributeCAPMT();
 		client->sendClientInfo();
 		m_handshake_attempted = true;
 	}
+	else
+	{
+		/* Legacy softcam - send CAPMTs immediately */
+		distributeCAPMT();
+	}
 }
 
 void eDVBCAHandler::connectionLost(ePMTClient *client)

lib/dvb/cwhandler.cpp

@@ -257,6 +257,7 @@ void eDVBCWHandler::threadLoop()
 			const Connection& conn = conns_snapshot[i];
 
 			// Softcam → proxy_fd (and intercept CWs)
+			bool softcam_disconnected = false;
 			if (pfds[softcam_idx].revents & POLLIN)
 			{
 				ssize_t n = ::read(conn.softcam_fd, buf, sizeof(buf));
@@ -283,31 +284,40 @@ void eDVBCWHandler::threadLoop()
 						written += w;
 					}
 				}
+				else if (n == 0)
+				{
+					// EOF - softcam closed the connection
+					eDebug("[eDVBCWHandler] Softcam EOF on fd %d", conn.softcam_fd);
+					softcam_disconnected = true;
+				}
+				else if (errno != EINTR && errno != EAGAIN)
+				{
+					eDebug("[eDVBCWHandler] Softcam read error on fd %d: %m", conn.softcam_fd);
+					softcam_disconnected = true;
+				}
 			}
 
 			// Handle softcam disconnect
-			if (pfds[softcam_idx].revents & (POLLHUP | POLLERR))
+			if (softcam_disconnected || (pfds[softcam_idx].revents & (POLLHUP | POLLERR)))
 			{
-				if (!(pfds[softcam_idx].revents & POLLIN)) // Only if no data pending
+				eDebug("[eDVBCWHandler] Softcam disconnected on fd %d", conn.softcam_fd);
+				// Close proxy_fd so ePMTClient gets connectionLost
+				std::lock_guard<std::mutex> lock(m_connections_mutex);
+				for (auto it = m_connections.begin(); it != m_connections.end(); ++it)
 				{
-					eDebug("[eDVBCWHandler] Softcam disconnected on fd %d", conn.softcam_fd);
-					// Close proxy_fd so ePMTClient gets connectionLost
-					std::lock_guard<std::mutex> lock(m_connections_mutex);
-					for (auto it = m_connections.begin(); it != m_connections.end(); ++it)
+					if (it->softcam_fd == conn.softcam_fd)
 					{
-						if (it->softcam_fd == conn.softcam_fd)
-						{
-							::close(it->softcam_fd);
-							::close(it->proxy_fd);
-							m_connections.erase(it);
-							break;
-						}
+						::close(it->softcam_fd);
+						::close(it->proxy_fd);
+						m_connections.erase(it);
+						break;
 					}
-					continue;
 				}
+				continue;
 			}
 
 			// proxy_fd → softcam (CAPMT writes from ePMTClient)
+			bool proxy_disconnected = false;
 			if (pfds[proxy_idx].revents & POLLIN)
 			{
 				ssize_t n = ::read(conn.proxy_fd, buf, sizeof(buf));
@@ -330,24 +340,31 @@ void eDVBCWHandler::threadLoop()
 						written += w;
 					}
 				}
+				else if (n == 0)
+				{
+					eDebug("[eDVBCWHandler] ePMTClient EOF on proxy_fd %d", conn.proxy_fd);
+					proxy_disconnected = true;
+				}
+				else if (errno != EINTR && errno != EAGAIN)
+				{
+					eDebug("[eDVBCWHandler] ePMTClient read error on proxy_fd %d: %m", conn.proxy_fd);
+					proxy_disconnected = true;
+				}
 			}
 
 			// Handle ePMTClient disconnect
-			if (pfds[proxy_idx].revents & (POLLHUP | POLLERR))
+			if (proxy_disconnected || (pfds[proxy_idx].revents & (POLLHUP | POLLERR)))
 			{
-				if (!(pfds[proxy_idx].revents & POLLIN))
+				eDebug("[eDVBCWHandler] ePMTClient disconnected on proxy_fd %d", conn.proxy_fd);
+				std::lock_guard<std::mutex> lock(m_connections_mutex);
+				for (auto it = m_connections.begin(); it != m_connections.end(); ++it)
 				{
-					eDebug("[eDVBCWHandler] ePMTClient disconnected on proxy_fd %d", conn.proxy_fd);
-					std::lock_guard<std::mutex> lock(m_connections_mutex);
-					for (auto it = m_connections.begin(); it != m_connections.end(); ++it)
+					if (it->proxy_fd == conn.proxy_fd)
 					{
-						if (it->proxy_fd == conn.proxy_fd)
-						{
-							::close(it->softcam_fd);
-							::close(it->proxy_fd);
-							m_connections.erase(it);
-							break;
-						}
+						::close(it->softcam_fd);
+						::close(it->proxy_fd);
+						m_connections.erase(it);
+						break;
 					}
 				}
 			}