IdentifiantMot de passe
Loading...
Mot de passe oublié ?Je m'inscris ! (gratuit)
logo
Sommaire > Réseau et Communications
        Comment récupérer le nom d'hôte à partir de l'adresse IP de la machine?
        Comment convertir un nom d'hôte en adresse IP ?
        Comment détecter la présence du réseau ?
        Comme détecter la perte d'un client avec les CSockets ?
        Comment travailler avec le port série ?



Comment récupérer le nom d'hôte à partir de l'adresse IP de la machine?
auteur : barthelv
#include <stdafx.h> 
#include <windows.h> 
#include <winsock.h> 
#include <stdio.h> 

int main ( int argc, char *argv[] ) { 
  struct hostent *sn; 
  struct in_addr in; 
  WSADATA wsaData; 
  WORD wVersionRequested; 

  if ( argc != 2 ) 
    exit(1); 

  wVersionRequested = MAKEWORD( 2, 2 ); 
  WSAStartup( wVersionRequested, &wsaData ); 

  in.s_addr = inet_addr(argv[1]); 
  sn = gethostbyaddr((char *)&in, 4, AF_INET); 

  if ( sn ) 
    printf("%s\n", sn->h_name); 
  else 
    printf("?\n"); 

  return 0; 
}

Comment convertir un nom d'hôte en adresse IP ?
Créé le 04/04/2005[haut]
auteur : Farscape

CString GetHostByName(const char *szName) 
{ 
     struct  hostent *h; 
     DWORD   dwMyAddress; 
     CString strLocalHost; 

   h = static_cast<struct hostent *>(::gethostbyname(szName)); 
     
   memcpy(&dwMyAddress,h->h_addr_list[0],sizeof(DWORD)); 
   if (dwMyAddress == INADDR_NONE)   return ""; 

   struct   in_addr     tAddr; 
   memcpy(&tAddr,&dwMyAddress,sizeof(DWORD)); 

  char *pAdr=::inet_ntoa(tAddr); 
   if(!pAdr) return ""; 

   return CString(pAdr); 
}

Comment détecter la présence du réseau ?
auteur : Farscape
En utilisant l'api IsNetworkAlive:

    unsigned long LAN = NETWORK_ALIVE_LAN;    
    if(IsNetworkAlive(&LAN) == true)
    {
         TRACE("\nRéseau Ok !!!");
    }
    else
    {
         TRACE("\nRéseau Not Ok !!!");
    } 
Note: L'utilisation de cette api requièrt la présence du fichier en-tête sensapi.h et de la bibliothèque sensapi.lib disponibles dans le SDK.
Néanmoins pour les pressés vous pouvez télécharger ces fichiers ici : http://farscape.developpez.com/Samples/SensAPI.zip



Comme détecter la perte d'un client avec les CSockets ?
auteur : Farscape
Il y a un mécanisme standard dans les Sockets permettant de vérifier si la connexion est toujours valide c'est le KEEPALIVE.
Au niveau de la socket :

long one=1;
/*CAsyncSocket*/ MySocket.SetSockOpt(SO_KEEPALIVE,(char *)&one,sizeof(one)))
Les connexions sockets seront vérifiées tout les x millisecondes si la connexion n'est plus valide on reçoit un close avec un code d'erreur.
Avec Windows NT le paramétrage du temps se fait dans la base de registre à cet emplacement:
HKEY_LOCAL_MACHINE\SYSTEM\ControlSet001\Services\NetBT\Parameters La clef: SessionKeepAlive valeur par défaut :3600000 ms. soit une heure .
On peut descendre la valeur pour 60s minimum.


Comment travailler avec le port série ?
Mise à jour le 31/10/2004[haut]
auteur : Farscape
Pour travailler avec le port série sous Windows on utilisera les fonctions suivantes :

  • Createfile : pour ouvrir le port ;
  • Writefile : pour envoyer des données ;
  • ReadFile : pour lire des données ;
  • CloseHandle : fermeture du handle de communication.
Liste des fonctions annexes à utiliser.

  • GetCommMask
  • SetCommMask
  • SetupComm
  • GetCommState
  • GetCommTimeouts
  • BuildCommDCB
  • ClearCommError
  • GetOverlappedResult
Différentes définitions :

  • RTS_CONTROL_HANDSHAKE = utilisation normale du handshake ;
  • RTS_CONTROL_DISABLE = position fixe du signal (modifiable par programme) ;
  • RTS_CONTROL_ENABLE = position fixe du signal(modifiable par programme) ;
  • RTS_CONTROL_TOGGLE= souvent utilisé pour commander l'émission des modems half/duplex sur ligne multipoints.
Définition généraliste du HandShaking :
L'expression handshaking est utilisée pour décrire les procédures de mise en accord de deux équipements connectés.

Contrôle de flux XON/XOFF :
Utilisé le plus souvent sur des périphériques tel que les imprimantes séries, ou des consoles Unix par exemple.
Ce protocole a l'avantage de n'utiliser du point de vue connectique que deux fils RX/TX (broches 2/3) , la gestion de flux étant réalisée par les caractères Xon/Xoff correspondant aux codes ASCII 17 et 19 .
Ce protocole ne doit pas être utilisé pour un transfert de fichier binaire sous peine de problèmes .
Xon:rétablit la communication lorsque le registre tampon de réception est vide.
Xoff:Interrompt la communication lorsque le registre tampon de réception est plein .L'arrêt est bilatérale.

Contrôle de flux Matériel :

RTS/CTS :
CTS :Clear To Send. PAE pour Prêt À Émettre en français. Réponse d'acceptation de l'émission, après un RTS.
RTS : Request To Send. Trame permettant à un émetteur de prévenir le récepteur qu'il veut parler. On lui répond par CTS.
Si RTS passe en position basse (tension négative), cela se traduit par : arrêtez d'envoyer.
Quand le récepteur est prêt à recevoir plus de données, il relance RTS, demandant à l'autre côté de reprendre l'envoi.

DTR/DSR :
C'est un contrôle de flux unidirectionnel uniquement.
DTR : Data Terminal Ready. Terminal de données prêt.
Indique au modem que l'ordinateur est sous tension et qu'il est prêt.
DSR : Data Set Ready. Modem Prêt.
Sert à indiquer à l'ordinateur (DTE) que le modem est sous tension et prêt .

Voici une classe de gestion du port série minimaliste avec les fonctions de base implémentées mettant en ?uvre les fonctions précitées.
Note : L'exemple qui suit utilise le flag FILE_FLAG_OVERLAPPED dans le createfile .
Ce flag active le mode de communication asynchrone parce qu'il ne faut pas faut pas travailler en mode synchrone c'est ingérable : C'est le moyen le plus sûr de perdre des caractères en réception ou de bloquer l'application.
Le mode asynchrone est beaucoup plus souple, les opérations sont placées en file d'attente par le système et traitées dés que possible.
La gestion des fonctions WriteFile et ReadFile est un peu plus compliqué voir dans le code les détails d'implémentations.

// SerialCom.h

#if !defined(AFX_SERIALCOM)
#define AFX_SERIALCOM

#if _MSC_VER > 1000
#pragma once
#endif 

// _MSC_VER > 1000

// Farscape-dev@Tiscali.fr : Classe Mininum gestion port série.
// Release du 01/11/2004: Met private le constructeur de copie et l'operateur d'affectation.
// Release du 05/05/2004 :Gestion d'un thread de reception des données
// rajoute les fonctions suivantes:
//
//   void SetParentNotify(CWnd *pParent){m_pParent=pParent;}
//   bool PurgeCom();
//   boolPurgeRx();
//   boolPurgeTx();
//   bool StartThread(CWnd *pParent);
//   boo lResumeThread();
//   bool StopThread();
//   bool SetTimeouts(DWORD dwRxTimeout=5000,DWORD dwTxTimeout=5000);  
//   virtual void OnError(DWORD dwError);
//   bool IsRXEmpty();
//   Modifications et correction de :
//   bool  WaitCommEvent(DWORD &rEvtMask);

#define XON  17
#define XOFF 19

// messages à destination de la fenêtre de traitement.

#define WM_CCOMRCV   WM_USER+100 // réceptions sur la voie série
#define WM_CCOMEVENT WM_USER+101 // evénements sur la voie série.
#define WM_CCOMERROR WM_USER+102 // erreurs sur la voie série.

class CCom
{
public:
   CCom();
   ~CCom();

   // ouverture du port série
   bool  PortOpen(int portnumber,long baudrate,char parity,int wordlength,int stopbits);
   // réglage vitesse ,parité ,longueur de la data et du bit de stop.
   // ex : 1 : Com1 , 'N' :none , 8 : data 8 bits ,   1 ou 2 : bit de stop
   bool  PortSet(long baudrate,char parity,int wordlength,int stopbits);

    //  Fermeture du port.
   bool  PortClose();

   // Envoie d'une chaîne de caractères la longueur est facultative si elle se termine par ?\0'
   bool  WriteBuffer(const char *buffer,unsigned int ucount=0);

   // lecture d'une chaîne de caractères d'une taille donnée.
   // GetCountRead() contiendra la taille reellement lue .
   int   ReadBuffer(char *buffer,unsigned int ucount);

   // lecture d'un charactere.
   bool ReadChar(char &rchar);

   // Réglage du mode de communication XON/XOFF
   bool  UseXonXoff(bool bEnable=true);

   // Réglage du mode de communication Rts/Cts
   bool  UseRtsCts(bool bEnable=true);

   // Réglage du mode de communication Dtr/Dsr
   bool  UseDtrDsr(bool bEnable=true);

   // Renvoie le nombre d'octets dans le buffer de reception avant lecture
   long SizeUsedInRXBuf();              

   // renvoie true si le buffer de reception est vide.
   bool IsRXEmpty();

   // Attente d'un événement fixé par SetCommMask()
   bool  WaitCommEvent(DWORD &rEvtMask);

   // fixe la gestion des evenements sur le port serie. Voir doc MSDN :   EV_RXCHAR
   bool  SetCommMask(DWORD EvtMask);

   // recupere l'événement en cours.
   DWORD GetCommMask();

   // Renvoie sous forme litterale la derniere erreur rencontrée avec GetLastError()
   CString GetStringError(){return m_StrError;}

   // Renvoie la derniere valeur du nombre d'octets lus.
   int   GetCountRead(){return m_count;}

   // fixe la fenetre parent pour les messages en provenance de la voie serie.
   void SetParentNotify(CWnd *pParent){m_pParent=pParent;}

   // purge le port serie.
   bool PurgeCom();

   // purge la réception
   bool PurgeRx();

   // purge l'émission
   bool PurgeTx();

   // lancer le thread
   bool StartThread(CWnd *pParent);

   // redemarre le thread 
   bool ResumeThread();

   // stop le thread.
   bool StopThread();

   // réglage du timeout sur la reception et l'émission
   // Note par défaut le reglage de la voie est a 1s. 
   bool SetTimeouts(DWORD dwRxTimeout=5000,DWORD dwTxTimeout=5000);

   // fonction appelée en cas d'erreur detectée dans le thread.
   // envoie un message à la fenetre parent.
   virtual void OnError(DWORD dwError);

private:
    CCom(const CCom &rCom){ASSERT(0);}
    CCom  & operator = (const CCom & arg){ASSERT(0);return *this;}

protected:

    // thread de communication.
   static UINT Thread(LPVOID pParam);

   // récupération de l'erreur
   DWORD  GetError();

protected:
CWnd            *m_pParent;
CString         m_StrError;
DWORD           m_comerr;
HANDLE          m_hCom;
UINT            m_nInputBufferSize;
UINT            m_nOutputBufferSize;
DCB             m_dcb;
DWORD           m_EventMask;
COMMTIMEOUTS    m_ComTimeouts;
OVERLAPPED      m_Ov;
unsigned int    m_count;

long            m_baudrate;
char            m_parity;
int             m_wordlength;
int             m_stopbits;
CWinThread*     m_pThread;
HANDLE          m_hCloseCom;
HANDLE          m_hArrayEvent[2];
bool            m_bThreadExist;
};
#endif

 // !defined(AFX_SERIALCOM)

// cpp

// SerialCom.cpp
// Farscape-dev@Tiscali.fr : Classe Mininum gestion port série.
#include "stdafx.h"
#include "SerialCom.h"

CCom::CCom()
{
    // Construct
    m_hCom =NULL;   
    m_Ov.hEvent=NULL;
    m_comerr=0;
    m_count=0;
    m_pParent=NULL;
    m_pThread=NULL;
    m_hCloseCom=NULL;
    m_bThreadExist=false;
}
//-----------------------------------------
CCom::~CCom()
{
    // Destruct    
    PortClose( );
}
//-----------------------------------------
DWORD CCom::GetError()
{
    LPVOID lpMsgBuf;
    DWORD dw;
    
    FormatMessage(
        FORMAT_MESSAGE_ALLOCATE_BUFFER |
        FORMAT_MESSAGE_FROM_SYSTEM |
        FORMAT_MESSAGE_IGNORE_INSERTS,
        NULL,
        (dw=GetLastError()),
        0, // Default language
        (LPTSTR) &lpMsgBuf,
        0,
        NULL
        );   
    m_StrError=CString((LPTSTR)lpMsgBuf);   
    // Free the buffer.
    LocalFree( lpMsgBuf );
    return dw;
}
//-----------------------------------------
bool CCom::PortOpen(int portnumber,long baudrate,char parity,int wordlength,int stopbits)
{
   //
    char sz[20];
    m_nInputBufferSize=1050;
    m_nOutputBufferSize=1050;
    
    memset(&m_Ov,0,sizeof(m_Ov));
    
    wsprintf( sz, "\\\\.\\COM%d", portnumber);   
    m_hCom = CreateFile( sz,
        GENERIC_READ | GENERIC_WRITE,
        0,
        NULL,
        OPEN_EXISTING,
        FILE_FLAG_OVERLAPPED,
        NULL );
    
    if ( m_hCom == INVALID_HANDLE_VALUE )
    {
        GetError();
        return false;
    }   
    
    SetupComm( m_hCom, m_nInputBufferSize, m_nOutputBufferSize );
    ::GetCommMask( m_hCom, &m_EventMask );
    ::SetCommMask( m_hCom, 0 );
    
    m_dcb.fBinary = 1;
    m_dcb.fParity = 0;
    m_dcb.fNull = 0;
    m_dcb.XonChar = XON;
    m_dcb.XoffChar = XOFF;
    m_dcb.XonLim = (WORD)( ( m_nInputBufferSize) / 4 );
    m_dcb.XoffLim = (WORD)( ( m_nOutputBufferSize ) / 4 );
    m_dcb.EofChar = 0;
    m_dcb.EvtChar = 0;
    m_dcb.fOutxDsrFlow = 0;
    m_dcb.fOutxCtsFlow = 0;
    m_dcb.fDtrControl = DTR_CONTROL_ENABLE;
    m_dcb.fRtsControl = RTS_CONTROL_ENABLE;
    
    GetCommState( m_hCom, &m_dcb );
        
    GetCommTimeouts( m_hCom, &m_ComTimeouts );
        
    m_ComTimeouts.ReadIntervalTimeout = 1000;
    m_ComTimeouts.ReadTotalTimeoutMultiplier = 1000;
    m_ComTimeouts.ReadTotalTimeoutConstant = 1000;
    m_ComTimeouts.WriteTotalTimeoutMultiplier = 1000;
    m_ComTimeouts.WriteTotalTimeoutConstant = 1000;
    
    SetCommTimeouts( m_hCom, &m_ComTimeouts );
    
    return PortSet(baudrate,parity,wordlength,stopbits);
}
//-----------------------------------------
bool CCom::SetTimeouts(DWORD dwRxTimeout /*=5000*/,DWORD dwTxTimeout /*=5000*/)
{
// 
    if(m_hCom== NULL)
    {
        TRACE0("CCom::SetTimeouts': NULL handle !");      
        return 0;
    } 
    COMMTIMEOUTS  commTimeOuts ;
    commTimeOuts.ReadIntervalTimeout = dwRxTimeout;
    commTimeOuts.ReadTotalTimeoutMultiplier = 1;
    commTimeOuts.ReadTotalTimeoutConstant = dwRxTimeout;
    commTimeOuts.WriteTotalTimeoutMultiplier = 1;
    commTimeOuts.WriteTotalTimeoutConstant = dwTxTimeout;
    
    SetCommTimeouts(m_hCom, &commTimeOuts ) ;
    return true;
}
//-----------------------------------------
bool CCom::PortSet(long baudrate,char parity,int wordlength,int stopbits )
{   
    int result;
    
    if(!m_hCom) return false;
    
    m_baudrate=baudrate;
    m_parity=parity;
    m_wordlength=wordlength;
    m_stopbits=stopbits;
    
    char *szBaud = new char[50];
    sprintf(szBaud, "baud=%d parity=%c data=%d stop=%d", baudrate,parity,wordlength,stopbits);
    if (result=GetCommState(m_hCom,&m_dcb))
    {
        m_dcb.fRtsControl = RTS_CONTROL_ENABLE;
        result=-1;
        if (BuildCommDCB(szBaud, &m_dcb)) result=SetCommState(m_hCom, &m_dcb);   
    }
    if ( result < 0 )  GetError();
    delete szBaud;
    PurgeCom();
    return( (result >0) );
}
//-----------------------------------------
bool CCom::PortClose()
{
    //
    if(!m_hCom) return false;
    
    if(m_pThread) // fermeture thread
    {
        do
        {
            SetEvent(m_hCloseCom);
        }
        while(m_bThreadExist);
        CloseHandle(m_hCloseCom);
    }
    if(m_Ov.hEvent) CloseHandle(m_Ov.hEvent);
    m_Ov.hEvent=NULL;
    m_hCloseCom=NULL;
    m_pThread=NULL;
    
    EscapeCommFunction( m_hCom, CLRDTR );
    EscapeCommFunction( m_hCom, CLRRTS );
    
    int status= CloseHandle( m_hCom);   
    m_hCom=NULL;
    if ( status ) return true;
    GetError();
    return false;
}
//-----------------------------------------
bool CCom::WriteBuffer(const char *buffer,unsigned int ucount /*=0*/)
{
   //
    int result;
    DWORD comerr;
    COMSTAT comstat;
    unsigned int amounttowrite;
    DWORD amountwritten;
    
    if(!ucount) ucount=strlen(buffer);
    
    ClearCommError( m_hCom, &comerr, &comstat );
    m_comerr |= comerr;
    amounttowrite = m_nOutputBufferSize - comstat.cbOutQue;
    if ( ucount < amounttowrite ) amounttowrite = ucount;
    
    result = WriteFile( m_hCom,
        buffer,
        (int) amounttowrite,
        &amountwritten,
        &m_Ov );
    
    m_count = amountwritten;
    if ( result == 0 )
    {
        if ( ( comerr = GetLastError() ) != ERROR_IO_PENDING )
        {
            ClearCommError( m_hCom, &comerr, &comstat );
            m_comerr|= comerr;
        }
        else m_count = amounttowrite;
    }
    if ( m_count < ucount ) return(0);
    return( 1 ); // succes
}
//-----------------------------------------
int CCom::ReadBuffer(char *buffer,unsigned int ucount)
{
   //
    int result;
    COMSTAT comstat;
    DWORD comerr;
    DWORD countread;
    DWORD counttoread;
    
    ClearCommError( m_hCom, &comerr, &comstat );
    if ( comerr > 0 ) m_comerr |= comerr;
    
    if ( comstat.cbInQue > 0 )
    {
        if ( comstat.cbInQue < ucount ) counttoread = comstat.cbInQue;
        else                        counttoread = ucount;
        result = ReadFile( m_hCom,buffer,(int) counttoread,&countread,&m_Ov );
        m_count = countread;
        if ( result == 0 )
        {
            if ( ( comerr = GetLastError() ) != ERROR_IO_PENDING )
            {
                ClearCommError( m_hCom, &comerr, &comstat );
                m_comerr |= comerr;
            }
        }
        if ( m_count < ucount )
        {
            if ( GetOverlappedResult( m_hCom, &m_Ov, &countread, TRUE ) )
            {
                m_count = countread;
                return ( 1 );
            }
            return ( - 1);
        }
        return( 1 );
    }
    else
    {
        m_count = 0;
        return( -1 );
    }
    return -1;
}
//-----------------------------------------
bool CCom::ReadChar(char &rchar )
{    
    return((ReadBuffer(&rchar,1)==0));
}
//-----------------------------------------
long CCom::SizeUsedInRXBuf()
{
    // 
    COMSTAT comstat;
    DWORD comerr;
    
    ClearCommError( m_hCom, &comerr, &comstat );
    m_comerr |= comerr;
    return comstat.cbInQue;
}
//-----------------------------------------
bool CCom::UseXonXoff(bool bEnable)
{
    //    
    int result;
    
    m_dcb.fInX = ( bEnable ) ? 1 : 0;
    m_dcb.fOutX = ( bEnable ) ? 1 : 0;
    result= SetCommState( m_hCom, &m_dcb );
    if ( result == TRUE ) return true;
    GetError();
    return false;
}
//-----------------------------------------
bool CCom::UseRtsCts(bool bEnable)
{
   //    
    int result;
    
    m_dcb.fOutxCtsFlow = ( bEnable ) ? 1 : 0;
    m_dcb.fRtsControl = ( bEnable) ? RTS_CONTROL_HANDSHAKE : RTS_CONTROL_DISABLE;
    result= SetCommState( m_hCom, &m_dcb );   
    if ( result == TRUE ) return true;
    GetError();
    return false;
}
//-----------------------------------------
bool CCom::UseDtrDsr(bool bEnable)
{
   //    
    int result;
    
    m_dcb.fOutxDsrFlow = ( bEnable ) ? 1 : 0;
    m_dcb.fDtrControl = ( bEnable ) ? DTR_CONTROL_HANDSHAKE : DTR_CONTROL_DISABLE;
    result= ::SetCommState( m_hCom, &m_dcb );
    if ( result == TRUE ) return true;   
    GetError();
    return false;
}
//-----------------------------------------
bool CCom::WaitCommEvent(DWORD &rEvtMask)
{
    //
    
    if(m_hCom== NULL)
    {
        TRACE0("CCom::WaitCommEvent': NULL handle !");
        ASSERT(FALSE);
        return false;
    }   
    
    if(!::WaitCommEvent(m_hCom,&rEvtMask,&m_Ov))
    {      
        TRACE1("\nCCom::WaitCommEvent:%d",GetLastError());
        GetError();
        return false;
    }
    return true;
}
//-----------------------------------------
DWORD CCom::GetCommMask()
{
    if(m_hCom== NULL)
    {
        TRACE0("CCom::GetCommMask': NULL handle !");      
        return 0;
    } 
    DWORD dwMask;
    ::GetCommMask( m_hCom, &dwMask);
    return dwMask;
}
//-----------------------------------------
bool CCom::SetCommMask(DWORD EvtMask)
{
   //    
    if(!m_Ov.hEvent)
        m_Ov.hEvent=CreateEvent(NULL,   // no security attributes
                                FALSE,  // auto reset event
                                FALSE,  // not signaled
                                NULL    // no name
                                );
    
    SetEvent(m_Ov.hEvent);
    
    return (::SetCommMask(m_hCom,EvtMask)>0);

}
//-----------------------------------------
bool CCom::PurgeRx()
{
    if(m_hCom== NULL)
    {
        TRACE0("CCom::PurgeRx': NULL handle !");      
        return false;
    } 
    ::PurgeComm(m_hCom, PURGE_RXCLEAR);
    return true;
}
//-----------------------------------------
bool CCom::PurgeTx()
{
    if(m_hCom== NULL)
    {
        TRACE0("CCom::PurgeTx': NULL handle !");      
        return false;
    } 
    ::PurgeComm(m_hCom, PURGE_TXCLEAR);
    return true;
}
//-----------------------------------------
bool CCom::PurgeCom()
{
    // 
    if(m_hCom== NULL)
    {
        TRACE0("CCom::PurgeCom': NULL handle !");      
        return false;
    } 
    // flush the port
    ::PurgeComm(m_hCom, PURGE_RXCLEAR | PURGE_TXCLEAR | PURGE_RXABORT | PURGE_TXABORT);
    return true;
}
//-----------------------------------------
bool CCom::StartThread(CWnd *pParent)
{
    // 
    SetParentNotify(pParent);
    
    if(!m_pParent || !PurgeCom()) return false;
    if(m_bThreadExist) // femeture thread .
    {
        do
        {
            SetEvent(m_hCloseCom);
        }
        while (m_bThreadExist);
        CloseHandle(m_hCloseCom);
    }
    m_hCloseCom =CreateEvent(NULL, TRUE, FALSE, NULL);
    m_hArrayEvent[0]=m_hCloseCom;
    m_hArrayEvent[1]=m_Ov.hEvent;
    
    if (!(m_pThread = AfxBeginThread(Thread, this))) return false;
    
    TRACE("Le Thread Démarre\n");
    return true;
}
//-----------------------------------------
bool CCom::IsRXEmpty() 
{
    long n;
    
    n = SizeUsedInRXBuf();
    if ( n < 0 )
    {
        OnError(GetError());
        return true;
    }
    return(( n==0));
}
//-----------------------------------------
bool CCom::ResumeThread()
{
    if(!m_pThread) return false;
    m_pThread->ResumeThread();
    return true;
}
//-----------------------------------------
bool CCom::StopThread()
{
    if(!m_pThread) return false;
    m_pThread->SuspendThread(); 
    return true;
}
//-----------------------------------------
/*virtual*/ void CCom::OnError(DWORD dwError)
{
// 
    if(m_pParent)
        m_pParent->PostMessage(WM_CCOMERROR,(WPARAM)this,dwError);
}
//-----------------------------------------
/*static*/ UINT CCom::Thread(LPVOID pParam)
{
// 
    CCom *pCom = (CCom*)pParam;
    int nResult;
    DWORD WaitEvent = 0;
    DWORD dwError=0;
    DWORD dwMaskEvent=0;
    
    pCom->m_bThreadExist=true; // amorce l'existance du thread
    while(1)
    {
        nResult=pCom->WaitCommEvent(dwMaskEvent);
        if (!nResult)  
        { 
            switch(dwError=GetLastError()) 
            {             
            case 87:
            case ERROR_IO_PENDING:
                break;
                
            default:
                {
                    // erreur de communication on fait suivre ...
                    pCom->GetError();
                    pCom->OnError(dwError);                    
                    break;
                }
            }
        }
        else
        {
            if(pCom->IsRXEmpty()) continue;
        }
        // attente evenement pour sortie eventuelle du thread ou reception
        WaitEvent = WaitForMultipleObjects(2, pCom->m_hArrayEvent, FALSE, INFINITE);
        
        switch (WaitEvent)
        {
        case 0: //Fermeture Thread 
                   pCom->m_bThreadExist=false;
                   AfxEndThread(1);
                   return(0);
            
        case 1:dwMaskEvent=pCom->GetCommMask();
                    if(dwMaskEvent & EV_RXCHAR) // reception sur la voie.
                         pCom->m_pParent->SendMessage(WM_CCOMRCV,(WPARAM)pCom,dwMaskEvent);
            
            if ((dwMaskEvent & EV_CTS) ||  // evenements divers.
                (dwMaskEvent & EV_RXFLAG) ||
                (dwMaskEvent & EV_BREAK) ||
                (dwMaskEvent & EV_ERR)
                || (dwMaskEvent & EV_RING))
            {
                pCom->m_pParent->SendMessage(WM_CCOMEVENT,(WPARAM)pCom,dwMaskEvent);
            }
            break;
        }
    };
    return 0;
}

// utilisation : consultation registres Modem Usr:
CCom com;
com.PortOpen(1,57600,'N',8,1);
com.UseRtsCts();

com.SetCommMask(EV_RXCHAR); // spécifie l'événement d'attente.
com.WriteBuffer("ATI7\r\n");

DWORD EvtMask;
com.WaitCommEvent(EvtMask);// attente réception 
char sz[1000];
com.ReadBuffer(sz,sizeof(sz));
AfxMessageBox(CString(sz,com.GetCountRead()));
Exemple d'implémentation avec un thread pour la réception des données:http://farscape.developpez.com/Samples/SerialDemo.zip



Consultez les autres F.A.Q.


Valid XHTML 1.0 TransitionalValid CSS!

Les sources présentées sur cette page sont libres de droits et vous pouvez les utiliser à votre convenance. Par contre, la page de présentation constitue une œuvre intellectuelle protégée par les droits d'auteur. Copyright © 2004 Developpez Developpez LLC. Tous droits réservés Developpez LLC. Aucune reproduction, même partielle, ne peut être faite de ce site ni de l'ensemble de son contenu : textes, documents et images sans l'autorisation expresse de Developpez LLC. Sinon vous encourez selon la loi jusqu'à trois ans de prison et jusqu'à 300 000 € de dommages et intérêts.