martin/aqhomecontrol
Public Access
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

cleanup connections every 10s.

Browse Source
This commit is contained in:
Martin Preuss
2023-09-16 15:47:39 +02:00
parent cf005fa60c
commit 8c60c3c8e4
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
apps/aqhome-data/main.c
View File

@@ -31,8 +31,9 @@
//#define WRITE_INTERVAL_IN_SECS (5*60) //#define WRITE_INTERVAL_IN_SECS (5*60)
#define WRITE_INTERVAL_IN_SECS (60) #define WRITE_INTERVAL_IN_SECS 60
#define PING_INTERVAL 120 #define PING_INTERVAL 120
#define CONNCLEAN_INTERVAL_IN_SECS 10
@@ -133,11 +134,13 @@ void _runService(AQHOME_DATA *aqh)
{ {
time_t timeStart; time_t timeStart;
time_t timeLastWrite; time_t timeLastWrite;
time_t timeLastConnectionCleanup;
int timeout; int timeout;
timeout=AqHomeData_GetTimeout(aqh); timeout=AqHomeData_GetTimeout(aqh);
timeStart=time(NULL); timeStart=time(NULL);
timeLastWrite=time(NULL); timeLastWrite=time(NULL);
timeLastConnectionCleanup=time(NULL);
while(!stopService) { while(!stopService) {
time_t now; time_t now;
@@ -147,6 +150,12 @@ void _runService(AQHOME_DATA *aqh)
now=time(NULL); now=time(NULL);
if (((int)difftime(now, timeLastConnectionCleanup))>CONNCLEAN_INTERVAL_IN_SECS) {
DBG_INFO(NULL, "Cleanup connections");
GWEN_MsgEndpoint_RemoveUnconnectedAndEmptyChildren(AqHomeData_GetIpcdEndpoint(aqh));
timeLastConnectionCleanup=now;
}
if (((int)difftime(now, timeLastWrite))>WRITE_INTERVAL_IN_SECS) { if (((int)difftime(now, timeLastWrite))>WRITE_INTERVAL_IN_SECS) {
DBG_INFO(NULL, "Write time"); DBG_INFO(NULL, "Write time");
_writeCurrentState(aqh); _writeCurrentState(aqh);