4 use vars qw( @part_export );
5 use subs qw(myshutdown);
6 use POSIX qw(:sys_wait_h);
8 use FS::Daemon qw(daemonize1 drop_root logfile daemonize2 sigint sigterm);
9 use FS::UID qw(adminsuidsetup); #forksuidsetup driver_name dbh myconnect);
10 use FS::Record qw(qsearch); # qsearchs);
15 my $user = shift or die &usage;
17 #daemonize1('freeside-sqlradius-radacctd', $user); #keep unique pid files w/multi installs
18 daemonize1('freeside-sqlradius-radacctd');
22 #$ENV{HOME} = (getpwuid($>))[7]; #for ssh
26 logfile( "/usr/local/etc/freeside/sqlradius-radacctd-log.". $FS::UID::datasrc );
32 #don't just look for ->can('usage_sessions'), we're sqlradius-specific
33 # (radiator is supposed to be setup with a radacct table)
36 qsearch('part_export', { 'exporttype' => 'sqlradius' } );
38 qsearch('part_export', { 'exporttype' => 'sqlradius_withdomain' } );
40 qsearch('part_export', { 'exporttype' => 'radiator' } );
42 @part_export = grep { ! $_->option('ignore_accounting') } @part_export;
44 die "no sqlradius, sqlradius_withdomain or radiator exports without".
50 #fork off one kid per export (machine)
51 # _>{'_radacct_kid'} is an evil kludge
52 foreach my $part_export ( grep ! $_->{'_radacct_kid'}, @part_export ) {
54 defined( my $pid = fork ) or do {
55 warn "WARNING: can't fork to spawn child for ". $part_export->machine;
60 $part_export->{'_radacct_kid'} = $pid;
61 warn "child $pid spawned for ". $part_export->machine;
64 adminsuidsetup($user); #get our own db handle
66 until ( sigint || sigterm ) {
67 $part_export->update_svc_acct();
71 warn "child for ". $part_export->machine. " done";
78 #reap up any kids that died...
81 myshutdown() if sigterm() || sigint();
92 kill 'TERM', $_ foreach grep $_, map $_->{'_radacct_kid'}, @part_export;
94 my $wait = 12; #wait up to 1 minute
95 while ( ( grep $_->{'_radacct_kid'}, @part_export ) && $wait-- ) {
96 warn "waiting for children to terminate";
100 warn "abandoning children" if grep $_->{'_radacct_kid'}, @part_export;
105 #warn "reaping kids\n";
106 foreach my $part_export ( grep $_->{'_radacct_kid'}, @part_export ) {
107 my $pid = $part_export->{'_radacct_kid'};
108 my $kid = waitpid($pid, WNOHANG);
110 $part_export->{'_radacct_kid'} = '';
113 #warn "done reaping\n";
117 die "Usage:\n\n freeside-sqlradius-radacctd user\n";
122 freeside-sqlradius-radacctd - Real-time radacct import daemon
126 freeside-sqlradius-radacctd username
130 Imports records from an the SQL radacct tables of all sqlradius,
131 sqlradius_withdomain and radiator exports (except those with the
132 ignore_accounting flag) and updates the svc_acct.seconds for each account.
133 Runs as a daemon and updates the database in real-time.
135 B<username> is a username added by freeside-adduser.
137 =head1 RADIUS DATABASE CHANGES
139 ALTER TABLE radacct ADD COLUMN FreesideStatus varchar(32) NULL;
141 If you want to ignore the existing accountg records, also do:
143 UPDATE radacct SET FreesideStatus = 'done' WHERE FreesideStatus IS NULL;