Diff: PC/PC.cpp

Revision:

0:1c1c9f47b8ad

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/PC/PC.cpp	Thu Jun 15 12:01:36 2017 +0000
@@ -0,0 +1,198 @@
+#include "PC.h"
+
+/***** Definitions *****/
+
+//******************************************************************************
+PC::PC(GV *_pgv, PinName _led, PinName tx, PinName rx) : MODSERIAL( tx, rx,  PCTxBufferSize,  PCRxBufferSize, NULL )
+{     
+    pgv=_pgv;
+    iEvent=NULL;
+    led=NULL;
+    
+    MailNum=0;
+    LOG=false;
+    SendStatus=false;
+    mode=0;
+    
+    if(_led!=NC) led=new DigitalOut(_led);
+    baud(PCBaudRateDef);
+    format(8,SerialBase::None,1);
+    autoDetectChar('\r');   
+    this->attach(this,&PC::messageFrom, MODSERIAL::RxAutoDetect); 
+}
+
+void PC::start(void)
+{
+    thread.start(this,&PC::Paralell_thread); 
+}
+
+PC::PC(GV *_pgv, PinName _led, PinName tx, PinName rx, void (*iEventHandler)(int, char *)) : MODSERIAL( tx, rx,  PCTxBufferSize,  PCRxBufferSize, NULL )
+{
+    pgv=_pgv;
+    iEvent=iEventHandler;
+    led=NULL;
+    
+    MailNum=0;
+    LOG=false;
+    SendStatus=false;
+    mode=0;
+    
+    if(_led!=NC) led=new DigitalOut(_led);
+    baud(PCBaudRateDef);
+    format(8,SerialBase::None,1);
+    autoDetectChar('\r');   
+    this->attach(this,&PC::messageFrom, MODSERIAL::RxAutoDetect); 
+}
+
+//******************************************************************************
+PC::~PC()
+{   
+}
+
+//******************************************************************************
+
+void PC::messageFrom(MODSERIAL_IRQ_INFO *q) {
+    MODSERIAL *sys = q->serial;
+    int i=sys->move(messageBufferIncoming, PCTxBufferSize);
+    messageBufferIncoming[i]='\r';
+    messageBufferIncoming[i+1]=0;
+    LoadMail(0,messageBufferIncoming);
+    
+    if(led!=NULL)
+    {
+        led->write(true);
+        wait_us(250);
+        led->write(false);
+    }
+    //sys->rxBufferFlush();
+}
+
+void PC::StatusToPC(void)
+{
+    if(SendStatus)
+    {
+        char tempMessPC[PCTxBufferSize];
+        sprintf(tempMessPC,"%.1f\r",pgv->Variable1);          
+        LoadMail(2,tempMessPC);        
+    }
+}
+
+void PC::Paralell_thread() 
+{
+    while(true) 
+    {
+        char mess[PCTxBufferSize];
+        char Tstr[20];
+        osEvent evt = mails.get(osWaitForever);
+        if (evt.status == osEventMail) 
+        {
+            mail_t *mail = (mail_t*)evt.value.p;
+            switch (mail->command) 
+            {
+                case 0: //request from PC
+                    switch (mail->message[0]) 
+                    {
+                        case '@': //command to PC
+                            switch(mail->message[1])
+                            {
+                                case 'L':
+                                    LOG=mail->message[2]=='1';
+                                    break;
+                                case 'S':
+                                    SendStatus=mail->message[2]=='1';
+                                    if(SendStatus) TStatusToPC.attach(this,&PC::StatusToPC, Rate);
+                                    else TStatusToPC.detach();
+                                    break;
+                                case 'M':
+                                    char temp[20];
+                                    temp[0]=mail->message[2];
+                                    temp[1]=0;
+                                    mode=atoi(temp);
+                                    break;
+                                case 'R'://Reboot
+                                    mbed_reset();//wd.Configure(2.0);
+                                    break;
+                                case 'r'://Reboot
+                                    mbed_reset();//wd.Configure(2.0);
+                                    break;
+                                case 'H':
+                                    time_t rawtime;
+                                    struct tm * timeinfo;
+                                    int year, month, day, hour, minute, second;
+                                    sscanf(&mail->message[2],"%02d%02d%02d%02d%02d%04d",&hour,&minute,&second,&day,&month,&year);
+                                    /* get current timeinfo and modify it to the user's choice */
+                                    time ( &rawtime );
+                                    timeinfo = localtime ( &rawtime );
+                                    timeinfo->tm_year = year-1900;
+                                    timeinfo->tm_mon = month - 1;
+                                    timeinfo->tm_mday = day;
+                                    timeinfo->tm_hour = hour;
+                                    timeinfo->tm_min = minute;
+                                    timeinfo->tm_sec = second;
+                                    /* call mktime: timeinfo->tm_wday will be set */
+                                    rawtime=mktime (timeinfo);
+                                    set_time(rawtime);                         
+                                    break;
+                                default:
+                                    break;
+                            }
+                            break;
+                        default: //
+                            switch (mode)
+                            {
+                                default:
+                                    mode=0;
+                                    break;
+                            }
+                            break;
+                    }
+                    break;
+                case 1: //Send LOG to PC
+                    TLogSTR(Tstr);
+                    snprintf(mess,PCTxBufferSize,"LOG(%s):%s",Tstr ,mail->message);
+                    Com_Write(mess);
+                    break;
+                case 2: //Send to PC
+                    Com_Write(mail->message);
+                    break;
+                default:
+                    break;
+            }
+            mails.free(mail);
+            MailNum--;
+        }
+    }
+}
+
+void PC::TLogSTR(char *Tstr)
+{
+    time_t ctTime;
+    struct tm * timeinfo;
+
+    ctTime = time(NULL);
+    timeinfo = localtime ( &ctTime );
+    strftime (Tstr,PCTxBufferSize,"%H:%M:%S",timeinfo);
+}
+
+void PC::LoadMail(char comm,  char *mess) //para cargar mensajes de trabajo al proceso paralelo ComPC_thread_proc
+{
+    if(comm!=1 || LOG)
+    {
+        while(MailNum>=PCMaxMailElements) wait_us(PCWaitMess_us);
+        mail_t *pmail = mails.alloc();
+        pmail->command = comm;
+        snprintf(pmail->message,PCTxBufferSize,"%s",mess);
+        mails.put(pmail);
+        MailNum++;
+    }
+ }
+
+int PC::Com_Write(char *mess) //sólo para usarse en ComPC_thread_proc
+{
+    int i=strlen(mess);
+    if(i>0) {
+        while((PCTxBufferSize-this->txBufferGetCount())<i) wait_us(PCWaitByte_us);
+        return this->printf(mess);
+    }
+    return 0;
+}