|
|
@@ -0,0 +1,62 @@
|
|
|
+#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) {
|
|
|
+
|
|
|
+ }
|
|
|
+ Slave_Ports_Status_QUEUE_A[_queue_count + 1]._queue_id = _queue_id_current + 1 ;
|
|
|
+ Slave_Ports_Status_QUEUE_A[_queue_count + 1].TASK_TYPE_A = QUEUE_A.TASK_TYPE_A ;
|
|
|
+ if(QUEUE_A.time_seq_id > 0) {
|
|
|
+ Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_seq_id = QUEUE_A.time_seq_id ;
|
|
|
+ } else {
|
|
|
+ Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_seq_id = millis();
|
|
|
+ }
|
|
|
+ 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 ) {
|
|
|
+
|
|
|
+
|
|
|
+ Slave_Ports_Status_QUEUE_A[_queue_count + 1]._queue_id = _queue_id_current + 1 ;
|
|
|
+ Slave_Ports_Status_QUEUE_A[_queue_count + 1].TASK_TYPE_A = TASK_TYPE_A ;
|
|
|
+ if(time_seq_id > 0) {
|
|
|
+ Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_seq_id = time_seq_id ;
|
|
|
+ } else {
|
|
|
+ Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_seq_id = millis();
|
|
|
+ }
|
|
|
+ Slave_Ports_Status_QUEUE_A[_queue_count + 1].time_min_run = time_min_run ;
|
|
|
+ Serial.print("#285:queue__add");
|
|
|
+ _queue_count++;
|
|
|
+ _queue_id_current++;
|
|
|
+ return _queue_id_current;
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+Slave_Ports_QUEUE::~Slave_Ports_QUEUE(){
|
|
|
+ delete[] Slave_Ports_Status_QUEUE_A;
|
|
|
+ //Serial.print("#40 free ~Slave_Ports_Status");
|
|
|
+}
|
|
|
+
|