xfnts.c

/*
 * Copyright (c) 1998-2004 by Sun Microsystems, Inc.
 * All rights reserved.
 *
 * xfnts.c - Utilidades comunes de HA-XFS
*
* Esta utilidad tiene los métodos para realizar la validación, iniciar
* y detener el servicio de datos y el supervisor de fallos. Contiene
* también el método para analizar el estado del servicio de datos. El
* analizador sólo devuelve satisfactorio o no satisfactorio. La acción se
* decide en función de este valor devuelto en el método encontrado en
* el archivo xfnts_probe.c
 *
 */

#pragma ident “@(#)xfnts.c 1.47 01/01/18 SMI”

#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include <sys/wait.h>
#include <netinet/in.h>
#include <scha.h>
#include <rgm/libdsdev.h>
#include <errno.h>
#include “xfnts.h”

/*
 * El tiempo de espera inicial permitido para que el servicio de datos
* HAXFS esté conectado y en ejecución. Se esperará un %
* (SVC_WAIT_PCT) del tiempo start_timeout antes de analizar el
* servicio.
 */
#define   SVC_WAIT_PCT      3

/*
 * Hay que usar 95% de probe_timeout para conectar al puerto y el
* resto del tiempo se usa para desconectarse del puerto de la
* función svc_probe.
 */
#define   SVC_CONNECT_TIMEOUT_PCT      95

/*
 * SVC_WAIT_TIME se usa sólo durante el inicio en svc_wait().
* En svc_wait() hay que estar seguro de que el servicio esté activo
* antes del retorno, por lo que hay que invocar a svc_probe() para
* que supervise el servicio. SVC_WAIT_TIME es el tiempo que pasa
* entre esos análisis.
*/
#define SVC_WAIT_TIME 5
/*
* Este valor se usará como tiempo de espera de desconexión, si no
* queda tiempo de probe_timeout.
*/
#define SVC_DISCONNECT_TIMEOUT_SECONDS 2


/*
 * svc_validate():
 *
* Realizar una validación específica de HA-XFS de la configuración del
* recurso.
*
* svc_validate comprobará:
* 1. Propiedad de extensión Confdir_list
* 2. Archivo fontserver.cfg
* 3. Binario xfs
* 4. Propiedad port_list
* 5. Recursos de red
* 6. Otras propiedades de extensión
*
* Si falla cualquiera de esas validaciones, devolver > 0; en caso
* contrario, devolver 0 para indicar satisfactorio
*/
int
svc_validate(scds_handle_t scds_handle)
{
char xfnts_conf[SCDS_ARRAY_SIZE];
scha_str_array_t *confdirs;
scds_net_resource_list_t *snrlp;
int rc;
struct stat statbuf;
scds_port_list_t *portlist;
scha_err_t err;
/*
* Obtener el directorio de configuración del servicio de datos XFS
* de la propiedad de extensión confdir_list.
*/
confdirs = scds_get_ext_confdir_list(scds_handle);

   /* Devolver un error si no hay propiedad de extensión confdir_list*/
   if (confdirs == NULL || confdirs->array_cnt != 1) {
      scds_syslog(LOG_ERR,
          “Propiedad Confdir_list no establecida adecuadamente.”);
      return (1); /* Fallo de validación */
   }

   /*
    * Construir la ruta al archivo de configuración desde la propiedad
    * de extensión confdir_list. Dado que HA-XFS sólo tiene una
    * configuración hay que usar la primera entrada de la propiedad
    * confdir_list.
    */
   (void) sprintf(xfnts_conf, “%s/fontserver.cfg”, confdirs->str_array[0]);

   /*
    * Comprobar si el archivo de configuración HA-XFS está en el lugar
    * correcto. Intentar acceder al archivo de configuración HA-XFS y
    * asegurarse de que se hayan configurado correctamente los
    * permisos
    */
   if (stat(xfnts_conf, &statbuf) != 0) {
      /*
       * suprimir error lint porque el prototipo errno.h
       * no tiene argumento vacío
       */
      scds_syslog(LOG_ERR,
          “No se ha podido acceder al archivo <%s> : <%s>”,
          xfnts_conf, strerror(errno));   /*lint !e746 */
      return (1);
   }

   /*
    * Asegurarse de que el binario xfs exista y de que los permisos
* sean correctos. El binario XFS se supone que está en el sistema
* local de archivos, no en el sistema global de archivos
    */
   if (stat(“/usr/openwin/bin/xfs”, &statbuf) != 0) {
      scds_syslog(LOG_ERR,
          “No se puede acceder al binario XFS: <%s> “, strerror(errno));
      return (1);
   }

   /* HA-XFS sólo tendrán puerto*/
   err = scds_get_port_list(scds_handle, &portlist);
   if (err != SCHA_ERR_NOERR) {
      scds_syslog(LOG_ERR,
          “No se puede acceder a la propiedad Port_list: %s.”,
         scds_error_string(err));
      return (1); /* Fallo de validación */
   }

#ifdef TEST
   if (portlist->num_ports != 1) {
      scds_syslog(LOG_ERR,
          “La propiedad Port_list sólo debe tener un valor.”);
      scds_free_port_list(portlist);
      return (1); /* Fallo de validación */
   }
#endif

   /*
   * Devolver un error si hay un error al intentar obtener los recursos
* de dirección de red disponibles para este recurso
    */
   if ((err = scds_get_rs_hostnames(scds_handle, &snrlp))
      != SCHA_ERR_NOERR) {
      scds_syslog(LOG_ERR,
          “No hay recursos de dirección de red en el grupo de recursos: %s.”,
         scds_error_string(err));
      return (1); /* Fallo de validación */
   }

   /* Devolver un error si no hay recursos de dirección de red */
   if (snrlp == NULL || snrlp->num_netresources == 0) {
      scds_syslog(LOG_ERR,
          “No hay recursos de dirección de red en el grupo de recursos.”);
      rc = 1;
      goto finished;
   }

   /* Comprobar si hay otras propiedades de extensión importantes
* establecidas*/
   if (scds_get_ext_monitor_retry_count(scds_handle) <= 0)
   {
      scds_syslog(LOG_ERR,
          “La propiedad Monitor_retry_count no está establecida.”);
      rc = 1; /* Fallo de validación */
      goto finished;
   }
   if (scds_get_ext_monitor_retry_interval(scds_handle) <= 0) {
      scds_syslog(LOG_ERR,
          “La propiedad Monitor_retry_interval no está establecida.”);
      rc = 1; /* Fallo de validación */
      goto finished;
   }

   /* Todas las comprobaciones han sido satisfactorias*/
   scds_syslog(LOG_INFO, “Validación satisfactoria.”);
   rc = 0;

finished:
   scds_free_net_list(snrlp);
   scds_free_port_list(portlist);

   return (rc); /* devolver resultado de validación */
}

/*
 * svc_start():
 *
 * Iniciar el servidor de fuentes X
 * Devolver 0 si es satisfactorio, > 0 si hay fallos.
 *
 * El servicio XFS se iniciará al ejecutar la orden  /usr/openwin/bin/xfs
 * -config <archivo fontserver.cfg -port <puerto para escuchar>
 * XFS se iniciará bajo PMF. XFS se iniciará como servicio de instancia 
 * única. La etiqueta de PMF para el servicio de datos tendrá el formato
 * <nombre_grupo_recurso,nombre_recurso,número_instancia.svc>. En el caso
* de XFS, dado que sólo habrá una instancia, instance_number de la etiqueta
* tag será 0.
 */

int
svc_start(scds_handle_t scds_handle)
{
   char    xfnts_conf[SCDS_ARRAY_SIZE];
   char   cmd[SCDS_ARRAY_SIZE];
   scha_str_array_t *confdirs;
   scds_port_list_t    *portlist;
   scha_err_t   err;

   /* obtener el directorio de configuración de la propiedad confdir_list */
   confdirs = scds_get_ext_confdir_list(scds_handle);

   (void) sprintf(xfnts_conf, “%s/fontserver.cfg”, confdirs->str_array[0]);

   /* obtener el puerto que debe usar XFS de la propiedad Port_list */
   err = scds_get_port_list(scds_handle, &portlist);
   if (err != SCHA_ERR_NOERR) {
      scds_syslog(LOG_ERR,
          “No se ha podido acceder a la propiedad Port_list.”);
      return (1);
   }

   /*
    * Construir la orden para iniciar HA-XFS.
   * NOTA: el daemon de XFS imprime el siguiente mensaje mientras
    *detiene XFS  “/usr/openwin/bin/xfs notice: finalizando”
    * Para suprimir el mensaje del daemon, la salida se redirige a /dev/null.
    */
   (void) sprintf(cmd,
       “/usr/openwin/bin/xfs -config %s -port %d 2>/dev/null”,
       xfnts_conf, portlist->ports[0].port);

   /*
    * Iniciar HA-XFS bajo PMF. Observar que HA-XFS se inicia como un
* servicio de instancia única. El último argumento de la función
* scds_pmf_start denota el nivel de los secundarios que hay que supervisar.
* Un valor de -1 para este parámetro significa que todos los secundarios
* y el proceso original deben supervisarse.
    */
   scds_syslog(LOG_INFO, “Emitir una solicitud de inicio.”);
   err = scds_pmf_start(scds_handle, SCDS_PMF_TYPE_SVC,
      SCDS_PMF_SINGLE_INSTANCE, cmd, -1);

   if (err == SCHA_ERR_NOERR) {
      scds_syslog(LOG_INFO,
          “Orden de inicio completada satisfactoriamente.”);
   } else {
      scds_syslog(LOG_ERR,
          “No se ha podido iniciar HA-XFS “);
   }

   scds_free_port_list(portlist);
   return (err); /* devolver estado satisfactorio/no satisfactorio */
}


/*
 * svc_stop():
 *
 * Detener el servidor XFS
* Devolver 0 si es satisfactorio,> 0 si hay fallos.
 *
 * svc_stop detendrá el servidor, invocando la función toolkit:
* scds_pmf_stop.
 */
int
svc_stop(scds_handle_t scds_handle)
{
   scha_err_t   err;

   /*
    * El valor de tiempo de espera necesario para que el método de parada
    * sea satisfactorio se define en la propiedad Stop_Timeout (definida
    * por el sistema)
    */
   scds_syslog(LOG_ERR, “Emitir una solicitud de parada.”);
   err = scds_pmf_stop(scds_handle,
       SCDS_PMF_TYPE_SVC, SCDS_PMF_SINGLE_INSTANCE, SIGTERM,
       scds_get_rs_stop_timeout(scds_handle));

   if (err != SCHA_ERR_NOERR) {
      scds_syslog(LOG_ERR,
          “No se ha podido detener HA-XFS.”);
      return (1);
   }

   scds_syslog(LOG_INFO,
       “Se ha detenido satisfactoriamente  HA-XFS.”);
   return (SCHA_ERR_NOERR); /* Se ha detenido satisfactoriamente*/
}

/*
 * svc_wait():
 *
 * esperar que el servicio de datos se inicie por completo y asegurarse
 * de que se ejecute correctamente
 */

int
svc_wait(scds_handle_t scds_handle)
{
   int rc, svc_start_timeout, probe_timeout;
   scds_netaddr_list_t   *netaddr;

   /* obtener el recurso de red que hay que usar para analizar */
   if (scds_get_netaddr_list(scds_handle, &netaddr)) {
      scds_syslog(LOG_ERR,
          ““No se ha encontrado recurso de dirección de red en el grupo de recursos.”);
      return (1);
   }

   /* Devolver un error si no hay recursos de red */
   if (netaddr == NULL || netaddr->num_netaddrs == 0) {
      scds_syslog(LOG_ERR,
          “No se ha encontrado recurso de dirección de red en el grupo de recursos.”);
      return (1);
   }

   /*
    * Obtener el tiempo de espera del método Start, número de puerto en
    * el que analizar, el valor de tiempo de espera de Probe
    */
   svc_start_timeout = scds_get_rs_start_timeout(scds_handle);
   probe_timeout = scds_get_ext_probe_timeout(scds_handle);

   /*
    * reposar durante un porcentaje de SVC_WAIT_PCT del tiempo
* start_timeout antes de analizar efectivamente el servicio de datos.
* Así se permite que el servicio de datos esté totalmente activo para
* responder al análisis.
* NOTA: el valor de SVC_WAIT_PCT puede variar según el servicio de datos.
* En lugar de invocar sleep(), invocar scds_svc_wait() para que si el
* servicio falla demasiadas veces, se deje de intentar y se dé antes
* una respuesta.
    */
   if (scds_svc_wait(scds_handle, (svc_start_timeout * SVC_WAIT_PCT)/100)
      != SCHA_ERR_NOERR) {

      scds_syslog(LOG_ERR, “No se ha podido iniciar el servicio.”);
      return (1);
   }

   do {
      /*
       * analizar el servicio de datos en la dirección IP del
* recurso de red y el nombre de puerto
*/
rc = svc_probe(scds_handle,
netaddr->netaddrs[0].hostname,
netaddr->netaddrs[0].port_proto.port, probe_timeout);
if (rc == SCHA_ERR_NOERR) {
/* Satisfactorio. Liberar recursos y retornar */
scds_free_netaddr_list(netaddr);
return (0);
      }

      /*
       * El servicio de datos sigue intentando activarse. Reposar antes de
       * volver a analizar. En lugar de invocar sleep(), invocar scds_svc_wait()
       *para que si el servicio falla demasiadas veces, se deje de intentar
       * y se dé una respuesta antes..
       */
      if (scds_svc_wait(scds_handle, SVC_WAIT_TIME)
         != SCHA_ERR_NOERR) {
         scds_syslog(LOG_ERR, “No se ha podido iniciar el servicio.”);
         return (1);
      }

   /* RGM debe agotar el tiempo de espera y terminar el programa */
   } while (1);

}

/*
 * Esta función inicia el supervisor de fallos para un recurso de HA-XFS.
 * Esto se realiza iniciando el análisis bajo PMF. La etiqueta PMF 
 * se deriva como <RG-name,RS-name,instance_number.mon>. 
 * La opción re reinicio de PMF se usa pero no el “reinicio infinito”. 
 * En su lugar, se obtiene  interval/retry_time del archivo RTR.
 */

int
mon_start(scds_handle_t scds_handle)
{
   scha_err_t   err;

   scds_syslog_debug(DBG_LEVEL_HIGH,
      “Invocando método MONITOR_START del recurso <%s>.”,
      scds_get_resource_name(scds_handle));

   /*
    * El analizador xfnts_probe se supone disponible en el mismo
* subdirectorio en el que hay instalados otros métodos de rellamada
* para el TR. El último parámetro de scds_pmf_start indica el nivel
* de supervisión de secundarios. Dado que el análisis se inició bajo PMF,
* hay que supervisar sólo el proceso de análisis, por lo que se usa
* un valor de 0.
    */
   err = scds_pmf_start(scds_handle, SCDS_PMF_TYPE_MON,
       SCDS_PMF_SINGLE_INSTANCE, “xfnts_probe”, 0);

   if (err != SCHA_ERR_NOERR) {
      scds_syslog(LOG_ERR,
          “No se ha podido iniciar el supervisor de fallos.”);
      return (1);
   }

   scds_syslog(LOG_INFO,
       ““Se ha iniciado el supervisor de fallos.”);

   return (SCHA_ERR_NOERR); /* Supervisor iniciado satisfactoriamente */
}


/*
* Esta función detiene el supervisor de fallos de un recurso HA-XFS.
* Esto se hace a través de PMF. La etiqueta de PMF para el supervisor
* de fallos se construye basándose en <RG-name_RS-name,instance_number.mon>.
 */

int
mon_stop(scds_handle_t scds_handle)
{

   scha_err_t   err;

   scds_syslog_debug(DBG_LEVEL_HIGH,
      “Invocando método scds_pmf_stop”);

   err = scds_pmf_stop(scds_handle, SCDS_PMF_TYPE_MON,
       SCDS_PMF_SINGLE_INSTANCE, SIGKILL,
       scds_get_rs_monitor_stop_timeout(scds_handle));

   if (err != SCHA_ERR_NOERR) {
      scds_syslog(LOG_ERR,
          “No se ha podido detener el supervisor de fallos.”);
      return (1);
   }

   scds_syslog(LOG_INFO,
       “Se ha detenido el supervisor de fallos.”);

   return (SCHA_ERR_NOERR); /* Supervisor detenido satisfactoriamente */
}

/*
 * svc_probe(): realizar análisis específico de servicio de datos.
* Devolver un valor flotante entre 0 (satisfactorio) y 100 (fallo total).
*
* El análisis realiza una conexión de zócalo simple al servidor XFS en el
* puerto especificado, que se configura como la propiedad de extensión de
* recurso (Port_list) y realiza un pulso de sondeo del servicio de datos.
* Si el análisis no puede conectarse al puerto, se devuelve un valor de 100,
* que indica que el fallo es total. Si la conexión se realiza y falla
* la desconexión del puerto, se devuelve un valor de 50, que indica un
* fallo parcial.
 */
int
svc_probe(scds_handle_t scds_handle, char *hostname, int port, int
timeout)
{
   int  rc;
   hrtime_t   t1, t2;
   int    sock;
   char   testcmd[2048];
   int    time_used, time_remaining;
   time_t      connect_timeout;


   /*
    * Analizar el servicio de datos con una conexión de zócalo al puerto
* especificado en la propiedad port_list del sistema que sirve al
* servicio de datos XFS. Si el servicio XFS configurado para
* recibir en el puerto especificado responde a la conexión, el
* análisis es satisfactorio. En caso contrario, se esperará durante un
* tiempo definido en la propiedad probe_timeout antes de concluir
* que el análisis ha fallado.
    */

   /*
    * Utilizar el porcentaje SVC_CONNECT_TIMEOUT_PCT del tiempo de 
* espera para conectarse al puerto
*/
   connect_timeout = (SVC_CONNECT_TIMEOUT_PCT * timeout)/100;
   t1 = (hrtime_t)(gethrtime()/1E9);

   /*
    * el analizador establece una conexión al puerto y nombre de sistema
* especificados. La conexión debe ocupar un 95% del probe_timeout real.
    */
   rc = scds_fm_tcp_connect(scds_handle, &sock, hostname, port,
       connect_timeout);
   if (rc) {
      scds_syslog(LOG_ERR,
          “No se ha podido conectar con el puerto <%d> del recurso <%s>.”,
          port, scds_get_resource_name(scds_handle));
      /* es un fallo total  */
      return (SCDS_PROBE_COMPLETE_FAILURE);
   }

   t2 = (hrtime_t)(gethrtime()/1E9);

   /*
    * Calcular el tiempo real que tardó la conexión. Debe ser inferior o igual
* a connect_timeout, el tiempo asignado para la conexión. Si la conexión
* emplea todo el tiempo que se le ha asignado, el valor restante de
* probe_timeout pasado a esta función se utilizará como tiempo de espera
* de desconexión. En caso contrario, el tiempo restante de la llamada de
* conexión se agregará también al tiempo de espera de desconexión.
    *
    */

   time_used = (int)(t2 - t1);

   /*
    * Utilizar el tiempo restante (tiempo de espera - time_took_to_connect) 
    * para la desconexión
    */

   time_remaining = timeout - (int)time_used;

   /*
   * Si se usa todo el tiempo, utilizar un tiempo de espera estático reducido
* para intentar la desconexión. Así se evitan fugas de fd.
    */
   if (time_remaining <= 0) {
      scds_syslog_debug(DBG_LEVEL_LOW,
          “svc_probe ha utilizado el tiempo de espera completo de  “
          “%d segundos durante la operación de conexión y ha superado el  “
          “tiempo de espera en %d segundos. Intentando desconectar con un“
“tiempo de eespera de“ 
          “ %d “,
          connect_timeout,
          abs(time_used),
          SVC_DISCONNECT_TIMEOUT_SECONDS);

      time_remaining = SVC_DISCONNECT_TIMEOUT_SECONDS;
   }

   /*
   * Devolver fallo parcial en caso de un fallo de desconexión.
* Motivo: la llamada de conexión ha sido satisfactoria, lo que significa
* que la aplicación está activa. Un fallo de desconexión puede
* deberse a una aplicación bloqueada o a una carga pesada. Si es éste
* el caso, no declarar la aplicación terminada devolviendo un fallo total.
* Declarar un fallo parcial en su lugar. Si la situación persiste, la
* llamada de desconexión fallará otra vez y se reiniciará la aplicación.
    */
   rc = scds_fm_tcp_disconnect(scds_handle, sock, time_remaining);
   if (rc != SCHA_ERR_NOERR) {
      scds_syslog(LOG_ERR,
          “No se ha podido desconectar el puerto %d del recurso %s.”,
          port, scds_get_resource_name(scds_handle));
      /* es un fallo parcial */
      return (SCDS_PROBE_COMPLETE_FAILURE/2);
   }

   t2 = (hrtime_t)(gethrtime()/1E9);
   time_used = (int)(t2 - t1);
   time_remaining = timeout - time_used;

   /*
    * Si no hay tiempo, no realizar la comprobación total con
* fsinfo. Devolver SCDS_PROBE_COMPLETE_FAILURE/2. Así, si
* persiste el tiempo de espera agotado, el servidor se reiniciará.
    */
   if (time_remaining <= 0) {
      scds_syslog(LOG_ERR, “Tiempo de espera de análisis excedido.”);
      return (SCDS_PROBE_COMPLETE_FAILURE/2);
   }

   /*
    * La conexión y desconexión del puerto son satisfactorias,
* Ejecutar la orden fsinfo para realizar una comprobación total
* del estado del servidor. Redirigir stdout, si no, la salida de
* fsinfo terminará en la consola.
    */
   (void) sprintf(testcmd,
       “/usr/openwin/bin/fsinfo -server %s:%d > /dev/null”,
       hostname, port);
   scds_syslog_debug(DBG_LEVEL_HIGH,
       “Comprobar el estado del servidor con %s.”, testcmd);
   if (scds_timerun(scds_handle, testcmd, time_remaining,
      SIGKILL, &rc) != SCHA_ERR_NOERR || rc != 0) {

      scds_syslog(LOG_ERR,
         “No se pudo comprobar estado del servidor con la orden <%s>”,
         testcmd);
      return (SCDS_PROBE_COMPLETE_FAILURE/2);
   }
   return (0);
}