arif/xcat-core
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

-Make DB worker persist in the event of catastrophe and log the catastophre

Browse Source 
git-svn-id: https://svn.code.sf.net/p/xcat/code/xcat-core/trunk@3994 8638fb3e-16cb-4fca-ae20-7b5d299a9bcd
This commit is contained in:
jbjohnso 2009-08-13 14:32:22 +00:00
parent 4e79358fc2
commit 1aa8107eda
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
perl-xCAT/xCAT/Table.pm
View File

@ -6,6 +6,7 @@
#creating new sqlite db files when only requested to read non-existant table, easy to fix,
#class xcattable
package xCAT::Table;
use xCAT::MsgUtils;
use Sys::Syslog;
use Storable qw/freeze thaw/;
use Data::Dumper;
@ -114,18 +115,22 @@ sub init_dbworker {
my $clientset = new IO::Select;
$clientset->add($dbworkersocket);
while (not $exitdbthread) {
my @ready_socks = $clientset->can_read;
foreach $currcon (@ready_socks) {
if ($currcon == $dbworkersocket) { #We have a new connection to register
my $dbconn = $currcon->accept;
if ($dbconn) {
$clientset->add($dbconn);
eval {
my @ready_socks = $clientset->can_read;
foreach $currcon (@ready_socks) {
if ($currcon == $dbworkersocket) { #We have a new connection to register
my $dbconn = $currcon->accept;
if ($dbconn) {
$clientset->add($dbconn);
}
} else {
handle_dbc_conn($currcon,$clientset);
}
} else {
handle_dbc_conn($currcon,$clientset);
}
};
if ($@) {
xCAT::MsgUtils->message("S","xcatd: possible BUG encountered by xCAT DB worker ".$@);
}
}
close($dbworkersocket);
unlink($dbsockpath);