mirror of
				https://github.com/xcat2/xcat-core.git
				synced 2025-10-31 19:32:31 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			302 lines
		
	
	
		
			9.4 KiB
		
	
	
	
		
			Plaintext
		
	
	
	
	
	
			
		
		
	
	
			302 lines
		
	
	
		
			9.4 KiB
		
	
	
	
		
			Plaintext
		
	
	
	
	
	
| export XCATDEBUGMODE="#TABLEBLANKOKAY:site:key=xcatdebugmode:value#"
 | |
| if [ "$XCATDEBUGMODE" = "1" ] || [ "$XCATDEBUGMODE" = "2" ]; then
 | |
|     set -x
 | |
| fi
 | |
| export MASTER_IP="#ENV:MASTER_IP#"
 | |
| #INCLUDE:#ENV:XCATROOT#/share/xcat/install/scripts/scriptlib#
 | |
| log_label="xcat.deployment"
 | |
| msgutil_r "$MASTER_IP" "info" "============deployment starting============" "/var/log/xcat/xcat.log" "$log_label"
 | |
| msgutil_r "$MASTER_IP" "info" "Running Anaconda Pre-Installation script..." "/var/log/xcat/xcat.log" "$log_label"
 | |
| if grep n8r /proc/cmdline > /dev/null 2>&1;
 | |
| then
 | |
|   stty crtscts
 | |
| fi
 | |
| for x in 0 1 2 3 4 5 6 7 8
 | |
| do
 | |
| 	mknod /dev/vcs$x c 7 $x
 | |
| 	mknod /dev/vcsa$x c 7 $[$x+128]
 | |
| done
 | |
| chmod 644 /dev/vcs*
 | |
| chown root /dev/vcs*
 | |
| if [ -r /tmp/updates/etc/pki/tls/certs/ca-bundle.crt ]; then
 | |
|         cp -f /tmp/updates/etc/pki/tls/certs/ca-bundle.crt /etc/pki/tls/certs/
 | |
| fi
 | |
| 
 | |
| 
 | |
| #there is no boot option to set dns search domain in kickstart file,
 | |
| #the search domain in /etc/resolv.conf is set in the pre installation script
 | |
| export MANAGEDADDRESSMODE=#MANAGEDADDRESSMODE#
 | |
| export SEARCHDOMAIN=#GETNODEDOMAIN:THISNODE#
 | |
| 
 | |
| if [ "$MANAGEDADDRESSMODE" == "static" ]; then
 | |
|  echo "#appended by %pre " >> /etc/resolv.conf
 | |
|  echo "search $SEARCHDOMAIN" >> /etc/resolv.conf
 | |
| fi
 | |
| 
 | |
| 
 | |
| 
 | |
| cat >/tmp/baz.py <<EOF
 | |
| #!/usr/bin/python
 | |
| import socket
 | |
| import sys
 | |
| 
 | |
| sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 | |
| sock.connect(('#XCATVAR:XCATMASTER#',#TABLE:site:key=xcatiport:value#))
 | |
| 
 | |
| print sys.argv[1]
 | |
| response = sock.recv(100)
 | |
| if(response == "ready\n"):
 | |
|         sock.send(sys.argv[1]+"\n")
 | |
|         response = sock.recv(100)
 | |
| 
 | |
| sock.close()
 | |
| EOF
 | |
| 
 | |
| 
 | |
| 
 | |
| cat >/tmp/foo.py <<EOF
 | |
| #!/usr/bin/python
 | |
| 
 | |
| import socket
 | |
| import os
 | |
| import linecache
 | |
| import re
 | |
| 
 | |
| sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 | |
| sock.connect(('#XCATVAR:XCATMASTER#',#TABLE:site:key=xcatiport:value#))
 | |
| 
 | |
| response = sock.recv(100)
 | |
| if(response == "ready\n"):
 | |
| 	sock.send("installmonitor\n")
 | |
| 	response = sock.recv(100)
 | |
| 
 | |
| sock.close()
 | |
| 
 | |
| sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 | |
| sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
 | |
| 
 | |
| port = 3054
 | |
| sock.bind(('', port))
 | |
| 
 | |
| sock.listen(5)
 | |
| 
 | |
| try:
 | |
| 	while 1:
 | |
| 		newSocket, address = sock.accept()
 | |
| 		while 1:
 | |
| 			received = newSocket.recv(200)
 | |
| 			if not received:
 | |
| 				break
 | |
| 			command = re.split('\s+',received)
 | |
| 			if(command[0] == "stat"):
 | |
| 				ilog = ""
 | |
| 				firstline = ""
 | |
| 				line = ""
 | |
| 				post = 0
 | |
| 				percent = 0
 | |
| 				count = 0
 | |
| 				numpack = 0
 | |
| 				pre = 0
 | |
| 				if(os.path.isfile('/tmp/xcatpre.log')):
 | |
| 					ilog = '/tmp/xcatpre.log'
 | |
| 					pre = 1
 | |
| 				if(os.path.isfile('/tmp/packaging.log')):
 | |
| 					ilog = '/tmp/packaging.log'
 | |
| 				if(os.path.isfile('/mnt/sysimage/root/install.log')):
 | |
| 					ilog = '/mnt/sysimage/root/install.log'
 | |
| 				if(os.path.isfile('/mnt/sysimage/tmp/install.log')):
 | |
| 					ilog = '/mnt/sysimage/tmp/install.log'
 | |
| 				if(os.path.isfile('/mnt/sysimage/root/post.log')):
 | |
| 					ilog = '/mnt/sysimage/root/post.log'
 | |
| 					post = 1
 | |
| 				if(ilog):
 | |
| 					count = len(open(ilog).readlines())
 | |
| 					firstline = linecache.getline(ilog,1)
 | |
| 					line = linecache.getline(ilog,count)
 | |
| 					linecache.clearcache()
 | |
| 				if(line and not post and not pre):
 | |
| 					r1 = re.compile("^Installing (\d+) ")
 | |
| 					m1 = r1.search(firstline)
 | |
| 					if m1:
 | |
| 						numpack = int(m1.group(1))
 | |
| 						if(numpack > 0):
 | |
| 							percent = int(((count - 2) * 100)/numpack + .5)
 | |
| 						if(percent > 100):
 | |
| 							percent = 100
 | |
| 						if(percent < 0):
 | |
| 							percent = 0
 | |
| 					r2 = re.compile("^Installing (.*)\.")
 | |
| 					m2 = r2.search(line)
 | |
| 					if m2:
 | |
| 						newline = m2.group(1)
 | |
| 						newline = newline + " ("
 | |
| 						newline = newline + str(percent)
 | |
| 						newline = newline + "%)"
 | |
| #						newline = newline + " ["
 | |
| #						count = count - 2
 | |
| #						newline = newline + str(count)
 | |
| #						newline = newline + "/"
 | |
| #						newline = newline + str(numpack)
 | |
| #						newline = newline + "]"
 | |
| 					else:
 | |
| 						newline = "prep"
 | |
| 					line = "installing " + newline
 | |
| 				if(line and post and not pre):
 | |
| 					line = "installing " + line
 | |
| 				if(not line):
 | |
| 					line = "installing prep"
 | |
| 				newSocket.send(line)
 | |
| 				break
 | |
| #UNCOMMENTOENABLEDEBUGPORT#			if(command[0] == "sh"): #DEBUG purposes only, wide open root priv command here.
 | |
| #UNCOMMENTOENABLEDEBUGPORT#				newcommand = ""
 | |
| #UNCOMMENTOENABLEDEBUGPORT#				for i in command[1:]:
 | |
| #UNCOMMENTOENABLEDEBUGPORT#					newcommand = newcommand + i + " "
 | |
| #UNCOMMENTOENABLEDEBUGPORT#				output = os.popen(newcommand).read()
 | |
| #UNCOMMENTOENABLEDEBUGPORT#				newSocket.send(output)
 | |
| #UNCOMMENTOENABLEDEBUGPORT#				break
 | |
| 			if(command[0] == "screendump"):
 | |
| 				newcommand = "cat /dev/vcs"
 | |
| 				for i in command[1:]:
 | |
| 					newcommand = newcommand + i
 | |
| 				output = os.popen(newcommand).read()
 | |
| 				newSocket.send(output)
 | |
| 				break
 | |
| 				
 | |
| 		newSocket.close()
 | |
| 
 | |
| finally:
 | |
| 	sock.close()
 | |
| EOF
 | |
| 
 | |
| chmod 755 /tmp/foo.py
 | |
| chmod 755 /tmp/baz.py
 | |
| 
 | |
| NODESTATUS=#TABLEBLANKOKAY:site:key=nodestatus:value#
 | |
| 
 | |
| if [ -z "$NODESTATUS" ] || [ "$NODESTATUS" != "0" -a   "$NODESTATUS" != "N"  -a  "$NODESTATUS" != "n" ]; then
 | |
|    /tmp/baz.py "installstatus installing" &
 | |
| fi
 | |
| 
 | |
| /tmp/foo.py >/foo.log 2>&1 &
 | |
| 
 | |
| base64decode()
 | |
| {
 | |
|     h0="0";  h1="1";  h2="2";  h3="3";  h4="4";  h5="5";  h6="6";  h7="7";
 | |
|     h8="8";  h9="9"; h10="A"; h11="B"; h12="C"; h13="D"; h14="E"; h15="F";
 | |
| 
 | |
|     while :
 | |
|     do
 | |
|         i=0
 | |
|         while [ "$i" -lt 4 ]
 | |
|         do
 | |
|             read -n 1 c || return
 | |
| 
 | |
|             case "${c}" in
 | |
|             "A") d=0  ;; "B") d=1  ;; "C") d=2  ;; "D") d=3  ;;
 | |
|             "E") d=4  ;; "F") d=5  ;; "G") d=6  ;; "H") d=7  ;;
 | |
|             "I") d=8  ;; "J") d=9  ;; "K") d=10 ;; "L") d=11 ;;
 | |
|             "M") d=12 ;; "N") d=13 ;; "O") d=14 ;; "P") d=15 ;;
 | |
|             "Q") d=16 ;; "R") d=17 ;; "S") d=18 ;; "T") d=19 ;;
 | |
|             "U") d=20 ;; "V") d=21 ;; "W") d=22 ;; "X") d=23 ;;
 | |
|             "Y") d=24 ;; "Z") d=25 ;; "a") d=26 ;; "b") d=27 ;;
 | |
|             "c") d=28 ;; "d") d=29 ;; "e") d=30 ;; "f") d=31 ;;
 | |
|             "g") d=32 ;; "h") d=33 ;; "i") d=34 ;; "j") d=35 ;;
 | |
|             "k") d=36 ;; "l") d=37 ;; "m") d=38 ;; "n") d=39 ;;
 | |
|             "o") d=40 ;; "p") d=41 ;; "q") d=42 ;; "r") d=43 ;;
 | |
|             "s") d=44 ;; "t") d=45 ;; "u") d=46 ;; "v") d=47 ;;
 | |
|             "w") d=48 ;; "x") d=49 ;; "y") d=50 ;; "z") d=51 ;;
 | |
|             "0") d=52 ;; "1") d=53 ;; "2") d=54 ;; "3") d=55 ;;
 | |
|             "4") d=56 ;; "5") d=57 ;; "6") d=58 ;; "7") d=59 ;;
 | |
|             "8") d=60 ;; "9") d=61 ;; "+") d=62 ;; "/") d=63 ;;
 | |
|             "=") d=0  ;;
 | |
|             *) continue ;;
 | |
|             esac
 | |
| 
 | |
|             eval "a${i}=${c}"
 | |
|             eval "b${i}=${d}"
 | |
| 
 | |
|             i=$(( i + 1 ))
 | |
|         done
 | |
| 
 | |
|         o0=$(( ((b0 << 2) | (b1 >> 4)) & 0xff ))
 | |
|         o1=$(( ((b1 << 4) | (b2 >> 2)) & 0xff ))
 | |
|         o2=$(( ((b2 << 6) | b3) & 0xff ))
 | |
| 
 | |
|         [ "${a2}" == "=" ] &&
 | |
|             eval "printf \"\\x\${h$(( o0 / 16 ))}\${h$(( o0 % 16
 | |
|                 ))}\"" &&
 | |
|             return
 | |
|         [ "${a3}" == "=" ] &&
 | |
|             eval "printf \"\\x\${h$(( o0 / 16 ))}\${h$(( o0 % 16
 | |
|                 ))}\\x\${h$(( o1 / 16 ))}\${h$(( o1 % 16
 | |
|                 ))}\"" &&
 | |
|             return
 | |
|         eval "printf \"\\x\${h$(( o0 / 16 ))}\${h$(( o0 % 16
 | |
|             ))}\\x\${h$(( o1 / 16 ))}\${h$(( o1 % 16
 | |
|             ))}\\x\${h$(( o2 / 16 ))}\${h$(( o2 % 16 ))}\""
 | |
|     done
 | |
| }
 | |
| 
 | |
| #time to ascertain fstype and PReP/UEFI/legacy
 | |
| #also, find first available block device (sda or vda likely)
 | |
| #TODO: pick a likely non-SAN target if possible
 | |
| shopt -s nullglob
 | |
| msgutil_r "$MASTER_IP" "info" "Detecting install disk..." "/var/log/xcat/xcat.log" "$log_label"
 | |
| #
 | |
| # The getinstdisk script is common for RHEL/SLES/PowerKVM/Ubuntu.
 | |
| # It will attempt to select the install disk and write the selection to /tmp/xcat.install_disk
 | |
| #
 | |
| #INCLUDE:#ENV:XCATROOT#/share/xcat/install/scripts/getinstdisk#
 | |
| if [ -e "/tmp/xcat.install_disk" ]; then
 | |
|     instdisk=`cat /tmp/xcat.install_disk`
 | |
| fi
 | |
| 
 | |
| modprobe ext4 >& /dev/null
 | |
| modprobe ext4dev >& /dev/null
 | |
| if grep ext4dev /proc/filesystems > /dev/null; then
 | |
| 	FSTYPE=ext3
 | |
| elif grep ext4 /proc/filesystems > /dev/null; then
 | |
| 	FSTYPE=ext4
 | |
| else
 | |
| 	FSTYPE=ext3
 | |
| fi
 | |
| BOOTFSTYPE=ext3
 | |
| EFIFSTYPE=vfat
 | |
| msgutil_r "$MASTER_IP" "info" "Found $instdisk, generate partition file..." "/var/log/xcat/xcat.log" "$log_label"
 | |
| if [ `uname -m` = "ppc64" ]; then
 | |
| 	echo 'part None --fstype "PPC PReP Boot" --ondisk '$instdisk' --size 8' >> /tmp/partitionfile
 | |
| fi
 | |
| if [ -d /sys/firmware/efi ]; then
 | |
|     echo 'bootloader --driveorder='$instdisk >> /tmp/partitionfile
 | |
|     echo 'part /boot/efi --size 50 --ondisk '$instdisk' --fstype '$EFIFSTYPE >> /tmp/partitionfile
 | |
| else
 | |
|     echo 'bootloader' >> /tmp/partitionfile
 | |
| fi
 | |
| 
 | |
| #TODO: ondisk detection, /dev/disk/by-id/edd-int13_dev80 for legacy maybe, and no idea about efi.  at least maybe blacklist SAN if mptsas/mpt2sas/megaraid_sas seen...
 | |
| echo "part /boot --size 256 --fstype $BOOTFSTYPE --ondisk $instdisk" >> /tmp/partitionfile
 | |
| echo "part swap --recommended --ondisk $instdisk" >> /tmp/partitionfile
 | |
| echo "part / --size 1 --grow --ondisk $instdisk --fstype $FSTYPE" >> /tmp/partitionfile
 | |
| 	
 | |
| #XCA_PARTITION_SCRIPT#
 | |
| 
 | |
| #save the content of /tmp/partitionfile in /var/log/xcat/xcat.log
 | |
| #so that we can inspect the partition scheme after installation
 | |
| echo "=================The Partition Scheme================"
 | |
| cat /tmp/partitionfile
 | |
| echo "====================================================="
 | |
| msgutil_r "$MASTER_IP" "info" "Generate the repository for the installation" "/var/log/xcat/xcat.log" "$log_label"
 | |
| # The following code is to generate the repository for the installation
 | |
| cat /proc/cmdline
 | |
| 
 | |
| NEXTSERVER=`cat /proc/cmdline | grep http | head -n 1`
 | |
| NEXTSERVER=${NEXTSERVER#*http://}
 | |
| NEXTSERVER=${NEXTSERVER%%:*}
 | |
| 
 | |
| export nextserver=$NEXTSERVER
 | |
| #INSTALL_SOURCES_IN_PRE#
 | |
| 
 | |
| if [ "$XCATDEBUGMODE" = "1" ] || [ "$XCATDEBUGMODE" = "2" ]; then
 | |
|     set +x
 | |
| fi
 |