Librerias
/
LibS7Adv
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: Librerias:4aa1e8ec27dbba197e89426eb091983f4cc7f34f
Branches Tags
Librerias:master
..
compare: Librerias:c0ff14a5ae8c413c6708cddd06c61e59270a1ea7
Branches Tags
Librerias:master

No commits in common. "4aa1e8ec27dbba197e89426eb091983f4cc7f34f" and "c0ff14a5ae8c413c6708cddd06c61e59270a1ea7" have entirely different histories.
4aa1e8ec27 ... c0ff14a5ae

1 changed files with 112 additions and 164 deletions
Show Stats Expand all files Collapse all files

138
PLCViewModel.cs
View File

@ -57,13 +57,6 @@ namespace LibS7Adv
private DateTime _lastUpdateStartTime = DateTime.MinValue; private DateTime _lastUpdateStartTime = DateTime.MinValue;
private TimeSpan _updateTimeout = TimeSpan.FromSeconds(10); // Timeout para reintentar después de un tiempo private TimeSpan _updateTimeout = TimeSpan.FromSeconds(10); // Timeout para reintentar después de un tiempo
// Añadir protección contra loops infinitos
private readonly object _updateLock = new object();
private int _concurrentUpdateCount = 0;
private const int MAX_CONCURRENT_UPDATES = 1;
private DateTime _lastUpdateAttempt = DateTime.MinValue;
private readonly TimeSpan _minUpdateInterval = TimeSpan.FromSeconds(2);
[ObservableProperty] [ObservableProperty]
PlcData plcData = new PlcData(); PlcData plcData = new PlcData();
@ -129,14 +122,6 @@ namespace LibS7Adv
{ {
IsConnected = false; IsConnected = false;
PlcData.ConnectionStatus = "offline"; PlcData.ConnectionStatus = "offline";
// Limpiar estado al desconectar
lock (_updateLock)
{
_isUpdating = false;
_concurrentUpdateCount = 0;
}
Instance = null; Instance = null;
} }
@ -147,7 +132,7 @@ namespace LibS7Adv
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Actualizar cuando recibimos el evento // Actualizar cuando recibimos el evento
SafeUpdateTagList(); UpdateTagList();
// Cuando la actualización se completa exitosamente, desactivar la bandera // Cuando la actualización se completa exitosamente, desactivar la bandera
if (IsConfigured) if (IsConfigured)
@ -156,45 +141,8 @@ namespace LibS7Adv
} }
else else
{ {
// Si no se pudo configurar, programar UN SOLO reintento después de un tiempo // Si no se pudo configurar, programar un reintento después de un tiempo
// Solo si no hay otra actualización en curso Task.Delay(1000).ContinueWith(_ => UpdateTagList());
lock (_updateLock)
{
if (_concurrentUpdateCount == 0)
{
Task.Delay(2000).ContinueWith(_ => SafeUpdateTagList());
}
}
}
}
private void SafeUpdateTagList()
{
// Verificar si podemos hacer la actualización
lock (_updateLock)
{
// No permitir más de una actualización concurrente
if (_concurrentUpdateCount >= MAX_CONCURRENT_UPDATES)
return;
// No actualizar muy frecuentemente
if (DateTime.Now - _lastUpdateAttempt < _minUpdateInterval)
return;
_concurrentUpdateCount++;
_lastUpdateAttempt = DateTime.Now;
}
try
{
UpdateTagList();
}
finally
{
lock (_updateLock)
{
_concurrentUpdateCount--;
}
} }
} }
@ -205,7 +153,7 @@ namespace LibS7Adv
try try
{ {
Instance?.UpdateTagList(ETagListDetails.IO | ETagListDetails.DB | ETagListDetails.M, true); // Instance?.UpdateTagList(ETagListDetails.IO | ETagListDetails.DB | ETagListDetails.M, true);
IsConfigured = true; IsConfigured = true;
_isUpdating = false; // Éxito en la actualización _isUpdating = false; // Éxito en la actualización
} }
@ -234,7 +182,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar leer durante la actualización // No intentar leer durante la actualización
@ -266,8 +214,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = sTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = sTag + ": Tags no actualizados, reintentando...";
} }
@ -297,7 +245,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar escribir durante la actualización // No intentar escribir durante la actualización
@ -330,8 +278,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = sTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = sTag + ": Tags no actualizados, reintentando...";
} }
@ -360,7 +308,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar leer durante la actualización // No intentar leer durante la actualización
@ -430,8 +378,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = sTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = sTag + ": Tags no actualizados, reintentando...";
} }
@ -456,7 +404,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar leer durante la actualización // No intentar leer durante la actualización
@ -473,8 +421,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = "Byte " + pByte + ", Bit " + pBit + ": Tags no actualizados, reintentando..."; PlcData.LastError = "Byte " + pByte + ", Bit " + pBit + ": Tags no actualizados, reintentando...";
} }
@ -497,7 +445,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar escribir durante la actualización // No intentar escribir durante la actualización
@ -514,8 +462,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = "Byte " + pByte + ", Bit " + pBit + ": Tags no actualizados, reintentando..."; PlcData.LastError = "Byte " + pByte + ", Bit " + pBit + ": Tags no actualizados, reintentando...";
} }
@ -543,7 +491,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar escribir durante la actualización // No intentar escribir durante la actualización
@ -560,8 +508,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = pTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = pTag + ": Tags no actualizados, reintentando...";
} }
@ -589,7 +537,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar leer durante la actualización // No intentar leer durante la actualización
@ -606,8 +554,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = pTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = pTag + ": Tags no actualizados, reintentando...";
} }
@ -636,7 +584,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar escribir durante la actualización // No intentar escribir durante la actualización
@ -653,8 +601,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = pTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = pTag + ": Tags no actualizados, reintentando...";
} }
@ -681,7 +629,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar escribir durante la actualización // No intentar escribir durante la actualización
@ -698,8 +646,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = pTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = pTag + ": Tags no actualizados, reintentando...";
} }
@ -727,7 +675,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar leer durante la actualización // No intentar leer durante la actualización
@ -745,8 +693,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = pTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = pTag + ": Tags no actualizados, reintentando...";
} }
@ -775,7 +723,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar leer durante la actualización // No intentar leer durante la actualización
@ -793,8 +741,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = pTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = pTag + ": Tags no actualizados, reintentando...";
} }
@ -823,7 +771,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar leer durante la actualización // No intentar leer durante la actualización
@ -841,8 +789,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = pTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = pTag + ": Tags no actualizados, reintentando...";
} }
@ -871,7 +819,7 @@ namespace LibS7Adv
if (DateTime.Now - _lastUpdateStartTime > _updateTimeout) if (DateTime.Now - _lastUpdateStartTime > _updateTimeout)
{ {
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
SafeUpdateTagList(); UpdateTagList();
} }
// No intentar escribir durante la actualización // No intentar escribir durante la actualización
@ -888,8 +836,8 @@ namespace LibS7Adv
_isUpdating = true; _isUpdating = true;
_lastUpdateStartTime = DateTime.Now; _lastUpdateStartTime = DateTime.Now;
// Iniciar actualización de tags de forma segura // Iniciar actualización de tags
SafeUpdateTagList(); Task.Run(() => UpdateTagList());
PlcData.LastError = pTag + ": Tags no actualizados, reintentando..."; PlcData.LastError = pTag + ": Tags no actualizados, reintentando...";
} }