se/SE/stuff/P5_Automation_can-dev/Slave_Ports_QUEUE.cpp

#include "Slave_Ports_QUEUE.h"  





Slave_Ports_QUEUE::Slave_Ports_QUEUE(){
    Serial.print("#8 Slave_Ports_Status_QUEUE");
    _queue_id_current = 0 ;
    _queue_count =  0 ;
   
    Slave_Ports_Status_QUEUE_T Slave_Ports_Status_QUEUE_A[10] ;
   
}




int Slave_Ports_QUEUE::queue__add_A( Slave_Ports_Status_QUEUE_T QUEUE_A ) {
 
    if(_queue_count == 0) {
    
     }
     this->Slave_Ports_Status_QUEUE_A[_queue_count + 1]._queue_id = _queue_id_current + 1 ;
     this->Slave_Ports_Status_QUEUE_A[_queue_count + 1].TASK_TYPE_A = QUEUE_A.TASK_TYPE_A ;
     if(QUEUE_A.time_seq_id > 0) { 
       this->Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_seq_id = QUEUE_A.time_seq_id ;
     } else {
        this->Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_seq_id =  millis();
     }
      this->Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_min_run = QUEUE_A.time_min_run ;
         Serial.print("#261:queue__add A");

}



int Slave_Ports_QUEUE::queue__add(  int TASK_TYPE_A, long time_seq_id, long time_min_run ) {
 
    
     this->Slave_Ports_Status_QUEUE_A[_queue_count + 1]._queue_id = _queue_id_current + 1 ;
     this->Slave_Ports_Status_QUEUE_A[_queue_count + 1].TASK_TYPE_A = TASK_TYPE_A ;
     if(time_seq_id > 0) { 
        this->Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_seq_id = time_seq_id ;
     } else {
        this->Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_seq_id =  millis();
     }
      this->Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_min_run = time_min_run ;
         Serial.print("#285:queue__add  new _queue_count[");
      this->_queue_count++;
      this->_queue_id_current++;
      Serial.print(this->_queue_count); Serial.print("]  _queue_id_current[");
      Serial.print(this->_queue_id_current); Serial.println("]  ");
      return this->_queue_id_current;
      
}



Slave_Ports_QUEUE::~Slave_Ports_QUEUE(){
     delete[] Slave_Ports_Status_QUEUE_A;
    //Serial.print("#40 free ~Slave_Ports_Status");
}