fix: properly close connections when stream ends

Fixes issues where connections were not being closed after RTSP TEARDOWN
or when switching channels, causing stale connections in the status display.

Fixes #305
Fixes #306

Co-Authored-By: Claude Opus 4.5 <[email protected]>

Author: stackia

src/stream.c

@@ -344,13 +344,12 @@ int stream_handle_fd_event(stream_context_t *ctx, int fd, uint32_t events,
     if (ctx->http_proxy.state == HTTP_PROXY_STATE_COMPLETE) {
       logger(LOG_DEBUG, "HTTP Proxy: Transfer complete");
       /* Set connection to closing state - worker will close it after
-       * output queue is drained. Return -2 to indicate graceful close. */
+       * output queue is drained. */
       ctx->conn->state = CONN_CLOSING;
       /* Trigger EPOLLOUT to flush any remaining data in the queue */
       connection_epoll_update_events(
           ctx->conn->epfd, ctx->conn->fd,
           EPOLLIN | EPOLLOUT | EPOLLRDHUP | EPOLLHUP | EPOLLERR);
-      return -2;
     }
     return 0;
   }

src/worker.c

@@ -523,16 +523,11 @@ int worker_run_event_loop(int *listen_sockets, int num_sockets, int notif_fd) {
 
               connection_queue_output_and_flush(c, (const uint8_t *)response,
                                                 strlen(response));
-            } else if (c->state != CONN_CLOSING) {
-              /* Only handle if not in CONN_CLOSING state.
-               * CONN_CLOSING connections will be closed by EPOLLOUT handler
-               * after output queue is drained (graceful close). */
-              if (!c->headers_sent) {
-                /* Send 503 if headers not sent yet (no data ever arrived) */
-                http_send_503(c);
-              } else {
-                worker_close_and_free_connection(c);
-              }
+            } else if (!c->headers_sent && c->state != CONN_CLOSING) {
+              /* Send 503 if headers not sent yet (no data ever arrived) */
+              http_send_503(c);
+            } else {
+              worker_close_and_free_connection(c);
             }
             continue; /* Skip further processing for this connection */
           }