Keep session active for explicit disconnect and refresh timeout docs

Author: mondain

README.md

@@ -427,7 +427,7 @@ Behavior notes:
 - `--coalesce-cmaf-chunks` disables that split and falls back to one media object per group
 - when multiple tracks are subscribed, matching objects are served in publish-plan order so time-aligned audio/video stay interleaved instead of draining one track before the next
 - `--forward 1` proactively publishes tracks and objects after namespace setup completes
-- `--timeout <seconds>` controls how long the publisher waits for inbound `SUBSCRIBE` requests; the default is 3 seconds
+- `--timeout <seconds>` controls how long the publisher waits for inbound `SUBSCRIBE` requests; the default is 30 seconds
 - `--sni <value>` overrides the TLS SNI sent to the relay, which is useful when `--endpoint` uses a raw IP address; WebTransport still sends HTTP authority from the configured endpoint host
 - `--paced` applies pacing only to media-object sends; setup and publish control messages are sent immediately
 - `OPENMOQ_PICOQUIC_TRACE_CSV=/path/file.csv` is optional and only writes CSV output when `OPENMOQ_PICOQUIC_TRACE` is also set; rows include `pacing_before`, `pacing_after`, `enqueue`, and `served`/`sent` events for media objects

docs/publisher-api.md

@@ -30,7 +30,7 @@ config.include_sap = false;
 config.split_cmaf_chunks = true;
 config.paced = false;
 config.loop = false;
-config.subscriber_timeout = std::chrono::seconds(3);
+config.subscriber_timeout = std::chrono::seconds(30);
 
 openmoq::publisher::Publisher publisher(config);
 ```
@@ -266,7 +266,7 @@ int main() {
     config.draft_version = DraftVersion::kDraft14;
     config.track_namespace = "media";
     config.split_cmaf_chunks = true;
-    config.subscriber_timeout = std::chrono::seconds(3);
+    config.subscriber_timeout = std::chrono::seconds(30);
 
     Publisher publisher(config);
 

src/publisher_api.cpp

@@ -150,6 +150,7 @@ transport::TransportStatus Publisher::publish(const PreparedPublish& prepared,
     status = active->session->publish(materialized);
     if (!status.ok) {
         const std::string error = "transport publish failed: " + status.message;
+        static_cast<void>(active->session->close(0));
         clear_active_session(active, true, error);
         return transport::TransportStatus::failure(error);
     }
@@ -161,7 +162,6 @@ transport::TransportStatus Publisher::publish(const PreparedPublish& prepared,
         stats_.groups_published = batch_stats.groups_published;
     }
 
-    clear_active_session(active, true, "");
     return transport::TransportStatus::success();
 }
 
@@ -216,6 +216,7 @@ transport::TransportStatus Publisher::publish_live(std::istream& input,
     status = active->session->publish_live(input, config_.draft_version, config_.split_cmaf_chunks);
     if (!status.ok) {
         const std::string error = "transport live publish failed: " + status.message;
+        static_cast<void>(active->session->close(0));
         clear_active_session(active, true, error);
         return transport::TransportStatus::failure(error);
     }
@@ -227,7 +228,6 @@ transport::TransportStatus Publisher::publish_live(std::istream& input,
         stats_.groups_published = live_stats.groups_published;
     }
 
-    clear_active_session(active, true, "");
     return transport::TransportStatus::success();
 }