source: client/shared/scripts/updateCache @ 46f7d6f

918-git-images-111dconfigfileconfigure-oglivegit-imageslgromero-new-oglivemainmaint-cronmount-efivarfsmultivmmultivm-ogboot-installerogClonningEngineogboot-installer-jenkinsoglive-ipv6test-python-scriptsticket-301ticket-50ticket-50-oldticket-577ticket-585ticket-611ticket-612ticket-693ticket-700ubu24tplunification2use-local-agent-oglivevarios-instalacionwebconsole3
Last change on this file since 46f7d6f was 791d013, checked in by irina <irinagomez@…>, 11 years ago

#565 #537 #636 Log en tiempo real para imagenes sincronizadas.

git-svn-id: https://opengnsys.es/svn/branches/version1.0@4153 a21b9725-9963-47de-94b9-378ad31fedc9

  • Property mode set to 100755
File size: 12.2 KB
Line 
1#!/bin/bash
2
3
4#/**
5#         updateCache
6#@brief   Actualiza la cache del cliente con imagen o fichero iso.
7#@param 1 REPO          Origen del fichero. -accesible por nfs-samba-
8#@param 2 str_fichero   nombre del fichero a actualizar.
9#@param 3 str_protoco.  TORRENT | MULTICAST    | UNICAST.
10#@param 4 str_opcionesprotocolo
11#@param 4 str_opcionesupdatecache
12#@ejemplo: oneRemoteFromMaster 172.17.36.11 CACHE /imagen1 9000:full-duplex:239.194.17.36:70M:50:100 1 1 partclone lzop
13#@return 
14#@exception OG_ERR_FORMAT       formato incorrecto.
15#@exception OG_ERR_NOTCACHE     No existe cache -15-
16#@exception $OG_ERR_CACHESIZE   Tamaño de la paticion menor al archivo a descargar -16-
17#@note   
18#@todo:
19#@version 0.9.1 - integracion EAC
20#@author  Antonio J. Doblas Viso. Universidad de Malaga.
21#@date    2008/03/17
22#@version 0.9.2 - integracion OpenGnsys
23#@author  Antonio J. Doblas Viso. Universidad de Malaga.
24#@date    2010/07/27
25#@version 1.0.1 - Control de espacio requerido
26#@author  Antonio J.Doblas Viso
27#@date   2011-05-10
28#@version 2.0.1 - Imagenes sincronizadas
29#@date    2013-02-20
30#*/ ##
31
32PROG="$(basename $0)"
33if [ $# -lt 3 ]; then
34    ogRaiseError $OG_ERR_FORMAT "$MSG_FORMAT: $PROG str_REPO _str_Relative_Path_OGIMG_with_/ PROTOCOLO OPCIONES_PROTOCOLO OPCIONES_UPDATECACHE" 2>&1  | tee -a $OGLOGSESSION $OGLOGFILE
35    exit ${PIPESTATUS[0]}
36fi
37
38#Carga del configurador del engine
39[ -z $OGENGINECONFIGURATE ] && source /opt/opengnsys/etc/engine.cfg
40
41# Clear temporary file used as log track by httpdlog
42# Limpia los ficheros temporales usados como log de seguimiento para httpdlog
43echo " " > $OGLOGCOMMAND
44[ "$(ogGetCaller)" == "deployImage" ] || echo -n "" > $OGLOGSESSION;
45
46REPOSITORIO="${1^^}"
47PROTOCOLO="${3^^}"
48OPTPROTOCOLO="$4"
49REPOIP=$(ogGetRepoIp)
50echo $REPOSITORIO $REPOIP $PROTOCOLO $OPTPROTOCOLO
51
52# Si el repositorio local CACHE no existe error 15.
53if ! $(ogFindCache >/dev/null); then
54        ogRaiseError $OG_ERR_NOTCACHE "CACHE" 2>&1 | tee -a $OGLOGSESSION $OGLOGFILE
55        exit ${PIPESTATUS[0]}
56fi
57
58# comprobar si la imagen existe (.img, .img.diff o directorio)
59REPOFILE=$(ogGetPath "REPO" "/$2")
60if [ "$REPOFILE" == "" ]; then
61        ogRaiseError $OG_ERR_NOTFOUND "REPO /$2" 2>&1 | tee -a $OGLOGSESSION $OGLOGFILE
62        exit ${PIPESTATUS[0]}
63fi
64
65echo "$MSG_SCRIPTS_UPDATECACHE_DOUPDATE " | tee -a $OGLOGSESSION $OGLOGFILE
66# Distingo si es monolitica o sincronizable
67file "$REPOFILE" | grep -i -e " BTRFS Filesystem " -e " ext4 filesystem " -e " directory" 2>&1 > /dev/null
68if [ $? == 0 ]; then
69        IMGSYNC=TRUE
70        # Para imagen sincronizada, si hay imagen en cache siempre protocolo = rsync.
71        CACHEFILE="$(ogGetPath "CACHE" "/$2")"  && PROTOCOLO="RSYNC"
72        # Si es sincronizada tipo directorio  siempre protocolo = rsync.
73        [ -d $REPOFILE ] && PROTOCOLO="RSYNC" && IMGTYPE="dir"
74
75        # Si es imagen sincronizada siempre da distinto md5. No podemos comprobar -> actualizamos.
76        RETVAL=0
77else
78        # Si la imagen es monolitica y ha elegido protocolo = RSYNC salimos con error.
79        if [ $PROTOCOLO == "RSYNC" ]; then
80                ogRaiseError $OG_ERR_DONTSYNC_IMAGE "REPO $2" 2>&1| tee -a $OGLOGSESSION $OGLOGFILE
81                exit ${PIPESTATUS[0]}
82        fi     
83        IMGSYNC=FALSE
84        #TODO: ogUpdateCacheIsNecesary debe borrar la imagen que tenga igual nombre pero distinto sum-
85        ogUpdateCacheIsNecesary $1 $2
86        RETVAL=$?
87fi
88# si RETVAL=0 => actualizamos  si RETVAL=1 no actaulizasmo-exit 0  || si RETVAL>2 exit 1
89[ "$RETVAL" == "1" ] && exit 0
90[ "$RETVAL" -gt  "1" ] && exit 1
91
92echo "$MSG_SCRIPTS_UPDATECACHE_CHECKSIZECACHE" | tee -a $OGLOGSESSION $OGLOGFILE
93CACHESIZE=$(ogGetCacheSize)
94CACHESIZEFREE=$(ogGetFreeSize `ogFindCache`)
95FILESIZE=$(ls -sk $(ogGetPath $REPOSITORIO "$2") | cut -f1 -d" ")
96if [ "$IMGTYPE" == "dir" ]; then
97        echo "   * $MSG_SCRIPTS_UPDATECACHE_CHECKSIZEDIR" | tee -a $OGLOGSESSION $OGLOGFILE
98        echo "     du -sk $REPOFILE" | tee -a $OGLOGSESSION $OGLOGFILE
99        REALFILESIZE=$(du -sk "$REPOFILE"|awk '{print $1}')
100else
101        REALFILESIZE=$(ls -l --block-size=1024 $REPOFILE | cut -f5 -d" ")
102fi
103
104# La sincronizada, si existe la imagen en cache el espacio necesario
105#        es la nueva menos lo que ocupa la que ya hay.
106if [ "$PROTOCOLO" == "RSYNC" ]; then
107        if [ "$CACHEFILE" == "" ]; then
108                CACHEFILESIZE=0
109        else
110           if [ "$IMGTYPE" == "dir" ]; then
111                echo "   * $MSG_SCRIPTS_UPDATECACHE_CHECKSIZEDIR $CACHEFILESIZE" | tee -a $OGLOGSESSION $OGLOGFILE
112                echo "     du -sk $CACHEFILE" | tee -a $OGLOGSESSION $OGLOGFILE
113                CACHEFILESIZE=$(du -sk $CACHEFILE |awk '{print $1}')
114           else
115                CACHEFILESIZE=$(ls -l --block-size=1024 "$CACHEFILE" | cut -f5 -d" ")
116           fi
117        fi
118        let SIZEREQUIRED=$REALFILESIZE-$CACHEFILESIZE
119        [ $SIZEREQUIRED -lt 0 ] && SIZEREQUIRED=0
120else
121        SIZEREQUIRED=$FILESIZE
122fi
123
124#ERROR CACHESIZE 16
125if [ "$SIZEREQUIRED" -ge "$CACHESIZE" ] 
126then
127        echo "$MSG_WARNING: $MSG_ERR_CACHESIZE:  $2 = $SIZEREQUIRED > CACHE = $CACHESIZE" | tee -a $OGLOGSESSION $OGLOGFILE
128        ogRaiseError $OG_ERR_CACHESIZE "CACHE" 2>&1 | tee -a $OGLOGSESSION $OGLOGFILE
129        exit ${PIPESTATUS[0]}
130fi
131
132echo "$MSG_SCRIPTS_UPDATECACHE_IFNOTCACHEDO" | tee -a $OGLOGSESSION $OGLOGFILE
133#ERROR CACHESIZE 16
134if [ "$SIZEREQUIRED" -ge "$CACHESIZEFREE" ] 
135then
136        # echo "[ ] No hay espacio sufiente en la CACHE, detectar que hacer con engine.cfg"  | tee -a $OGLOGSESSION $OGLOGFILE
137        case "$ACTIONCACHEFULL" in
138        NONE)
139                NEXTOPERATION=UNICAST
140        ;;
141        FORMAT)
142            echo "[51] $MSG_HELP_ogFormatCache "  | tee -a $OGLOGSESSION $OGLOGFILE
143            ogUnmountCache
144            ogFormatCache
145            ogMountCache
146            NEXTOPERATION=REPEAT
147        ;;
148        DELETE)
149            echo "[51] #MSG_HELP_ogDeleteTree $OGCAC$OGIMG/* "  | tee -a $OGLOGSESSION $OGLOGFILE
150            rm -fr  $OGCAC$OGIMG/*
151            NEXOPERATION=REPEAT
152        ;;
153        *)
154                echo "$MSG_WARNING: $MSG_ERR_CACHESIZE:  $2 = $FILESIZE > CACHE = $CACHESIZEFREE" | tee -a $OGLOGSESSION $OGLOGFILE
155                ogRaiseError $OG_ERR_CACHESIZE "CACHE" 2>&1 | tee -a $OGLOGSESSION $OGLOGFILE
156                exit ${PIPESTATUS[0]}
157        ;;
158        esac   
159fi
160
161# Comprobamos que imagen cache igual a la del repo. Si sincronizada no podemos comprobar.
162[ "$IMGSYNC" == "TRUE" ] || ogUpdateCacheIsNecesary $REPOSITORIO "$2"
163RETVAL=$?
164# si RETVAL=0 => actualizamos  si RETVAL=1 no actaulizasmo-exit 0  || si RETVAL>2 exit 1
165[ "$RETVAL" == "1" ] && exit 0
166[ "$RETVAL" -gt  "1" ] && exit 1
167
168ogMountCache >/dev/null
169
170## Si no existe, crear subdirectorio para el fichero en la cache.
171IMGDIR=$(ogGetParentPath CACHE "/$2")
172if [ $? != 0 ]; then
173    echo "[5] $MSG_HELP_ogMakeDir  \"$2 $(dirname "$2")." | tee -a $OGLOGSESSION $OGLOGFILE
174    ogMakeDir CACHE $(dirname "/$2")
175    IMGDIR=$(ogGetParentPath CACHE "/$2") || exit $?
176fi
177
178TIME1=$SECONDS
179
180case "$PROTOCOLO" in
181        TORRENT)
182                echo "ogCopyFile $1 $2.torrent absolute $OGCAC/$OGIMG" | tee -a $OGLOGSESSION $OGLOGFILE
183                # tiempos
184                timewait=$(expr $(printf '%d\n' 0x$(ogGetMacAddress | awk -F: '{print $5$6}')) \* 120 / 65535)                         
185                ogCopyFile $REPOSITORIO "$2.torrent" "$IMGDIR" 2>&1 | tee -a   $OGLOGCOMMAND
186                #TODO: comprobar que el tracker definido en el fichero es correcto.
187                #TODO comprobar que el fichero torrent está en cache
188                # retardamos el inicio -aleatorio de 0 a 120 segundos- al tracker para gestionar mas de +-40 equipos
189                P2PWAIT=$[ ( $RANDOM % 120 )  + 1 ]
190                echo "   [ ] $MSG_SCRIPTS_TASK_SLEEP :  $P2PWAIT seconds ogTorrentStart CACHE $2.torrent $4" | tee -a $OGLOGSESSION $OGLOGFILE
191                sleep $P2PWAIT
192                echo "   [  ] $MSG_SCRIPTS_TASK_START:  ogTorrentStart CACHE $2.torrent $4" | tee -a $OGLOGSESSION $OGLOGFILE
193                ogTorrentStart CACHE "$2.torrent" $4 2>&1 | tee -a   $OGLOGCOMMAND
194                RESUMEUPDATECACHE=$(grep -m 1 -B1 "Download" $OGLOGCOMMAND)
195        ;;
196        MULTICAST)
197                PORT=$(echo $OPTPROTOCOLO | cut -f1 -d":")
198                let PORTAUX=$PORT+1
199                echo "$MSG_SCRIPTS_UPDATECACHE_CHECKMCASTSESSION : $REPOIP:$PORTAUX:$PORT" | tee -a $OGLOGSESSION $OGLOGFILE
200                #TODO: ticket 379
201                NUMBER=$[ ( $RANDOM % 30 )  + 1 ]
202                sleep $NUMBER
203                #FIN TODO
204                if (nmap -n -sU -p $PORTAUX $REPOIP | grep open)
205                then
206                        ogMcastReceiverFile $PORT CACHE "$2" 2>&1  | tee -a   $OGLOGCOMMAND
207
208                else
209                    # TODO ticket 379 Realizar la petición basada en identificador de operacion
210                        echo "$MSG_SCRIPTS_TASK_START :  hose $REPOIP 2009 --out sh -c "echo -ne START_MULTICAST $2 $OPTPROTOCOLO"" | tee -a $OGLOGSESSION $OGLOGFILE
211                        hose $REPOIP 2009 --out sh -c "echo -ne START_MULTICAST $2 $OPTPROTOCOLO"
212                        #echo "espero y llamo a: ogMcastReceiverFile $PORT CACHE $2"
213                        sleep 10
214                        if (nmap -n -sU -p $PORTAUX $REPOIP | grep open)
215                        then
216                                ogMcastReceiverFile $PORT CACHE "$2" 2>&1  | tee -a   $OGLOGCOMMAND
217
218                        else
219                            echo "$MSG_SCRIPTS_TASK_ERR : hose $REPOIP 2009 --out sh -c echo -ne START_MULTICAST $2 $OPTPROTOCOLO" | tee -a $OGLOGSESSION $OGLOGFILE
220                            exit 1
221                        fi
222                fi
223                #cat $OGLOGCOMMAND.tmp | grep -B1 "Transfer complete"
224                sleep 5
225                #cat $OGLOGCOMMAND.tmp | grep -B1 "Transfer complete"
226                RESUMEUPDATECACHE=$(grep -m 1  -B1 "Transfer complete" $OGLOGCOMMAND.tmp)
227        ;;
228        UNICAST)
229                echo "unicast" | tee -a $OGLOGSESSION $OGLOGFILE
230                ogCopyFile $REPOSITORIO "$2" "$IMGDIR" 2>&1  | tee -a   $OGLOGCOMMAND
231                sleep 5
232                RESUMEUPDATECACHE=$(grep -m 1  "100%" $OGLOGCOMMAND.tmp)
233        ;;
234        RSYNC)
235           # Opciones de rsync
236           USERRSYNC="opengnsys"
237           PASSWORD=" --password-file=/scripts/passrsync "
238           OPTRSYNC=" --delete --progress "
239           [ "$ogrsyncz" ==  "true" ] && OPTRSYNC="z $OPTRSYNC"
240           [ "$ogrsyncw" ==  "true" ] && OPTRSYNC="w$OPTRSYNC"
241
242           if [ -d $REPOFILE ]; then
243                # Si es sincronizada tipo directorio.
244                [ -d "$OGCAC$OGIMG/$2" ] || mkdir "$OGCAC$OGIMG/$2"
245                echo "rsync -aHAX$OPTRSYNC  $USERRSYNC@$REPOIP::ogimages/$2/ $OGCAC$OGIMG/$2" |tee -a $OGLOGSESSION $OGLOGFILE
246                rsync -aHAX$OPTRSYNC  $PASSWORD "$USERRSYNC@$REPOIP::ogimages/$2/" "$OGCAC$OGIMG/$2" 2>&1  | egrep "^sent|^sending|^total%" >>  $OGLOGCOMMAND
247           else
248                # Si es sincronizada tipo archivo.
249                [ "${2##*.}" == "img" ] && IMGTYPE="img" ||  IMGTYPE="diff"
250                IMGNAME="${2%.img*}"
251
252                DIRMOUNT=$(ogGetMountImageDir "$IMGNAME" $IMGTYPE)
253                DIRLOCAL="/tmp/$DIRMOUNT"
254                mkdir "$DIRLOCAL" 2>/dev/null
255                echo "$MSG_SCRIPTS_UPDATECACHE_CHECKSIZEIMG"  | tee -a $OGLOGSESSION $OGLOGFILE
256
257                # Si la imagen no existe la creo
258                # Si la imagen del repositorio es mayor, redimensiono la imagen de cache
259                if [ "$CACHEFILE" == "" -o  $CACHEFILESIZE -lt $REALFILESIZE ]; then
260                   echo "$MSG_HELP_ogCreateFileImage" | tee -a $OGLOGSESSION $OGLOGFILE
261                   ogCreateFileImage CACHE "$IMGNAME" $IMGTYPE $REALFILESIZE
262                   TIMEAUX3=$[SECONDS-TIMEAUX3]
263                   echo "      $MSG_SCRIPTS_TASK_END, $MSG_SCRIPTS_TIME_PARTIAL: $[TIMEAUX3/60]m $[TIMEAUX3%60]s" | tee -a $OGLOGSESSION $OGLOGFILE
264                fi
265                # Montamos las imagenes para sincronizarlas. Quitamos / inicial.
266                ogMountImage CACHE  "${IMGNAME#\/}" $IMGTYPE >/dev/null
267                ogMountImage REPO  "${IMGNAME#\/}" $IMGTYPE >/dev/null
268                # Esperamos que se monte la imagen en el servidor
269                ogWaitMountImage  REPO  "$IMGNAME" $IMGTYPE
270                echo "$MSG_HELP_ogSyncCreate" | tee -a $OGLOGSESSION $OGLOGFILE
271                echo "rsync -aHAX$OPTRSYNC  $USERRSYNC@$REPOIP::ogimages/$DIRMOUNT/ $DIRLOCAL" |tee -a $OGLOGSESSION $OGLOGFILE
272                rsync -aHAX$OPTRSYNC  $PASSWORD "$USERRSYNC@$REPOIP::ogimages/$DIRMOUNT/" "$DIRLOCAL" 2>&1  | egrep "^sent|^sending|^total|%" >>   $OGLOGCOMMAND
273                # RETVAL="1" -> OK  RETVAL="2" -> error  # valores igual que ogUpdateCacheIsNecesary
274                [ ${PIPESTATUS[0]} == 0 ] && RETVAL="1"|| RETVAL="2"
275                # Desmonto las imagenes
276                ogUnmountImage CACHE  "$IMGNAME" $IMGTYPE
277                ogUnmountImage REPO  "$IMGNAME" $IMGTYPE
278           fi
279        ;;
280esac
281
282TIME1=$[SECONDS-TIME1]
283
284echo "   [ ] $RESUMEUPDATECACHE " | tee -a $OGLOGSESSION $OGLOGFILE
285echo "   [ ] $MSG_SCRIPTS_TIME_PARTIAL updateCache $[TIME1/60]m $[TIME1%60]s" | tee -a $OGLOGSESSION $OGLOGFILE
286echo "   [ ] $MSG_SCRIPTS_TASK_START $MSG_HELP_ogCalculateChecksum " | tee -a $OGLOGSESSION $OGLOGFILE
287TIME2=$SECONDS
288# Si es imagen sincronizada siempre da distinto md5. No podemos comprobar
289if [ "$IMGSYNC" == "TRUE" ]; then
290        # RETVAL="1" -> OK  RETVAL="2" -> error  # valores igual que ogUpdateCacheIsNecesary
291        [ $PROTOCOLO == "RSYNC" ] || RETVAL=1
292else
293        ogUpdateCacheIsNecesary $REPOSITORIO "$2"
294        RETVAL=$?
295fi
296
297if [ "$(ogGetCaller)" != "deployImage" ]; then
298        TIME2=$[SECONDS-TIME2]
299        echo "   [ ] $MSG_SCRIPTS_TIME_PARTIAL $MSG_HELP_ogCalculateChecksum $[TIME2/60]m $[TIME2%60]s" | tee -a $OGLOGSESSION $OGLOGFILE
300fi
301# si RETVAL=0 => actualizamos  si RETVAL=1 no actaulizamos-exit 0  || si RETVAL>2 exit 1
302[ "$RETVAL" == "0" ] && exit 1
303[ "$RETVAL" == "1" ] && exit 0
304[ "$RETVAL" -gt  "1" ] && exit 1
305
Note: See TracBrowser for help on using the repository browser.