fix: 修复 poll task 中 results 和 poll_points 可能错位的 bug
This commit is contained in:
parent
8e4abd0af9
commit
afac9f1eb9
|
|
@ -403,12 +403,7 @@ impl ConnectionManager {
|
||||||
// 执行批量读取
|
// 执行批量读取
|
||||||
match session.read(&read_requests, TimestampsToReturn::Both, 0f64).await {
|
match session.read(&read_requests, TimestampsToReturn::Both, 0f64).await {
|
||||||
Ok(results) => {
|
Ok(results) => {
|
||||||
for (i, result) in results.iter().enumerate() {
|
for (poll_point, result) in poll_points.iter().zip(results.iter()) {
|
||||||
if i >= poll_points.len() {
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
let poll_point = &poll_points[i];
|
|
||||||
let dv = result;
|
let dv = result;
|
||||||
let val = dv.value.clone();
|
let val = dv.value.clone();
|
||||||
let unified_value = val.as_ref().map(crate::telemetry::opcua_variant_to_data);
|
let unified_value = val.as_ref().map(crate::telemetry::opcua_variant_to_data);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue