# IBM(c) 2007 EPL license http://www.eclipse.org/legal/epl-v10.html package xCAT_plugin::windows; use strict; BEGIN { $::XCATROOT = $ENV{'XCATROOT'} ? $ENV{'XCATROOT'} : '/opt/xcat'; } use lib "$::XCATROOT/lib/perl"; use Storable qw(dclone); use Sys::Syslog; use File::Temp qw/tempdir/; use xCAT::Table; use xCAT::Utils; use xCAT::TableUtils; use xCAT::SvrUtils; use File::stat; use Socket; use xCAT::MsgUtils; use Data::Dumper; use Getopt::Long; my $globaltftpdir = "/tftpboot"; Getopt::Long::Configure("bundling"); Getopt::Long::Configure("pass_through"); use File::Path; use File::Copy; my @cpiopid; sub handled_commands { return { copycd => "windows", mkinstall => "nodetype:os=(hyperv.*|win.*|imagex)", mkwinshell => "windows", mkimage => "nodetype:os=imagex", }; } sub process_request { my $request = shift; my $callback = shift; my $doreq = shift; my $distname = undef; my $arch = undef; my $path = undef; my $installroot; $installroot = xCAT::TableUtils->getInstallDir(); my $tftpdir = xCAT::TableUtils->get_site_attribute("tftpdir"); if ($tftpdir) { $globaltftpdir = $tftpdir; } if ($request->{command}->[0] eq 'copycd') { return copycd($request, $callback, $doreq); } elsif ($request->{command}->[0] eq 'mkwinshell') { return winshell($request,$callback,$doreq); } elsif ($request->{command}->[0] eq 'mkinstall') { return mkinstall($request, $callback, $doreq); } elsif ($request->{command}->[0] eq 'mkimage') { return mkimage($request, $callback, $doreq); } } sub mkimage { #NOTES ON IMAGING: #-System must be sysprepped before capture, with /generalize #-EMS settings appear to be lost in the process #-If going to /audit, it's more useful than /oobe. # audit complains about incorrect password on first boot, without any login attempt # audit causes a 'system preparation tool' dialog on first boot that I close my $installroot = xCAT::TableUtils->getInstallDir(); my $request = shift; my $callback = shift; my $doreq = shift; my @nodes = @{$request->{node}}; my $node; my $ostab = xCAT::Table->new('nodetype'); my $oshash = $ostab->getNodesAttribs(\@nodes,['profile','arch']); my $vpdtab = xCAT::Table->new('vpd'); my $vpdhash = $vpdtab->getNodesAttribs(\@nodes,['uuid']); my $shandle; unless (-d "$installroot/autoinst") { mkpath "$installroot/autoinst"; } my $ent; foreach $node (@nodes) { $ent = $oshash->{$node}->[0]; unless ($ent->{arch} and $ent->{profile}) { $callback->( { error => ["No profile defined in nodetype for $node"], errorcode => [1] } ); next; #No profile } open($shandle,">","$installroot/autoinst/$node.cmd"); print $shandle "if exist c:\\xcatimgcred.txt move c:\\xcatimgcred.txt c:\\xcatimgcred.cmd\r\n"; print $shandle "if not exist c:\\xcatimgcred.cmd (\r\n"; print $shandle " echo ERROR: C:\\xcatimgcred.txt was missing, can't authenticate to server to store image\r\n"; print $shandle ")\r\n"; print $shandle "call c:\\xcatimgcred.cmd\r\n"; print $shandle "del c:\\xcatimgcred.cmd\r\n"; print $shandle "x:\r\n"; print $shandle "cd \\xcat\r\n"; print $shandle "net use /delete i:\r\n"; print $shandle 'net use i: %IMGDEST% %PASSWORD% /user:%USER%'."\r\n"; print $shandle 'mkdir i:\images'."\r\n"; print $shandle 'mkdir i:\images'."\\".$ent->{arch}."\r\n"; print $shandle "imagex /capture c: i:\\images\\".$ent->{arch}."\\".$ent->{profile}.".wim ".$ent->{profile}."_".$ent->{arch}."\r\n"; print $shandle "IF %PROCESSOR_ARCHITECTURE%==AMD64 GOTO x64\r\n"; print $shandle "IF %PROCESSOR_ARCHITECTURE%==x64 GOTO x64\r\n"; print $shandle "IF %PROCESSOR_ARCHITECTURE%==x86 GOTO x86\r\n"; print $shandle ":x86\r\n"; print $shandle "i:\\postscripts\\upflagx86 %XCATD% 3002 next\r\n"; print $shandle "GOTO END\r\n"; print $shandle ":x64\r\n"; print $shandle "i:\\postscripts\\upflagx64 %XCATD% 3002 next\r\n"; print $shandle ":END\r\n"; print $shandle "pause\r\n"; close($shandle); if ($vpdhash->{$node}) { mkwinlinks($node,$ent,$vpdhash->{$node}->[0]->{uuid}); } else { mkwinlinks($node,$ent); } } } sub mkwinlinks { my $installroot = xCAT::TableUtils->getInstallDir(); # for now put this, as it breaks for imagex my $node = shift; my $ent = shift; my $uuid = shift; foreach (getips($node)) { link "$installroot/autoinst/$node.cmd","$installroot/autoinst/$_.cmd"; } if ($uuid) { link "$installroot/autoinst/$node.cmd","$installroot/autoinst/$uuid.cmd"; #sadly, UUID endiannes is contentious to this day, tolerate a likely mangling #of the UUID $uuid =~ s/^(..)(..)(..)(..)-(..)(..)-(..)(..)-/$4$3$2$1-$6$5-$8$7-/; link "$installroot/autoinst/$node.cmd","$installroot/autoinst/$uuid.cmd"; } } sub winshell { my $installroot = xCAT::TableUtils->getInstallDir(); my $request = shift; my $script = "cmd"; my @nodes = @{$request->{node}}; my $node; my $ostab = xCAT::Table->new('nodetype'); my $oshash = $ostab->getNodesAttribs(\@nodes,['profile','arch']); my $vpdtab = xCAT::Table->new('vpd'); my $vpdhash = $vpdtab->getNodesAttribs(\@nodes,['uuid']); my $shandle; foreach $node (@nodes) { open($shandle,">","$installroot/autoinst/$node.cmd"); print $shandle $script; close $shandle; if ($vpdhash->{$node}) { mkwinlinks($node,$oshash->{$node}->[0],$vpdhash->{$node}->[0]->{uuid}); } else { mkwinlinks($node,$oshash->{$node}->[0]); } my $bptab = xCAT::Table->new('bootparams',-create=>1); $bptab->setNodeAttribs( $node, { kernel => "Boot/pxeboot.0", initrd => "", kcmdline => "" } ); } } sub applyimagescript { #Applying will annoy administrator with password change and sysprep tool #in current process #EMS settings loss also bad.. #require/use setup.exe for 2k8 to alleviate this? my $arch=shift; my $profile=shift; my $applyscript=< x:/xcat/diskprep.prt echo clean >> x:/xcat/diskprep.prt echo create partition primary >> x:/xcat/diskprep.prt echo format quick >> x:/xcat/diskprep.prt echo active >> x:/xcat/diskprep.prt echo assign >> x:/xcat/diskprep.prt if exist i:/images/$arch/$profile.prt copy i:/images/$arch/$profile.prt x:/xcat/diskprep.prt diskpart /s x:/xcat/diskprep.prt x:/windows/system32/imagex /apply i:/images/$arch/$profile.wim 1 c: reg load HKLM\\csystem c:\\windows\\system32\\config\\system reg copy HKLM\\system\\CurrentControlSet\\services\\TCPIP6\\parameters HKLM\\csystem\\ControlSet001\\services\\TCPIP6\\parameters /f reg copy HKLM\\system\\CurrentControlSet\\services\\TCPIP6\\parameters HKLM\\csystem\\ControlSet002\\services\\TCPIP6\\parameters /f reg unload HKLM\\csystem IF %PROCESSOR_ARCHITECTURE%==AMD64 GOTO x64 IF %PROCESSOR_ARCHITECTURE%==x64 GOTO x64 IF %PROCESSOR_ARCHITECTURE%==x86 GOTO x86 :x86 i:/postscripts/upflagx86 %XCATD% 3002 next GOTO END :x64 i:/postscripts/upflagx64 %XCATD% 3002 next :END ENDAPPLY } sub get_server_certname { my @certdata = `openssl x509 -in /etc/xcat/cert/server-cert.pem -text -noout`; foreach (@certdata) { if (/Subject:/) { s/.*=//; return $_; last; } } } #Don't sweat os type as for mkimage it is always 'imagex' if it got here sub mkinstall { my $installroot; $installroot = xCAT::TableUtils->getInstallDir(); my $request = shift; my $callback = shift; my $doreq = shift; my @nodes = @{$request->{node}}; my $tftpdir=$globaltftpdir; my $node; my $ostab = xCAT::Table->new('nodetype'); my %doneimgs; my $bptab = xCAT::Table->new('bootparams',-create=>1); my $hmtab = xCAT::Table->new('nodehm'); my $vpdtab = xCAT::Table->new('vpd'); my $vpdhash = $vpdtab->getNodesAttribs(\@nodes,['uuid']); my %img_hash=(); my $winimagetab; my $osimagetab; unless (-r "$tftpdir/Boot/pxeboot.0" ) { $callback->( {error => [ "The Windows netboot image is not created, consult documentation on how to add Windows deployment support to xCAT"],errorcode=>[1] }); return; } my $xcatsslname=get_server_certname(); unless (-r "$installroot/xcat/ca.pem" and stat("/etc/xcat/cert/ca.pem")->mtime <= stat("$installroot/xcat/ca.pem")->mtime) { mkpath("$installroot/xcat/"); copy("/etc/xcat/cert/ca.pem","$installroot/xcat/ca.pem"); } require xCAT::Template; # get image attributes my $osents = $ostab->getNodesAttribs(\@nodes, ['profile', 'os', 'arch', 'provmethod']); foreach $node (@nodes) { my $os; my $arch; my $profile; my $tmplfile; my $imagename; # set it if running of 'nodeset osimage=xxx' my $partfile; my $installto; my $ent = $osents->{$node}->[0]; if ($ent and $ent->{provmethod} and ($ent->{provmethod} ne 'install') and ($ent->{provmethod} ne 'netboot') and ($ent->{provmethod} ne 'statelite')) { $imagename=$ent->{provmethod}; 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 (!$winimagetab) { $winimagetab=xCAT::Table->new('winimage', -create=>1); } my $ref1 = $winimagetab->getAttribs({imagename => $imagename}, 'template', 'installto', 'partitionfile'); if ($ref1) { if ($ref1->{'template'}) { $img_hash{$imagename}->{template}=$ref1->{'template'}; } if ($ref1->{'installto'}) { $img_hash{$imagename}->{installto}=$ref1->{'installto'}; } if ($ref1->{'partitionfile'}) { $img_hash{$imagename}->{partitionfile}=$ref1->{'partitionfile'}; } } } 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}; $partfile = $ph->{partitionfile}; $tmplfile = $ph->{template}; $installto = $ph->{installto}; } else { unless ($ent->{os} and $ent->{arch} and $ent->{profile}) { $callback->( { error => ["No profile defined in nodetype for $node"], errorcode => [1] } ); next; #No profile } $os = $ent->{os}; $arch = $ent->{arch}; $profile = $ent->{profile}; if ($os eq "imagex") { my $wimfile="$installroot/images/$arch/$profile.wim"; unless ( -r $wimfile ) { $callback->({error=>["$wimfile not found, run rimage on a node to capture first"],errorcode=>[1]}); next; } my $script=applyimagescript($arch,$profile); my $shandle; open($shandle,">","$installroot/autoinst/$node.cmd"); print $shandle $script; close($shandle); if ($vpdhash->{$node}) { mkwinlinks($node,$ent,$vpdhash->{$node}->[0]->{uuid}); } else { mkwinlinks($node,$ent); } if ($arch =~ /x86_64/) { $bptab->setNodeAttribs( $node, { kernel => "Boot/pxeboot.0", initrd => "", kcmdline => "" } ); } elsif ($arch =~ /x86/) { unless (-r "$tftpdir/Boot/pxeboot32.0") { my $origpxe; my $pxeboot; open($origpxe,"<$tftpdir/Boot/pxeboot.0"); open($pxeboot,">$tftpdir/Boot/pxeboot32.0"); binmode($origpxe); binmode($pxeboot); my @origpxecontent = <$origpxe>; foreach (@origpxecontent) { s/bootmgr.exe/bootm32.exe/; print $pxeboot $_; } } unless (-r "$tftpdir/bootm32.exe") { my $origmgr; my $bootmgr; open($origmgr,"<$tftpdir/bootmgr.exe"); open($bootmgr,">$tftpdir/bootm32.exe"); binmode($origmgr); binmode($bootmgr); my @data = <$origmgr>; foreach (@data) { s/(\\.B.o.o.t.\\.B.)C(.)D/${1}3${2}2/; # 16 bit encoding... cheat print $bootmgr $_; } } $bptab->setNodeAttribs( $node, { kernel => "Boot/pxeboot32.0", initrd => "", kcmdline => "" } ); } next; } my $custmplpath = "$installroot/custom/install/windows"; my $tmplpath = "$::XCATROOT/share/xcat/install/windows"; if ($os =~ /^hyperv/) { $custmplpath = "$installroot/custom/install/hyperv"; $tmplpath = "$::XCATROOT/share/xcat/install/hyperv"; } my $tmplfile=xCAT::SvrUtils::get_tmpl_file_name($custmplpath, $profile, $os, $arch); if (! $tmplfile) { $tmplfile=xCAT::SvrUtils::get_tmpl_file_name($tmplpath, $profile, $os, $arch); } } unless ( -r "$tmplfile") { $callback->({error =>["No unattended template exists for " . $ent->{profile}],errorcode => [1]}); next; } #Call the Template class to do substitution to produce an unattend.xml file in the autoinst dir my $tmperr; my @utilfiles = ( "fixupunattend.vbs", "detectefi.exe", "xCAT.psd1", "xCAT.psm1", "xCAT.format.ps1xml", "nextdestiny.ps1", ); foreach my $utilfile (@utilfiles) { unless (-r "$installroot/utils/windows/$utilfile" and stat("$::XCATROOT/share/xcat/netboot/windows/$utilfile")->mtime <= stat("$installroot/utils/windows/$utilfile")->mtime) { mkpath("$installroot/utils/windows/"); copy("$::XCATROOT/share/xcat/netboot/windows/$utilfile","$installroot/utils/windows/$utilfile"); } } if (-r "$tmplfile") { $tmperr = xCAT::Template->subvars( $tmplfile, "$installroot/autoinst/$node.xml", $node, 0); } if ($tmperr) { $callback->({node => [{name => [$node], error => [$tmperr], errorcode => [1]}]}); next; } # create the node-specific post script DEPRECATED, don't do #mkpath "/install/postscripts/"; if (! -r "$tftpdir/Boot/pxeboot.0" ) { $callback->( {error => [ "The Windows netboot image is not created, consult documentation on how to add Windows deployment support to xCAT"],errorcode=>[1] }); } elsif (-r $installroot."/$os/$arch/sources/install.wim") { if ($arch =~ /x86/) { $bptab->setNodeAttribs( $node, { kernel => "Boot/pxeboot.0", initrd => "", kcmdline => "" } ); } } else { $callback->( { error => [ "Failed to detect copycd configured install source at /$installroot/$os/$arch/sources/install.wim" ], errorcode => [1] } ); } my $shandle; my $sspeed; my $sport; if ($hmtab) { my $sent = $hmtab->getNodeAttribs($node,"serialport","serialspeed"); if ($sent and defined($sent->{serialport}) and $sent->{serialspeed}) { $sport = $sent->{serialport}; $sspeed = $sent->{serialspeed}; } } if (-f "$::XCATROOT/share/xcat/netboot/detectefi.exe" and not -f "$installroot/utils/detectefi.exe") { mkpath("$installroot/utils/"); copy("$::XCATROOT/share/xcat/netboot/detectefi.exe","$installroot/utils/detectefi.exe"); } my $partcfg; if ($partfile) { if (-r $partfile) { $partcfg = "[BIOS]"; if (open (PFILE, "<$partfile")) { while () { s/\s*$//g; s/^\s*//g; if (/^\[bios\](.*)/i) { $partcfg .= $1; } elsif (/^\[uefi\](.*)/i) { $partcfg .= "[UEFI]$1"; } else { $partcfg .= $_; } } } } else { $callback->({data =>["Cannot open partition configuration file: $partfile."]}); } } if ($installto && ($installto !~ /^[\d:]+$/)) { $callback->({error =>["The format of installto is not correct: installto."]}); $installto = ""; } # generate the auto running command file for windows deployment open($shandle,">","$installroot/autoinst/$node.cmd"); if ($partcfg) { print $shandle "set PARTCFG=\"$partcfg\n"; } if ($installto) { print $shandle "set INSTALLTO=$installto\n"; } print $shandle 'for /f "tokens=2 delims= " %%i in ('."'net use ^| find ".'"install"'."') do set instdrv=%%i\r\n"; print $shandle "%instdrv%\\utils\\windows\\fixupunattend.vbs %instdrv%\\autoinst\\$node.xml x:\\unattend.xml\r\n"; #### test part #print $shandle "start /max cmd\r\n"; #print $shandle "pause\r\n"; if ($sspeed) { $sport++; print $shandle "%instdrv%\\$os\\$arch\\setup /unattend:x:\\unattend.xml /emsport:COM$sport /emsbaudrate:$sspeed /noreboot\r\n"; } else { print $shandle "%instdrv%\\$os\\$arch\\setup /unattend:x:\\unattend.xml /noreboot\r\n"; } #print $shandle "i:\\postscripts\ print $shandle 'reg load HKLM\csystem c:\windows\system32\config\system'."\r\n"; #copy installer DUID to system before boot print $shandle 'reg copy HKLM\system\CurrentControlSet\services\TCPIP6\parameters HKLM\csystem\ControlSet001\services\TCPIP6\parameters /f'."\r\n"; print $shandle 'reg copy HKLM\system\CurrentControlSet\services\TCPIP6\parameters HKLM\csystem\ControlSet002\services\TCPIP6\parameters /f'."\r\n"; print $shandle 'reg unload HKLM\csystem'."\r\n"; print $shandle "If EXIST %instdrv%\\winpostscripts GOTO wps\r\n"; print $shandle "goto up\r\n"; print $shandle ":wps\r\n"; print $shandle "mkdir c:\\xcatpost\r\n"; print $shandle "xcopy %instdrv%\\winpostscripts c:\\xcatpost\r\n"; print $shandle ":up\r\n"; print $shandle "If EXIST X:\\Windows\\system32\\WindowsPowerShell GOTO PSH\r\n"; print $shandle "IF %PROCESSOR_ARCHITECTURE%==AMD64 GOTO x64\r\n"; print $shandle "IF %PROCESSOR_ARCHITECTURE%==x64 GOTO x64\r\n"; print $shandle "IF %PROCESSOR_ARCHITECTURE%==x86 GOTO x86\r\n"; print $shandle ":x86\r\n"; print $shandle "%instdrv%\\postscripts\\upflagx86 %XCATD% 3002 next\r\n"; print $shandle "GOTO END\r\n"; print $shandle ":x64\r\n"; print $shandle "%instdrv%\\postscripts\\upflagx64 %XCATD% 3002 next\r\n"; print $shandle "GOTO END\r\n"; print $shandle ":PSH\r\n"; print $shandle "set mastername=$xcatsslname\r\n"; print $shandle "set master=%XCATD%\r\n"; print $shandle "mkdir x:\\windows\\system32\\WindowsPowerShell\\v1.0\\Modules\\xCAT\r\n"; print $shandle "copy %instdrv%\\utils\\windows\\xCAT.* x:\\windows\\system32\\WindowsPowerShell\\v1.0\\Modules\\xCAT\r\n"; print $shandle "powershell set-executionpolicy bypass CurrentUser\r\n"; print $shandle "powershell %instdrv%\\utils\\windows\\nextdestiny.ps1\r\n"; print $shandle ":END\r\n"; close($shandle); if ($vpdhash->{$node}) { mkwinlinks($node,undef,$vpdhash->{$node}->[0]->{uuid}); } else { mkwinlinks($node,undef); } #since we are manipulating the 'filename' more precisely, no longer any reason to make per node BCD links # foreach (getips($node)) { #This should be deprecated, probably # unlink "$tftpdir/Boot/BCD.$_"; # if ($arch =~ /64/) { # link "$tftpdir/Boot/BCD.64","$tftpdir/Boot/BCD.$_"; # } else { # link "$tftpdir/Boot/BCD.32","$tftpdir/Boot/BCD.$_"; # } # } } } sub getips { #TODO: all the possible ip addresses my $node = shift; my $ipn = inet_aton($node); #would use proper method, but trying to deprecate this anyhow unless ($ipn) { return (); } #THIS CURRENTLY WOULD BREAK WITH IPV6 anyway... my $ip = inet_ntoa($ipn); return ($ip); } sub copycd { my $request = shift; my $callback = shift; my $doreq = shift; my $distname = ""; my $arch; my $path; my $mntpath=undef; my $inspection=undef; my $noosimage=undef; my $installroot; $installroot = "/install"; #my $sitetab = xCAT::Table->new('site'); #if ($sitetab) #{ #(my $ref) = $sitetab->getAttribs({key => installdir}, value); my @entries = xCAT::TableUtils->get_site_attribute("installdir"); my $t_entry = $entries[0]; if ( defined($t_entry) ) { $installroot = $t_entry; } #} @ARGV = @{$request->{arg}}; GetOptions( 'n=s' => \$distname, 'a=s' => \$arch, 'p=s' => \$path, 'm=s' => \$mntpath, 'i' => \$inspection, 'o' => \$noosimage, ); unless ($mntpath) { #this plugin needs $mntpath... return; } if ($distname and $distname !~ /^win.*/ and $distname !~ /^hyperv.*/) { #If they say to call it something other than win, give up? return; } my $darch; if (-d $mntpath . "/sources/6.0.6000.16386_amd64" and -r $mntpath . "/sources/install.wim") { $darch = "x86_64"; unless ($distname) { $distname = "win2k8"; } } # add support for Win7 if(-r $mntpath . "/sources/idwbinfo.txt"){ open(DBNAME, $mntpath . "/sources/idwbinfo.txt"); while(){ if(/BuildArch=amd64/){ $darch = "x86_64"; } elsif (/BuildBranch=win7_rtm/){ $distname = "win7"; } elsif (/BuildBranch=win8_rtm/){ if (-r $mntpath . "/sources/background_cli.bmp") { $distname = "win8"; } elsif (-r $mntpath . "/sources/background_svr.bmp") { if (-r $mntpath . "/sources/EI.CFG") { my $eicfg; open($eicfg,"<", $mntpath . "/sources/EI.CFG"); my $eiline = <$eicfg>; $eiline = <$eicfg>; if ($eiline =~ /Hyper/) { $distname = "hyperv2012"; } } unless ($distname) { $distname = "win2012"; } } } } close(DBNAME); } if (-r $mntpath . "/sources/install_Windows Server 2008 R2 SERVERENTERPRISE.clg") { $distname = "win2k8r2"; } unless ($distname) { return; } if ($darch) { unless ($arch) { $arch = $darch; } if ($arch and $arch ne $darch) { $callback->( { error => ["Requested Windows architecture $arch, but media is $darch"], errorcode => [1] } ); return; } } if($inspection) { $callback->( { info => "DISTNAME:$distname\n"."ARCH:$arch\n" } ); return; } %{$request} = (); #clear request we've got it. my $defaultpath="$installroot/$distname/$arch"; unless($path) { $path=$defaultpath; } my $osdistroname=$distname."-".$arch; if ($::XCATSITEVALS{osimagerequired}){ my ($nohaveimages,$errstr) = xCAT::SvrUtils->update_tables_with_templates($distname, $arch,$path,$osdistroname,checkonly=>1); if ($nohaveimages) { $callback->({error => "No Templates found to support $distname($arch)",errorcode=>2}); return; } } $callback->( {data => "Copying media to $path"}); my $omask = umask 0022; if(-l $path) { unlink($path); } mkpath("$path"); umask $omask; my $rc; $SIG{INT} = $SIG{TERM} = sub { foreach(@cpiopid){ kill 2, $_; } if ($mntpath) { chdir("/"); system("umount $mntpath"); } }; my $kid; chdir $mntpath; 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 { my $c = "nice -n 20 cpio -vdump $path"; my $k2 = open(PIPE, "$c 2>&1 |") || $callback->({error => "Media copy operation fork failure"}); push @cpiopid, $k2; my $copied = 0; my ($percent, $fout); while(){ next if /^cpio:/; $percent = $copied / $numFiles; $fout = sprintf "%0.2f%%", $percent * 100; $callback->({sinfo => "$fout"}); ++$copied; } exit; } chmod 0755, "$path"; unless($path =~ /^($defaultpath)/) { mkpath($defaultpath); if(-d $defaultpath) { rmtree($defaultpath); } else { unlink($defaultpath); } my $hassymlink = eval { symlink("",""); 1 }; if ($hassymlink) { symlink($path,$defaultpath); }else { link($path,$defaultpath); } } if ($rc != 0) { $callback->({error => "Media copy operation failed, status $rc"}); } else { $callback->({data => "Media copy operation successful"}); my @ret=xCAT::SvrUtils->update_osdistro_table($distname,$arch,$path,$osdistroname); if ($ret[0] != 0) { $callback->({data => "Error when updating the osdistro tables: " . $ret[1]}); } unless($noosimage){ my @ret=xCAT::SvrUtils->update_tables_with_templates($distname, $arch,$path,$osdistroname); if ($ret[0] != 0) { $callback->({data => "Error when updating the osimage tables: " . $ret[1]}); } } } } #sub get_tmpl_file_name { # my $base=shift; # my $profile=shift; # my $os=shift; # my $arch=shift; # if (-r "$base/$profile.$os.$arch.tmpl") { # return "$base/$profile.$os.$arch.tmpl"; # } # elsif (-r "$base/$profile.$arch.tmpl") { # return "$base/$profile.$arch.tmpl"; # } # elsif (-r "$base/$profile.$os.tmpl") { # return "$base/$profile.$os.tmpl"; # } # elsif (-r "$base/$profile.tmpl") { # return "$base/$profile.tmpl"; # } # # return ""; #} 1;