update()

void FLASHMEM SvcSerialCommandInterface::update ( void  )

overrideprotectedvirtual

update loop

Reimplemented from AppBaseClass.

Definition at line 650 of file svcSerialCommandInterface.cpp.

                                               { 
    char endMarker = '\n';
    boolean newRxMsg = false;
    char bufferChr;
    
    if (is_streaming_file){ //streaming file handler
        streamTransmitHandler();
    }
    
    if(is_capturing_bulk_data){ //bulk data state handler
        streamReceiveHandler();
    }else { //check for incoming data
        //This is the incoming message handler - it collects the message one byte at a time until 
        //the end of message marker. If a full message is received the newRxMsg flag is set true.
        //if a partial message is received the flag remains false.
        //if the receiving buffer reaches an overflow condition, reset the buffer and clear in remaining serial input
        if (Serial.available() > 0 && false == newRxMsg ){
            do{
                bufferChr = Serial.read();
                p_received_chars[index_rx_buffer++] = bufferChr;
 
                if(index_rx_buffer >= (SERIAL_RX_BUFFER_SIZE-2)){
                    //input overflow - clear serial input and reset the index
                    index_rx_buffer = 0;
                    Serial.clear();
                    Serial.clearReadError();
                    return;
                }
 
                if (bufferChr == endMarker){
                    p_received_chars[--index_rx_buffer] = '\0'; //remove the end marker and null terminate the string
                    index_rx_buffer = 0; //reset the input write index
                    newRxMsg = true;
                }
            } while (Serial.available() > 0 && false == newRxMsg);
        }
        if (newRxMsg){
            //Once a new message is received, first the command is parsed out from the message
            // this first split into cmd and param is for the purpose of identifying the requested command
            // each individual message handler is then responsible for parsing out their own parameters if required.
            char cmd[128], param[128],param2[128];
            int total_read;
            total_read = sscanf(p_received_chars, "%127s %127s" , cmd, param);
            while(throttle()){delay(10);}; //let the transmitt buffer clear out
            if (strncmp(cmd, "LS",sizeof(cmd)) == 0){
                messageHandler_LS();
            }else if (strncmp(cmd, "GET",sizeof(cmd)) == 0){
                messageHandler_GET();
            }else if (strncmp(cmd, "ACON",sizeof(cmd)) == 0){ //audio connections
                uint16_t i;  
                char csBuffer[128];
                i = 0;
                Serial.println(F("M ACON START"));
                
                while(ad->getConnectionString(i,csBuffer)){
                    i += 1;
                    Serial.print("M ");
                    Serial.println(csBuffer);
                }
                Serial.println(F("M ACON END"));
 
            }else if (strncmp(cmd, "CONNECT",sizeof(cmd)) == 0){
                int source_port;
                int dest_port;
                
                total_read = sscanf(p_received_chars, "%127s %127s %d %127s %d" , cmd, param,&source_port,param2,&dest_port);
                if (total_read < 3){
                    Serial.print(F("M CONNECT WRONG PARAM COUNT "));
                    Serial.println(p_received_chars);
                } else{
                    ad->connect(param,source_port,param2,dest_port);
                }
            }else if (strncmp(cmd, "DISCONNECT",sizeof(cmd)) == 0){
                int dest_port;
                total_read = sscanf(p_received_chars, "%127s %127s %d" , cmd, param,&dest_port);
                if (total_read < 2){
                    Serial.print(F("M DISCONNECT WRONG PARAM COUNT "));
                    Serial.println(p_received_chars);
                } else{
                    if (ad->disconnect(param,dest_port)){
                        Serial.printf(F("M DISCONNECTED %s %d\n"),param,dest_port);
                    }else{
                        Serial.printf(F("M FAILED DISCONNECT OF %s %d\n"),param,dest_port);
                    }
                }
            }else if (strncmp(cmd, "AA",sizeof(cmd)) == 0){         //active app message
                if (total_read > 1) am->getActiveApp()->messageHandler(this,param);
            }else if (strncmp(cmd, "APC",sizeof(cmd)) == 0){
                //forward the message to the SvcErisAudioParameterController
                am->getAppByName("APC")->messageHandler(this,p_received_chars + 4);
            }else if (strncmp(cmd, "STATS",sizeof(cmd)) == 0){
                ad->printStats();
                while(throttle()){delay(1);}
                am->printStats();
            }else if (strncmp(cmd, "CQT_CFG",sizeof(cmd)) == 0){ 
                am->sendMessage(this,"AppCQT","CQT_INFO");
            }else if (strncmp(cmd, "GET_DD",sizeof(cmd)) == 0){ 
                am->data->printDictionary(this);
            }else if (strncmp(cmd, "GET_WREN_SCRIPT",sizeof(cmd)) == 0){ 
                while(throttle()){delay(100);}
                if(requestStartLZ4Message()){
                    println("#WREN_START!"); 
                    println(g_wrenScript);
                    println("#WREN_EOF!");
                    sendLZ4Message();
                }
            }else if (strncmp(cmd, "WREN_SCRIPT_START",sizeof(cmd)) == 0){
                messageHandler_WREN_SCRIPT_START();
            }else if (strncmp(cmd, "WREN_SCRIPT_COMPILE",sizeof(cmd)) == 0){
                messageHandler_WREN_SCRIPT_COMPILE();  
            }else if (strncmp(cmd, "WREN_SCRIPT_EXECUTE",sizeof(cmd)) == 0){
                messageHandler_WREN_SCRIPT_EXECUTE();
            }else if (strncmp(cmd, "WREN_SCRIPT_SAVE",sizeof(cmd)) == 0){
                messageHandler_WREN_SCRIPT_SAVE();
            }else if (strncmp(cmd, "UPDATE_DD",sizeof(cmd)) == 0){
                messageHandler_UPDATE_DD();
            }else if (strncmp(cmd, "HELO",sizeof(cmd)) == 0){ 
                if(requestStartLZ4Message()){
                    println(gWelcomeMessage);
                    sendLZ4Message();
                }
            }else if (strncmp(cmd, "GET_RAM",sizeof(cmd)) == 0){ 
                char* mp;
                long num;
                num = strtol(param,NULL,10);
                mp = (char*)num;
                Serial.printf("M GET_RAM {\"addr\":\"%08X\",\"data\":\"%02X\"}\n",num,(uint8_t)*mp);
            }else if (strncmp(cmd, "GET_RAM2",sizeof(cmd)) == 0){ 
                messageHandler_GET_RAM2();
            }else if (strncmp(cmd, "GET_RAM1",sizeof(cmd)) == 0){ 
                messageHandler_GET_RAM1();
            }else if (strncmp(cmd, "AUDIO_NO_INTERRUPTS",sizeof(cmd)) == 0){
                AudioNoInterrupts();
            }else if (strncmp(cmd, "AUDIO_INTERRUPTS",sizeof(cmd)) == 0){
                AudioInterrupts();
            }
            //END
            newRxMsg = false;
        
        #ifdef SERIAL_AUTO_TRANSMIT_DATA_PERIODICALLY
        } else if(is_periodic_messages_enabled && !is_streaming_file){
            if (et_since_periodic_stats_tx > SERIAL_AUTO_TRANSMIT_STATS_PERIOD){
                et_since_periodic_stats_tx = 0; 
                AppManager::getInstance()->printStats();
                ad->printStats();            
            }else if (et_since_periodic_data_dict_tx > SERIAL_AUTO_TRANSMIT_DATA_DICT_PERIOD){
                    et_since_periodic_data_dict_tx = 0;
                    AppManager::getInstance()->data->printDictionary(this);
            }
        }
        #else
        }
        #endif
    }

References AppBaseClass::ad, AppBaseClass::am, AudioDirector::connect(), AppManager::data, AudioDirector::disconnect(), et_since_periodic_data_dict_tx, et_since_periodic_stats_tx, AppManager::getActiveApp(), AppManager::getAppByName(), AudioDirector::getConnectionString(), AppManager::getInstance(), gWelcomeMessage, index_rx_buffer, is_capturing_bulk_data, is_periodic_messages_enabled, is_streaming_file, AppBaseClass::messageHandler(), messageHandler_GET(), messageHandler_GET_RAM1(), messageHandler_GET_RAM2(), messageHandler_LS(), messageHandler_UPDATE_DD(), messageHandler_WREN_SCRIPT_COMPILE(), messageHandler_WREN_SCRIPT_EXECUTE(), messageHandler_WREN_SCRIPT_SAVE(), messageHandler_WREN_SCRIPT_START(), p_received_chars, SvcDataDictionary::printDictionary(), AppManager::printStats(), AudioDirector::printStats(), requestStartLZ4Message(), sendLZ4Message(), AppManager::sendMessage(), streamReceiveHandler(), streamTransmitHandler(), and throttle().

Here is the call graph for this function: