IdentifiantMot de passe
Loading...
Mot de passe oublié ?Je m'inscris ! (gratuit)
logo

FAQ VC++ et MFCConsultez toutes les FAQ

Nombre d'auteurs : 20, nombre de questions : 545, dernière mise à jour : 5 avril 2013  Ajouter une question

 

Cette faq a été réalisée pour répondre aux questions les plus fréquement posées sur le forum Développement Visual C++

Je tiens à souligner que cette faq ne garantit en aucun cas que les informations qu'elle contient sont correctes ; Les auteurs font le maximum, mais l'erreur est humaine. Si vous trouvez une erreur, ou si vous souhaitez devenir redacteur, lisez ceci.

Sur ce, je vous souhaite une bonne lecture. Farscape

SommaireRéseau et Communications (5)
précédent sommaire suivant
 

Code c++ : Sélectionner tout
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
#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;  
}

Mis à jour le 5 avril 2013 barthelv

Code c++ : Sélectionner tout
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
  
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);  
}

Mis à jour le 4 avril 2005 farscape

En utilisant l'api IsNetworkAlive :

Code C++ : Sélectionner tout
1
2
3
4
5
6
7
8
9
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 requiert 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 : SensAPI.zip

Autres liens utiles :

Mis à jour le 5 avril 2013 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 :

Code c++ : Sélectionner tout
1
2
3
  
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.

Mis à jour le 5 avril 2013 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.

Code C++ : Sélectionner tout
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
// 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
Code C++ : Sélectionner tout
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
// 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 : SerialDemo.zip

Mis à jour le 31 octobre 2004 farscape

Proposer une nouvelle réponse sur la FAQ

Ce n'est pas l'endroit pour poser des questions, allez plutôt sur le forum de la rubrique pour ça


Réponse à la question

Liens sous la question
précédent sommaire suivant
 

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 © 2024 Developpez Developpez LLC. Tous droits réservés Developpez LLC. Aucune reproduction, même partielle, ne peut être faite de ce site et 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.