2012-01-04 20:23:07 +00:00
# IBM(c) 2007 EPL license http://www.eclipse.org/legal/epl-v10.html
package xCAT_plugin::anaconda ;
BEGIN
{
$ ::XCATROOT = $ ENV { 'XCATROOT' } ? $ ENV { 'XCATROOT' } : '/opt/xcat' ;
}
use lib "$::XCATROOT/lib/perl" ;
use Storable qw( dclone ) ;
use Sys::Syslog ;
use Thread qw( yield ) ;
use POSIX qw( WNOHANG nice ) ;
use xCAT::Table ;
use xCAT::Utils ;
use xCAT::NetworkUtils ;
use xCAT::MsgUtils ;
use xCAT::SvrUtils ;
#use Data::Dumper;
use Getopt::Long ;
Getopt::Long:: Configure ( "bundling" ) ;
Getopt::Long:: Configure ( "pass_through" ) ;
use File::Path ;
use File::Copy ;
use File::Temp qw/mkdtemp/ ;
use Socket ;
2012-02-24 21:12:51 +00:00
use strict ;
2012-01-04 20:23:07 +00:00
my @ cpiopid ;
2012-01-13 09:38:47 +00:00
2012-01-04 20:23:07 +00:00
sub handled_commands
{
return {
copycd = > "anaconda" ,
mknetboot = > "nodetype:os=(centos.*)|(rh.*)|(fedora.*)|(SL.*)" ,
mkinstall = > "nodetype:os=(esxi4.1)|(esx[34].*)|(centos.*)|(rh.*)|(fedora.*)|(SL.*)" ,
mkstatelite = > "nodetype:os=(esx[34].*)|(centos.*)|(rh.*)|(fedora.*)|(SL.*)" ,
} ;
}
sub preprocess_request
{
my $ req = shift ;
my $ callback = shift ;
return [ $ req ] ; #calls are only made from pre-farmed out scenarios
if ( $ req - > { command } - > [ 0 ] eq 'copycd' )
{ #don't farm out copycd
return [ $ req ] ;
}
2012-05-21 10:00:16 +00:00
#my $stab = xCAT::Table->new('site');
#my $sent;
#($sent) = $stab->getAttribs({key => 'sharedtftp'}, 'value');
my @ ents = xCAT::Utils - > get_site_attribute ( "sharedtftp" ) ;
my $ site_ent = $ ents [ 0 ] ;
unless ( defined ( $ site_ent )
and ( $ site_ent =~ /no/i or $ site_ent =~ /0/ ) )
2012-01-04 20:23:07 +00:00
{
#unless requesting no sharedtftp, don't make hierarchical call
return [ $ req ] ;
}
my % localnodehash ;
my % dispatchhash ;
my $ nrtab = xCAT::Table - > new ( 'noderes' ) ;
my $ nrents = $ nrtab - > getNodesAttribs ( $ req - > { node } , [ qw( tftpserver servicenode ) ] ) ;
foreach my $ node ( @ { $ req - > { node } } )
{
my $ nodeserver ;
my $ tent = $ nrents - > { $ node } - > [ 0 ] ; #$nrtab->getNodeAttribs($node, ['tftpserver']);
if ( $ tent ) { $ nodeserver = $ tent - > { tftpserver } }
unless ( $ tent and $ tent - > { tftpserver } )
{
$ tent = $ nrents - > { $ node } - > [ 0 ] ; #$nrtab->getNodeAttribs($node, ['servicenode']);
if ( $ tent ) { $ nodeserver = $ tent - > { servicenode } }
}
if ( $ nodeserver )
{
$ dispatchhash { $ nodeserver } - > { $ node } = 1 ;
}
else
{
$ localnodehash { $ node } = 1 ;
}
}
my @ requests ;
my $ reqc = { %$ req } ;
$ reqc - > { node } = [ keys % localnodehash ] ;
if ( scalar ( @ { $ reqc - > { node } } ) ) { push @ requests , $ reqc }
foreach my $ dtarg ( keys % dispatchhash )
{ #iterate dispatch targets
my $ reqcopy = { %$ req } ; #deep copy
$ reqcopy - > { '_xcatdest' } = $ dtarg ;
$ reqcopy - > { node } = [ keys % { $ dispatchhash { $ dtarg } } ] ;
push @ requests , $ reqcopy ;
}
return \ @ requests ;
}
sub process_request
{
my $ request = shift ;
my $ callback = shift ;
my $ doreq = shift ;
my $ distname = undef ;
my $ arch = undef ;
my $ path = undef ;
if ( $ request - > { command } - > [ 0 ] eq 'copycd' )
{
return copycd ( $ request , $ callback , $ doreq ) ;
}
elsif ( $ request - > { command } - > [ 0 ] eq 'mkinstall' )
{
return mkinstall ( $ request , $ callback , $ doreq ) ;
}
elsif ( $ request - > { command } - > [ 0 ] eq 'mknetboot' or
$ request - > { command } - > [ 0 ] eq 'mkstatelite' )
{
return mknetboot ( $ request , $ callback , $ doreq ) ;
}
}
# Check whether the dracut is supported by this os
sub using_dracut
{
my $ os = shift ;
if ( $ os =~ /(rhels|rhel)(\d+)/ ) {
if ( $ 2 >= 6 ) {
return 1 ;
}
} elsif ( $ os =~ /fedora(\d+)/ ) {
if ( $ 1 >= 12 ) {
return 1 ;
}
} elsif ( $ os =~ /SL(\d+)/ ) {
if ( $ 1 >= 6 ) {
return 1 ;
}
}
return 0 ;
}
sub mknetboot
{
my $ xenstyle = 0 ;
my $ req = shift ;
my $ callback = shift ;
my $ doreq = shift ;
my $ statelite = 0 ;
if ( $ req - > { command } - > [ 0 ] =~ 'mkstatelite' ) {
$ statelite = "true" ;
}
2012-02-15 21:04:42 +00:00
my $ globaltftpdir = "/tftpboot" ;
2012-01-04 20:23:07 +00:00
my $ nodes = @ { $ req - > { node } } ;
2012-03-05 05:52:08 +00:00
my @ args = @ { $ req - > { arg } } if ( exists ( $ req - > { arg } ) ) ;
2012-01-04 20:23:07 +00:00
my @ nodes = @ { $ req - > { node } } ;
my $ ostab = xCAT::Table - > new ( 'nodetype' ) ;
2012-05-21 10:00:16 +00:00
#my $sitetab = xCAT::Table->new('site');
2012-01-04 20:23:07 +00:00
my $ linuximagetab ;
my $ osimagetab ;
my % img_hash = ( ) ;
my $ installroot ;
$ installroot = "/install" ;
my $ xcatdport = "3001" ;
2012-05-21 10:00:16 +00:00
#if ($sitetab)
#{
# (my $ref) = $sitetab->getAttribs({key => 'installdir'}, 'value');
my @ ents = xCAT::Utils - > get_site_attribute ( "installdir" ) ;
my $ site_ent = $ ents [ 0 ] ;
if ( defined ( $ site_ent ) )
2012-01-04 20:23:07 +00:00
{
2012-05-21 10:00:16 +00:00
$ installroot = $ site_ent ;
}
# ($ref) = $sitetab->getAttribs({key => 'xcatdport'}, 'value');
@ ents = xCAT::Utils - > get_site_attribute ( "installdir" ) ;
$ site_ent = $ ents [ 0 ] ;
if ( defined ( $ site_ent ) )
{
$ xcatdport = $ site_ent ;
}
# ($ref) = $sitetab->getAttribs({key => 'tftpdir'}, 'value');
@ ents = xCAT::Utils - > get_site_attribute ( "tftpdir" ) ;
$ site_ent = $ ents [ 0 ] ;
if ( defined ( $ site_ent ) )
{
$ globaltftpdir = $ site_ent ;
2012-01-04 20:23:07 +00:00
}
my % donetftp = ( ) ;
my % oents = % { $ ostab - > getNodesAttribs ( \ @ nodes , [ qw( os arch profile provmethod ) ] ) } ;
my $ restab = xCAT::Table - > new ( 'noderes' ) ;
my $ bptab = xCAT::Table - > new ( 'bootparams' , - create = > 1 ) ;
my $ hmtab = xCAT::Table - > new ( 'nodehm' ) ;
my $ mactab = xCAT::Table - > new ( 'mac' ) ;
my $ machash = $ mactab - > getNodesAttribs ( \ @ nodes , [ 'interface' , 'mac' ] ) ;
2012-02-15 21:04:42 +00:00
my $ reshash = $ restab - > getNodesAttribs ( \ @ nodes , [ 'primarynic' , 'tftpserver' , 'tftpdir' , 'xcatmaster' , 'nfsserver' , 'nfsdir' , 'installnic' ] ) ;
2012-01-04 20:23:07 +00:00
my $ hmhash =
$ hmtab - > getNodesAttribs ( \ @ nodes ,
[ 'serialport' , 'serialspeed' , 'serialflow' ] ) ;
my $ statetab ;
my $ stateHash ;
if ( $ statelite ) {
$ statetab = xCAT::Table - > new ( 'statelite' , - create = > 1 ) ;
$ stateHash = $ statetab - > getNodesAttribs ( \ @ nodes , [ 'statemnt' ] ) ;
}
#my $addkcmdhash =
# $bptab->getNodesAttribs(\@nodes, ['addkcmdline']);
foreach my $ node ( @ nodes )
{
my $ osver ;
my $ arch ;
my $ profile ;
my $ platform ;
my $ rootimgdir ;
my $ nodebootif ; # nodebootif will be used if noderes.installnic is not set
my $ dump ; # for kdump, its format is "nfs://<nfs_server_ip>/<kdump_path>"
my $ crashkernelsize ;
my $ rootfstype ;
2012-02-15 21:04:42 +00:00
my $ tftpdir ;
if ( $ reshash - > { $ node } - > [ 0 ] and $ reshash - > { $ node } - > [ 0 ] - > { tftpdir } ) {
$ tftpdir = $ reshash - > { $ node } - > [ 0 ] - > { tftpdir } ;
} else {
$ tftpdir = $ globaltftpdir ;
}
2012-01-04 20:23:07 +00:00
my $ ent = $ oents { $ node } - > [ 0 ] ; #ostab->getNodeAttribs($node, ['os', 'arch', 'profile']);
if ( $ ent and $ ent - > { provmethod } and ( $ ent - > { provmethod } ne 'install' ) and ( $ ent - > { provmethod } ne 'netboot' ) and ( $ ent - > { provmethod } ne 'statelite' ) ) {
my $ imagename = $ ent - > { provmethod } ;
#print "imagename=$imagename\n";
if ( ! exists ( $ img_hash { $ imagename } ) ) {
if ( ! $ osimagetab ) {
$ osimagetab = xCAT::Table - > new ( 'osimage' , - create = > 1 ) ;
}
( my $ ref ) = $ osimagetab - > getAttribs ( { imagename = > $ imagename } , 'osvers' , 'osarch' , 'profile' , 'provmethod' , 'rootfstype' ) ;
if ( $ ref ) {
$ img_hash { $ imagename } - > { osver } = $ ref - > { 'osvers' } ;
$ img_hash { $ imagename } - > { osarch } = $ ref - > { 'osarch' } ;
$ img_hash { $ imagename } - > { profile } = $ ref - > { 'profile' } ;
$ img_hash { $ imagename } - > { provmethod } = $ ref - > { 'provmethod' } ;
$ img_hash { $ imagename } - > { rootfstype } = $ ref - > { rootfstype } ;
if ( ! $ linuximagetab ) {
$ linuximagetab = xCAT::Table - > new ( 'linuximage' , - create = > 1 ) ;
}
( my $ ref1 ) = $ linuximagetab - > getAttribs ( { imagename = > $ imagename } , 'rootimgdir' , 'nodebootif' , 'dump' , 'crashkernelsize' ) ;
if ( ( $ ref1 ) && ( $ ref1 - > { 'rootimgdir' } ) ) {
$ img_hash { $ imagename } - > { rootimgdir } = $ ref1 - > { 'rootimgdir' } ;
}
if ( ( $ ref1 ) && ( $ ref1 - > { 'nodebootif' } ) ) {
$ img_hash { $ imagename } - > { nodebootif } = $ ref1 - > { 'nodebootif' } ;
}
if ( $ ref1 ) {
if ( $ ref1 - > { 'dump' } ) {
$ img_hash { $ imagename } - > { dump } = $ ref1 - > { 'dump' } ;
}
}
if ( ( $ ref1 ) && ( $ ref1 - > { 'crashkernelsize' } ) ) {
$ img_hash { $ imagename } - > { crashkernelsize } = $ ref1 - > { 'crashkernelsize' } ;
}
} else {
$ callback - > (
{ error = > [ "The os image $imagename does not exists on the osimage table for $node" ] ,
errorcode = > [ 1 ] } ) ;
next ;
}
}
my $ ph = $ img_hash { $ imagename } ;
$ osver = $ ph - > { osver } ;
$ arch = $ ph - > { osarch } ;
$ profile = $ ph - > { profile } ;
$ rootfstype = $ ph - > { rootfstype } ;
$ rootimgdir = $ ph - > { rootimgdir } ;
unless ( $ rootimgdir ) {
$ rootimgdir = "$installroot/netboot/$osver/$arch/$profile" ;
}
$ nodebootif = $ ph - > { nodebootif } ;
$ crashkernelsize = $ ph - > { crashkernelsize } ;
$ dump = $ ph - > { dump } ;
}
else {
$ osver = $ ent - > { os } ;
$ arch = $ ent - > { arch } ;
$ profile = $ ent - > { profile } ;
$ rootimgdir = "$installroot/netboot/$osver/$arch/$profile" ;
$ rootfstype = "nfs" ; # TODO: try to get it from the option or table
my $ imgname ;
if ( $ statelite ) {
$ imgname = "$osver-$arch-statelite-$profile" ;
} else {
$ imgname = "$osver-$arch-netboot-$profile" ;
}
if ( ! $ osimagetab ) {
$ osimagetab = xCAT::Table - > new ( 'osimage' ) ;
}
if ( $ osimagetab ) {
my ( $ ref1 ) = $ osimagetab - > getAttribs ( { imagename = > $ imgname } , 'rootfstype' ) ;
if ( ( $ ref1 ) && ( $ ref1 - > { 'rootfstype' } ) ) {
$ rootfstype = $ ref1 - > { 'rootfstype' } ;
}
} else {
$ callback - > (
2012-02-24 21:12:51 +00:00
{ error = > [ qq{ Cannot find the linux image called "$osver-$arch-$imgname-$profile", maybe you need to use the "nodeset <nr> osimage=<osimage name>" command to set the boot state } ] ,
2012-01-04 20:23:07 +00:00
errorcode = > [ 1 ] }
) ;
}
if ( ! $ linuximagetab ) {
$ linuximagetab = xCAT::Table - > new ( 'linuximage' ) ;
}
if ( $ linuximagetab ) {
( my $ ref1 ) = $ linuximagetab - > getAttribs ( { imagename = > $ imgname } , 'dump' , 'crashkernelsize' ) ;
if ( $ ref1 and $ ref1 - > { 'dump' } ) {
$ dump = $ ref1 - > { 'dump' } ;
}
if ( $ ref1 and $ ref1 - > { 'crashkernelsize' } ) {
$ crashkernelsize = $ ref1 - > { 'crashkernelsize' } ;
}
} else {
$ callback - > (
2012-02-24 21:12:51 +00:00
{ error = > [ qq{ Cannot find the linux image called "$osver-$arch-$imgname-$profile", maybe you need to use the "nodeset <nr> osimage=<your_image_name>" command to set the boot state } ] ,
2012-01-04 20:23:07 +00:00
errorcode = > [ 1 ] }
) ;
}
}
#print"osvr=$osver, arch=$arch, profile=$profile, imgdir=$rootimgdir\n";
unless ( $ osver and $ arch and $ profile )
{
$ callback - > (
{
error = > [ "Insufficient nodetype entry or osimage entry for $node" ] ,
errorcode = > [ 1 ]
}
) ;
next ;
}
$ platform = xCAT_plugin::anaconda:: getplatform ( $ osver ) ;
my $ suffix = 'gz' ;
$ suffix = 'sfs' if ( - r "$rootimgdir/rootimg.sfs" ) ;
# statelite images are not packed.
if ( $ statelite ) {
unless ( - r "$rootimgdir/kernel" ) {
$ callback - > ( {
error = > [ qq{ Did you run "genimage" before running "liteimg"? kernel cannot be found... } ] ,
errorcode = > [ 1 ]
} ) ;
next ;
}
if ( ! - r "$rootimgdir/initrd-statelite.gz" ) {
if ( ! - r "$rootimgdir/initrd.gz" ) {
$ callback - > ( {
error = > [ qq{ Did you run "genimage" before running "liteimg"? initrd.gz or initrd-statelite.gz cannot be found } ] ,
errorcode = > [ 1 ]
} ) ;
next ;
}
else {
copy ( "$rootimgdir/initrd.gz" , "$rootimgdir/initrd-statelite.gz" ) ;
}
}
if ( $ rootfstype eq "ramdisk" and ! - r "$rootimgdir/rootimg-statelite.gz" ) {
$ callback - > ( {
error = > [ qq{ No packed image for platform $osver, architecture $arch and profile $profile, please run "liteimg" to create it. } ] ,
errorcode = > [ 1 ]
} ) ;
next ;
}
} else {
unless ( - r "$rootimgdir/kernel" ) {
$ callback - > ( {
error = > [ qq{ Did you run "genimage" before running "packimage"? kernel cannot be found } ] ,
errorcode = > [ 1 ]
} ) ;
next ;
}
if ( ! - r "$rootimgdir/initrd-stateless.gz" ) {
if ( ! - r "$rootimgdir/initrd.gz" ) {
$ callback - > ( {
error = > [ qq{ Did you run "genimage" before running "packimage"? initrd.gz or initrd-stateless.gz cannot be found } ] ,
errorcode = > [ 1 ]
} ) ;
next ;
}
else {
copy ( "$rootimgdir/initrd.gz" , "$rootimgdir/initrd-stateless.gz" ) ;
}
}
unless ( - r "$rootimgdir/rootimg.gz" or - r "$rootimgdir/rootimg.sfs" ) {
$ callback - > ( {
error = > [ "No packed image for platform $osver, architecture $arch, and profile $profile, please run packimage (e.g. packimage -o $osver -p $profile -a $arch" ] ,
errorcode = > [ 1 ] } ) ;
next ;
}
}
# create the node-specific post scripts
#mkpath "/install/postscripts/";
#xCAT::Postage->writescript($node,"/install/postscripts/".$node, "netboot", $callback);
mkpath ( "/$tftpdir/xcat/netboot/$osver/$arch/$profile/" ) ;
#TODO: only copy if newer...
unless ( $ donetftp { $ osver , $ arch , $ profile } ) {
if ( - f "$rootimgdir/hypervisor" ) {
copy ( "$rootimgdir/hypervisor" , "/$tftpdir/xcat/netboot/$osver/$arch/$profile/" ) ;
$ xenstyle = 1 ;
}
copy ( "$rootimgdir/kernel" , "/$tftpdir/xcat/netboot/$osver/$arch/$profile/" ) ;
if ( $ statelite ) {
if ( $ rootfstype eq "ramdisk" ) {
copy ( "$rootimgdir/initrd-stateless.gz" , "/$tftpdir/xcat/netboot/$osver/$arch/$profile/" ) ;
} else {
copy ( "$rootimgdir/initrd-statelite.gz" , "/$tftpdir/xcat/netboot/$osver/$arch/$profile/" ) ;
}
} else {
copy ( "$rootimgdir/initrd-stateless.gz" , "/$tftpdir/xcat/netboot/$osver/$arch/$profile/" ) ;
}
$ donetftp { $ osver , $ arch , $ profile } = 1 ;
}
if ( $ statelite ) {
my $ initrdloc = "/$tftpdir/xcat/netboot/$osver/$arch/$profile/" ;
if ( $ rootfstype eq "ramdisk" ) {
$ initrdloc . = "initrd-stateless.gz" ;
} else {
$ initrdloc . = "initrd-statelite.gz" ;
}
unless ( - r "/$tftpdir/xcat/netboot/$osver/$arch/$profile/kernel"
and - r $ initrdloc ) {
$ callback - > ( {
error = > [ qq{ copying to /$tftpdir/xcat/netboot/$osver/$arch/$profile failed } ] ,
errorcode = > [ 1 ]
} ) ;
next ;
}
} else {
unless ( - r "/$tftpdir/xcat/netboot/$osver/$arch/$profile/kernel"
and - r "/$tftpdir/xcat/netboot/$osver/$arch/$profile/initrd-stateless.gz" ) {
$ callback - > ( {
error = > [ qq{ copying to /$tftpdir/xcat/netboot/$osver/$arch/$profile failed } ] ,
errorcode = > [ 1 ]
} ) ;
next ;
}
}
$ ent = $ reshash - > { $ node } - > [ 0 ] ; #$restab->getNodeAttribs($node, ['primarynic']);
my $ sent = $ hmhash - > { $ node } - > [ 0 ] ;
# $hmtab->getNodeAttribs($node,
# ['serialport', 'serialspeed', 'serialflow']);
# determine image server, if tftpserver use it, else use xcatmaster
# last resort use self
my $ imgsrv ;
my $ ient ;
my $ xcatmaster ;
$ ient = $ reshash - > { $ node } - > [ 0 ] ; #$restab->getNodeAttribs($node, ['tftpserver']);
if ( $ ient and $ ient - > { xcatmaster } )
{
$ xcatmaster = $ ient - > { xcatmaster } ;
} else {
$ xcatmaster = '!myipfn!' ; #allow service nodes to dynamically nominate themselves as a good contact point, this is of limited use in the event that xcat is not the dhcp/tftp server
}
if ( $ ient and $ ient - > { tftpserver } )
{
$ imgsrv = $ ient - > { tftpserver } ;
}
else
{
$ ient = $ reshash - > { $ node } - > [ 0 ] ; #$restab->getNodeAttribs($node, ['xcatmaster']);
#if ($ient and $ient->{xcatmaster})
#{
# $imgsrv = $ient->{xcatmaster};
#}
#else
#{
# master not correct for service node pools
#$ient = $sitetab->getAttribs({key => master}, value);
#if ($ient and $ient->{value})
#{
# $imgsrv = $ient->{value};
#}
#else
#{
# $imgsrv = '!myipfn!';
#}
#}
$ imgsrv = $ xcatmaster ;
}
unless ( $ imgsrv )
{
$ callback - > (
{
error = > [
"Unable to determine or reasonably guess the image server for $node"
] ,
errorcode = > [ 1 ]
}
) ;
next ;
}
my $ kcmdline ; # add two more arguments: XCAT=xcatmaster:xcatport and ifname=<eth0>:<mac address>
if ( $ statelite ) {
if ( $ rootfstype ne "ramdisk" ) {
# get entry for nfs root if it exists:
# have to get nfssvr and nfsdir from noderes table
my $ nfssrv = $ imgsrv ;
my $ nfsdir = $ rootimgdir ;
if ( $ ient - > { nfsserver } ) {
$ nfssrv = $ ient - > { nfsserver } ;
}
if ( $ ient - > { nfsdir } ne '' ) {
$ nfsdir = $ ient - > { nfsdir } . "/netboot/$osver/$arch/$profile" ;
#this code sez, "if nfsdir starts with //, then
#use a absolute path, i.e. do not append xCATisms"
#this is required for some statelite envs.
#still open for debate.
if ( $ ient - > { nfsdir } =~ m !^//! ) {
$ nfsdir = $ ient - > { nfsdir } ;
$ nfsdir =~ s!^/!! ;
}
}
# special case for redhat6, fedora12/13/14
if ( & using_dracut ( $ osver ) ) {
$ kcmdline = "root=nfs:$nfssrv:$nfsdir/rootimg:ro STATEMNT=" ;
} else {
$ kcmdline = "NFSROOT=$nfssrv:$nfsdir STATEMNT=" ;
}
} else {
$ kcmdline = "imgurl=http://$imgsrv/$rootimgdir/rootimg-statelite.gz STATEMNT=" ;
}
# add support for subVars in the value of "statemnt"
my $ statemnt = "" ;
if ( exists ( $ stateHash - > { $ node } ) ) {
$ statemnt = $ stateHash - > { $ node } - > [ 0 ] - > { statemnt } ;
if ( grep /\$/ , $ statemnt ) {
my ( $ server , $ dir ) = split ( /:/ , $ statemnt ) ;
#if server is blank, then its the directory
unless ( $ dir ) {
$ dir = $ server ;
$ server = '' ;
}
if ( grep /\$|#CMD/ , $ dir ) {
$ dir = xCAT::SvrUtils - > subVars ( $ dir , $ node , 'dir' , $ callback ) ;
$ dir =~ s/\/\//\//g ;
}
if ( $ server ) {
$ server = xCAT::SvrUtils - > subVars ( $ server , $ node , 'server' , $ callback ) ;
}
$ statemnt = $ server . ":" . $ dir ;
}
}
$ kcmdline . = $ statemnt . " " ;
$ kcmdline . =
"XCAT=$xcatmaster:$xcatdport " ;
if ( $ rootfstype ne "ramdisk" ) {
# BEGIN service node
my $ isSV = xCAT::Utils - > isServiceNode ( ) ;
my $ res = xCAT::Utils - > runcmd ( "hostname" , 0 ) ;
my $ sip = xCAT::NetworkUtils - > getipaddr ( $ res ) ; # this is the IP of service node
if ( $ isSV and ( ( $ xcatmaster eq $ sip ) or ( $ xcatmaster eq $ res ) ) ) {
# if the NFS directory in litetree is on the service node,
# and it is not exported, then it will be mounted automatically
xCAT::SvrUtils - > setupNFSTree ( $ node , $ sip , $ callback ) ;
# then, export the statemnt directory if it is on the service node
if ( $ statemnt ) {
xCAT::SvrUtils - > setupStatemnt ( $ sip , $ statemnt , $ callback ) ;
}
}
# END service node
}
}
else {
$ kcmdline =
"imgurl=http://$imgsrv/$rootimgdir/rootimg.$suffix " ;
$ kcmdline . = "XCAT=$xcatmaster:$xcatdport " ;
}
# add one parameter: ifname=<eth0>:<mac address>
# which is used for dracut
# the redhat5.x os will ignore it
my $ useifname = 0 ;
if ( $ reshash - > { $ node } - > [ 0 ] and $ reshash - > { $ node } - > [ 0 ] - > { installnic } and $ reshash - > { $ node } - > [ 0 ] - > { installnic } ne "mac" ) {
$ useifname = 1 ;
$ kcmdline . = "ifname=" . $ reshash - > { $ node } - > [ 0 ] - > { installnic } . ":" ;
} elsif ( $ nodebootif ) {
$ useifname = 1 ;
$ kcmdline . = "ifname=$nodebootif:" ;
} elsif ( $ reshash - > { $ node } - > [ 0 ] and $ reshash - > { $ node } - > [ 0 ] - > { primarynic } and $ reshash - > { $ node } - > [ 0 ] - > { primarynic } ne "mac" ) {
$ useifname = 1 ;
$ kcmdline . = "ifname=" . $ reshash - > { $ node } - > [ 0 ] - > { primarynic } . ":" ;
}
#else { #no, we autodetect and don't presume anything
# $kcmdline .="eth0:";
# print "eth0 is used as the default booting network devices...\n";
#}
# append the mac address
my $ mac ;
if ( $ useifname && $ machash - > { $ node } - > [ 0 ] && $ machash - > { $ node } - > [ 0 ] - > { 'mac' } ) {
# TODO: currently, only "mac" attribute with classic style is used, the "|" delimited string of "macaddress!hostname" format is not used
$ mac = $ machash - > { $ node } - > [ 0 ] - > { 'mac' } ;
# if ( (index($mac, "|") eq -1) and (index($mac, "!") eq -1) ) {
#convert to linux format
if ( $ mac !~ /:/ ) {
$ mac =~ s/(..)(..)(..)(..)(..)(..)/$1:$2:$3:$4:$5:$6/ ;
}
# } else {
# $callback->({ error=>[ qq{In the "mac" table, the "|" delimited string of "macaddress!hostname" format is not supported by "nodeset <nr> netboot|statelite if installnic/primarynic is set".}], errorcode=>[1]});
# return;
# }
}
if ( $ useifname && $ mac ) {
$ kcmdline . = "$mac " ;
}
# add "netdev=<eth0>" or "BOOTIF=<mac>"
# which are used for other scenarios
my $ netdev = "" ;
if ( $ reshash - > { $ node } - > [ 0 ] and $ reshash - > { $ node } - > [ 0 ] - > { installnic } and $ reshash - > { $ node } - > [ 0 ] - > { installnic } ne "mac" ) {
$ kcmdline . = "netdev=" . $ reshash - > { $ node } - > [ 0 ] - > { installnic } . " " ;
} elsif ( $ nodebootif ) {
$ kcmdline . = "netdev=" . $ nodebootif . " " ;
} elsif ( $ reshash - > { $ node } - > [ 0 ] and $ reshash - > { $ node } - > [ 0 ] - > { primarynic } and $ reshash - > { $ node } - > [ 0 ] - > { primarynic } ne "mac" ) {
$ kcmdline . = "netdev=" . $ reshash - > { $ node } - > [ 0 ] - > { primarynic } . " " ;
} else {
if ( $ useifname && $ mac ) {
$ kcmdline . = "BOOTIF=" . $ mac . " " ;
}
}
2012-02-14 03:01:42 +00:00
my % client_nethash = xCAT::DBobjUtils - > getNetwkInfo ( [ $ node ] ) ;
if ( $ client_nethash { $ node } { mgtifname } =~ /hf/ )
2012-01-04 20:23:07 +00:00
{
$ kcmdline . = "rdloaddriver=hf_if " ;
}
if ( defined $ sent - > { serialport } )
{
#my $sent = $hmtab->getNodeAttribs($node,['serialspeed','serialflow']);
unless ( $ sent - > { serialspeed } )
{
$ callback - > (
{
error = > [
"serialport defined, but no serialspeed for $node in nodehm table"
] ,
errorcode = > [ 1 ]
}
) ;
next ;
}
$ kcmdline . =
2012-01-25 20:26:07 +00:00
" console=tty0 console=ttyS" . $ sent - > { serialport } . "," . $ sent - > { serialspeed } ;
2012-01-04 20:23:07 +00:00
if ( $ sent - > { serialflow } =~ /(hard|tcs|ctsrts)/ )
{
$ kcmdline . = "n8r" ;
}
}
# turn off the selinux
if ( $ osver =~ m/fedora12/ || $ osver =~ m/fedora13/ ) {
$ kcmdline . = " selinux=0 " ;
}
# if kdump service is enbaled, add "crashkernel=" and "kdtarget="
if ( $ dump ) {
2012-05-18 08:17:05 +00:00
if ( $ crashkernelsize ) {
$ kcmdline . = " crashkernel=$crashkernelsize dump=$dump " ;
}
else {
if ( $ arch eq "ppc64" ) {
$ kcmdline . = " crashkernel=256M\@64M dump=$dump " ;
}
if ( $ arch =~ /86/ ) {
$ kcmdline . = " crashkernel=128M dump=$dump " ;
2012-01-04 20:23:07 +00:00
}
}
}
# add the addkcmdline attribute to the end
# of the command, if it exists
#my $addkcmd = $addkcmdhash->{$node}->[0];
# add the extra addkcmd command info, if in the table
#if ($addkcmd->{'addkcmdline'}) {
# $kcmdline .= " ";
# $kcmdline .= $addkcmd->{'addkcmdline'};
#}
my $ kernstr = "xcat/netboot/$osver/$arch/$profile/kernel" ;
if ( $ xenstyle ) {
$ kernstr . = "!xcat/netboot/$osver/$arch/$profile/hypervisor" ;
}
my $ initrdstr = "xcat/netboot/$osver/$arch/$profile/initrd-stateless.gz" ;
$ initrdstr = "xcat/netboot/$osver/$arch/$profile/initrd-statelite.gz" if ( $ statelite ) ;
# special case for the dracut-enabled OSes
if ( & using_dracut ( $ osver ) ) {
if ( $ statelite and $ rootfstype eq "ramdisk" ) {
$ initrdstr = "xcat/netboot/$osver/$arch/$profile/initrd-stateless.gz" ;
}
}
if ( $ statelite )
{
my $ statelitetb = xCAT::Table - > new ( 'statelite' ) ;
my $ mntopts = $ statelitetb - > getNodeAttribs ( $ node , [ 'mntopts' ] ) ;
my $ mntoptions = $ mntopts - > { 'mntopts' } ;
unless ( defined ( $ mntoptions ) )
{
$ kcmdline . = " MNTOPTS=" ;
}
else
{
$ kcmdline . = " MNTOPTS=$mntoptions" ;
}
}
$ bptab - > setNodeAttribs (
$ node ,
{
kernel = > $ kernstr ,
initrd = > $ initrdstr ,
kcmdline = > $ kcmdline
}
) ;
}
#my $rc = xCAT::Utils->create_postscripts_tar();
#if ( $rc != 0 ) {
# xCAT::MsgUtils->message( "S", "Error creating postscripts tar file." );
#}
}
sub mkinstall
{
my $ request = shift ;
my $ callback = shift ;
my $ doreq = shift ;
my @ nodes = @ { $ request - > { node } } ;
2012-05-21 10:00:16 +00:00
#my $sitetab = xCAT::Table->new('site');
2012-01-04 20:23:07 +00:00
my $ linuximagetab ;
my $ osimagetab ;
my % img_hash = ( ) ;
my $ installroot ;
2012-02-15 21:04:42 +00:00
my $ globaltftpdir ;
2012-01-04 20:23:07 +00:00
$ installroot = "/install" ;
2012-02-15 21:04:42 +00:00
$ globaltftpdir = "/tftpboot" ;
2012-01-04 20:23:07 +00:00
2012-05-21 10:00:16 +00:00
#if ($sitetab)
#{
# (my $ref) = $sitetab->getAttribs({key => 'installdir'}, 'value');
my @ ents = xCAT::Utils - > get_site_attribute ( "installdir" ) ;
my $ site_ent = $ ents [ 0 ] ;
if ( defined ( $ site_ent ) )
2012-01-04 20:23:07 +00:00
{
2012-05-21 10:00:16 +00:00
$ installroot = $ site_ent ;
2012-01-04 20:23:07 +00:00
}
2012-05-21 10:00:16 +00:00
#( $ref) = $sitetab->getAttribs({key => 'tftpdir'}, 'value');
@ ents = xCAT::Utils - > get_site_attribute ( "tftpdir" ) ;
$ site_ent = $ ents [ 0 ] ;
if ( defined ( $ site_ent ) )
{
$ globaltftpdir = $ site_ent ;
}
#}
2012-01-04 20:23:07 +00:00
my $ node ;
my $ ostab = xCAT::Table - > new ( 'nodetype' ) ;
my % doneimgs ;
my $ restab = xCAT::Table - > new ( 'noderes' ) ;
my $ bptab = xCAT::Table - > new ( 'bootparams' , - create = > 1 ) ;
my $ hmtab = xCAT::Table - > new ( 'nodehm' ) ;
my % osents = % { $ ostab - > getNodesAttribs ( \ @ nodes , [ 'profile' , 'os' , 'arch' , 'provmethod' ] ) } ;
my % rents =
% { $ restab - > getNodesAttribs ( \ @ nodes ,
2012-02-20 07:20:41 +00:00
[ 'xcatmaster' , 'nfsserver' , 'tftpdir' , 'primarynic' , 'installnic' ] ) } ;
2012-01-04 20:23:07 +00:00
my % hents =
% { $ hmtab - > getNodesAttribs ( \ @ nodes ,
[ 'serialport' , 'serialspeed' , 'serialflow' ] ) } ;
#my $addkcmdhash =
# $bptab->getNodesAttribs(\@nodes, ['addkcmdline']);
require xCAT::Template ;
foreach $ node ( @ nodes )
{
my $ os ;
2012-02-15 21:04:42 +00:00
my $ tftpdir ;
2012-01-04 20:23:07 +00:00
my $ arch ;
my $ profile ;
my $ tmplfile ;
my $ pkgdir ;
my $ pkglistfile ;
my $ imagename ;
my $ platform ;
2012-02-20 07:20:41 +00:00
my $ xcatmaster ;
2012-02-24 21:12:51 +00:00
my $ ient = $ rents { $ node } - > [ 0 ] ;
2012-02-20 07:20:41 +00:00
if ( $ ient and $ ient - > { xcatmaster } )
{
$ xcatmaster = $ ient - > { xcatmaster } ;
} else {
$ xcatmaster = '!myipfn!' ;
}
2012-01-04 20:23:07 +00:00
my $ osinst ;
2012-02-15 21:04:42 +00:00
if ( $ rents { $ node } - > [ 0 ] and $ rents { $ node } - > [ 0 ] - > { tftpdir } ) {
$ tftpdir = $ rents { $ node } - > [ 0 ] - > { tftpdir } ;
} else {
$ tftpdir = $ globaltftpdir ;
}
2012-01-04 20:23:07 +00:00
my $ ent = $ osents { $ node } - > [ 0 ] ; #$ostab->getNodeAttribs($node, ['profile', 'os', 'arch']);
if ( $ ent and $ ent - > { provmethod } and ( $ ent - > { provmethod } ne 'install' ) and ( $ ent - > { provmethod } ne 'netboot' ) and ( $ ent - > { provmethod } ne 'statelite' ) ) {
$ imagename = $ ent - > { provmethod } ;
#print "imagename=$imagename\n";
if ( ! exists ( $ img_hash { $ imagename } ) ) {
if ( ! $ osimagetab ) {
$ osimagetab = xCAT::Table - > new ( 'osimage' , - create = > 1 ) ;
}
( my $ ref ) = $ osimagetab - > getAttribs ( { imagename = > $ imagename } , 'osvers' , 'osarch' , 'profile' , 'provmethod' ) ;
if ( $ ref ) {
$ img_hash { $ imagename } - > { osver } = $ ref - > { 'osvers' } ;
$ img_hash { $ imagename } - > { osarch } = $ ref - > { 'osarch' } ;
$ img_hash { $ imagename } - > { profile } = $ ref - > { 'profile' } ;
$ img_hash { $ imagename } - > { provmethod } = $ ref - > { 'provmethod' } ;
if ( ! $ linuximagetab ) {
$ linuximagetab = xCAT::Table - > new ( 'linuximage' , - create = > 1 ) ;
}
( my $ ref1 ) = $ linuximagetab - > getAttribs ( { imagename = > $ imagename } , 'template' , 'pkgdir' , 'pkglist' ) ;
if ( $ ref1 ) {
if ( $ ref1 - > { 'template' } ) {
$ img_hash { $ imagename } - > { template } = $ ref1 - > { 'template' } ;
}
if ( $ ref1 - > { 'pkgdir' } ) {
$ img_hash { $ imagename } - > { pkgdir } = $ ref1 - > { 'pkgdir' } ;
}
if ( $ ref1 - > { 'pkglist' } ) {
$ img_hash { $ imagename } - > { pkglist } = $ ref1 - > { 'pkglist' } ;
}
}
# if the install template wasn't found, then lets look for it in the default locations.
unless ( $ img_hash { $ imagename } - > { template } ) {
my $ pltfrm = xCAT_plugin::anaconda:: getplatform ( $ ref - > { 'osvers' } ) ;
my $ tmplfile = xCAT::SvrUtils:: get_tmpl_file_name ( "$installroot/custom/install/$pltfrm" ,
$ ref - > { 'profile' } , $ ref - > { 'osvers' } , $ ref - > { 'osarch' } , $ ref - > { 'osvers' } ) ;
if ( ! $ tmplfile ) { $ tmplfile = xCAT::SvrUtils:: get_tmpl_file_name ( "$::XCATROOT/share/xcat/install/$pltfrm" ,
$ ref - > { 'profile' } , $ ref - > { 'osvers' } , $ ref - > { 'osarch' } , $ ref - > { 'osvers' } ) ;
}
# if we managed to find it, put it in the hash:
if ( $ tmplfile ) {
$ img_hash { $ imagename } - > { template } = $ tmplfile ;
}
}
#if the install pkglist wasn't found, then lets look for it in the default locations
unless ( $ img_hash { $ imagename } - > { pkglist } ) {
my $ pltfrm = xCAT_plugin::anaconda:: getplatform ( $ ref - > { 'osvers' } ) ;
my $ pkglistfile = xCAT::SvrUtils:: get_pkglist_file_name ( "$installroot/custom/install/$pltfrm" ,
$ ref - > { 'profile' } , $ ref - > { 'osvers' } , $ ref - > { 'osarch' } , $ ref - > { 'osvers' } ) ;
if ( ! $ pkglistfile ) { $ pkglistfile = xCAT::SvrUtils:: get_pkglist_file_name ( "$::XCATROOT/share/xcat/install/$pltfrm" ,
$ ref - > { 'profile' } , $ ref - > { 'osvers' } , $ ref - > { 'osarch' } , $ ref - > { 'osvers' } ) ;
}
# if we managed to find it, put it in the hash:
if ( $ pkglistfile ) {
$ img_hash { $ imagename } - > { pkglist } = $ pkglistfile ;
}
}
} else {
$ callback - > (
{ error = > [ "The os image $imagename does not exists on the osimage table for $node" ] ,
errorcode = > [ 1 ] } ) ;
next ;
}
}
my $ ph = $ img_hash { $ imagename } ;
$ os = $ ph - > { osver } ;
$ arch = $ ph - > { osarch } ;
$ profile = $ ph - > { profile } ;
$ platform = xCAT_plugin::anaconda:: getplatform ( $ os ) ;
$ tmplfile = $ ph - > { template } ;
$ pkgdir = $ ph - > { pkgdir } ;
if ( ! $ pkgdir ) {
$ pkgdir = "$installroot/$os/$arch" ;
}
$ pkglistfile = $ ph - > { pkglist } ;
}
else {
$ os = $ ent - > { os } ;
$ arch = $ ent - > { arch } ;
$ profile = $ ent - > { profile } ;
$ platform = xCAT_plugin::anaconda:: getplatform ( $ os ) ;
my $ genos = $ os ;
$ genos =~ s/\..*// ;
if ( $ genos =~ /rh.*(\d+)\z/ )
{
unless ( - r "$installroot/custom/install/$platform/$profile.$genos.$arch.tmpl"
or - r "/install/custom/install/$platform/$profile.$genos.tmpl"
or - r "$::XCATROOT/share/xcat/install/$platform/$profile.$genos.$arch.tmpl"
or - r "$::XCATROOT/share/xcat/install/$platform/$profile.$genos.tmpl" )
{
$ genos = "rhel$1" ;
}
}
$ tmplfile = xCAT::SvrUtils:: get_tmpl_file_name ( "$installroot/custom/install/$platform" , $ profile , $ os , $ arch , $ genos ) ;
if ( ! $ tmplfile ) { $ tmplfile = xCAT::SvrUtils:: get_tmpl_file_name ( "$::XCATROOT/share/xcat/install/$platform" , $ profile , $ os , $ arch , $ genos ) ; }
$ pkglistfile = xCAT::SvrUtils:: get_pkglist_file_name ( "$installroot/custom/install/$platform" , $ profile , $ os , $ arch , $ genos ) ;
if ( ! $ pkglistfile ) { $ pkglistfile = xCAT::SvrUtils:: get_pkglist_file_name ( "$::XCATROOT/share/xcat/install/$platform" , $ profile , $ os , $ arch , $ genos ) ; }
$ pkgdir = "$installroot/$os/$arch" ;
}
my @ missingparms ;
unless ( $ os ) {
if ( $ imagename ) { push @ missingparms , "osimage.osvers" ; }
else { push @ missingparms , "nodetype.os" ; }
}
unless ( $ arch ) {
if ( $ imagename ) { push @ missingparms , "osimage.osarch" ; }
else { push @ missingparms , "nodetype.arch" ; }
}
unless ( $ profile ) {
if ( $ imagename ) { push @ missingparms , "osimage.profile" ; }
else { push @ missingparms , "nodetype.profile" ; }
}
unless ( $ os and $ arch and $ profile )
{
$ callback - > (
{
error = > [ "Missing " . join ( ',' , @ missingparms ) . " for $node" ] ,
errorcode = > [ 1 ]
}
) ;
next ; #No profile
}
unless ( - r "$tmplfile" )
{
$ callback - > (
{
error = > [
"No $platform kickstart template exists for "
. $ profile
. " in directory $installroot/custom/install/$platform or $::XCATROOT/share/xcat/install/$platform"
] ,
errorcode = > [ 1 ]
}
) ;
next ;
}
#Call the Template class to do substitution to produce a kickstart file in the autoinst dir
my $ tmperr ;
if ( $ imagename ) {
$ tmperr = "Unable to find template file: $tmplfile" ;
} else {
$ tmperr = "Unable to find template in /install/custom/install/$platform or $::XCATROOT/share/xcat/install/$platform (for $profile/$os/$arch combination)" ;
}
if ( - r "$tmplfile" )
{
$ tmperr =
xCAT::Template - > subvars (
$ tmplfile ,
"/$installroot/autoinst/" . $ node ,
$ node ,
$ pkglistfile
) ;
}
if ( $ tmperr )
{
$ callback - > (
{
node = >
[ { name = > [ $ node ] , error = > [ $ tmperr ] , errorcode = > [ 1 ] } ]
}
) ;
next ;
}
#my $installdir="/install"; #TODO: not hardcode installdir
#my $tftpdir = "/tftpboot";
# create the node-specific post scripts
#mkpath "/install/postscripts/";
#xCAT::Postage->writescript($node,"/install/postscripts/".$node, "install", $callback);
my $ kernpath ;
my $ initrdpath ;
my $ maxmem ;
my $ esxi = 0 ;
if (
(
$ arch =~ /x86/ and
(
- r "$pkgdir/images/pxeboot/vmlinuz"
and $ kernpath = "$pkgdir/images/pxeboot/vmlinuz"
and - r "$pkgdir/images/pxeboot/initrd.img"
and $ initrdpath = "$pkgdir/images/pxeboot/initrd.img"
) or ( #Handle the case seen in VMWare 4.0 ESX media
#In VMWare 4.0 they dropped the pxe-optimized initrd
#leaving us no recourse but the rather large optical disk
#initrd, but perhaps we can mitigate with gPXE
- d "$pkgdir/VMware"
and - r "$pkgdir/isolinux/vmlinuz"
and $ kernpath = "$pkgdir/isolinux/vmlinuz"
and - r "$pkgdir/isolinux/initrd.img"
and $ initrdpath = "$pkgdir/isolinux/initrd.img"
and $ maxmem = "512M" #Have to give up linux room to make room for vmware hypervisor evidently
) or ( #Handle the case seen in VMware ESXi 4.1 media scripted installs.
- r "$pkgdir/mboot.c32"
and - r "$pkgdir/vmkboot.gz"
and - r "$pkgdir/vmkernel.gz"
and - r "$pkgdir/sys.vgz"
and - r "$pkgdir/cim.vgz"
and - r "$pkgdir/ienviron.vgz"
and - r "$pkgdir/install.vgz"
and $ esxi = 'true'
)
) or ( $ arch =~ /ppc/
and - r "$pkgdir/ppc/ppc64/vmlinuz"
and $ kernpath = "$pkgdir/ppc/ppc64/vmlinuz"
and ( ( - r "$pkgdir/ppc/ppc64/ramdisk.image.gz"
and $ initrdpath = "$pkgdir/ppc/ppc64/ramdisk.image.gz" )
or ( - r "$pkgdir/ppc/ppc64/initrd.img"
and $ initrdpath = "$pkgdir/ppc/ppc64/initrd.img" ) ) )
)
{
#TODO: driver slipstream, targetted for network.
unless ( $ doneimgs { "$os|$arch" } )
{
mkpath ( "$tftpdir/xcat/$os/$arch" ) ;
if ( $ esxi ) {
copyesxiboot ( $ pkgdir , "$tftpdir/xcat/$os/$arch" ) ;
} else {
copy ( $ kernpath , "$tftpdir/xcat/$os/$arch" ) ;
copy ( $ initrdpath , "$tftpdir/xcat/$os/$arch/initrd.img" ) ;
& insert_dd ( $ callback , $ os , $ arch , "$tftpdir/xcat/$os/$arch/initrd.img" ) ;
}
$ doneimgs { "$os|$arch" } = 1 ;
}
#We have a shot...
my $ ent = $ rents { $ node } - > [ 0 ] ;
# $restab->getNodeAttribs($node,
# ['nfsserver', 'primarynic', 'installnic']);
my $ sent = $ hents { $ node } - > [ 0 ] ;
# $hmtab->getNodeAttribs(
# $node,
# [
# 'serialport', 'serialspeed', 'serialflow'
# ]
# );
2012-02-20 07:20:41 +00:00
my $ instserver = $ xcatmaster ;
2012-01-04 20:23:07 +00:00
if ( $ ent and $ ent - > { nfsserver } ) {
$ instserver = $ ent - > { nfsserver } ;
}
my $ kcmdline =
"quiet repo=http://$instserver/install/$os/$arch/ ks=http://"
. $ instserver
. "/install/autoinst/"
. $ node ;
if ( $ maxmem ) {
$ kcmdline . = " mem=$maxmem" ;
}
my $ ksdev = "" ;
if ( $ ent - > { installnic } )
{
if ( $ ent - > { installnic } eq "mac" )
{
my $ mactab = xCAT::Table - > new ( "mac" ) ;
my $ macref = $ mactab - > getNodeAttribs ( $ node , [ 'mac' ] ) ;
$ ksdev = $ macref - > { mac } ;
}
else
{
$ ksdev = $ ent - > { installnic } ;
}
}
elsif ( $ ent - > { primarynic } )
{
if ( $ ent - > { primarynic } eq "mac" )
{
my $ mactab = xCAT::Table - > new ( "mac" ) ;
my $ macref = $ mactab - > getNodeAttribs ( $ node , [ 'mac' ] ) ;
$ ksdev = $ macref - > { mac } ;
}
else
{
$ ksdev = $ ent - > { primarynic } ;
}
}
else
{
$ ksdev = "bootif" ; #if not specified, fall back to bootif
}
if ( $ ksdev eq "" )
{
$ callback - > (
{
error = > [ "No MAC address defined for " . $ node ] ,
errorcode = > [ 1 ]
}
) ;
}
if ( $ esxi ) {
$ ksdev =~ s/eth/vmnic/g ;
}
$ kcmdline . = " ksdevice=" . $ ksdev ;
#TODO: dd=<url> for driver disks
if ( defined ( $ sent - > { serialport } ) )
{
unless ( $ sent - > { serialspeed } )
{
$ callback - > (
{
error = > [
"serialport defined, but no serialspeed for $node in nodehm table"
] ,
errorcode = > [ 1 ]
}
) ;
next ;
}
#go cmdline if serial console is requested, the shiny ansi is just impractical
$ kcmdline . =
2012-01-25 20:26:07 +00:00
" cmdline console=tty0 console=ttyS"
2012-01-04 20:23:07 +00:00
. $ sent - > { serialport } . ","
. $ sent - > { serialspeed } ;
if ( $ sent - > { serialflow } =~ /(hard|cts|ctsrts)/ )
{
$ kcmdline . = "n8r" ;
}
}
#$kcmdline .= " noipv6";
# add the addkcmdline attribute to the end
# of the command, if it exists
#my $addkcmd = $addkcmdhash->{$node}->[0];
# add the extra addkcmd command info, if in the table
#if ($addkcmd->{'addkcmdline'}) {
# $kcmdline .= " ";
# $kcmdline .= $addkcmd->{'addkcmdline'};
#}
my $ k ;
my $ i ;
if ( $ esxi ) {
$ k = "xcat/$os/$arch/mboot.c32" ;
$ i = "" ;
my @ addfiles = qw( vmkernel.gz sys.vgz cim.vgz ienviron.vgz install.vgz mod.tgz ) ;
$ kcmdline = "xcat/$os/$arch/vmkboot.gz " . $ kcmdline ;
foreach ( @ addfiles ) {
$ kcmdline . = " --- xcat/$os/$arch/$_" ;
}
} else {
$ k = "xcat/$os/$arch/vmlinuz" ;
$ i = "xcat/$os/$arch/initrd.img" ;
}
$ bptab - > setNodeAttribs (
$ node ,
{
kernel = > $ k ,
initrd = > $ i ,
kcmdline = > $ kcmdline
}
) ;
}
else
{
$ callback - > (
{
error = > [ "Install image not found in $installroot/$os/$arch" ] ,
errorcode = > [ 1 ]
}
) ;
}
}
#my $rc = xCAT::Utils->create_postscripts_tar();
#if ($rc != 0)
#{
# xCAT::MsgUtils->message("S", "Error creating postscripts tar file.");
#}
}
sub copycd
{
my $ request = shift ;
my $ callback = shift ;
my $ doreq = shift ;
my $ installroot = "/install" ;
my $ sitetab = xCAT::Table - > new ( 'site' ) ;
2012-01-13 09:38:47 +00:00
require xCAT::data::discinfo ;
2012-05-21 10:00:16 +00:00
#if ($sitetab)
#{
# (my $ref) = $sitetab->getAttribs({key => 'installdir'}, 'value');
my @ ents = xCAT::Utils - > get_site_attribute ( "installdir" ) ;
my $ site_ent = $ ents [ 0 ] ;
if ( defined ( $ site_ent ) )
2012-01-04 20:23:07 +00:00
{
2012-05-21 10:00:16 +00:00
$ installroot = $ site_ent ;
2012-01-04 20:23:07 +00:00
}
my $ distname ;
my $ arch ;
my $ path ;
@ ARGV = @ { $ request - > { arg } } ;
GetOptions (
'n=s' = > \ $ distname ,
'a=s' = > \ $ arch ,
'p=s' = > \ $ path
) ;
unless ( $ path )
{
#this plugin needs $path...
return ;
}
if ( $ distname
and $ distname !~ /^centos/
and $ distname !~ /^fedora/
and $ distname !~ /^SL/
and $ distname !~ /^rh/ )
{
#If they say to call it something unidentifiable, give up?
return ;
}
unless ( - r $ path . "/.discinfo" )
{
return ;
}
my $ dinfo ;
open ( $ dinfo , $ path . "/.discinfo" ) ;
my $ did = <$dinfo> ;
chomp ( $ did ) ;
my $ desc = <$dinfo> ;
chomp ( $ desc ) ;
my $ darch = <$dinfo> ;
chomp ( $ darch ) ;
if ( $ darch and $ darch =~ /i.86/ )
{
$ darch = "x86" ;
}
close ( $ dinfo ) ;
2012-01-13 09:38:47 +00:00
if ( $ xCAT:: data:: discinfo:: distnames { $ did } )
2012-01-04 20:23:07 +00:00
{
unless ( $ distname )
{
2012-01-13 09:38:47 +00:00
$ distname = $ xCAT:: data:: discinfo:: distnames { $ did } ;
2012-01-04 20:23:07 +00:00
}
}
elsif ( $ desc =~ /^Final$/ )
{
unless ( $ distname )
{
$ distname = "centos5" ;
}
}
elsif ( $ desc =~ /^Fedora 8$/ )
{
unless ( $ distname )
{
$ distname = "fedora8" ;
}
}
elsif ( $ desc =~ /^CentOS-4 .*/ )
{
unless ( $ distname )
{
$ distname = "centos4" ;
}
}
elsif ( $ desc =~ /^Red Hat Enterprise Linux Client 5$/ )
{
unless ( $ distname )
{
$ distname = "rhelc5" ;
}
}
elsif ( $ desc =~ /^Red Hat Enterprise Linux Server 5$/ )
{
unless ( $ distname )
{
$ distname = "rhels5" ;
}
}
elsif ( $ desc =~ /^LTS$/ )
{
unless ( $ distname )
{
$ distname = "SL5" ;
}
}
unless ( $ distname )
{
return ; #Do nothing, not ours..
}
if ( $ darch )
{
unless ( $ arch )
{
$ arch = $ darch ;
}
if ( $ arch and $ arch ne $ darch )
{
$ callback - > (
{
error = >
"Requested distribution architecture $arch, but media is $darch"
}
) ;
return ;
}
if ( $ arch =~ /ppc/ ) { $ arch = "ppc64" }
}
% { $ request } = ( ) ; #clear request we've got it.
$ callback - > ( { data = > "Copying media to $installroot/$distname/$arch/" } ) ;
my $ omask = umask 0022 ;
mkpath ( "$installroot/$distname/$arch" ) ;
umask $ omask ;
my $ rc ;
my $ reaped = 0 ;
$ SIG { INT } = $ SIG { TERM } = sub {
foreach ( @ cpiopid ) {
kill 2 , $ _ ;
}
if ( $ ::CDMOUNTPATH ) {
chdir ( "/" ) ;
system ( "umount $::CDMOUNTPATH" ) ;
}
} ;
my $ KID ;
chdir $ path ;
my $ numFiles = `find . -print | wc -l` ;
my $ child = open ( $ KID , "|-" ) ;
unless ( defined $ child )
{
$ callback - > ( { error = > "Media copy operation fork failure" } ) ;
return ;
}
if ( $ child )
{
push @ cpiopid , $ child ;
my @ finddata = `find .` ;
for ( @ finddata )
{
print $ KID $ _ ;
}
close ( $ KID ) ;
$ rc = $? ;
}
else
{
nice 10 ;
my $ c = "nice -n 20 cpio -vdump $installroot/$distname/$arch" ;
my $ k2 = open ( PIPE , "$c 2>&1 |" ) ||
$ callback - > ( { error = > "Media copy operation fork failure" } ) ;
push @ cpiopid , $ k2 ;
my $ copied = 0 ;
my ( $ percent , $ fout ) ;
while ( <PIPE> ) {
next if /^cpio:/ ;
$ percent = $ copied / $ numFiles ;
$ fout = sprintf "%0.2f%%" , $ percent * 100 ;
$ callback - > ( { sinfo = > "$fout" } ) ;
+ + $ copied ;
}
exit ;
}
#my $rc = system("cd $path; find . | nice -n 20 cpio -dump $installroot/$distname/$arch");
#my $rc = system("cd $path;rsync -a . $installroot/$distname/$arch/");
chmod 0755 , "$installroot/$distname/$arch" ;
require xCAT::Yum ;
xCAT::Yum - > localize_yumrepo ( $ installroot , $ distname , $ arch ) ;
if ( $ rc != 0 )
{
$ callback - > ( { error = > "Media copy operation failed, status $rc" } ) ;
}
else
{
$ callback - > ( { data = > "Media copy operation successful" } ) ;
my @ ret = xCAT::SvrUtils - > update_tables_with_templates ( $ distname , $ arch ) ;
if ( $ ret [ 0 ] != 0 ) {
$ callback - > ( { data = > "Error when updating the osimage tables: " . $ ret [ 1 ] } ) ;
}
my @ ret = xCAT::SvrUtils - > update_tables_with_diskless_image ( $ distname , $ arch , undef , "netboot" ) ;
if ( $ ret [ 0 ] != 0 ) {
$ callback - > ( { data = > "Error when updating the osimage tables for stateless: " . $ ret [ 1 ] } ) ;
}
my @ ret = xCAT::SvrUtils - > update_tables_with_diskless_image ( $ distname , $ arch , undef , "statelite" ) ;
if ( $ ret [ 0 ] != 0 ) {
$ callback - > ( { data = > "Error when updating the osimage tables for statelite: " . $ ret [ 1 ] } ) ;
}
}
}
sub getplatform {
my $ os = shift ;
my $ platform ;
if ( $ os =~ /rh.*/ )
{
$ platform = "rh" ;
}
elsif ( $ os =~ /centos.*/ )
{
$ platform = "centos" ;
}
elsif ( $ os =~ /fedora.*/ )
{
$ platform = "fedora" ;
}
elsif ( $ os =~ /esx.*/ )
{
$ platform = "esx" ;
}
elsif ( $ os =~ /SL.*/ )
{
$ platform = "SL" ;
}
return $ platform ;
}
sub copyesxiboot {
my $ srcdir = shift ;
my $ targetdir = shift ;
# this just does the same thing that the stateless version does.
unless ( - f "$targetdir/mod.tgz" ) {
xCAT_plugin::esx:: makecustomizedmod ( 'esxi' , $ targetdir ) ;
}
my @ files = qw( mboot.c32 vmkboot.gz vmkernel.gz sys.vgz cim.vgz ienviron.vgz install.vgz ) ;
foreach my $ f ( @ files ) {
copy ( "$srcdir/$f" , "$targetdir" ) ;
}
}
# Get the driver update disk from /install/driverdisk/<os>/<arch>
# Take out the drivers from driver update disk and insert them
# into the initrd
sub insert_dd {
my $ callback = shift ;
my $ os = shift ;
my $ arch = shift ;
my $ img = shift ;
my $ install_dir = xCAT::Utils - > getInstallDir ( ) ;
# Find out the dirver disk which need to be inserted into initrd
if ( ! - d "$install_dir/driverdisk/$os/$arch" ) {
return ( ) ;
}
my $ cmd = "find $install_dir/driverdisk/$os/$arch -type f" ;
my @ dd_list = xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
chomp ( @ dd_list ) ;
if ( ! @ dd_list ) {
return ( ) ;
}
# Create the tmp dir for dd hack
my $ dd_dir = mkdtemp ( "/tmp/ddtmpXXXXXXX" ) ;
2012-02-24 21:12:51 +00:00
if ( <$install_dir/$os/$arch/Packages/dracut*> ) { #new style, skip the fanagling, copy over the dds and append them...
2012-02-25 15:12:12 +00:00
mkpath ( "$dd_dir/dd" ) ;
2012-02-24 21:12:51 +00:00
if ( scalar ( @ dd_list ) == 1 ) { #only one, just append it..
copy ( $ dd_list [ 0 ] , "$dd_dir/dd/dd.img" ) ;
2012-02-25 15:12:12 +00:00
} elsif ( scalar ( @ dd_list ) > 1 ) {
unless ( - x "/usr/bin/createrepo" and - x "/usr/bin/mkisofs" ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Merging multiple driver disks requires createrepo and mkisofs utilities" ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
return undef ;
}
mkpath ( "$dd_dir/newddimg" ) ;
mkpath ( "$dd_dir/tmpddmnt" ) ;
foreach my $ dd ( @ dd_list ) {
xCAT::Utils - > runcmd ( "mount -o loop $dd $dd_dir/tmpddmnt" , - 1 ) ;
xCAT::Utils - > runcmd ( "cp -a $dd_dir/tmpddmnt/* $dd_dir/newddimg" , - 1 ) ;
xCAT::Utils - > runcmd ( "umount $dd_dir/tmpddmnt" , - 1 ) ;
}
foreach my $ repodir ( <$dd_dir/newddimg/*/*/repodata> ) {
$ repodir =~ s/\/repodata\z// ;
xCAT::Utils - > runcmd ( "createrepo $repodir" , - 1 ) ;
}
chdir ( "$dd_dir/newddimg" ) ;
xCAT::Utils - > runcmd ( "mkisofs -J -R -o $dd_dir/dd/dd.img ." , - 1 ) ;
} else { #there should be no else...
die "This should never occur" ;
}
2012-02-24 21:12:51 +00:00
chdir ( $ dd_dir . "/dd" ) ;
$ cmd = "find .|cpio -H newc -o|gzip -9 -c - > ../dd.gz" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
unless ( - f "../dd.gz" ) {
die "Error attempting to archive driver disk" ;
}
my $ ddhdl ;
my $ inithdl ;
open ( $ inithdl , ">>" , $ img ) ;
open ( $ ddhdl , "<" , "../dd.gz" ) ;
binmode ( $ ddhdl ) ;
binmode ( $ inithdl ) ;
{
local $/ = \ 32768 ;
while ( my $ block = <$ddhdl> ) { print $ inithdl $ block ; }
}
2012-02-25 15:12:12 +00:00
chdir ( "/" ) ;
xCAT::Utils - > runcmd ( "rm -rf $dd_dir" ) ;
2012-02-25 17:48:18 +00:00
my $ rsp ;
push @ { $ rsp - > { data } } , "Inserted the driver update disk:" . join ( ',' , @ dd_list ) . "." ;
xCAT::MsgUtils - > message ( "I" , $ rsp , $ callback ) ;
return @ dd_list ;
2012-02-24 21:12:51 +00:00
return ;
}
2012-01-04 20:23:07 +00:00
mkpath "$dd_dir/initrd_img" ; # The dir for the new initrd
# unzip the initrd image
$ cmd = "gunzip -c $img > $dd_dir/initrd" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not gunzip the initial initrd." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
return undef ;
}
# Extract the files from original initrd
$ cmd = "cd $dd_dir/initrd_img; cpio -id --quiet < ../initrd" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not extract files from the initial initrd." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
return undef ;
}
# Create directory for the driver modules hack
mkpath "$dd_dir/modules" ;
my @ inserted_dd = ( ) ;
my @ dd_drivers = ( ) ;
# The rh6 has different initrd format with old version (rh 5.x)
# The new format of initrd is made by dracut, it has the /lib/modules/<kernel>
# directory like the root image
# If the os has dracut rpm packet, then copy the drivers to the /lib/modules/<kernel>
# and recreate the dependency by the depmod command
$ cmd = "find $install_dir/$os/$arch/ | grep dracut" ;
my @ dracut = xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( grep ( /dracut-.*\.rpm/ , @ dracut ) ) { #dracut mode, for rh6, fedora13 ...
#copy the firmware into the initrd
if ( - d "$dd_dir/mnt/firmware" ) {
$ cmd = "cp -rf $dd_dir/mnt/firmware/* $dd_dir/initrd_img/lib/firmware" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
}
# Figure out the kernel version of the initrd
my $ kernelver ;
opendir ( KERNEL , "$dd_dir/initrd_img/lib/modules" ) ;
while ( $ kernelver = readdir ( KERNEL ) ) {
if ( $ kernelver =~ /^\./ || $ kernelver !~ /^\d/ ) {
$ kernelver = "" ;
next ;
}
if ( - d "$dd_dir/initrd_img/lib/modules/$kernelver" ) {
last ;
}
$ kernelver = "" ;
}
# The initrd has problem
if ( $ kernelver eq "" ) {
return ( ) ;
}
# Copy the drivers to the lib/modules/<$kernelver>/
if ( ! - d "$dd_dir/initrd_img/lib/modules/$kernelver/kernel/drivers/driverdisk" ) {
mkpath "$dd_dir/initrd_img/lib/modules/$kernelver/kernel/drivers/driverdisk" ;
}
foreach my $ dd ( @ dd_list ) {
mkpath "$dd_dir/mnt" ;
mkpath "$dd_dir/dd_modules" ;
$ cmd = "mount -o loop $dd $dd_dir/mnt" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not mount the driver update disk." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
return undef ;
}
$ cmd = "cd $dd_dir/dd_modules; gunzip -c $dd_dir/mnt/modules.cgz | cpio -id" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not gunzip the modules.cgz from the driver update disk." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
system ( "umount -f $dd_dir/mnt" ) ;
return undef ;
}
# Get all the drivers which belong to $kernelver/$arch
$ cmd = "find $dd_dir/dd_modules/$kernelver/$arch/ -type f" ;
my @ drivers = xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
foreach my $ d ( @ drivers ) {
chomp ( $ d ) ;
# The drivers in the initrd is in zip format
$ cmd = "gzip $d" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
$ d . = ".gz" ;
my $ driver_name = $ d ;
$ driver_name =~ s/.*\/// ;
# If the driver file existed, then over write
$ cmd = "find $dd_dir/initrd_img/lib/modules/$kernelver -type f -name $driver_name" ;
my @ exist_file = xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( ! @ exist_file ) {
$ cmd = "cp $d $dd_dir/initrd_img/lib/modules/$kernelver/kernel/drivers/driverdisk" ;
} else {
$ cmd = "cp $d $exist_file[0]" ;
}
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
}
$ cmd = "umount -f $dd_dir/mnt" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not unmount the driver update disk." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
system ( "umount -f $dd_dir/mnt" ) ;
return undef ;
}
# Clean the env
rmtree "$dd_dir/mnt" ;
rmtree "$dd_dir/dd_modules" ;
push @ inserted_dd , $ dd ;
}
# Generate the dependency relationship
$ cmd = "chroot $dd_dir/initrd_img/ depmod $kernelver" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
} else {
# Extract files from the modules.cgz of initrd
$ cmd = "cd $dd_dir/modules; gunzip -c $dd_dir/initrd_img/modules/modules.cgz | cpio -id" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not gunzip modules.cgz from the initial initrd." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
return undef ;
}
my @ modinfo = ( ) ;
foreach my $ dd ( @ dd_list ) {
mkpath "$dd_dir/mnt" ;
mkpath "$dd_dir/dd_modules" ;
$ cmd = "mount -o loop $dd $dd_dir/mnt" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not mount the driver update disk." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
return undef ;
}
$ cmd = "cd $dd_dir/dd_modules; gunzip -c $dd_dir/mnt/modules.cgz | cpio -id" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not gunzip the modules.cgz from the driver update disk." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
system ( "umount -f $dd_dir/mnt" ) ;
return undef ;
}
# Copy all the driver files out
$ cmd = "cp -rf $dd_dir/dd_modules/* $dd_dir/modules" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
# Copy the firmware into the initrd
mkpath "$dd_dir/initrd_img/firmware" ;
$ cmd = "cp -rf $dd_dir/dd_modules/firmware/* $dd_dir/initrd_img/firmware" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
# Get the entries from modinfo
open ( DDMODINFO , "<" , "$dd_dir/mnt/modinfo" ) ;
while ( <DDMODINFO> ) {
if ( $ _ =~ /^Version/ ) { next ; }
if ( $ _ =~ /^(\S*)/ ) {
push @ dd_drivers , $ 1 ;
}
push @ modinfo , $ _ ;
}
close ( DDMODINFO ) ;
# Append the modules.alias
$ cmd = "cat $dd_dir/mnt/modules.alias >> $dd_dir/initrd_img/modules/modules.alias" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
# Append the modules.dep
$ cmd = "cat $dd_dir/mnt/modules.dep >> $dd_dir/initrd_img/modules/modules.dep" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
# Append the pcitable
$ cmd = "cat $dd_dir/mnt/pcitable >> $dd_dir/initrd_img/modules/pcitable" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
$ cmd = "umount -f $dd_dir/mnt" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not unmount the driver update disk." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
system ( "umount -f $dd_dir/mnt" ) ;
return undef ;
}
# Clean the env
rmtree "$dd_dir/mnt" ;
rmtree "$dd_dir/dd_modules" ;
push @ inserted_dd , $ dd ;
}
# Append the modinfo into the module-info
open ( MODINFO , "<" , "$dd_dir/initrd_img/modules/module-info" ) ;
open ( MODINFONEW , ">" , "$dd_dir/initrd_img/modules/module-info.new" ) ;
my $ removeflag = 0 ;
while ( <MODINFO> ) {
my $ line = $ _ ;
if ( $ line =~ /^(\S+)/ ) {
if ( grep /$1/ , @ dd_drivers ) {
$ removeflag = 1 ;
next ;
} else {
$ removeflag = 0 ;
}
}
if ( $ removeflag == 1 ) { next ; }
print MODINFONEW $ line ;
}
print MODINFONEW @ modinfo ;
close ( MODINFONEW ) ;
close ( MODINFO ) ;
move ( "$dd_dir/initrd_img/modules/module-info.new" , "$dd_dir/initrd_img/modules/module-info" ) ;
# Repack the modules
$ cmd = "cd $dd_dir/modules; find . -print | cpio -o -H crc | gzip -9 > $dd_dir/initrd_img/modules/modules.cgz" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not pack the hacked modules.cgz." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
return undef ;
}
} # End of non dracut
# Repack the initrd
$ cmd = "cd $dd_dir/initrd_img; find .|cpio -H newc -o|gzip -9 -c - > $dd_dir/initrd.img" ;
xCAT::Utils - > runcmd ( $ cmd , - 1 ) ;
if ( $ ::RUNCMD_RC != 0 ) {
my $ rsp ;
push @ { $ rsp - > { data } } , "Handle the driver update disk failed. Could not pack the hacked initrd." ;
xCAT::MsgUtils - > message ( "E" , $ rsp , $ callback ) ;
return undef ;
}
copy ( "$dd_dir/initrd.img" , $ img ) ;
rmtree $ dd_dir ;
my $ rsp ;
push @ { $ rsp - > { data } } , "Inserted the driver update disk:" . join ( ',' , @ inserted_dd ) . "." ;
xCAT::MsgUtils - > message ( "I" , $ rsp , $ callback ) ;
return @ inserted_dd ;
}
1 ;
