//---------------------------------------------------------------------------// // Autor: José Manuel Toledo Fernández // // Fecha: 17-12-2005 // // Nombre: hilolec.cpp // // // // Descripción: Este fichero contiene todo lo referente al hilo de lectura // // que trabaja de forma paralela tanto al hilo de escritura // // como a la aplicación en general // //---------------------------------------------------------------------------// #include #pragma hdrstop #include "Plano\MPlano.h" #include "hilolec.h" #include "CalculaCRC.h" #include "UFcomvent.h" #pragma package(smart_init) //--------------------------------------------------------------------------- // Important: Methods and properties of objects in VCL can only be // used in a method called using Synchronize, for example: // // Synchronize(UpdateCaption); // // where UpdateCaption could look like: // // void __fastcall Unit2::UpdateCaption() // { // Form1->Caption = "Updated in a thread"; // } //--------------------------------------------------------------------------- /*! En el constructor iniciamos las distintas banderas*/ __fastcall Thilolectura::Thilolectura(bool CreateSuspended) : TThread(CreateSuspended) { Token_ok=true; SC = new TCriticalSection(); } //---------------------------------------------------------------------------- /*! Se encarga de gestionar todos los datos recibidos por el puerto serie, si los datos son correctos los almacenamos en la cola de recepcion o bien los trabajamos con ellos*/ void __fastcall Thilolectura::Execute() { DWORD dwCommEvent; // Registra el evento ocurrido en MComLec AnsiString cadena; bool bandera=false; bool trama_ok=false; bool recibiendo=false; // int k=0; flag=0; Token_ok=true; trama=cadena=""; Est_trama = new Trama; osReader.hEvent=CreateEvent(NULL,FALSE,FALSE,NULL);//primero creamos un evento if (osReader.hEvent!=NULL) { ResetEvent(osReader.hEvent); SetCommMask(MComLec,EV_RXCHAR | EV_ERR); //sensibilidad del evento } else { ShowMessage("NO_EVENTOS"); } while(!Terminated) { if ((WaitCommEvent(MComLec,&dwCommEvent,&osReader)==false)&&(GetLastError()==ERROR_IO_PENDING)) WaitForSingleObject(osReader.hEvent,INFINITE); // Dormimos hilo bandera=true; while((bandera==true)&&(!Terminated)) { bandera=ReadFile(MComLec,&CHAR,1,&Numleidos,&(osReader)); if ((bandera==false)&&(GetLastError()==ERROR_IO_PENDING)) WaitForSingleObject(osReader.hEvent,INFINITE); // Dormimos hilo if ((dwCommEvent!=(EV_RXCHAR|EV_ERR))&&(dwCommEvent!=EV_ERR)) { if(FormComVent->Visible == false) { if(CHAR=='$') { recibiendo=true; cadena="$"; // Token_ok=false; } else if(CHAR=='#') //Espera una trama GPZDA para establecer la comunucacion { recibiendo=true; cadena="#"; // Token_ok=false; } else if(recibiendo==true) //entramos si hemos empezado a recibir una cabecera { if(CHAR != 13) { cadena = cadena+CHAR; } else //cuando llega al final de la trama entramos a gestionarla { trama = cadena; recibiendo=false; Token_ok= true; CHAR=NULL; //una vez llega final de trama bajamos la bandera trama_ok=verifica_trama(trama.c_str(),trama.Length()); if(trama_ok) { flag=Rellenatrama(trama.c_str(),trama.Length(),Est_trama); if((flag>0)&&(confirmacion==true)) { SC->Acquire(); try { PilaTrama.push_front(Est_trama); } __finally { SC->Release(); } } if((confirmacion==false)&&(flag==2)) //si hemos recibido una GPZDA ok=>comunicaciones ok { PilaTrama.push_back(Est_trama); confirmacion=true; } } cadena=""; //aqui procesamos la trama } } } else if(FormComVent->Visible == true) //si Ventana de comandos abierto entonces no tratamos la trama { Token_ok= true; //y token siempre a true FormComVent->Outs->Lines->Text=(FormComVent->Outs->Lines->Text+CHAR); if ((CHAR == 0x0A)||(CHAR == ']')) { WORD wScrollNotify = 0xFFFF; wScrollNotify = SB_BOTTOM; SendMessage(FormComVent->Outs->Handle, WM_VSCROLL,MAKELONG(wScrollNotify, 0), 0L); } CHAR = NULL; } } else { ShowMessage("error en la recepción del carácter"); cadena=""; bandera=false; recibiendo=false; Token_ok= true; } } } if ((osReader.hEvent)!=NULL) CloseHandle (osReader.hEvent); delete (SC); } //--------------------------------------------------------------------------- /*! Verifiacamos que todas las tramas recibida por el puerto serie, tienen la estructura adecuada y además que no contienen errores. En caso de que sea todo correcto devolvemos true y en caso contrario false*/ bool Thilolectura::verifica_trama(char *ptrama,int lon) { char CHAR[2]; char ccr_cad[8]; int i=0; int j=0; unsigned long ccr_calculada=0; unsigned long ccr_recibida=0; unsigned long ccr_aux=0; bool trama_ok=false; if(ptrama[i]=='#') j=28; else if(ptrama[i]=='$') j=4; else j=0; if(j!=0) { ptrama++; while((ptrama[i]!='*')&&(ptrama[i]!='\0')) { i++; } if (ptrama[i]=='*') { strcpy(ccr_cad,&ptrama[i+1]); //cogemos el ccr sin el * y lo guadamos ptrama[i] = '\0'; //cortamos la cadena quitando el * lon=i; i=0; if(j==28) ccr_calculada = CalculateBlockCRC32(lon,ptrama); //devuelve 32 bits else if(j==4) ccr_calculada = CalculateBlockCRC8(ptrama); //devuelve 8 bits while(j>=0) { CHAR[0]=ccr_cad[i]; //copiamos caracter a caracter CHAR[1]='\0'; ccr_aux = strtol(CHAR,NULL,16); //pasamos a long desde HEX ccr_aux=ccr_aux< e-REdING. Biblioteca de la Escuela Superior de Ingenieros de Sevilla.


SOFTWARE PARA LA MONITORIZACIÓN Y CONTROL DE RECEPTORES GPS. APLICACIÓN A RECEPTORES NOVATEL RT-2

: TOLEDO FERNÃNDEZ, JOSÉ MANUEL
: Ingeniería Telecomunicación
Contenido del proyecto:
Directorio raíz  >  InterGPS  >  InterGPS_codigo  >  hilolec.cpp