Egalware/cms-core-active
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added lock for avoid connect resource contention

Browse Source
This commit is contained in:
Samuele Locatelli
2020-06-23 18:28:43 +02:00
parent 81f05f615f
commit 36a8ac2fd5
1 changed files with 30 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
CMS_CORE_Library/S7Net/Nc_S7Net.cs
+30 -24
View File
@@ -69,6 +69,10 @@ namespace CMS_CORE_Library.S7Net
/// Oggetto PLC da ri-utilizzare...
/// </summary>
protected Plc currPLC;
/// <summary>
/// Lock per connessione PLC
/// </summary>
private readonly object connectLock = new object();
#endregion
@@ -137,40 +141,42 @@ namespace CMS_CORE_Library.S7Net
/// <returns></returns>
public override CmsError NC_Connect()
{
// Try to get information
try
lock (connectLock)
{
// Check if Siemens Environment is started
CmsError libraryError = CheckS7Ping();
if (libraryError.IsError())
return libraryError;
// Check connection
currPLC = new Plc(tipoCpu, this.Ip, this.rack, this.slot);
currPLC.Open();
if (currPLC.IsConnected)
Connected = true;
// FARE TODO FIXME
// Setup the alarms (with DB bitmap) --> PlcMessages
if (this.EnableAlarms)
// Try to get information
try
{
// PlcMessages
// Check if Siemens Environment is started
CmsError libraryError = CheckS7Ping();
if (libraryError.IsError())
return libraryError;
// Check connection
currPLC = new Plc(tipoCpu, this.Ip, this.rack, this.slot);
currPLC.Open();
if (currPLC.IsConnected)
Connected = true;
// FARE TODO FIXME
// Setup the alarms (with DB bitmap) --> PlcMessages
if (this.EnableAlarms)
{
// PlcMessages
#if false
SiemensAlarms = new Alarm[] { };
SiemensAlmSvc = new AlarmSvc(ConvertToSTEPLanguage(SiemensLanguage).ThreeLetterISOLanguageName);
SiemensAlmSvc.Subscribe(AlarmsChanged);
Infrastructure.SubscribeLanguageChanged(NcLanguageChanged);
#endif
}
}
catch (Exception ex)
{
return ManageException(ex);
}
}
catch (Exception ex)
{
return ManageException(ex);
}
return NO_ERROR;
}
/// <summary>