messages.c

Go to the documentation of this file.

/*  Implémentation Linux de la bibliotheque XADLL de Sidena
 *  Copyright (C) 2005 ENSTAR
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 *  You can contact us:
 *    Association ENSTAR
 *    Ecole Nationale Superieure de Techniques Avancees
 *    32 boulevard Victor
 *    75739 Paris Cedex 15
 *    FRANCE
 *
 *    enstar@ensta.fr
 */

/** @file    messages.c
 *  @brief   Construction des messages
 *  @author  Francois Fevotte <francois.fevotte@ensta.org>
 *  $Revision: 51 $
 *  $Date: 2006-03-15 12:14:13 +0100 (Wed, 15 Mar 2006) $
 */

/* $Id: messages.c 51 2006-03-15 11:14:13Z francois $ */

#define MESSAGES_C
#include <time.h>

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/time.h>
#include <sys/types.h>

#include "statique.h"
#include "xalib.h"
#include "os_dep_usb.h"    /* Fonctions bas-niveau spécifiques pour l'USB    */
#include "os_dep_serial.h" /* Fonctions bas-niveau spécifiques pour le RS232 */
#include "messages.h"


/* Gestion des erreurs */
#define SOURCE_ERREUR "messages"
#ifdef DEBUG
#define SCREEN_LEVEL 3 // messages de warning a l'ecran
#else
#define SCREEN_LEVEL 2 // pas de messages de warning
#endif
#include "erreur.h"


unsigned int somme;        /**< Checksum */


void XA_raw_insertB (unsigned char octet)
{
  Out_buffer [XA_lastcar_out] = octet ;
 
  if( XA_lastcar_out < 255 )
    XA_lastcar_out++;
 
  somme += octet ;
}


void XA_insertB (unsigned char octet)
{
  if( (octet >= 26) && (octet <= 30) )
    {
      XA_raw_insertB (26);
      XA_raw_insertB (octet - 26);
    }
  else
    {
      XA_raw_insertB (octet) ;
    }
}


void XA_createmsg (unsigned char adrmod, char read)
{
  if( XA_lastcar_out == 0) /* Nouveau message */
    {
      XA_raw_insertB (27);
      if( (XA_typepack==2) || (XA_typepack==3) )
        XA_insertB (XA_adrpack);
      somme = 27;
    }
  else
    {
      XA_raw_insertB (28);
    }
 


  if( read==1 )
    XA_insertB (adrmod + adrmod + 1);
  else
    XA_insertB (adrmod + adrmod);
}


void XA_build (unsigned char adrmod, unsigned char fonction, unsigned char lngrec)
{
  XA_createmsg (adrmod, 1) ;
  XA_insertB (lngrec) ;
  XA_insertB (fonction) ;
}


char XA_send()
{
  int indice;
  clock_t time_now;
  unsigned char octet;
 
  if( !XA_opendone )
    {
      coderr = 103;
      XA_lastss = 0;
      XA_ptrget = 1;
      XA_lastcar_out = 0;
      return coderr;
    }
 
  if( XA_lastcar_out==0 )
    {
      coderr = 104;
      XA_lastss = 0;
      XA_ptrget = 1;
      XA_lastcar_out = 0;
      return coderr;
    }
 
  /* nettoyages */
  for(indice=0 ; indice<255 ; indice++)
    Rec_buffer[indice] = 0;
 
  /* table des positions des sous messages */
  for(indice=0 ; indice<8 ; indice++)
    tabss[indice] = 0;
 
  coderr = 113 ;             /* Erreur non identifiée */
  XA_insertB (lo (somme));   /* ajouter la checksum */
  XA_raw_insertB (29) ;      /* ajouter 29 (=fin message) */

  time_now = clock();        /* Top départ */
  octet = XA_lastss = XA_lastcar_in = somme = 0;

  if( XA_typepack > 2 || XA_typepack < 0 )
    {
      char message[1024];
      snprintf(message,1023,"XA_send : type de pack inconnu (typepack=%d)",XA_typepack);
      erreur::fatale( message );
      coderr = 102;
      return coderr;
    }

  if( XA_typepack==0 ) /* USB */
    {
      int i;
      if( !(usb::write(XA_lastcar_out)))
        {
          XA_lastss = 0;
          XA_ptrget = 1;
          XA_lastcar_out = 0;
          return coderr;
        }
  
      /* Lecture ... */
      usb::read( 3+Out_buffer[2] );
      octet = Rec_buffer[XA_lastcar_in-1];
      for( i=0 ; i<XA_lastcar_in-1 ; i++ )
        {
          somme += Rec_buffer[i];
        }

      if( octet != 30 )
        {
          char message[1024];
          snprintf(message,1023,"XA_send : message non termine (dernier caractere = %02X)",octet);
          erreur::warning(message);
          XA_lastss = 0;
          XA_ptrget = 1;
          XA_lastcar_out = 0;
          coderr = 117;
          return coderr;
        }
    }
  else /* Port série */
    {
      if( !(serial::write(XA_lastcar_out)))
        {
          XA_lastss = 0;
          XA_ptrget = 1;
          XA_lastcar_out = 0;
          return coderr;
        }
  
      /* Lecture ... */
      serial::read( &somme );
      octet = Rec_buffer[XA_lastcar_in-1];

      if( octet != 30 )
        {
          char message[1024];
          snprintf(message,1023,"XA_send : message non termine (dernier caractere = %02X)",octet);
          erreur::warning(message);
          XA_lastss = 0;
          XA_ptrget = 1;
          XA_lastcar_out = 0;
          coderr = 117;
          return coderr;
        }
    }

  XA_lastss = 0;
  XA_ptrget = 1;
  XA_lastcar_out = 0;

  if ((somme%256) != 255)
    {
      char message[1024];
      snprintf(message,1023,"XA_send : erreur de checksum (checksum = %3d)",somme%256);
      erreur::warning(message);
      coderr = 106;
      return coderr;
    }

  if( (coderr = Rec_buffer[0]) != 0 )
    {
      char message[1024];
      snprintf(message,1023,"XA_send : erreur renvoyee par les cartes XA (code = %3d)",coderr);
      erreur::warning(message);
      return coderr;
    }
 
  return coderr;
}

---