File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -587,11 +587,13 @@ class McpClient : public application::ApplicationBase {
587587 std::string current_uri_;
588588
589589 // Dead connection managers awaiting deferred destruction.
590- // During reconnect, the old connection manager cannot be destroyed immediately
591- // because libevent callbacks referencing it may still be in-flight on the
592- // dispatcher's current event loop iteration. Moved here and cleaned up on
593- // the next dispatcher iteration via deferredDelete or explicit clear.
594- std::vector<std::unique_ptr<mcp::McpConnectionManager>> dead_connection_managers_;
590+ // During reconnect, the old connection manager cannot be destroyed
591+ // immediately because libevent callbacks referencing it may still be
592+ // in-flight on the dispatcher's current event loop iteration. Moved here and
593+ // cleaned up on the next dispatcher iteration via deferredDelete or explicit
594+ // clear.
595+ std::vector<std::unique_ptr<mcp::McpConnectionManager>>
596+ dead_connection_managers_;
595597
596598 // Connection activity tracking for detecting stale connections
597599 std::chrono::steady_clock::time_point last_activity_time_;
Original file line number Diff line number Diff line change @@ -68,7 +68,8 @@ class HttpSseFilterChainFactory : public network::FilterChainFactory {
6868 * HTTP (direct POST)
6969 * @param sse_path Server-side SSE endpoint path (e.g., "/sse")
7070 * @param rpc_path Server-side JSON-RPC endpoint path (e.g., "/mcp")
71- * @param external_url External URL for absolute SSE callback URLs (proxy support)
71+ * @param external_url External URL for absolute SSE callback URLs (proxy
72+ * support)
7273 */
7374 HttpSseFilterChainFactory (event::Dispatcher& dispatcher,
7475 McpProtocolCallbacks& message_callbacks,
@@ -179,7 +180,7 @@ class HttpSseFilterChainFactory : public network::FilterChainFactory {
179180 std::string http_path_; // HTTP request path for client mode
180181 std::string http_host_; // HTTP Host header for client mode
181182 bool use_sse_; // True for SSE mode, false for Streamable HTTP
182- std::string sse_path_; // Server-side SSE endpoint path (e.g., "/sse")
183+ std::string sse_path_; // Server-side SSE endpoint path (e.g., "/sse")
183184 std::string rpc_path_; // Server-side JSON-RPC endpoint path (e.g., "/mcp")
184185 std::string external_url_; // External URL for absolute SSE callback URLs
185186 mutable bool enable_metrics_ = true ; // Enable metrics by default
Original file line number Diff line number Diff line change @@ -90,7 +90,7 @@ struct McpServerConfig : public application::ApplicationBase::Config {
9090 std::string http_rpc_path = " /rpc" ; // Path for JSON-RPC over HTTP
9191 std::string http_sse_path = " /sse" ; // Path for SSE event stream
9292 std::string http_health_path = " /health" ; // Path for health check endpoint
93- std::string external_url; // External URL for SSE callbacks (proxy support)
93+ std::string external_url; // External URL for SSE callbacks (proxy support)
9494
9595 // Session management
9696 size_t max_sessions = 100 ;
Original file line number Diff line number Diff line change 4949 "@typescript-eslint/parser" : " ^6.21.0" ,
5050 "eslint" : " ^8.0.0" ,
5151 "jest" : " ^29.0.0" ,
52- "prettier" : " ^3.6.2 " ,
52+ "prettier" : " ^3.8.3 " ,
5353 "ts-jest" : " ^29.0.0" ,
5454 "tsx" : " ^4.20.6" ,
5555 "typescript" : " ^5.0.0"
You can’t perform that action at this time.
0 commit comments