diff options
| -rw-r--r-- | admin/Sources/Includes/Database.cpp | 203 | ||||
| -rw-r--r-- | admin/Sources/Includes/Database.h | 61 | ||||
| -rw-r--r-- | admin/Sources/Includes/ogAdmLib.c | 1074 | ||||
| -rw-r--r-- | admin/Sources/Includes/ogAdmLib.h | 319 |
4 files changed, 0 insertions, 1657 deletions
diff --git a/admin/Sources/Includes/Database.cpp b/admin/Sources/Includes/Database.cpp deleted file mode 100644 index 84add9ce..00000000 --- a/admin/Sources/Includes/Database.cpp +++ /dev/null @@ -1,203 +0,0 @@ -// ******************************************************************************************************** -// Nombre del fichero: Database.cpp -// Autor: José Manuel Alonso (E.T.S.I.I.) Universidad de Sevilla -// Fecha Creación: Marzo-2010 -// Fecha Última modificación: Marzo-2010 -// Descripción: -// Fichero de implementación de la clase Database para funciones de manipulación -// de bases de datos sobre un Servidor Mysql -// ******************************************************************************************************** -#include "Database.h" -// __________________________________________________________________________ -void ErrorHandler(Herror hr, char* ErrStr) -{ - sprintf(ErrStr,"Error:\n"); - sprintf(ErrStr,"%sCode = %d\n",ErrStr ,hr.nError); - sprintf(ErrStr,"%sDescription = %s",ErrStr, (char*) hr.dError); -} -// __________________________________________________________________________ -Database::Database() -{ - m_Cnn=NULL; - sprintf(m_ErrStr,"NULL POINTER"); -} -// __________________________________________________________________________ -void Database::GetErrorErrStr(char* ErrStr) -{ - sprintf(ErrStr,"%s",m_ErrStr); -} -// __________________________________________________________________________ -void Table::GetErrorErrStr(char* ErrStr) -{ - sprintf(ErrStr,"%s",m_ErrStr); -} -// __________________________________________________________________________ -bool Database::Open(char* UserName, char* Pwd,char* server,char*Bd) -{ - Herror hr; - m_Cnn=mysql_init(NULL); - if(m_Cnn==NULL){ - hr.nError=0; - strcpy(hr.dError,"Error en la Creación del objeto MYSQL"); - ErrorHandler(hr,m_ErrStr); - return(false); // Fallo de inicializaci� - } - - if(!mysql_real_connect(m_Cnn, server,UserName,Pwd,Bd, MYSQL_PORT,NULL,0)){ - mysql_error(m_Cnn); - hr.nError=mysql_errno(m_Cnn); - strcpy(hr.dError,mysql_error(m_Cnn)); - ErrorHandler(hr,m_ErrStr); - return(false); // Fallo de conexi� - } - hr.nError=0; - strcpy(hr.dError,"Success"); - ErrorHandler(hr,m_ErrStr); - return (true); -} -// __________________________________________________________________________ -bool Database::Close() -{ - mysql_close(m_Cnn); - return(true); -} -// __________________________________________________________________________ -bool Database::Execute(char* CmdStr) -{ - Herror hr; - if (mysql_query(m_Cnn,CmdStr)){ // Ejecuta la consulta - mysql_error(m_Cnn); - hr.nError=mysql_errno(m_Cnn); - strcpy(hr.dError,mysql_error(m_Cnn)); - ErrorHandler(hr,m_ErrStr); - mysql_close(m_Cnn); - return(false); // Fallo de conexión - } - hr.nError=0; - strcpy(hr.dError,"Success"); - ErrorHandler(hr,m_ErrStr); - return (true); -} -// __________________________________________________________________________ -bool Database::Execute(char* CmdStr, Table& Tbl) -{ - Herror hr; - if (mysql_query(m_Cnn,CmdStr)) { // Ejecuta la consulta - mysql_error(m_Cnn); - hr.nError=mysql_errno(m_Cnn); - strcpy(hr.dError,mysql_error(m_Cnn)); - ErrorHandler(hr,m_ErrStr); - mysql_close(m_Cnn); - return(false); // Fallo de conexi� - } - - hr.nError=0; - strcpy(hr.dError,"Success"); - ErrorHandler(hr,m_ErrStr); - - Tbl.m_Rec = mysql_store_result(m_Cnn) ; // Toma el recordset - if(Tbl.m_Rec){ - Tbl.row=mysql_fetch_row(Tbl.m_Rec); - Tbl.fields = mysql_fetch_fields(Tbl.m_Rec); - Tbl.num_fields = mysql_num_fields(Tbl.m_Rec); - Tbl.numreg=mysql_num_rows(Tbl.m_Rec); - Tbl.eof=Tbl.numreg==0; // Consulta vacia - } - return (true); -} -// __________________________________________________________________________ -void Database::liberaResult (Table& Tbl) { - //Free resources after mysql_store_result - mysql_free_result(Tbl.m_Rec); -} -// __________________________________________________________________________ -Table::Table() -{ - m_Rec=NULL; -} -// __________________________________________________________________________ -bool Table::ISEOF() -{ - return(eof); -} -// __________________________________________________________________________ -bool Table::Get(const char* FieldName, char *FieldValue) -{ - char * aux; - aux=tomadato(FieldName); - if(aux) - strcpy(FieldValue,aux); - else - strcpy(FieldValue,""); - return(true); -} -// __________________________________________________________________________ -bool Table::Get(const char* FieldName,int &FieldValue) -{ - char *aux; - aux=tomadato(FieldName); - if(aux) - FieldValue=atoi(aux); - else - FieldValue=0; - return(true); -} -// __________________________________________________________________________ -bool Table::Get(const char* FieldName,char &FieldValue) -{ - char *aux; - aux=tomadato(FieldName); - FieldValue=aux[0]; - return(true); -} -// __________________________________________________________________________ -char* Table::tomadato(const char* FieldName) -{ - Herror hr; - unsigned int i; - - for(i = 0; i < num_fields; i++){ - if(strcmp((char*)fields[i].name,FieldName)==0){ - sprintf(m_ErrStr,"Success"); - return((char*)row[i]); - } - } - hr.nError=-1; - strcpy(hr.dError,"El nombre del campo no existe"); - ErrorHandler(hr,m_ErrStr); - return(NULL); // No existe el nombre del campo en la tabla -} -// __________________________________________________________________________ - -bool Table::MoveNext() -{ - eof=false; - row=mysql_fetch_row(m_Rec); - if(row==NULL){ - if(!mysql_eof(m_Rec)) - return(false); // Fallo de lectura - else - eof=true; // Fin de fichero - } - return (true); -} -// __________________________________________________________________________ -bool Table::MoveFirst() -{ - my_ulonglong auxnumreg; - - auxnumreg=0; - mysql_data_seek(m_Rec,auxnumreg); - return (MoveNext()); -} -// __________________________________________________________________________ -bool Table::MoveLast() -{ - my_ulonglong auxnumreg; - auxnumreg=numreg; - auxnumreg--; - if(auxnumreg<0) auxnumreg=0; // Principio de fichero - mysql_data_seek(m_Rec,auxnumreg); - return (MoveNext()); - return (true); -} diff --git a/admin/Sources/Includes/Database.h b/admin/Sources/Includes/Database.h deleted file mode 100644 index ae318bdb..00000000 --- a/admin/Sources/Includes/Database.h +++ /dev/null @@ -1,61 +0,0 @@ -// ****************************************************************************************************** -// Aplicación HIDRA -// Copyright 2004 Jos�Manuel Alonso. Todos los derechos reservados. -// Fichero: Database.h -// Descripción: -// Fichero de cabecera de la clase Database para implementar funciones de manipulaci� -// de bases de datos sobre un Servidor Mysql -// ****************************************************************************************************** -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include </usr/include/mysql/mysql.h> -// __________________________________________________________________________ -class Database; -class Table; -// __________________________________________________________________________ -class Database -{ -public: - MYSQL *m_Cnn; - char m_ErrStr[500]; - Database(); - bool Open(char* UserName, char* Pwd,char* server,char*Database); - bool OpenTbl(int Mode, char* CmdStr, Table& Tbl); - bool Close(void); - bool Execute(char* CmdStr); - bool Execute(char* CmdStr, Table& Tbl); - void liberaResult(Table& Tbl); - void GetErrorErrStr(char* ErrStr); -}; -// __________________________________________________________________________ -class Table{ - char* tomadato(const char* FieldName); -public: - bool eof,bof; - MYSQL_RES * m_Rec ; - MYSQL_FIELD *fields; - unsigned int num_fields; - MYSQL_ROW row ; - MYSQL_ROW_OFFSET ptr; - my_ulonglong numreg; - char m_ErrStr[500]; - Table(); - void GetErrorErrStr(char* ErrStr); - bool ISEOF(); - bool MoveNext(); - bool MovePrevious(); - bool MoveFirst(); - bool MoveLast(); - - bool Get(const char* FieldName, char* FieldValue); - bool Get(const char* FieldName,int &FieldValue); - bool Get(const char* FieldName,char &FieldValue); -}; -// __________________________________________________________________________ -class Herror -{ -public: - int nError; // C�igo del error - char dError[500]; // Descripción del error -}; diff --git a/admin/Sources/Includes/ogAdmLib.c b/admin/Sources/Includes/ogAdmLib.c deleted file mode 100644 index 2f0a714d..00000000 --- a/admin/Sources/Includes/ogAdmLib.c +++ /dev/null @@ -1,1074 +0,0 @@ -// ************************************************************************************************************************************************** -// Libreria: ogAdmLib -// Autor: José Manuel Alonso (E.T.S.I.I.) Universidad de Sevilla -// Fecha Creación: Marzo-2010 -// Fecha Última modificación: Marzo-2010 -// Nombre del fichero: ogAdmLib.c -// Descripción: Este fichero implementa una libreria de funciones para uso común de los servicios -// ************************************************************************************************************************************************** -// ________________________________________________________________________________________________________ -// Función: tomaHora -// -// Descripción: -// Devuelve la hora del sistema -// Parametros: -// Ninguno -// ________________________________________________________________________________________________________ -struct tm * tomaHora() -{ - time_t rawtime; - time ( &rawtime ); - return(localtime(&rawtime)); -} -// ________________________________________________________________________________________________________ -// Función: registraLog -// -// Descripción: -// Registra los eventos en un fichero log ya sean errores o información -// Parametros: -// - fileLog : Ruta completa del archivo de log -// - msg : Descripción del error -// - swe: Switch que indica si se debe recuperar además el literal de error del propio sistema operativo -// ________________________________________________________________________________________________________ -void registraLog(const char* filelog,const char *msg,int swe) -{ - FILE *flog; - struct tm * t; - - t = tomaHora(); - flog=fopen(filelog,"at"); - if(swe) - fprintf (flog,"%02d/%02d/%d %02d:%02d %s: %s\n",t->tm_mday,t->tm_mon+1,t->tm_year+1900,t->tm_hour,t->tm_min,msg,strerror(errno)); - else - fprintf (flog,"%02d/%02d/%d %02d:%02d %s\n",t->tm_mday,t->tm_mon+1,t->tm_year+1900,t->tm_hour,t->tm_min,msg); - fclose(flog); -} -// ________________________________________________________________________________________________________ -// Función: errorLog -// -// Descripción: -// Registra los sucesos de errores preestablecidos en el fichero de log -// Parametros: -// - coderr : Código del mensaje de error -// - swe: Switch que indica si se debe recuperar además el literal de error del propio sistema operativo -// ________________________________________________________________________________________________________ -void errorLog(const char *modulo, int coderr, int swe) { - char msglog[LONSUC]; - - sprintf(msglog, "*** Error: %s. Módulo %s", tbErrores[coderr], modulo); - registraLog(szPathFileLog, msglog, swe); -} -// ________________________________________________________________________________________________________ -// Función: errorInfo -// -// Descripción: -// Registra los sucesos de errores dinámicos en el fichero de log -// Parametros: -// - msgerr : Descripción del error -// - swe: Switch que indica si se debe recuperar además el literal de error del propio sistema operativo -// ________________________________________________________________________________________________________ -void errorInfo(const char *modulo, char *msgerr) { - char msglog[LONSUC]; - - sprintf(msglog, "*** Error: %s. Módulo %s", msgerr, modulo); - registraLog(szPathFileLog, msglog, FALSE); -} -// ________________________________________________________________________________________________________ -// Función: infoLog -// -// Descripción: -// Registra los sucesos de información en el fichero de log -// Parametros: -// - coderr : Código del mensaje de información -// ________________________________________________________________________________________________________ -void infoLog(int codinf) { - char msglog[LONSUC]; - - sprintf(msglog, "*** Info: %s", tbMensajes[codinf]); - registraLog(szPathFileLog, msglog, FALSE); -} -// ________________________________________________________________________________________________________ -// Función: infoDebug -// -// Descripción: -// Registra los mensajes de debugs en el fichero de log -// Parametros: -// - msgdeb : Descripción del mensaje de información -// ________________________________________________________________________________________________________ -void infoDebug(char* msgdeb) { - char msglog[LONSUC+15]; // Cadena de registro (reserva caracteres para el prefijo). - - sprintf(msglog, "*** Debug: %d-%s", ndebug, msgdeb); - registraLog(szPathFileLog, msglog, FALSE); -} -//______________________________________________________________________________________________________ -// Función: ValidacionParametros -// -// Descripción: -// Valida que los parametros de ejecución del programa sean correctos -// Parámetros: -// - argc: Número de argumentos -// - argv: Puntero a cada argumento -// - eje: Tipo de ejecutable (1=Servicio,2=Repositorio o 3=Cliente) -// Devuelve: -// - TRUE si los argumentos pasados son correctos -// - FALSE en caso contrario -// Especificaciones: -// La sintaxis de los argumentos es la siguiente -// -f Archivo de configuración del servicio -// -l Archivo de logs -// -d Nivel de debuger (mensages que se escribirán en el archivo de logs) -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -//______________________________________________________________________________________________________ -BOOLEAN validacionParametros(int argc, char*argv[],int eje) { - int i; - char modulo[] = "validacionParametros()"; - - switch(eje){ - case 1: // Administrador - strcpy(szPathFileCfg, "ogAdmServer.cfg"); // Valores por defecto de archivos - strcpy(szPathFileLog, "ogAdmServer.log"); // de configuración y de logs - break; - case 2: // Repositorio - strcpy(szPathFileCfg, "ogAdmRepo.cfg"); // Valores por defecto de archivos - strcpy(szPathFileLog, "ogAdmRepo.log"); // de configuración y de logs - break; - case 3: // Cliente OpenGnsys - strcpy(szPathFileCfg, "ogAdmClient.cfg"); // Valores por defecto de archivos - strcpy(szPathFileLog, "ogAdmClient.log"); // de configuración y de logs - break; - case 4: // Servicios DHCP,BOOTP Y TFTP - strcpy(szPathFileCfg, "ogAdmBoot.cfg"); // Valores por defecto de archivos - strcpy(szPathFileLog, "ogAdmBoot.log"); // de configuración y de logs - break; - case 5: // Agente - strcpy(szPathFileCfg, "ogAdmAgent.cfg"); // Valores por defecto de archivos - strcpy(szPathFileLog, "ogAdmAgent.log"); // de configuración y de logs - break; - case 6: // Agente - strcpy(szPathFileCfg, "ogAdmWinClient.cfg"); // Valores por defecto de archivos - strcpy(szPathFileLog, "ogAdmWinClient.log"); // de configuración y de logs - break; - case 7: // Agente - strcpy(szPathFileCfg, "ogAdmnxClient.cfg"); // Valores por defecto de archivos - strcpy(szPathFileLog, "ogAdmLnxClient.log"); // de configuración y de logs - break; - } - - ndebug = 1; // Nivel de debuger por defecto - - for (i = 1; (i + 1) < argc; i += 2) { - if (argv[i][0] == '-') { - switch (tolower(argv[i][1])) { - case 'f': - if (argv[i + 1] != NULL) - strcpy(szPathFileCfg, argv[i + 1]); - else { - errorLog(modulo, 10, FALSE); - return (FALSE); - } - break; - case 'l': - if (argv[i + 1] != NULL) - strcpy(szPathFileLog, argv[i + 1]); - else { - errorLog(modulo, 11, FALSE); - return (FALSE); - } - break; - case 'd': - if (argv[i + 1] != NULL) { - ndebug = atoi(argv[i + 1]); - if (ndebug < 1) - ndebug = 1; // Por defecto el nivel de debug es 1 - } else - ndebug = 1; // Por defecto el nivel de debug es 1 - break; - default: - errorLog(modulo, 12, FALSE); - exit(EXIT_FAILURE); - break; - } - } - } - return (TRUE); -} -//______________________________________________________________________________________________________ -// Función: reservaMemoria -// -// Descripción: -// Reserva memoria para una variable -// Parámetros: -// - lon: Longitud en bytes de la reserva -// Devuelve: -// Un puntero a la zona de memoria reservada que ha sido previamente rellena con zeros o nulos -//______________________________________________________________________________________________________ -char* reservaMemoria(int lon) -{ - char *mem; - - mem=(char*)malloc(lon); - if(mem!=NULL) - memset(mem,0,lon); - return(mem); -} -//______________________________________________________________________________________________________ -// Función: ampliaMemoria -// -// Descripción: -// Amplia memoria para una variable -// Parámetros: -// - ptr: Puntero al buffer de memoria que se quiere ampliar -// - lon: Longitud en bytes de la amplicación -// Devuelve: -// Un puntero a la zona de memoria reservada que ha sido previamente rellena con zeros o nulos -//______________________________________________________________________________________________________ -char* ampliaMemoria(char* ptr,int lon) -{ - char *mem; - - mem=(char*)realloc(ptr,lon*sizeof(char*)); - if(mem!=NULL) - return(mem); - return(NULL); -} -//______________________________________________________________________________________________________ -// Función: liberaMemoria -// -// Descripción: -// Libera memoria para una variable -// Parámetros: -// - ptr: Puntero al buffer de memoria que se quiere liberar -// Devuelve: -// Nada -//______________________________________________________________________________________________________ -void liberaMemoria(void* ptr) -{ - if(ptr){ - free (ptr); - } -} -// ________________________________________________________________________________________________________ -// Función: splitCadena -// -// Descripción: -// Trocea una cadena según un carácter delimitador -// Parámetros: -// - trozos: Array de punteros a cadenas -// - cadena: Cadena a trocear -// - chd: Carácter delimitador -// Devuelve: -// Número de trozos en que se divide la cadena -// ________________________________________________________________________________________________________ -int splitCadena(char **trozos,char *cadena, char chd) -{ - int w=0; - if(cadena==NULL) return(w); - - trozos[w++]=cadena; - while(*cadena!='\0'){ - if(*cadena==chd){ - *cadena='\0'; - if(*(cadena+1)!='\0') - trozos[w++]=cadena+1; - } - cadena++; - } - return(w); // Devuelve el número de trozos -} -// ________________________________________________________________________________________________________ -// Función: sustituir -// -// Descripción: -// Sustituye las apariciones de un caracter por otro en una cadena -// Parámetros: -// - cadena: Cadena a convertir -// - cho: Caracter a sustituir -// - chs: Caracter sustituto -// ________________________________________________________________________________________________________ -void sustituir(char *cadena,char cho,char chs) -{ - int x=0; - - while(cadena[x]!=0) { - if (cadena[x]==cho) - cadena[x]=chs; - x++; - } -} -// ________________________________________________________________________________________________________ -// Función: escaparCadena -// -// Descripción: -// Sustituye las apariciones de un caracter comila simple ' por \' -// Parámetros: -// - cadena: Cadena a escapar -// Devuelve: -// La cadena con las comillas simples sustituidas por \' -// ________________________________________________________________________________________________________ -char* escaparCadena(char *cadena) -{ - int b,c; - char *buffer; - - buffer = (char*) reservaMemoria(strlen(cadena)*2); // Toma memoria para el buffer de conversión - if (buffer == NULL) { // No hay memoria suficiente para el buffer - return (FALSE); - } - - c=b=0; - while(cadena[c]!=0) { - if (cadena[c]=='\''){ - buffer[b++]='\\'; - buffer[b++]='\''; - } - else{ - buffer[b++]=cadena[c]; - } - c++; - } - return(buffer); -} -// ________________________________________________________________________________________________________ -// Función: StrToUpper -// -// Descripción: -// Convierta una cadena en mayúsculas -// Parámetros: -// - cadena: Cadena a convertir -// ________________________________________________________________________________________________________ -char* StrToUpper(char *cadena) -{ - int x=0; - - while(cadena[x]!=0) { - if (cadena[x] >= 'a' && cadena[x] <= 'z') { - cadena[x] -= 32; - } - x++; - } - return(cadena); -} -// ________________________________________________________________________________________________________ -// Función: StrToUpper -// -// Descripción: -// Convierta una cadena en mayúsculas -// Parámetros: -// - cadena: Cadena a convertir -// ________________________________________________________________________________________________________ -char* StrToLower(char *cadena) -{ - int x=0; - - while(cadena[x]!=0) { - if (cadena[x] >= 'A' && cadena[x] <= 'Z') { - cadena[x] += 32; - } - x++; - } - return(cadena); -} -// ________________________________________________________________________________________________________ -// Función: INTROaFINCAD -// -// Descripción: -// Cambia caracteres INTROS por fin de cadena ('\0') en una trama -// Parametros: -// - parametros: Puntero a los parametros de la trama -// - lon: Longitud de la cadena de parametros -// ________________________________________________________________________________________________________ -void INTROaFINCAD(TRAMA* ptrTrama) -{ - char *i,*a,*b; - - a=ptrTrama->parametros; - b=a+ptrTrama->lonprm; - for(i=a;i<b;i++){ // Cambia los NULOS por INTROS - if(*i=='\r') *i='\0'; - } -} -// ________________________________________________________________________________________________________ -// Función: FINCADaINTRO -// -// Descripción: -// Cambia caracteres fin de cadena ('\0') por INTROS en una trama -// Parametros: -// - parametros: Puntero a los parametros de la trama -// - lon: Longitud de la cadena de parametros -// ________________________________________________________________________________________________________ -void FINCADaINTRO(TRAMA* ptrTrama) -{ - char *i,*a,*b; - - a=ptrTrama->parametros; - b=a+ptrTrama->lonprm; - for(i=a;i<b;i++){ // Cambia los NULOS por INTROS - if(*i=='\0') *i='\r'; - } -} -// ________________________________________________________________________________________________________ -// Función: cuentaIPES -// -// Descripción: -// Cuenta los caracteres "." de las IPES dentro del parámetros iph de una trama -// con lo cual dividiendo por 3 se puede saber la cantdad de direcciones IPES en la cadena -// Parametros: -// - ipes: Cadena con las IPES separadas por ";" -// ________________________________________________________________________________________________________ -int cuentaIPES(char* ipes) -{ - int i,a,b,c=0; - - a=0; - b=strlen(ipes); - for(i=a;i<b;i++){ // Cambia los NULOS por INTROS - if(ipes[i]=='.') c++; - } - return(c/3); -} -// ________________________________________________________________________________________________________ -// Función: tomaParametro -// -// Descripción: -// Devuelve el valor de un parametro incluido en una cadena con formatos: "nombre=valor" -// Parámetros: -// - nombre: Nombre del parámetro a recuperar -// - paramestros: Cadena que contiene todos los parámetros -// ________________________________________________________________________________________________________ -char* tomaParametro(const char* nombre,TRAMA* ptrTrama) -{ - char *a,*b,*pos; - - a=ptrTrama->parametros; - b=a+ptrTrama->lonprm; - for(pos=a;pos<b;pos++){ // Busca valor del parámetro - if(pos[0]==nombre[0]){ - if(pos[1]==nombre[1]){ - if(pos[2]==nombre[2]){ - if(pos[3]=='='){ - pos+=4; - return(pos); - } - } - } - } - } - return(NULL); -} -//______________________________________________________________________________________________________ -// Función: copiaParametro -// -// Descripción: -// Devuelve una copia del valor de un parámetro -// Parámetros: -// - ptrTrama: contenido del mensaje -// - parametro: Nombre del parámetro -// - lon: Nombre del parámetro -// Devuelve: -// Un puntero a la cadena que contiene el valor del parámetro -// ________________________________________________________________________________________________________ -char* copiaParametro(const char*nombre,TRAMA* ptrTrama) -{ - char *prm,*buffer; - char modulo[] = "copiaParametro()"; - - - prm=tomaParametro(nombre,ptrTrama); // Toma identificador de acción - if(!prm) - return(NULL); - buffer = (char*) reservaMemoria(strlen(prm)+1); // Toma memoria para el buffer de lectura. - if (buffer == NULL) { // No hay memoria suficiente para el buffer - errorLog(modulo, 3, FALSE); - return (FALSE); - } - strcpy(buffer,prm); - return(buffer); -} -// ________________________________________________________________________________________________________ -// Función: igualIP -// -// Descripción: -// Comprueba si una cadena con una dirección IP está incluida en otra que contienen varias direcciones ipes -// separadas por punto y coma -// Parámetros: -// - cadenaiph: Cadena de direcciones IPES -// - ipcliente: Cadena de la IP a buscar -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -// ________________________________________________________________________________________________________ -BOOLEAN contieneIP(char *cadenaiph,char *ipcliente) -{ - char *posa,*posb; - int lon, i; - - posa=strstr(cadenaiph,ipcliente); - if(posa==NULL) return(FALSE); // No existe la IP en la cadena - posb=posa; // Iguala direcciones - for (i = 0; i < LONIP; i++) { - if(*posb==';') break; - if(*posb=='\0') break; - if(*posb=='\r') break; - posb++; - } - lon=strlen(ipcliente); - if((posb-posa)==lon) return(TRUE); // IP encontrada - return(FALSE); -} -// ________________________________________________________________________________________________________ -// Función: rTrim -// -// Descripción: -// Elimina caracteres de espacios y de asci menor al espacio al final de la cadena -// Parámetros: -// - cadena: Cadena a procesar -// ________________________________________________________________________________________________________ -char* rTrim(char *cadena) -{ - int i,lon; - - lon=strlen(cadena); - for (i=lon-1;i>=0;i--){ - if(cadena[i]<32) - cadena[i]='\0'; - else - return(cadena); - } - return(cadena); -} -// ________________________________________________________________________________________________________ -// Función: mandaTrama -// -// Descripción: -// Envía una trama por la red -// Parametros: -// - sock : El socket del host al que se dirige la trama -// - trama: El contenido de la trama -// - lon: Longitud de la parte de parametros de la trama que se va a mandar -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -// ________________________________________________________________________________________________________ -BOOLEAN mandaTrama(SOCKET *sock, TRAMA* ptrTrama) -{ - int lonprm; - char *buffer,hlonprm[LONHEXPRM+1]; - BOOLEAN res; - - lonprm=strlen(ptrTrama->parametros); - sprintf(hlonprm,"%05X",LONGITUD_CABECERATRAMA+LONHEXPRM+lonprm); // Convierte en hexadecimal la longitud - - buffer=reservaMemoria(LONGITUD_CABECERATRAMA+LONHEXPRM+lonprm); // Longitud total de la trama - if(buffer==NULL) - return(FALSE); - memcpy(buffer,ptrTrama,LONGITUD_CABECERATRAMA); // Copia cabecera de trama - memcpy(&buffer[LONGITUD_CABECERATRAMA],hlonprm,LONHEXPRM); // Copia longitud de la trama - memcpy(&buffer[LONGITUD_CABECERATRAMA+LONHEXPRM],ptrTrama->parametros,lonprm); - res=sendData(sock,buffer,LONGITUD_CABECERATRAMA+LONHEXPRM+lonprm); - liberaMemoria(buffer); - return (res); -} -// ________________________________________________________________________________________________________ -// Función: sendData -// -// Descripción: -// Envía datos por la red a través de un socket -// Parametros: -// - sock : El socket por donde se envía -// - datos: El contenido a enviar -// - lon: Cantidad de bites a enviar -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -// ________________________________________________________________________________________________________ -BOOLEAN sendData(SOCKET *sock, char* datos,int lon) -{ - int idx,ret; - idx = 0; - while (lon > 0) { - ret = send(*sock,&datos[idx],lon, 0); - if (ret == 0) { // Conexión cerrada por parte del cliente (Graceful close) - break; - } - else{ - if (ret == SOCKET_ERROR) - return (FALSE); - } - lon -= ret; - idx += ret; - } - return (TRUE); -} -// ________________________________________________________________________________________________________ -// Función: recibeTrama -// -// Descripción: -// Recibe una trama por la red -// Parametros: -// - sock : El socket del cliente -// - trama: El buffer para recibir la trama -// Devuelve: -// Un puntero a una estrucutra TRAMA o NULL si ha habido algún error -// FALSE: En caso de ocurrir algún error -// ________________________________________________________________________________________________________ -TRAMA* recibeTrama(SOCKET *sock) -{ - int ret,lon,lSize; - char *buffer,*bufferd,bloque[LONBLK],*hlonprm; - TRAMA * ptrTrama; - - lon=lSize=0; - do{ - if(!recData(sock,bloque,LONBLK,&ret)) // Lee bloque - return(NULL); - - if (lon==0 && lSize==0 && ret==0) // Comprueba trama válida - return(NULL); - - if(lSize==0){ // Comprueba tipo de trama y longitud total de los parámetros - if (strncmp(bloque, "@JMMLCAMDJ_MCDJ",15)!=0) - return(NULL); // No se reconoce la trama - hlonprm=reservaMemoria(LONHEXPRM+1); - if(!hlonprm) return(NULL); - memcpy(hlonprm,&bloque[LONGITUD_CABECERATRAMA],LONHEXPRM); - lSize=strtol(hlonprm,NULL,16); // Longitud total de la trama con los parametros encriptados - liberaMemoria(hlonprm); - buffer=(char*)reservaMemoria(lSize); // Toma memoria para la trama completa - if(!buffer) - return(NULL); - } - - if(ret>0){ // Datos recibidos - memcpy(&buffer[lon],bloque,ret); // Añade bloque - lon+=ret; - } - }while(lon<lSize); - - ptrTrama=(TRAMA *)reservaMemoria(sizeof(TRAMA)); - if (!ptrTrama) return(NULL); - memcpy(ptrTrama,buffer,LONGITUD_CABECERATRAMA); // Copia cabecera de trama - lon=lSize-(LONGITUD_CABECERATRAMA+LONHEXPRM); // Longitud de los parametros aún encriptados - bufferd = &buffer[LONGITUD_CABECERATRAMA+LONHEXPRM]; - initParametros(ptrTrama,lon); // Desencripta la trama - memcpy(ptrTrama->parametros,bufferd,lon); - liberaMemoria((char*)buffer); - ptrTrama->lonprm=lon; // Almacena longitud de los parámetros ya desencriptados - return(ptrTrama); -} -// ________________________________________________________________________________________________________ -// Función: recData -// -// Descripción: -// Recibe datos por la red a través de un socket -// Parametros: -// - sock : El socket por el que se reciben los datos -// - datos: El buffer donde se almacenan -// - lon: Cantidad máxima de bites a recibir -// - ret: Cantidad de bites recibidos (Parámetro de salida) -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -// ________________________________________________________________________________________________________ -BOOLEAN recData(SOCKET *sock, char* buffer,int lon,int* ret) -{ - *ret = 0; - - while (TRUE) { // Bucle para recibir datos del cliente - *ret = recv(*sock,buffer, lon, 0); - if (*ret == 0) // Conexión cerrada por parte del cliente (Graceful close) - break; - else { - if (*ret == SOCKET_ERROR) { - return (FALSE); - } else - // Datos recibidos - break; - } - } - return(TRUE); -} -//______________________________________________________________________________________________________ -// Función: enviaFlag -// -// Descripción: -// Envia una señal de sincronización -// Parámetros: -// - socket_c: (Salida) Socket utilizado para el envío (operativo) -// - ptrTrama: contenido del mensaje -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -// ________________________________________________________________________________________________________ -BOOLEAN enviaFlag(SOCKET *socket_c,TRAMA *ptrTrama) -{ - char modulo[] = "enviaFlag()"; - if (!mandaTrama(socket_c,ptrTrama)) { - errorLog(modulo,26,FALSE); - return (FALSE); - } - return(TRUE); -} -//______________________________________________________________________________________________________ -// Función: recibeFlag -// -// Descripción: -// Recibe una señal de sincronización -// Parámetros: -// - socket_c: Socket utilizadopara la recepción (operativo) -// - ptrTrama: (Salida) Contenido del mensaje -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -// ________________________________________________________________________________________________________ -BOOLEAN recibeFlag(SOCKET *socket_c,TRAMA *ptrTrama) -{ - ptrTrama=recibeTrama(socket_c); - if(!ptrTrama){ - return(FALSE); - } - return(TRUE); -} -//______________________________________________________________________________________________________ -// Función: URLEncode -// -// Descripción: -// Codifica una cadena en UrlEncode -// Parámetros: -// - src: La cadena a decodificar -// Devuelve: -// La cadena decodificada -// ________________________________________________________________________________________________________ -char* URLEncode(char *src) -{ - char *dest; - int i,j=0,lon; - - lon=strlen(src); - dest=(char*)reservaMemoria(lon*2); // Reserva buffer para la cadena - for(i=0;i<lon;i++){ - if(src[i]==0x20){ // Espacio - dest[j++] = '%'; - dest[j++] = '2'; - dest[j++] = '0'; - } - else - dest[j++] = src[i]; - } - return(dest); -} -//______________________________________________________________________________________________________ -// Función: URLDecode -// -// Descripción: -// Decodifica una cadena codificada con UrlEncode -// Parámetros: -// - src: La cadena a decodificar -// Devuelve: -// La cadena decodificada -// ________________________________________________________________________________________________________ -char* URLDecode(char *src) -{ - const char *p = src; - char code[3] = {0}; - unsigned long ascii = 0; - char *end = NULL; - char *dest,*cad; - - dest=(char*)reservaMemoria(strlen(src)); // Reserva buffer para la cadena - cad=dest; - while(*p){ - if(*p == '%'){ - memcpy(code, ++p, 2); - ascii = strtoul(code, &end, 16); - *dest++ = (char)ascii; - p += 2; - } - else - *dest++ = *p++; - } - return(cad); -} -// ________________________________________________________________________________________________________ -// Función: leeArchivo -// -// Descripción: -// Lee un archivo -// Parámetros: -// fil: Nombre completo del archivo -// Devuelve: -// Un puntero al buffer con el contenido leido - -//______________________________________________________________________________________________________ -char * leeArchivo(char *fil) -{ - FILE *f; - long lSize; - char* buffer; - - f=fopen(fil,"rb"); - if (!f) - return(NULL); - fseek (f,0,SEEK_END); // Obtiene tamaño del fichero. - lSize = ftell (f); - rewind (f); - buffer = (char*) reservaMemoria(lSize+1); // Toma memoria para el buffer de lectura. - if (!buffer) // No hay memoria suficiente para el buffer - return (NULL); - lSize=fread (buffer,1,lSize,f); // Lee contenido del fichero - fclose(f); - return (buffer); -} -// ________________________________________________________________________________________________________ -// Función: leeArchivo -// -// Descripción: -// Calcula la longitud de un archivo -// Parámetros: -// fil: Nombre completo del archivo -// Devuelve: -// Un puntero al buffer con el contenido leido - -//______________________________________________________________________________________________________ -int lonArchivo(char *fil) -{ - FILE *f; - long lSize; - - f=fopen(fil,"rb"); - if (!f) - return(0); - fseek (f,0,SEEK_END); // Obtiene tamaño del fichero. - lSize = ftell (f); - fclose(f); - return (lSize); -} -// ________________________________________________________________________________________________________ -// Función: escribeArchivo -// -// Descripción: -// Escribe un archivo -// Parámetros: -// fil: Nombre completo del archivo -// buffer: Un puntero al buffer con el contenido a escribir -// Devuelve: -//______________________________________________________________________________________________________ -BOOLEAN escribeArchivo(char *fil,char*buffer) -{ - FILE *f; - long lSize; - - f=fopen(fil,"wb"); - if (!f){ - return(FALSE); - } - lSize=strlen(buffer); - fwrite(buffer,1,lSize,f); // Escribe el contenido en el fichero - fclose(f); - return (TRUE); -} -// ________________________________________________________________________________________________________ -// Función: sendArchivo -// -// Descripción: -// Envía un archivo por la red -// Parámetros: -// sock: Socket para el envío -// fil: Nombre local completo del archivo -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -//______________________________________________________________________________________________________ -BOOLEAN sendArchivo(SOCKET *sock,char *fil) -{ - long lSize; - FILE *f; - char buffer[LONBLK]; - - f = fopen(fil,"rb"); - if(!f) // El fichero no existe - return(FALSE); - - while(!feof(f)){ - lSize=fread (buffer,1,LONBLK,f); // Lee el contenido del fichero - if(!sendData(sock,buffer,lSize)) - return (FALSE); - } - fclose(f); - return(TRUE); -} -// ________________________________________________________________________________________________________ -// Función: recArchivo -// -// Descripción: -// Recibe un archivo por la red -// Parámetros: -// sock: Socket para la recepción -// fil: Nombre local completo del archivo que se creará -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -//______________________________________________________________________________________________________ -BOOLEAN recArchivo(SOCKET *sock,char *fil) -{ - int lon; - FILE *f; - char buffer[LONBLK]; - - f = fopen(fil,"wb"); - if(!f) // No se ha podido crear el archivo - return(FALSE); - do{ - if(!recData(sock,buffer,LONBLK,&lon)) - return(FALSE); - // Datos recibidos - if(lon>0) - fwrite(buffer,1,lon,f); // Lee el contenido del fichero - }while(lon>0); // Bucle para recibir datos del cliente - fclose(f); - return(TRUE); -} -//______________________________________________________________________________________________________ -// Función: initParammetros -// -// Descripción: -// Libera memoria del buffer de los parametros de la trama y vuelve a reservar espacio -// Parámetros: -// - parametros : Puntero a la zona donde están los parametros de una trama -// - lon : Tamaño de la nueva reserva de espacio para los parametros -// Devuelve: -// Un puntero a la nueva zona de memoria o NULL si ha habido algún error -// Especificaciones: -// En caso de que el parámetro lon valga cero el tamaño a reservar será el estandar -//______________________________________________________________________________________________________ -BOOLEAN initParametros(TRAMA* ptrTrama,int lon) -{ - if(lon==0) lon=LONGITUD_PARAMETROS; - ptrTrama->parametros=(char*)ampliaMemoria(ptrTrama->parametros,lon); - if(!ptrTrama->parametros) - return(FALSE); - else - return(TRUE); -} -//______________________________________________________________________________________________________ -// Función: TCPConnect -// -// Descripción: -// Crea un socket y lo conecta a un servidor -// Parámetros: -// - ips : La Dirección IP del servidor -// - port : Puerto para la comunicación -// Devuelve: -// Un socket para comunicaciones por protocolo TCP -//______________________________________________________________________________________________________ -SOCKET TCPConnect(char *ips,char* port) -{ - SOCKET s; - struct sockaddr_in server; - char modulo[] = "TCPConnect()"; - - s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); - if (s == INVALID_SOCKET){ - return (INVALID_SOCKET); - } - server.sin_family = AF_INET; - server.sin_port = htons((short)atoi(port)); - server.sin_addr.s_addr = inet_addr(ips); - - if (connect(s, (struct sockaddr *)&server, sizeof(server)) == INVALID_SOCKET){ - errorLog(modulo,38,TRUE); - return (INVALID_SOCKET); - } - - return(s); -} -//______________________________________________________________________________________________________ -// Función: AbreConexion -// -// Descripción: -// Abre la conexión entre el cliente y el servidor de administración -// Parámetros: -// - Ninguno -// Devuelve: -// Un socket de cliente para comunicaciones -//______________________________________________________________________________________________________ -SOCKET abreConexion(void) -{ - int swloop=0; - SOCKET s; - - while(swloop<MAXCNX){ - s=TCPConnect(servidoradm,puerto); - if(s!= INVALID_SOCKET){ - return(s); - } - swloop++; - #ifdef __WINDOWS__ - Sleep(5*1000); - #else - sleep(5); // Espera cinco segundos antes de intentar una nueva conexión - #endif - } - return(INVALID_SOCKET); -} -//______________________________________________________________________________________________________ -// Función: enviaMensaje -// -// Descripción: -// Envia un mensaje al servidor de Administración -// Parámetros: -// - socket_c: (Salida) Socket utilizado para el envío -// - ptrTrama: contenido del mensaje -// - tipo: Tipo de mensaje -// C=Comando, N=Respuesta a un comando, P=Peticion,R=Respuesta a una petición, I=Informacion -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -// ________________________________________________________________________________________________________ -BOOLEAN enviaMensaje(SOCKET *socket_c,TRAMA *ptrTrama,char tipo) -{ - char modulo[] = "enviaMensaje()"; - - *socket_c=abreConexion(); - if(*socket_c==INVALID_SOCKET){ - errorLog(modulo,38,FALSE); // Error de conexión con el servidor - return(FALSE); - } - ptrTrama->arroba='@'; // Cabecera de la trama - strncpy(ptrTrama->identificador,"JMMLCAMDJ_MCDJ",14); // identificador de la trama - ptrTrama->tipo=tipo; // Tipo de mensaje - - if (!mandaTrama(socket_c,ptrTrama)) { - errorLog(modulo,26,FALSE); - return (FALSE); - } - return(TRUE); -} -//______________________________________________________________________________________________________ -// Función: recibeMensaje -// -// Descripción: -// Recibe un mensaje del servidor de Administración -// Parámetros: -// - socket_c: Socket utilizadopara la recepción -// - ptrTrama: (Salida) Contenido del mensaje -// Devuelve: -// TRUE: Si el proceso es correcto -// FALSE: En caso de ocurrir algún error -// ________________________________________________________________________________________________________ -TRAMA* recibeMensaje(SOCKET *socket_c) -{ - TRAMA* ptrTrama; - char modulo[] = "recibeMensaje()"; - - ptrTrama=recibeTrama(socket_c); - if(!ptrTrama){ - errorLog(modulo,17,FALSE); - return(NULL); - } - return(ptrTrama); -} - -// ________________________________________________________________________________________________________ diff --git a/admin/Sources/Includes/ogAdmLib.h b/admin/Sources/Includes/ogAdmLib.h deleted file mode 100644 index 42279a3e..00000000 --- a/admin/Sources/Includes/ogAdmLib.h +++ /dev/null @@ -1,319 +0,0 @@ -// ************************************************************************************************************************************************** -// Libreria: ogAdmLib -// Autor: José Manuel Alonso (E.T.S.I.I.) Universidad de Sevilla -// Fecha Creación: Marzo-2010 -// Fecha Última modificación: Marzo-2010 -// Nombre del fichero: ogAdmLib.h -// Descripción: Este fichero implementa el archivo de cabecera de la libreria ogAdmLib -// ************************************************************************************************************************************************** -// ________________________________________________________________________________________________________ -// Valores definidos -// ________________________________________________________________________________________________________ -#define LONSTD 1024 // Longitud de memoria estandar -#define LONINT 16 // Longitud de memoria estandar para un número entero -#define LONFIL 1024 // Longitud de memoria estandar para nombres de archivo completos (incluido path) -#define LONIP 16 // Longitud de memoria estandar para cadenas que contiene una dirección IP -#define LONMAC 16 // Longitud de memoria estandar para cadenas que contiene una dirección MAC -#define LONSQL 8192 // Longitud de memoria estandar para una sentencia SQL -#define LONPRM 4098 // Longitud estandar de los parámetros del fichero de configuración del servicio -#define LONSCP 4098 // Longitud estandar de los parámetros de las tramas -#define LONFUN 512 // Longitud estandar de los nombres de las funciones que procesan las tramas -#define LONSUC 4098 // Longitud de los mensajes de sucesos -#define LONBLK 8192 // Longitud de los paquetes de tramas leidos cada vez -#define MAXPRM 20 // Máximo número de parámeros del fichero de configuración del servicio -#define MAXPAR 128 // Maximo numero de particiones manejadas por el sistema, ahora con GPT es 128 -#define MAXLONURL 1024 // Longitud máxima de una dirección url con parámetros - -#define LONHEXPRM 5 // Longitud del campo que contiene el tamaño de la cadena de parámetros -#define LONGITUD_CABECERATRAMA 16 // Longitud de la cabecera de las tramas -#define LONGITUD_PARAMETROS 8192 // Longitud estandar de la información de la trama (parámetros) -#define MAXCMD_PARAMETROS 200 // Máximo número de parámetros de una trama - -#define MAXIMOS_CLIENTES 4000 // Máximo número de conexiones con ordenadores clientes -#define MAXIMAS_FUNCIONES LONSTD // Máximo número de funciones que procesan los mensajes entre servicio y clientes -#define MAXIMAS_LINEAS 3000 // Longitud máxima de lineas en un archivo de comandos - -#define AUTOINCORPORACION_OFF 0x0000 // Los ordenadores no se pueden dar de alta automáticamente -#define AUTOINCORPORACION_ONA 0x0001 // Los ordenadores se pueden dar de alta automáticamente si existe el aula -#define AUTOINCORPORACION_ONX 0x0002 // Los ordenadores se pueden dar de alta automáticamentee y si no existe el aula la crea - -#define DEBUG_BAJO 1 // Nivel de debug bajo -#define DEBUG_MEDIO 2 // Nivel de debug medio -#define DEBUG_ALTO 3 // Nivel de debug alto -#define DEBUG_MAXIMO 4 // Nivel de debug máximo - -#define CLIENTE_OCUPADO "BSY" // Cliente ocupado -#define CLIENTE_APAGADO "OFF" // Cliente apagado -#define CLIENTE_INICIANDO "INI" // Cliente iniciando - -#define CLIENTE_OPENGNSYS "OPG" // Cliente Opengnsys - -#define CLIENTE_WIN "WIN" // Cliente Windows genérico -#define CLIENTE_WNT "WNT" // Windows NT -#define CLIENTE_W2K "W2K" // Windows 2000 -#define CLIENTE_WS2 "WS2" // Windows Server 2003 -#define CLIENTE_WXP "WXP" // Cliente Windows XP -#define CLIENTE_W95 "W95" // Windows 95 -#define CLIENTE_W98 "W98" // Windows 98 -#define CLIENTE_WML "WML" // Windows Milenium -#define CLIENTE_MS2 "MS2" // MsDos -#define CLIENTE_WVI "WVI" // Cliente Windows Vista -#define CLIENTE_WI7 "WI7" // Cliente Windows 7 - -#define CLIENTE_LNX "LNX" // Cliente Linux - -#define ACCION_SINRESULTADO 0 // Sin resultado -#define ACCION_EXITOSA 1 // Finalizada con éxito -#define ACCION_FALLIDA 2 // Finalizada con errores - -#define ACCION_INICIADA 1 // Acción activa -#define ACCION_DETENIDA 2 // Acción momentanemente parada -#define ACCION_FINALIZADA 3 // Accion finalizada - -#define EJECUCION_COMANDO 1 -#define EJECUCION_PROCEDIMIENTO 2 -#define EJECUCION_TAREA 3 -#define EJECUCION_RESERVA 4 - -#define AMBITO_CENTROS 0x01 -#define AMBITO_GRUPOSAULAS 0x02 -#define AMBITO_AULAS 0x04 -#define AMBITO_GRUPOSORDENADORES 0x08 -#define AMBITO_ORDENADORES 0x10 - -// Código de los tipos de mensajes -#define MSG_COMANDO '1' // Mensaje del tipo comando -#define MSG_NOTIFICACION '2' // Respuesta a la ejecución un comando -#define MSG_PETICION '3' // Petición de cualquier actuación -#define MSG_RESPUESTA '4' // Respuesta a una petición -#define MSG_INFORMACION '5' // Envío de cualquier información sin espera de confirmación o respuesta - -#define ANNOREF 2009 // Año de referencia base - -#define LONGITUD_SCRIPTSALIDA 131072 // Longitud máxima de la información devuelta por una función de interface -#define MAXARGS 16 // Número máximo de argumentos enviados a un scripts -#define MAXCNX 5 // Máximos intentos de conexión al servidor de Administración - -#define PUERTO_WAKEUP 9 // Puerto wake up - -#define MAXHARDWARE 128 // Máximos elementos hardware a detectar -#define MAXSOFTWARE 8096 // Máximos elementos software a detectar -// ________________________________________________________________________________________________________ -// Tipos definidos -// ________________________________________________________________________________________________________ -typedef unsigned long DWORD; -typedef unsigned short WORD; -typedef int BOOLEAN; -typedef char BYTE; -typedef int SOCKET; -typedef void* LPVOID; - -#define TRUE 1 -#define FALSE 0 - -#define SOCKET_ERROR (-1) -#define INVALID_SOCKET (SOCKET)(~0) - -#define LEER 0 -#define ESCRIBIR 1 - -#define CHARNULL '\0' - -// ________________________________________________________________________________________________________ -// Variables globales -// ________________________________________________________________________________________________________ -char szPathFileCfg[LONSTD],szPathFileLog[LONSTD]; -int ndebug; // Nivel de debuger - -typedef struct{ // Estructura de las tramas - char arroba; // Caracter arroba siempre - char identificador[14]; // Identificador de la trama, siempre JMMLCAMDJ_MCDJ - char tipo; // Tipo de mensaje - long lonprm; // Longitud en hexadecimal de los parámetros - char *parametros; // Parámetros de la trama -}TRAMA; -// ________________________________________________________________________________________________________ -// Tabla de errores -// ________________________________________________________________________________________________________ -const char* tbErrores[]={"Se han generado errores. No se puede continuar la ejecución de este módulo",\ - "001-El nombre del fichero de configuración del programa está vacío",\ - "002-No existe fichero de configuración del programa",\ - "003-No hay memoria suficiente para el buffer",\ - "004-Error en el fichero de configuración del programa. No se ha definido el parámetro SERVIDORADM",\ - "005-Error en el fichero de configuración del programa. No se ha definido el parámetro PUERTO",\ - "006-Error en el fichero de configuración del programa. No se ha definido el parámetro USUARIO",\ - "007-Error en el fichero de configuración del programa. No se ha definido el parámetro PASSWORD",\ - "008-Error en el fichero de configuración del programa. No se ha definido el parámetro DATASOURCE",\ - "009-Error en el fichero de configuración del programa. No se ha definido el parámetro CATALOG",\ - "010-Error en los parámetros de ejecución del programa. Debe especificar el fichero de configuración",\ - "011-Error en los parámetros de ejecución del programa. Debe especificar el fichero de log",\ - "012-Error de sintaxis en los parámetros de ejecución del programa: Debe especificar -f nombre_del_fichero_de_configuración_del_programa -l nombre_del_fichero_de_log_del_programa -d nivel de debug",\ - "013-Error al crear socket ***socket() fallo",\ - "014-Error al enlazar socket al interface ***bind() fallo",\ - "015-Error al acceptar conexión de clientes ***accept() fallo",\ - "016-Error al crear hebra de cliente en módulo main()",\ - "017-Error al recibir trama ***recv() fallo",\ - "018-No se reconoce el mensaje enviado",\ - "019-Trama recibida NO válida",\ - "020-No se puede establecer conexión con la base de datos",\ - "021-No se han podido recuperar los datos de la consulta o bien insertar, modificar o eliminar datos",\ - "022-El cliente no se ha sido dado de alta en la base de datos del sistema. Se rechaza su petición de inclusión",\ - "023-Ha habido algún problema en la incorporación automática del cliente",\ - "024-Ha habido algún problema en la actualización de la configuración del cliente",\ - "025-La tabla de clientes está llena, no pueden registrarse más clientes en el sistema",\ - "026-Error al enviar trama ***send() fallo",\ - "027-No se encuentra Repositorio del cliente",\ - "028-Ha ocurrido algún error al tomar las particiones",\ - "029-Ha ocurrido algún problema en el proceso de inclusión del cliente. Se rechaza su petición",\ - "030-Ha ocurrido algún problema en el proceso de respuesta al comando",\ - "031-No se ha encontrado la acción a notificar es posible que se haya eliminado el registro",\ - "032-Ha ocurrido algún problema en el envío del comando",\ - "033-Error en el fichero de configuración del programa. No se ha definido el parámetro PATHSCRIPTS",\ - "034-Error en el fichero de configuración del programa. No se ha definido el parámetro URLMENU",\ - "035-Error en el fichero de configuración del programa. No se ha definido el parámetro URLMSG",\ - "036-No se ha podido recuperar la configuración de las particiones del disco",\ - "037-Ha ocurrido algún problema en el proceso de inclusión del cliente",\ - "038-No se ha podido establecer conexión con el Servidor de Administración",\ - "039-Ha ocurrido algún problema al procesar la trama recibida",\ - "040-Se han recibido parámetros con valores no válidos",\ - "041-Ha ocurrido algún problema en el proceso de inclusión del cliente",\ - "042-Ha ocurrido algún problema al enviar una petición de comandos o tareas pendientes al Servidor de Administración",\ - "043-Ha ocurrido algún problema al enviar una petición de comandos interactivos al Servidor de Administración",\ - "044-Ha ocurrido algún problema al enviar una respuesta de comandos al servidor",\ - "045-Ha ocurrido algún problema al recibir una petición de comandos o tareas pendientes desde el Servidor de Administración",\ - "046-Ha ocurrido algún problema al recibir un comando interactivo desde el Servidor de Administración",\ - "047-El cliente no está registrado en la tabla de sockest del sistema",\ - "048-Error al configurar opción BROADCAST para socket: setsockopt(SO_BROADCAST)",\ - "049-Error al enviar trama magic packet",\ - "050-Ha ocurrido algún problema al enviar un fichero por la red",\ - "051-Error en el fichero de configuración del programa. No se ha definido el parámetro PATHLOGFIL",\ - "052-No se puede crear archivo temporal para ejecución de Comandos",\ - "053-Ha ocurrido algún problema al procesar el Inventario Hardware del cliente",\ - "054-Existe un tipo de hardware que no está registrado",\ - "055-Ha ocurrido algún problema al actualizar el hardware del cliente",\ - "056-Error en el fichero de configuración del programa. No se ha definido el parámetro PATHINTERFACE",\ - "057-Ha ocurrido algún problema al enviar un archivo por la red",\ - "058-Ha ocurrido algún problema al recibir un archivo por la red",\ - "059-Error al crear la hebra DHCP o BOOTP",\ - "060-Error al crear la hebra TFTP",\ - "061-Error al crear socket para servicio DHCP",\ - "062-Error al enlazar socket con interface para servicio DHCP",\ - "063-No hay puertos libres para la hebra del servicio",\ - "064-Error al crear estructura de control para protocolo DHCP",\ - "065-Error al recibir mensaje DHCP. Se para el servicio",\ - "066-Error al crear la hebra cliente DHCP",\ - "067-Error al crear socket para servicio BOOTP",\ - "068-Error al enlazar socket con interface para servicio BOOTP",\ - "069-Error al crear estructura de control para protocolo BOOTP",\ - "070-Error al recibir mensaje BOOTP. Se para el servicio",\ - "071-Error al crear la hebra cliente BOOTP",\ - "072-Error al crear socket para servicio TFTP",\ - "073-Error al enlazar socket con interface para servicio TFTP",\ - "074-Error al crear estructura de control para protocolo TFTP",\ - "075-Error al recibir mensaje TFTP. Se para el servicio",\ - "076-Error al crear la hebra cliente TFTP",\ - "077-No se encontró opción DHCP",\ - "078-ERROR TFTP",\ - "079-Error al recibir mensaje TFTP en hebra cliente",\ - "080-Error al recibir mensaje DHCP",\ - "081-Error al crear socket de usuario para hebra",\ - "082-Ha ocurrido algún problema al procesar el Inventario software del cliente",\ - "083-Ha ocurrido algún problema al actualizar el software del cliente",\ - "084-Ha ocurrido algún problema al reiniciar la sesión del cliente",\ - "085-No se ha podido recuperar la dirección IP del cliente",\ - "086-Error al ejecutar el comando",\ - "087-Error al leer o escribir el contenido del archivo de eco de consola remota",\ - "088-Ha habido algún problerma al procesar la caché",\ - "089-Error en el fichero de configuración del programa. No se ha definido el parámetro URLMENU",\ - "090-Error en el fichero de configuración del programa. No se ha definido el parámetro URLMSG",\ - "091-Ha habido algún problema al enviar un mensaje de tipo petición al Servidor",\ - "092-Error en el fichero de configuración del programa. No se ha definido el parámetro IPLOCAL",\ - "093-No se puede cargar la librería Windows para trabajar con sockets",\ - "094-Ha habido algún problerma al procesar la actualización después de crear una imagen",\ - "095-Ha habido algún problerma al procesar la actualización después de restaurar una imagen",\ - "096-Ha habido algún problerma al procesar la actualización después de crear un software incremental",\ - "097-Este fichero de log está obsoleto, este proceso usa ahora syslog para gestionar los mensajes de log",\ -}; -// ________________________________________________________________________________________________________ -// Tabla de mensajes -// ________________________________________________________________________________________________________ -const char* tbMensajes[]={"",\ - "001-Inicio de sesion",\ - "002-Petición de inclusión de cliente",\ - "003-Abriendo sesión en el servidor de Administración",\ - "004-Cliente iniciado",\ - "005-Ejecución de archivo Autoexec",\ - "006-Procesa comandos pendientes",\ - "007-Acciones pendientes procesadas",\ - "008-Ejecución del script",\ - "009-Parámetro del script",\ - "010-Ha ocurrido algún error en la creación del proceso hijo",\ - "011-Aviso: La información de salida del script excede de la longitud permitida. Puede haberse truncado",\ - "012-Información devuelta por el script",\ - "013-Estatus de finalización del script",\ - "014-Configuración de particiones",\ - "015-Enviando petición de inclusión en el sistema al Servidor de Administración",\ - "016-Recibiendo respuesta de inclusión desde el Servidor de Administración",\ - "017-Enviando petición de comandos o tareas pendientes al Servidor de Administración",\ - "018-Recibiendo respuesta de comandos o tareas pendientes desde el Servidor de Administración",\ - "019-Disponibilidad de comandos activada",\ - "020-Disponibilidad de comandos desactivada",\ - "021-Ejecución de comando",\ - "022-Sin eco",\ - "023-Procesando caché",\ - "024-Repositorio iniciado",\ - -}; -// ________________________________________________________________________________________________________ -// Prototipo de funciones -// ________________________________________________________________________________________________________ -struct tm * tomaHora(); -void registraLog(const char *,const char *,int ); -void errorLog(const char *,int ,int); -#define og_log(err, swe) errorLog(__FUNCTION__, err, swe) -void errorInfo(const char *,char *); -#define og_info(err) errorInfo(__FUNCTION__, err) -void infoLog(int); -void infoDebug(char*); -BOOLEAN validacionParametros(int,char**,int); -char* reservaMemoria(int); -char* ampliaMemoria(char*,int); -void liberaMemoria(void*); -BOOLEAN initParametros(TRAMA*,int); -int splitCadena(char **,char *, char); -void sustituir(char *,char ,char ); -char* StrToUpper(char *); -char* StrToLower(char *); -void INTROaFINCAD(TRAMA*); -void FINCADaINTRO(TRAMA*); -int cuentaIPES(char*); -char *tomaParametro(const char*,TRAMA*); -char *copiaParametro(const char*,TRAMA *); -BOOLEAN contieneIP(char *,char *); -char* rTrim(char *); -SOCKET TCPConnect(char *,char *); -SOCKET abreConexion(void); -BOOLEAN enviaMensaje(SOCKET *,TRAMA *,char); -TRAMA* recibeMensaje(SOCKET *); -BOOLEAN mandaTrama(SOCKET*,TRAMA*); -BOOLEAN sendData(SOCKET *, char* ,int ); -BOOLEAN enviaTrama(SOCKET *,TRAMA *); -TRAMA* recibeTrama(SOCKET*); -BOOLEAN recData(SOCKET *,char*,int,int*); -BOOLEAN sendFlag(SOCKET *, char* ,int ); -BOOLEAN recibeFlag(SOCKET*,TRAMA*); -char* URLEncode(char *); -char* URLDecode(char *); -char* leeArchivo(char*); -int lonArchivo(char *); -BOOLEAN escribeArchivo(char *,char*); -BOOLEAN sendArchivo(SOCKET *,char *); -BOOLEAN recArchivo(SOCKET *,char *); -SOCKET TCPConnect(char *,char*); - -#include <stddef.h> /* for offsetof. */ - -#define container_of(ptr, type, member) ({ \ - typeof( ((type *)0)->member ) *__mptr = (ptr); \ - (type *)( (char *)__mptr - offsetof(type,member) );}) - |