zcdsj
/
plc_control
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

PointNewValue

This commit is contained in:
caoqianming 2026-03-03 16:44:53 +08:00
parent 02de1f4552
commit a82921193c
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/connection.rs
View File

@ -262,7 +262,7 @@ impl ConnectionManager {
.unwrap_or(crate::telemetry::PointQuality::Unknown); .unwrap_or(crate::telemetry::PointQuality::Unknown);
let _ = event_manager.send(crate::event::ReloadEvent::PointValueChange( let _ = event_manager.send(crate::event::ReloadEvent::PointValueChange(
crate::telemetry::PointValueChangeEvent { crate::telemetry::PointNewValue {
source_id, source_id,
point_id: Some(point_id), point_id: Some(point_id),
client_handle: 0, client_handle: 0,
@ -759,7 +759,7 @@ impl ConnectionManager {
if let Some(event_manager) = &self.event_manager { if let Some(event_manager) = &self.event_manager {
for (source_id, point_id, variant) in success_events { for (source_id, point_id, variant) in success_events {
if let Err(e) = event_manager.send(crate::event::ReloadEvent::PointValueChange( if let Err(e) = event_manager.send(crate::event::ReloadEvent::PointValueChange(
crate::telemetry::PointValueChangeEvent { crate::telemetry::PointNewValue {
source_id, source_id,
point_id: Some(point_id), point_id: Some(point_id),
client_handle: 0, client_handle: 0,
@ -884,7 +884,7 @@ impl ConnectionManager {
if let Some(event_manager) = &manager.event_manager { if let Some(event_manager) = &manager.event_manager {
let _ = event_manager.send(crate::event::ReloadEvent::PointValueChange( let _ = event_manager.send(crate::event::ReloadEvent::PointValueChange(
crate::telemetry::PointValueChangeEvent { crate::telemetry::PointNewValue {
source_id: current_source_id, source_id: current_source_id,
point_id: None, point_id: None,
client_handle, client_handle,

2
src/event.rs
View File

@ -24,7 +24,7 @@ pub enum ReloadEvent {
source_id: Uuid, source_id: Uuid,
point_ids: Vec<Uuid>, point_ids: Vec<Uuid>,
}, },
PointValueChange(crate::telemetry::PointValueChangeEvent), PointValueChange(crate::telemetry::PointNewValue),
} }
pub struct EventManager { pub struct EventManager {

2
src/telemetry.rs
View File

@ -94,7 +94,7 @@ impl PointMonitorInfo {
} }
#[derive(Debug, Clone)] #[derive(Debug, Clone)]
pub struct PointValueChangeEvent { pub struct PointNewValue {
pub source_id: Uuid, pub source_id: Uuid,
pub point_id: Option<Uuid>, pub point_id: Option<Uuid>,
pub client_handle: u32, pub client_handle: u32,