ViciDial/agc_2-X
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix for multi-server clusters in flushDB script

Browse Source 
git-svn-id: svn://192.168.202.10@4017 3d104415-ff17-0410-8863-d5cf3c621b8a
This commit is contained in:
mattf
2026-09-01 03:58:46 +00:00
parent a1d416bba8
commit 3d86d97a32
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bin/AST_flush_DBqueue.pl
+3 -2
View File
@@ -39,6 +39,7 @@
# 250914-1537 - Added archiving of recording_live table # 250914-1537 - Added archiving of recording_live table
# 251003-0837 - Added --preserve-dtmf flag (DTMF logs would then be kept for 1-2 days) # 251003-0837 - Added --preserve-dtmf flag (DTMF logs would then be kept for 1-2 days)
# 260515-2212 - Added internal logging # 260515-2212 - Added internal logging
# 260831-2357 - Fix for multi-server clusters
# #
$session_flush=0; $session_flush=0;
@@ -951,7 +952,7 @@ if ($check_xfers > 0)
{ {
$active_count=0; $active_count=0;
$channelSQL=''; $channelSQL='';
if (length($ST_channel[$a]) > 0) {$channelSQL="or channel='$ST_channel[$a]'";} if (length($ST_channel[$a]) > 0) {$channelSQL="or ( (channel='$ST_channel[$a]') and (server_ip='$ST_server_ip[$a]') )";}
$stmtA = "SELECT count(*) FROM live_channels where channel_group='$ST_callerid[$a]' $channelSQL;"; $stmtA = "SELECT count(*) FROM live_channels where channel_group='$ST_callerid[$a]' $channelSQL;";
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr; $sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr; $sthA->execute or die "executing: $stmtA ", $dbhA->errstr;
@@ -996,7 +997,7 @@ if ($check_xfers > 0)
$active_count=0; $active_count=0;
$channelSQL=''; $channelSQL='';
if (length($TK_channel[$a]) > 0) {$channelSQL="or channel='$TK_channel[$a]'";} if (length($TK_channel[$a]) > 0) {$channelSQL="or ( (channel='$TK_channel[$a]') and (server_ip='$TK_server_ip[$a]') )";}
$stmtA = "SELECT count(*) FROM live_channels where channel_group='$TK_callerid[$a]' $channelSQL;"; $stmtA = "SELECT count(*) FROM live_channels where channel_group='$TK_callerid[$a]' $channelSQL;";
$sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr; $sthA = $dbhA->prepare($stmtA) or die "preparing: ",$dbhA->errstr;
$sthA->execute or die "executing: $stmtA ", $dbhA->errstr; $sthA->execute or die "executing: $stmtA ", $dbhA->errstr;