From 6f62d753a5e19468c503eb22ca6a86fd48b9d486 Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Wed, 4 Mar 2026 11:26:38 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E7=BC=96=E8=AF=91=E8=AD=A6?=
 =?UTF-8?q?=E5=91=8A=EF=BC=9A=E5=B0=86=20PollPointInfo=20=E6=94=B9?=
 =?UTF-8?q?=E4=B8=BA=E5=85=AC=E5=BC=80=EF=BC=8C=E7=A7=BB=E9=99=A4=E6=9C=AA?=
 =?UTF-8?q?=E4=BD=BF=E7=94=A8=E7=9A=84=E5=AD=97=E6=AE=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/connection.rs | 12 +++---------
 1 file changed, 3 insertions(+), 9 deletions(-)

diff --git a/src/connection.rs b/src/connection.rs
index 2fa8eee..e2e3e0f 100644
--- a/src/connection.rs
+++ b/src/connection.rs
@@ -59,10 +59,8 @@ struct PointWriteTarget {
     external_id: String,
 }
 
-struct PollPointInfo {
+pub struct PollPointInfo {
     handle: JoinHandle<()>,
-    external_id: String,
-    interval_s: i32,
 }
 
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
@@ -325,11 +323,7 @@ impl ConnectionManager {
             if let Some(conn_status) = status.get_mut(&source_id) {
                 conn_status.poll_points.insert(
                     point_id,
-                    PollPointInfo {
-                        handle,
-                        external_id: point.external_id.clone(),
-                        interval_s: point.scan_interval_s,
-                    },
+                    PollPointInfo { handle },
                 );
             }
         }
@@ -670,7 +664,7 @@ impl ConnectionManager {
             let source_connected = self
                 .get_status(*source_id)
                 .await
-                .map(|s| s.is_connected && s.session.is_some())
+                .map(|s| s.is_connected)
                 .unwrap_or(false);
             if !source_connected {
                 return Ok(Self::write_value_batch_result(