#!/bin/bash #/** #@file Protocol.lib #@brief Librería o clase Protocol #@class Protocol #@brief Funciones para transmisión de datos #@version 1.0 #@warning License: GNU GPLv3+ #*/ ##################### FUNCIONES UNICAST ################ #/** # ogUcastSyntax #@brief Función para generar la instrucción de transferencia de datos unicast #@param 1 Tipo de operación [ SENDPARTITION RECEIVERPARTITION SENDFILE RECEIVERFILE ] #@param 2 Sesion Unicast #@param 3 Dispositivo (opción PARTITION) o fichero(opción FILE) que será enviado. #@param 4 Tools de clonación (opcion PARTITION) #@param 5 Tools de compresion (opcion PARTITION) #@return instrucción para ser ejecutada. #@exception OG_ERR_FORMAT formato incorrecto. #@exception OG_ERR_UCASTSYNTAXT formato de la sesion unicast incorrecta. #@note Requisitos: mbuffer #@todo: controlar que mbuffer esta disponible para los clientes. #@version 1.0 - #@author Antonio Doblas Viso, Universidad de Málaga #@date 2011/03/09 #*/ ## function ogUcastSyntax () { local PARM SESSION SESSIONPARM MODE PORTBASE PERROR local ADDRESS local TOOL LEVEL DEVICE MBUFFER SYNTAXSERVER SYNTAXCLIENT # Si se solicita, mostrar ayuda. if [ "$*" == "help" -o "$2" == "help" ]; then ogHelp "$FUNCNAME SENDPARTITION str_sessionSERVER str_device str_tools str_level" \ "$FUNCNAME RECEIVERPARTITION str_sessionCLIENT str_device str_tools str_level "\ "$FUNCNAME SENDFILE str_sessionSERVER str_file "\ "$FUNCNAME RECEIVERFILE str_sessionCLIENT str_file " \ "sessionServer syntax: portbase:ipCLIENT-1:ipCLIENT-2:ipCLIENT-N " \ "sessionServer example: 8000:172.17.36.11:172.17.36.12" \ "sessionClient syntax: portbase:ipMASTER " \ "sessionClient example: 8000:172.17.36.249 " return fi PERROR=0 # Error si no se reciben $PARM parámetros. echo "$1" | grep "PARTITION" > /dev/null && PARM=5 || PARM=3 [ "$#" -eq "$PARM" ] || ogRaiseError $OG_ERR_FORMAT "sin parametros"|| return $? # 1er param check ogCheckStringInGroup "$1" "SENDPARTITION sendpartition RECEIVERPARTITION receiverpartition SENDFILE sendfile RECEIVERFILE receiverfile" || ogRaiseError $OG_ERR_FORMAT "1st param: $1" || PERROR=1 #return $? # 2º param check echo "$1" | grep "SEND" > /dev/null && MODE=server || MODE=client ######### No controlamos el numero de elementos de la session unicast porque en el master es variable en numero #TODO: diferenciamos los paramatros especificos de la sessión unicast #SI: controlamos todos los parametros de la sessión unicast. #[ $MODE == "client" ] && SESSIONPARM=2 || SESSIONPARM=6 OIFS=$IFS; IFS=':' ; SESSION=($2); IFS=$OIFS #[[ ${#SESSION[*]} == $SESSIONPARM ]] || ogRaiseError $OG_ERR_FORMAT "parametros session multicast no completa" || PERROR=2# return $? #controlamos el PORTBASE de la sesion. Comun.- PORTBASE=${SESSION[0]} ogCheckStringInGroup ${SESSION[0]} "8000 8001 8002 8003 8004 8005" || ogRaiseError $OG_ERR_FORMAT "McastSession portbase ${SESSION[0]}" || PERROR=3 #return $? if [ $MODE == "server" ] then SIZEARRAY=${#SESSION[@]} for (( i = 1 ; i < $SIZEARRAY ; i++ )) do ADDRESS="$ADDRESS -O ${SESSION[$i]}:$PORTBASE" #echo " -O ${SESSION[$i]}:$PORTBASE" done else ADDRESS=${SESSION[1]}:${PORTBASE} fi #3er param check - que puede ser un dispositvo o un fichero. #ogGetPath "$3" > /dev/null || ogRaiseError $OG_ERR_NOTFOUND " device or file $3" || PERROR=9 #return $? DEVICE=$3 #4 y 5 param check . solo si es sobre particiones. if [ "$PARM" == "5" ] then # 4 param check ogCheckStringInGroup "$4" "partclone PARTCLONE partimage PARTIMAGE ntfsclone NTFSCLONE" || ogRaiseError $OG_ERR_NOTFOUND " herramienta $4 no soportada" || PERROR=10 #return $? TOOL=$4 ogCheckStringInGroup "$5" "lzop gzip LZOP GZIP 0 1" || ogRaiseError $OG_ERR_NOTFOUND " compresor $5 no valido" || PERROR=11 #return $? LEVEL=$5 fi [ "$PERROR" == "0" ] || ogRaiseError $OG_ERR_UCASTSYNTAXT " $PERROR" || return $? # Generamos la instrucción base de unicast -Envio,Recepcion- SYNTAXSERVER="mbuffer $ADDRESS" SYNTAXCLIENT="mbuffer -I $ADDRESS " case "$1" in SENDPARTITION) PROG1=`ogCreateImageSyntax $DEVICE " " $TOOL $LEVEL | awk -F"|" '{print $1 "|" $3}' | tr -d ">"` echo "$PROG1 | $SYNTAXSERVER" ;; RECEIVERPARTITION) COMPRESSOR=`ogRestoreImageSyntax " " $DEVICE $TOOL $LEVEL | awk -F\| '{print $1}'` TOOLS=`ogRestoreImageSyntax " " $DEVICE $TOOL $LEVEL | awk -F\| '{print $NF}'` echo "$SYNTAXCLIENT | $COMPRESSOR | $TOOLS " ;; SENDFILE) echo "$SYNTAXSERVER -i $3" ;; RECEIVERFILE) echo "$SYNTAXCLIENT -i $3" ;; *) ;; esac } #/** # ogUcastSendPartition #@brief Función para enviar el contenido de una partición a multiples particiones remotas usando UNICAST. #@param 1 disk #@param 2 partition #@param 3 sesionUcast #@param 4 tool image #@param 5 tool compresor #@return #@exception $OG_ERR_FORMAT #@exception $OG_ERR_UCASTSENDPARTITION #@note #@todo: ogIsLocked siempre devuelve 1 #@version 1.0 - #@author Antonio Doblas Viso, Universidad de Málaga #@date 2011/03/09 #*/ ## function ogUcastSendPartition () { # Variables locales local PART COMMAND RETVAL # Si se solicita, mostrar ayuda. if [ "$*" == "help" ]; then ogHelp "$FUNCNAME" "$FUNCNAME int_ndisk int_npart SessionUNICAST-SERVER tools compresor" \ "$FUNCNAME 1 1 8000:172.17.36.11:172.17.36.12 partclone lzop" return fi # Error si no se reciben 5 parámetros. [ "$#" == 5 ] || ogRaiseError $OG_ERR_FORMAT || return $? #chequeamos la particion. PART=$(ogDiskToDev "$1" "$2") || return $? #ogIsLocked $1 $2 || ogRaiseError $OG_ERR_LOCKED "$1,$2" || return $? ogUnmount $1 $2 #generamos la instrucción a ejecutar. COMMAND=`ogUcastSyntax SENDPARTITION "$3" $PART $4 $5` RETVAL=$? if [ "$RETVAL" -gt "0" ] then return $RETVAL else echo $COMMAND eval $COMMAND || ogRaiseError $OG_ERR_UCASTSENDPARTITION " "; return $? fi } #/** # ogUcastReceiverPartition #@brief Función para recibir directamente en la partición el contenido de un fichero imagen remoto enviado por UNICAST. #@param 1 disk #@param 2 partition #@param 3 session unicast #@return #@exception OG_ERR_FORMAT #@exception OG_ERR_UCASTRECEIVERPARTITION #@note #@todo: #@version 1.0 - Integración para OpenGNSys. #@author Antonio Doblas Viso, Universidad de Málaga #@date 2011/03/09 #*/ ## function ogUcastReceiverPartition () { # Variables locales local PART COMMAND RETVAL # Si se solicita, mostrar ayuda. if [ "$*" == "help" ]; then ogHelp "$FUNCNAME" "$FUNCNAME int_ndisk int_npart SessionMulticastCLIENT tools compresor" \ "$FUNCNAME 1 1 8000:ipMASTER partclone lzop" return fi # Error si no se reciben 5 parámetros. [ "$#" == 5 ] || ogRaiseError $OG_ERR_FORMAT || return $? #chequeamos la particion. PART=$(ogDiskToDev "$1" "$2") || return $? #ogIsLocked $1 $2 || ogRaiseError $OG_ERR_LOCKED "$1,$2" || return $? ogUnmount $1 $2 #generamos la instrucción a ejecutar. COMMAND=`ogUcastSyntax RECEIVERPARTITION "$3" $PART $4 $5` RETVAL=$? if [ "$RETVAL" -gt "0" ] then return $RETVAL else echo $COMMAND eval $COMMAND || ogRaiseError $OG_ERR_UCASTRECEIVERPARTITION " "; return $? fi } #/** # ogUcastSendFile [ str_repo | int_ndisk int_npart ] /Relative_path_file sessionMulticast #@brief Envía un fichero por unicast ORIGEN(fichero) DESTINO(sessionmulticast) #@param (2 parámetros) $1 path_aboluto_fichero $2 sesionMcast #@param (3 parámetros) $1 Contenedor REPO|CACHE $2 path_absoluto_fichero $3 sesionMulticast #@param (4 parámetros) $1 disk $2 particion $3 path_absoluto_fichero $4 sesionMulticast #@return #@exception OG_ERR_FORMAT formato incorrecto. #@exception $OG_ERR_NOTFOUND #@exception OG_ERR_UCASTSENDFILE #@note Requisitos: #@version 1.0 - Definición de Protocol.lib #@author Antonio Doblas Viso, Universidad de Málaga #@date 2010/05/09 #*/ ## # function ogUcastSendFile () { # Variables locales. local ARGS SOURCE TARGET COMMAND DEVICE RETVAL LOGFILE #ARGS usado para controlar ubicación de la sesion multicast # Si se solicita, mostrar ayuda. if [ "$*" == "help" ]; then ogHelp "$FUNCNAME [str_REPOSITORY] [int_ndisk int_npart] /Relative_path_file sesionMcast(puerto:ip:ip:ip)" \ "$FUNCNAME 1 1 /aula1/winxp.img 8000:172.17.36.11:172.17.36.12" \ "$FUNCNAME REPO /aula1/ubuntu.iso sesionUcast" \ "$FUNCNAME CACHE /aula1/winxp.img sesionUcast" \ "$FUNCNAME /opt/opengnsys/images/aula1/hd500.vmx sesionUcast" return fi ARGS="$@" case "$1" in /*) # Camino completo. */ (Comentrio Doxygen) SOURCE=$(ogGetPath "$1") ARG=2 DEVICE="$1" ;; [1-9]*) # ndisco npartición. SOURCE=$(ogGetPath "$1" "$2" "$3") ARG=4 DEVICE="$1 $2 $3" ;; *) # Otros: repo, cache, cdrom (no se permiten caminos relativos). SOURCE=$(ogGetPath "$1" "$2") ARG=3 DEVICE="$1 $2 " ;; esac # Error si no se reciben los argumentos ARG necesarios según la opcion. [ $# == "$ARG" ] || ogRaiseError $OG_ERR_FORMAT || return $? # Comprobar fichero origen ogGetPath $SOURCE &> /dev/null || ogRaiseError $OG_ERR_NOTFOUND " device or file $DEVICE not found" || return $? SESSION=${!ARG} #generamos la instrucción a ejecutar. COMMAND=`ogUcastSyntax "SENDFILE" "$SESSION" "$SOURCE"` RETVAL=$? if [ "$RETVAL" -gt "0" ] then return $RETVAL else echo $COMMAND eval $COMMAND || ogRaiseError $OG_ERR_UCASTSENDFILE " "; return $? fi } #/** # ogMcastSyntax #@brief Función para generar la instrucción de ejucción la transferencia de datos multicast #@param 1 Tipo de operación [ SENDPARTITION RECEIVERPARTITION SENDFILE RECEIVERFILE ] #@param 2 Sesión Mulicast #@param 3 Dispositivo (opción PARTITION) o fichero(opción FILE) que será enviado. #@param 4 Tools de clonación (opcion PARTITION) #@param 5 Tools de compresion (opcion PARTITION) #@return instrucción para ser ejecutada. #@exception OG_ERR_FORMAT formato incorrecto. #@exception OG_ERR_NOTEXEC #@exception OG_ERR_MCASTSYNTAXT #@note Requisitos: upd-cast 2009 o superior #@todo localvar check versionudp #@version 1.0 - #@author Antonio Doblas Viso, Universidad de Málaga #@date 2010/05/09 #*/ ## # function ogMcastSyntax () { local ISUDPCAST PARM SESSION SESSIONPARM MODE PORTBASE PERROR local METHOD ADDRESS BITRATE NCLIENTS MAXTIME CERROR local TOOL LEVEL DEVICE MBUFFER SYNTAXSERVER SYNTAXCLIENT # Si se solicita, mostrar ayuda. if [ "$*" == "help" -o "$2" == "help" ]; then ogHelp "$FUNCNAME SENDPARTITION str_sessionSERVER str_device str_tools str_level" \ "$FUNCNAME RECEIVERPARTITION str_sessionCLIENT str_device str_tools str_level "\ "$FUNCNAME SENDFILE str_sessionSERVER str_file "\ "$FUNCNAME RECEIVERFILE str_sessionCLIENT str_file " \ "sessionServer syntax: portbase:method:mcastaddress:speed:nclients:ntimeWaitingUntilNclients " \ "sessionServer example: 9000:full-duplex|half-duplex|broadcast:239.194.17.36:80M:50:60 " \ "sessionClient syntax: portbase " \ "sessionClient example: 9000 " return fi PERROR=0 #si no tenemos updcast o su version superior 2009 udpcast error. ISUDPCAST=$(udp-receiver --help 2>&1) echo $ISUDPCAST | grep start-timeout > /dev/null || ogRaiseError $OG_ERR_NOTEXEC "upd-cast no existe o version antigua -requerida 2009-"|| return $? # Error si no se reciben $PARM parámetros. echo "$1" | grep "PARTITION" > /dev/null && PARM=5 || PARM=3 [ "$#" -eq "$PARM" ] || ogRaiseError $OG_ERR_FORMAT "sin parametros"|| return $? # 1er param check ogCheckStringInGroup "$1" "SENDPARTITION sendpartition RECEIVERPARTITION receiverpartition SENDFILE sendfile RECEIVERFILE receiverfile" || ogRaiseError $OG_ERR_FORMAT "1st param: $1" || PERROR=1 #return $? # 2º param check echo "$1" | grep "SEND" > /dev/null && MODE=server || MODE=client #TODO: diferenciamos los paramatros especificos de la sessión multicast #SI: controlamos todos los parametros de la sessión multicast. [ $MODE == "client" ] && SESSIONPARM=1 || SESSIONPARM=6 OIFS=$IFS; IFS=':' ; SESSION=($2); IFS=$OIFS [[ ${#SESSION[*]} == $SESSIONPARM ]] || ogRaiseError $OG_ERR_FORMAT "parametros session multicast no completa" || PERROR=2# return $? #controlamos el PORTBASE de la sesion. Comun.- PORTBASE=${SESSION[0]} ogCheckStringInGroup ${SESSION[0]} "9000 9002 9004 9006 9008 9010" || ogRaiseError $OG_ERR_FORMAT "McastSession portbase ${SESSION[0]}" || PERROR=3 #return $? if [ $MODE == "server" ] then ogCheckStringInGroup ${SESSION[1]} "full-duplex FULL-DUPLEX half-duplex HALF-DUPLEX broadcast BROADCAST" || ogRaiseError $OG_ERR_FORMAT "McastSession method ${SESSION[1]}" || PERROR=4 #return $? METHOD=${SESSION[1]} ogCheckIpAddress ${SESSION[2]} || ogRaiseError $OG_ERR_FORMAT "McastSession address ${SESSION[2]}" || PERROR=5 #return $? ADDRESS=${SESSION[2]} ogCheckStringInReg ${SESSION[3]} "^[0-9]{1,2}\M$" || ogRaiseError $OG_ERR_FORMAT "McastSession bitrate ${SESSION[3]}" || PERROR=6 # return $? BITRATE=${SESSION[3]} ogCheckStringInReg ${SESSION[4]} "^[0-9]{1,10}$" || ogRaiseError $OG_ERR_FORMAT "McastSession nclients ${SESSION[4]}" || PERROR=7 # return $? NCLIENTS=${SESSION[4]} ogCheckStringInReg ${SESSION[5]} "^[0-9]{1,10}$" || ogRaiseError $OG_ERR_FORMAT "McastSession maxtime ${SESSION[5]}" || PERROR=8 # return $? MAXTIME=${SESSION[5]} fi #3er param check - que puede ser un dispositvo o un fichero. #ogGetPath "$3" > /dev/null || ogRaiseError $OG_ERR_NOTFOUND " device or file $3" || PERROR=9 #return $? DEVICE=$3 #4 y 5 param check . solo si es sobre particiones. if [ "$PARM" == "5" ] then # 4 param check ogCheckStringInGroup "$4" "partclone PARTCLONE partimage PARTIMAGE ntfsclone NTFSCLONE" || ogRaiseError $OG_ERR_NOTFOUND " herramienta $4 no soportada" || PERROR=10 #return $? TOOL=$4 ogCheckStringInGroup "$5" "lzop LZOP gzip GZIP 0 1" || ogRaiseError $OG_ERR_NOTFOUND " compresor $5 no valido" || PERROR=11 #return $? LEVEL=$5 fi if [ "$PERROR" != "0" ]; then ogRaiseError $OG_ERR_MCASTSYNTAXT " $PERROR"; return $? fi # Valores estandar no configurables. CERROR="8x8/128" # opción del usuo de tuberia intermedia en memoria mbuffer. which mbuffer > /dev/null && MBUFFER=" --pipe 'mbuffer -q -m 20M' " # Generamos la instrucción base de multicast -Envio,Recepcion- SYNTAXSERVER="udp-sender $MBUFFER --nokbd --portbase $PORTBASE --$METHOD --mcast-data-address $ADDRESS --fec $CERROR --max-bitrate $BITRATE --ttl 16 --min-clients $NCLIENTS --max-wait $MAXTIME --autostart $MAXTIME --log /tmp/mcast.log" SYNTAXCLIENT="udp-receiver $MBUFFER --portbase $PORTBASE " case "$1" in SENDPARTITION) PROG1=`ogCreateImageSyntax $DEVICE " " $TOOL $LEVEL | awk -F"|" '{print $1 "|" $3}' | tr -d ">"` echo "$PROG1 | $SYNTAXSERVER" ;; RECEIVERPARTITION) COMPRESSOR=`ogRestoreImageSyntax " " $DEVICE $TOOL $LEVEL | awk -F\| '{print $1}'` TOOLS=`ogRestoreImageSyntax " " $DEVICE $TOOL $LEVEL | awk -F\| '{print $NF}'` echo "$SYNTAXCLIENT | $COMPRESSOR | $TOOLS " ;; SENDFILE) echo "$SYNTAXSERVER --file $3" ;; RECEIVERFILE) echo "$SYNTAXCLIENT --file $3" ;; *) ;; esac } #/** # ogMcastSendFile [ str_repo | int_ndisk int_npart ] /Relative_path_file sessionMulticast #@brief Envía un fichero por multicast ORIGEN(fichero) DESTINO(sessionmulticast) #@param (2 parámetros) $1 path_aboluto_fichero $2 sesionMcast #@param (3 parámetros) $1 Contenedor REPO|CACHE $2 path_absoluto_fichero $3 sesionMulticast #@param (4 parámetros) $1 disk $2 particion $3 path_absoluto_fichero $4 sesionMulticast #@return #@exception OG_ERR_FORMAT formato incorrecto. #@exception $OG_ERR_NOTFOUND #@exception OG_ERR_MCASTSENDFILE #@note Requisitos: #@version 1.0 - Definición de Protocol.lib #@author Antonio Doblas Viso, Universidad de Málaga #@date 2010/05/09 #*/ ## # function ogMcastSendFile () { # Variables locales. local ARGS SOURCE TARGET COMMAND DEVICE RETVAL LOGFILE #LOGFILE="/tmp/mcast.log" #ARGS usado para controlar ubicación de la sesion multicast # Si se solicita, mostrar ayuda. if [ "$*" == "help" ]; then ogHelp "$FUNCNAME [str_REPOSITORY] [int_ndisk int_npart] /Relative_path_file sesionMcast" \ "$FUNCNAME 1 1 /aula1/winxp.img sesionMcast" \ "$FUNCNAME REPO /aula1/ubuntu.iso sesionMcast" \ "$FUNCNAME CACHE /aula1/winxp.img sesionMcast" \ "$FUNCNAME /opt/opengnsys/images/aula1/hd500.vmx sesionMcast" return fi ARGS="$@" case "$1" in /*) # Camino completo. */ (Comentrio Doxygen) SOURCE=$(ogGetPath "$1") ARG=2 DEVICE="$1" ;; [1-9]*) # ndisco npartición. SOURCE=$(ogGetPath "$1" "$2" "$3") ARG=4 DEVICE="$1 $2 $3" ;; *) # Otros: repo, cache, cdrom (no se permiten caminos relativos). SOURCE=$(ogGetPath "$1" "$2") ARG=3 DEVICE="$1 $2 " ;; esac # Error si no se reciben los argumentos ARG necesarios según la opcion. [ $# == "$ARG" ] || ogRaiseError $OG_ERR_FORMAT || return $? # Comprobar fichero origen ogGetPath $SOURCE &> /dev/null || ogRaiseError $OG_ERR_NOTFOUND " device or file $DEVICE not found" || return $? # eliminamos ficheros antiguos de log #rm $LOGFILE SESSION=${!ARG} #generamos la instrucción a ejecutar. COMMAND=`ogMcastSyntax "SENDFILE" "$SESSION" "$SOURCE"` RETVAL=$? if [ "$RETVAL" -gt "0" ] then return $RETVAL else echo $COMMAND eval $COMMAND || ogRaiseError $OG_ERR_MCASTSENDFILE " "; return $? #[ -s "$LOGFILE" ] || return 21 fi } #/** # ogMcastReceiverFile sesion Multicast [ str_repo | int_ndisk int_npart ] /Relative_path_file #@brief Recibe un fichero multicast ORIGEN(sesionmulticast) DESTINO(fichero) #@param (2 parámetros) $1 sesionMcastCLIENT $2 path_aboluto_fichero_destino #@param (3 parámetros) $1 sesionMcastCLIENT $2 Contenedor REPO|CACHE $3 path_absoluto_fichero_destino #@param (4 parámetros) $1 sesionMcastCLIENT $2 disk $3 particion $4 path_absoluto_fichero_destino #@return #@exception OG_ERR_FORMAT formato incorrecto. #@exception $OG_ERR_MCASTRECEIVERFILE #@note Requisitos: #@version 1.0 - Definición de Protocol.lib #@author Antonio Doblas Viso, Universidad de Málaga #@date 2010/05/09 #*/ ## # function ogMcastReceiverFile () { # Variables locales. local ARGS ARG TARGETDIR TARGETFILE # Si se solicita, mostrar ayuda. if [ "$*" == "help" ]; then ogHelp "$FUNCNAME" "$FUNCNAME [ str_portMcast] [ [Relative_path_file] | [str_REPOSITORY path_file] | [int_ndisk int_npart path_file ] ]" \ "$FUNCNAME 9000 /PS1_PH1.img" \ "$FUNCNAME 9000 CACHE /aula1/PS2_PH4.img" \ "$FUNCNAME 9000 1 1 /isos/linux.iso" return fi ARGS="$@" case "$2" in /*) # Camino completo. */ (Comentrio Doxygen) TARGETDIR=$(ogGetParentPath "$2") ARG=2 ;; [1-9]*) # ndisco npartición. TARGETDIR=$(ogGetParentPath "$2" "$3" "$4") ARG=4 ;; *) # Otros: repo, cache, cdrom (no se permiten caminos relativos). TARGETDIR=$(ogGetParentPath "$2" "$3") ARG=3 ;; esac # Error si no se reciben los argumentos ARG necesarios según la opcion. [ $# == "$ARG" ] || ogRaiseError $OG_ERR_FORMAT "Parametros no admitidos"|| return $? #obtenemos el nombre del fichero a descargar. TARGETFILE=`basename ${!ARG}` #generamos la instrucción a ejecutar. COMMAND=`ogMcastSyntax RECEIVERFILE "$1" $TARGETDIR/$TARGETFILE ` RETVAL=$? if [ "$RETVAL" -gt "0" ] then return $RETVAL else echo $COMMAND eval $COMMAND || ogRaiseError $OG_ERR_MCASTRECEIVERFILE " "; return $? #[ -s "$LOGFILE" ] || return 21 fi } #/** # ogMcastSendPartition #@brief Función para enviar el contenido de una partición a multiples particiones remotas. #@param 1 disk #@param 2 partition #@param 3 session multicast #@param 4 tool clone #@param 5 tool compressor #@return #@exception OG_ERR_FORMAT #@exception OG_ERR_MCASTSENDPARTITION #@note #@todo: ogIsLocked siempre devuelve 1. crear ticket #@version 1.0 - Definición de Protocol.lib #@author Antonio Doblas Viso, Universidad de Málaga #@date 2010/05/09 #*/ ## function ogMcastSendPartition () { # Variables locales local PART COMMAND RETVAL # Si se solicita, mostrar ayuda. if [ "$*" == "help" ]; then ogHelp "$FUNCNAME" "$FUNCNAME int_ndisk int_npart SessionMulticastSERVER tools compresor" \ "$FUNCNAME 1 1 9000:full-duplex:239.194.37.31:50M:20:2 partclone lzop" return fi # Error si no se reciben 5 parámetros. [ "$#" == 5 ] || ogRaiseError $OG_ERR_FORMAT || return $? #chequeamos la particion. PART=$(ogDiskToDev "$1" "$2") || return $? #ogIsLocked $1 $2 || ogRaiseError $OG_ERR_LOCKED "$1,$2" || return $? ogUnmount $1 $2 #generamos la instrucción a ejecutar. COMMAND=`ogMcastSyntax SENDPARTITION "$3" $PART $4 $5` RETVAL=$? if [ "$RETVAL" -gt "0" ] then return $RETVAL else echo $COMMAND eval $COMMAND || ogRaiseError $OG_ERR_MCASTSENDPARTITION " "; return $? fi } #/** # ogMcastReceiverPartition #@brief Función para recibir directamente en la partición el contenido de un fichero imagen remoto enviado por multicast. #@param 1 disk #@param 2 partition #@param 3 session multicast #@param 4 tool clone #@param 5 tool compressor #@return #@exception $OG_ERR_FORMAT #@note #@todo: #@version 1.0 - Definición de Protocol.lib #@author Antonio Doblas Viso, Universidad de Málaga #@date 2010/05/09 #*/ ## function ogMcastReceiverPartition () { # Variables locales local PART COMMAND RETVAL # Si se solicita, mostrar ayuda. if [ "$*" == "help" ]; then ogHelp "$FUNCNAME" "$FUNCNAME int_ndisk int_npart SessionMulticastCLIENT tools compresor" \ "$FUNCNAME 1 1 9000 partclone lzop" return fi # Error si no se reciben 5 parámetros. [ "$#" == 5 ] || ogRaiseError $OG_ERR_FORMAT || return $? #chequeamos la particion. PART=$(ogDiskToDev "$1" "$2") || return $? #ogIsLocked $1 $2 || ogRaiseError $OG_ERR_LOCKED "$1,$2" || return $? ogUnmount $1 $2 #generamos la instrucción a ejecutar. COMMAND=`ogMcastSyntax RECEIVERPARTITION "$3" $PART $4 $5` RETVAL=$? if [ "$RETVAL" -gt "0" ] then return $RETVAL else echo $COMMAND eval $COMMAND || ogRaiseError $OG_ERR_MCASTSENDPARTITION " "; return $? fi } ########################################## ############## funciones torrent #/** # ogTorrentStart [ str_repo | int_ndisk int_npart ] Relative_path_file.torrent | SessionProtocol #@brief Función iniciar P2P - requiere un tracker para todos los modos, y un seeder para los modos peer y leecher y los ficheros .torrent. #@param str_pathDirectory str_Relative_path_file #@param int_disk int_partition str_Relative_path_file #@param str_REPOSITORY(CACHE - LOCAL) str_Relative_path_file #@param (2 parámetros) $1 path_aboluto_fichero_torrent $2 Parametros_Session_Torrent #@param (3 parámetros) $1 Contenedor CACHE $2 path_absoluto_fichero_Torrent $3 Parametros_Session_Torrent #@param (4 parámetros) $1 disk $2 particion $3 path_absoluto_fichero_Torrent 4$ Parametros_Session_Torrent #@return #@note #@todo: #@version 0.1 - Integración para OpenGNSys. #@author Antonio J. Doblas Viso. Universidad de Málaga #@date #@version 0.2 - Chequeo del tamaño de imagen descargado. #@author Irina . Univesidad de Sevilla. #@date #@version 0.3 - Control de los modos de operación, y estado de descarga. #@author Antonio J. Doblas Viso. Univesidad de Málaga. #@date #@version 0.4 - Enviadando señal (2) a ctorrent permiendo la comunicación final con tracker #@author Antonio J. Doblas Viso. Univesidad de Málaga. #@date #*/ ## #protocoloTORRENT mode:time #mode=seeder -> Dejar el equipo seedeando hasta que transcurra el tiempo indicado o un kill desde consola, #mode=peer -> seedear mientras descarga #mode=leecher -> NO seedear mientras descarga #time tiempo que una vez descargada la imagen queremos dejar al cliente como seeder. function ogTorrentStart () { # Variables locales. local ARGS ARG TARGETDIR TARGETFILE SESSION ERROR ERROR=0 # Si se solicita, mostrar ayuda. if [ "$*" == "help" ]; then ogHelp "$FUNCNAME $FUNCNAME [ str_repo] [ [Relative_path_fileTORRENT] | [str_REPOSITORY path_fileTORRENT] | [int_ndisk int_npart path_fileTORRENT ] ] SessionTorrent" \ "$FUNCNAME CACHE /PS1_PH1.img.torrent seeder:10000" \ "$FUNCNAME /opt/opengnsys/cache/linux.iso peer:60" \ "$FUNCNAME 1 1 /linux.iso.torrent leecher:60" return fi case "$1" in /*) # Camino completo. */ (Comentrio Doxygen) SOURCE=$(ogGetPath "$1") ARG=2 ;; [1-9]*) # ndisco npartición. SOURCE=$(ogGetPath "$1" "$2" "$3") ARG=4 ;; *) # Otros: Solo cache (no se permiten caminos relativos). SOURCE=$(ogGetPath "$1" "$2" 2>/dev/null) ARG=3 ;; esac # Error si no se reciben los argumentos ARG necesarios según la opcion. [ $# == "$ARG" ] || ogRaiseError $OG_ERR_FORMAT "Parametros no admitidos"|| return $? #controlar source, que no se haga al repo. if [ $ARG == "3" ] then ogCheckStringInGroup "$1" "CACHE cache" || ogRaiseError $OG_ERR_FORMAT "La descarga torrent solo se hace desde local, copia el torrent a la cache y realiza la operación desde esa ubicación" || return $? fi if [ $ARG == "2" ] then if `ogCheckStringInReg "$1" "^/opt/opengnsys/images"` then ogRaiseError $OG_ERR_FORMAT "La descarga torrent solo se hace desde local, copia el torrent a la cache y realiza la operación desde esa ubicación" return $? fi fi #controlar el source, para que sea un torrent. ctorrent -x ${SOURCE} &> /dev/null; [ $? -eq 0 ] || ogRaiseError $OG_ERR_NOTFOUND "${ARGS% $*}" || return $? TARGET=`echo $SOURCE | awk -F.torrent '{print $1}'` DIRSOURCE=`ogGetParentPath $SOURCE` cd $DIRSOURCE SESSION=${!ARG} OIFS=$IFS; IFS=':' ; SESSION=($SESSION); IFS=$OIFS [[ ${#SESSION[*]} == 2 ]] || ogRaiseError $OG_ERR_FORMAT "parametros session Torrent no completa: modo:tiempo" || ERROR=1# return $? #controlamos el modo de operación del cliente- ogCheckStringInGroup ${SESSION[0]} "seeder SEEDER peer PEER leecher LEECHER" || ogRaiseError $OG_ERR_FORMAT "valor modo Torrent no valido ${SESSION[0]}" || ERROR=1 #return $? MODE=${SESSION[0]} #contolamos el tiempo para el seeder o una vez descargada la imagen como peer o leecher. ogCheckStringInReg ${SESSION[1]} "^[0-9]{1,10}$" || ogRaiseError $OG_ERR_FORMAT "valor tiempo no valido ${SESSION[1]}" || ERROR=1 # return $? TIME=${SESSION[1]} # si ha habido error en el control de parametros error. [ "$ERROR" == "1" ] && return 1 #SYNTAXSEEDER="echo MODE seeder ctorrent ; (sleep \$TIME && kill -9 \`pidof ctorrent\`) & ; ctorrent \${SOURCE}" # si No fichero .bf, y Si fichero destino imagen ya descargada y su chequeo fue comprobado en su descarga inicial. if [ ! -f ${SOURCE}.bf -a -f ${TARGET} ] then echo "imagen ya descargada" case "$MODE" in seeder|SEEDER) echo "MODE seeder ctorrent" #### ${SOURCE} -X 'sleep $TIME; kill -9 \$(pidof ctorrent)' -C 100" (sleep $TIME && kill -2 `pidof ctorrent`) & ctorrent -f ${SOURCE} esac return 0 fi #Si no existe bf ni fichero destino descarga inicial. if [ ! -f ${SOURCE}.bf -a ! -f ${TARGET} ] then OPTION=DOWNLOAD echo "descarga inicial" fi # Si fichero bf descarga anterior no completada -. if [ -f ${SOURCE}.bf -a -f ${TARGET} ] then echo Continuar con Descargar inicial no terminada. OPTION=DOWNLOAD fi if [ "$OPTION" == "DOWNLOAD" ] then case "$MODE" in peer|PEER) echo "Donwloading Torrent as peer" ### echo "ctorrent -X 'sleep $TIME; kill -9 \$(pidof ctorrent)' -C 100 $SOURCE -s $TARGET -b ${SOURCE}.bf" ctorrent -f -X "sleep 15; kill -2 \$(pidof ctorrent)" -C 100 ${SOURCE} -s ${TARGET} -b ${SOURCE}.bf ;; leecher|LEECHER) echo "Donwloading Torrent as leecher" # echo "ctorrent ${SOURCE} -X 'sleep $TIME; kill -9 \$(pidof ctorrent)' -C 100 -U 0" ctorrent ${SOURCE} -X "sleep $TIME; kill -2 \$(pidof ctorrent)" -C 100 -U 0 ;; seeder|SEEDER) echo "MODE seeder ctorrent" #### ${SOURCE} -X 'sleep $TIME; kill -9 \$(pidof ctorrent)' -C 100" ctorrent -f -X "sleep $TIME; kill -2 \$(pidof ctorrent)" -C 100 ${SOURCE} -s ${TARGET} -b ${SOURCE}.bf ;; esac fi cd /tmp } #/** # ogCreateTorrent [ str_repo | int_ndisk int_npart ] Relative_path_file #@brief Función para crear el fichero torrent. #@param str_pathDirectory str_Relative_path_file #@param int_disk int_partition str_Relative_path_file #@param str_REPOSITORY(CACHE - LOCAL) str_Relative_path_file #@return #@exception OG_ERR_FORMAT Formato incorrecto. #@exception OG_ERR_NOTFOUND Disco o particion no corresponden con un dispositivo. #@exception OG_ERR_PARTITION Tipo de partición desconocido o no se puede montar. #@exception OG_ERR_NOTOS La partición no tiene instalado un sistema operativo. #@note #@version 0.1 - Integración para OpenGNSys. #@author Antonio J. Doblas Viso. Universidad de Málaga #@date #@version 0.2 - Integración para btlaunch. #@author Irina . Univesidad de Sevilla. #@date #*/ ## function ogCreateTorrent () { # Variables locales. local ARGS ARG SOURCE EXT IPTORRENT # Si se solicita, mostrar ayuda. if [ "$*" == "help" ]; then ogHelp "$FUNCNAME" "$FUNCNAME [str_REPOSITORY] [int_ndisk int_npart] Relative_path_file IpBttrack" \ "$FUNCNAME 1 1 /aula1/winxp 10.1.15.23" \ "$FUNCNAME REPO /aula1/winxp 10.1.15.45" return fi # Error si se quiere crear el fichero en cache y no existe [ "$1" != "CACHE" ] || `ogFindCache >/dev/null` || ogRaiseError $OG_ERR_NOTFOUND "CACHE"|| return $? case "$1" in /*) # Camino completo. */ (Comentrio Doxygen) SOURCE=$(ogGetPath "$1.img") ARG=2 ;; [1-9]*) # ndisco npartición. SOURCE=$(ogGetPath "$1" "$2" "$3.img") ARG=4 ;; *) # Otros: repo, cache, cdrom (no se permiten caminos relativos). EXT=$(ogGetImageType "$1" "$2") SOURCE=$(ogGetPath "$1" "$2.$EXT") ARG=3 ;; esac # Error si no se reciben los argumentos ARG necesarios según la opcion. [ $# -eq "$ARG" ] || ogRaiseError $OG_ERR_FORMAT || return $? # Error si no existe la imagen [ $SOURCE ] || ogRaiseError $OG_ERR_NOTFOUND || return $? [ -r $SOURCE.torrent ] && mv "$SOURCE.torrent" "$SOURCE.torrent.ant" && echo "Esperamos que se refresque el servidor" && sleep 20 IPTORRENT="${!#}" # Si ponemos el path completo cuando creamos el fichero torrent da error cd `dirname $SOURCE` echo ctorrent -t `basename $SOURCE` -u http://$IPTORRENT:6969/announce -s $SOURCE.torrent ctorrent -t `basename $SOURCE` -u http://$IPTORRENT:6969/announce -s $SOURCE.torrent } #/** # ogUpdateCacheIsNecesary [ str_repo ] Relative_path_file_OGIMG_with_/ #@brief Comprueba que el fichero que se desea almacenar en la cache del cliente, no esta. #@param 1 str_REPO #@param 2 str_Relative_path_file_OGIMG_with_/ #@return 0 si es necesario actualizar el fichero. #@return 1 si la imagen ya esta en la cache, por lo tanto no es necesario actualizar el fichero #@note #@todo: Proceso en el caso de que el fichero tenga el mismo nombre, pero su contenido sea distinto. #@todo: Se dejan mensajes mientras se confirma su funcionamiento. #@version 0.1 - Integracion para OpenGNSys. #@author Antonio J. Doblas Viso. Universidad de Malaga #@date #*/ ## function ogUpdateCacheIsNecesary () { # Variables locales. local ERROR SOURCE CACHE FILESOURCE MD5SOURCE FILETARGET MD5TARGET ERROR=0 # Si se solicita, mostrar ayuda. if [ "$*" == "help" ]; then ogHelp "$FUNCNAME $FUNCNAME [ str_repo] [ [Relative_path_image] " \ "$FUNCNAME REPO /PS1_PH1.img" \ "$FUNCNAME REPO /ogclient.sqfs" return fi #TODO: return 0->true, 1->false; si error, aunque sintaxis devuelve > 1 # Error si no se reciben los argumentos ARG necesarios según la opcion. #[ $# == "2" ] || ogRaiseError $OG_ERR_FORMAT "Parametros no admitidos"|| return $? #ogCheckStringInGroup "$1" "REPO repo" || ogRaiseError $OG_ERR_FORMAT "El contendor $1 no es valido, solo se admite REPO" || return $? [ $# == "2" ] || return $(ogRaiseError $OG_ERR_NOTFOUND " $1 $2"; echo $?) ogCheckStringInGroup "$1" "REPO repo" || return $(ogRaiseError $OG_ERR_NOTFOUND " $1 $2"; echo $?) FILESOURCE=`ogGetPath $1 $2` || return $(ogRaiseError $OG_ERR_NOTFOUND " $1 $2"; echo $?) #echo "paso 1. si no existe la imagen, confirmamos que es necesaria la actualizacion de la cache." FILETARGET=`ogGetPath CACHE $2` if [ -z $FILETARGET ] then # borramos el fichero bf del torrent, en el caso de que se hubiese quedado de algun proceso fallido ogDeleteFile CACHE /$2.torrent.bf &> /dev/null ogDeleteFile CACHE /$2.sum &> /dev/null echo "TRUE=0, es necesario actualizar. Paso 1, la cache no contiene esa imagen " return 0 fi #echo "Paso 2. Comprobamos que la imagen no estuviese en un proceso previo torrent" if ogGetPath $FILETARGET.torrent.bf > /dev/null then #TODO: comprobar los md5 para asegurarnos que la imagen es la misma. echo "TRUE=0, es necesario actualizar. Paso 2, la imagen esta en un estado de descarga torrent interrumpido" return 0 fi ## En este punto la imagen en el repo y en la cache se llaman igual, #echo "paso 4. recuperamos o calculamos los md5 de los ficheros" if [ -f $FILESOURCE.sum ] then # echo "leyendo el sum del fichero sum del repo" MD5SOURCE=$(cat $FILESOURCE.sum) else # echo "calculando el sun del repo" MD5SOURCE=$(md5sum $FILESOURCE | cut -f1 -d" ") fi if [ -f $FILETARGET.sum ] then #echo "leyendo el sum de la cache" MD5TARGET=$(cat $FILETARGET.sum) else #echo "calculando el sum de la cache" md5sum $FILETARGET | cut -f1 -d" " > $FILETARGET.sum MD5TARGET=$(cat $FILETARGET.sum) fi #echo "Paso 5. comparamos los md5" #TODO: que hacer cuando los md5 son distintos. Por defecto borrar. if [ "$MD5SOURCE" == "$MD5TARGET" ] then echo "FALSE=1, No es neceario actualizar. Paso5.A la imagen esta en cache" return 1 else echo "TRUE=0, Si es necesario actualizar. paso 5.b la imagen en cache es distinta, borramos la imagen anterior y devolvemos 0 para confirmar la actualizacion" rm $FILETARGET return 0 fi }