|
@@ -20,9 +20,10 @@ void _Slave_Ports_queue__INIT( Slave_Ports_Status_QUEUE_T* Slave_Ports_Status_QU
|
|
|
|
|
|
|
|
ARDUINO_FUNCT_INIT_RESULT_T _Slave_Ports_queue__add( Slave_Ports_Status_QUEUE_T* Slave_Ports_Status_QUEUE_A,
|
|
ARDUINO_FUNCT_INIT_RESULT_T _Slave_Ports_queue__add( Slave_Ports_Status_QUEUE_T* Slave_Ports_Status_QUEUE_A,
|
|
|
TASK_TYPE_T TASK_TYPE_A,
|
|
TASK_TYPE_T TASK_TYPE_A,
|
|
|
-TASK_PORT_ASSOC_T TASK_PORT_ASSOC_A,
|
|
|
|
|
|
|
+TASK_PORT_ASSOC_T TASK_PORT_ASSOC_A, //
|
|
|
long time_seq_id,
|
|
long time_seq_id,
|
|
|
-long time_min_run //,
|
|
|
|
|
|
|
+long time_min_run , //,
|
|
|
|
|
+ARDUINO_ARRAY_INDEX_T DISPLAY_ARDUINO_ARRAY_INDEX_A //optionally
|
|
|
//int _Slave_Ports_queue_peek , int _Slave_Ports_queue_push , int _Slave_Ports_queue_peek_new
|
|
//int _Slave_Ports_queue_peek , int _Slave_Ports_queue_push , int _Slave_Ports_queue_peek_new
|
|
|
) {
|
|
) {
|
|
|
Serial.println(".");
|
|
Serial.println(".");
|
|
@@ -51,6 +52,10 @@ long time_min_run //,
|
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_back + 1 ].TASK_PORT_ASSOC_A=TASK_PORT_ASSOC_A ;
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_back + 1 ].TASK_PORT_ASSOC_A=TASK_PORT_ASSOC_A ;
|
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_back + 1 ].time_seq_id=time_seq_id ;
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_back + 1 ].time_seq_id=time_seq_id ;
|
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_back + 1 ].time_min_run=time_min_run ;
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_back + 1 ].time_min_run=time_min_run ;
|
|
|
|
|
+
|
|
|
|
|
+ Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_back + 1 ].DISPLAY_ARDUINO_ARRAY_INDEX_A = DISPLAY_ARDUINO_ARRAY_INDEX_A ;
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
|
|
|
return true ;
|
|
return true ;
|
|
|
|
|
|
|
@@ -192,13 +197,14 @@ void _Slave_Ports_queue__list( Slave_Ports_Status_QUEUE_T* Slave_Ports_Status_QU
|
|
|
Serial.print("#182 QUEUE reassign .time_seq_id > millis() time_seq_id["); Serial.print( Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].time_seq_id);
|
|
Serial.print("#182 QUEUE reassign .time_seq_id > millis() time_seq_id["); Serial.print( Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].time_seq_id);
|
|
|
Serial.print("] millis()["); Serial.print(millis());
|
|
Serial.print("] millis()["); Serial.print(millis());
|
|
|
Serial.print("] TASK_TYPE_A["); Serial.print(Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A);
|
|
Serial.print("] TASK_TYPE_A["); Serial.print(Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A);
|
|
|
- Serial.print("] Will wait() to next ["); Serial.print(Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A);
|
|
|
|
|
|
|
+ Serial.print("] Will wait() to next ["); Serial.print(Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].time_seq_id);
|
|
|
Serial.print("] POP/ID ["); Serial.print(_Slave_Ports_queue_pop); Serial.println("] ");
|
|
Serial.print("] POP/ID ["); Serial.print(_Slave_Ports_queue_pop); Serial.println("] ");
|
|
|
_Slave_Ports_queue__add( Slave_Ports_Status_QUEUE_A,
|
|
_Slave_Ports_queue__add( Slave_Ports_Status_QUEUE_A,
|
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A,
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A,
|
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_PORT_ASSOC_A,
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_PORT_ASSOC_A,
|
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].time_seq_id,
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].time_seq_id,
|
|
|
- Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].time_min_run
|
|
|
|
|
|
|
+ Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].time_min_run,
|
|
|
|
|
+ Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].DISPLAY_ARDUINO_ARRAY_INDEX_A
|
|
|
);
|
|
);
|
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop]={} ;
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop]={} ;
|
|
|
|
|
|
|
@@ -216,16 +222,45 @@ void _Slave_Ports_queue__list( Slave_Ports_Status_QUEUE_T* Slave_Ports_Status_QU
|
|
|
} else if(Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A == TASK_TYPE_T_DISPLAY_queue_pop________ ) {
|
|
} else if(Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A == TASK_TYPE_T_DISPLAY_queue_pop________ ) {
|
|
|
Serial.print("#212 DISPLAY TASK_TYPE_A["); Serial.print( Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A);
|
|
Serial.print("#212 DISPLAY TASK_TYPE_A["); Serial.print( Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A);
|
|
|
Serial.println("] ");
|
|
Serial.println("] ");
|
|
|
|
|
+ _Slave_Ports_queue_task_type_DESC(Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A) ;
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
|
|
|
|
|
+
|
|
|
|
|
+ } else if(Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A == TASK_TYPE_T_Slave_Ports_set_I2C______) {
|
|
|
|
|
+ Serial.print("#221 running TASK_TYPE_T_Slave_Ports_set_I2C______ = "); Serial.println( Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A); Serial.println("]");
|
|
|
|
|
+ //#include "_Slave_Ports_ttl_decrement.h"
|
|
|
|
|
+ _Slave_Ports_I2C_POP(
|
|
|
|
|
+ //Slave_Ports_Status_QUEUE_A, _Slave_Ports_queue_pop , Slave_Ports_Status_A
|
|
|
|
|
+ Slave_Ports_Status_QUEUE_A,
|
|
|
|
|
+ _Slave_Ports_queue_pop ,
|
|
|
|
|
+ Slave_Ports_Status_A,
|
|
|
|
|
+ Slave_Ports_Status_T_ARDUINO_ATTR_ARRAY_A ,
|
|
|
|
|
+ //display
|
|
|
|
|
+ DISPLAY_A ,
|
|
|
|
|
+ DISPLAY_T_ARDUINO_ATTR_ARRAY_A ,
|
|
|
|
|
+ DISPLAY_PHYSICAL_CHAR_A,
|
|
|
|
|
+ DISPLAY_pos_seq_A_NEXT, //initial set
|
|
|
|
|
+ "#233 Setting I2C" , //DISPLAY_array16_A,
|
|
|
|
|
+ DISPLAY_TARGET_ANY , //DISPLAY_TARGET_A, - setting
|
|
|
|
|
+ Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].time_seq_id,
|
|
|
|
|
+ Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].time_min_run,
|
|
|
|
|
+ //tasks
|
|
|
|
|
+ Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A,
|
|
|
|
|
+ Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_PORT_ASSOC_A
|
|
|
|
|
+ ) ;
|
|
|
} else {
|
|
} else {
|
|
|
|
|
|
|
|
Serial.print("$177 Error unsupported type TASK_TYPE_A["); Serial.print( Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A);
|
|
Serial.print("$177 Error unsupported type TASK_TYPE_A["); Serial.print( Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A);
|
|
|
|
|
+ _Slave_Ports_queue_task_type_DESC(Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A) ;
|
|
|
Serial.println("] REASSIGN NEXT QUEUE FOR FURTHER ACTION");
|
|
Serial.println("] REASSIGN NEXT QUEUE FOR FURTHER ACTION");
|
|
|
_Slave_Ports_queue__add( Slave_Ports_Status_QUEUE_A,
|
|
_Slave_Ports_queue__add( Slave_Ports_Status_QUEUE_A,
|
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A,
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_TYPE_A,
|
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_PORT_ASSOC_A,
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].TASK_PORT_ASSOC_A,
|
|
|
millis(),
|
|
millis(),
|
|
|
- millis() + ARDUINO_time_seq_id_A_INCREMENT
|
|
|
|
|
|
|
+ millis() + ARDUINO_time_seq_id_A_INCREMENT ,
|
|
|
|
|
+ Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop].DISPLAY_ARDUINO_ARRAY_INDEX_A
|
|
|
);
|
|
);
|
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop]={} ;
|
|
Slave_Ports_Status_QUEUE_A[_Slave_Ports_queue_pop]={} ;
|
|
|
}
|
|
}
|
|
@@ -236,12 +271,14 @@ void _Slave_Ports_queue__list( Slave_Ports_Status_QUEUE_T* Slave_Ports_Status_QU
|
|
|
|
|
|
|
|
|
|
|
|
|
} else {
|
|
} else {
|
|
|
|
|
+
|
|
|
|
|
+ /*
|
|
|
String LCDarray1 = "Nothing to";
|
|
String LCDarray1 = "Nothing to";
|
|
|
String LCDarray2 = "process...";
|
|
String LCDarray2 = "process...";
|
|
|
//LCDarray2.reserve(16);
|
|
//LCDarray2.reserve(16);
|
|
|
Serial.print(LCDarray1);
|
|
Serial.print(LCDarray1);
|
|
|
Serial.println(LCDarray2);
|
|
Serial.println(LCDarray2);
|
|
|
-
|
|
|
|
|
|
|
+*/
|
|
|
// Serial.print("#32 String LCDarray2 len");
|
|
// Serial.print("#32 String LCDarray2 len");
|
|
|
// int LCDarray2_length = LCDarray2.length;
|
|
// int LCDarray2_length = LCDarray2.length;
|
|
|
/* Serial.print(LCDarray2.length());
|
|
/* Serial.print(LCDarray2.length());
|
|
@@ -256,7 +293,7 @@ void _Slave_Ports_queue__list( Slave_Ports_Status_QUEUE_T* Slave_Ports_Status_QU
|
|
|
Serial.print(LCDarray2.length());
|
|
Serial.print(LCDarray2.length());
|
|
|
Serial.println("] ");
|
|
Serial.println("] ");
|
|
|
*/
|
|
*/
|
|
|
-
|
|
|
|
|
|
|
+ /* todo
|
|
|
Serial.print(" #364 scount ");
|
|
Serial.print(" #364 scount ");
|
|
|
Serial.print(_Slave_Ports_queue_count);
|
|
Serial.print(_Slave_Ports_queue_count);
|
|
|
Serial.print(" _Slave_Ports_queue.front(): ");
|
|
Serial.print(" _Slave_Ports_queue.front(): ");
|
|
@@ -265,6 +302,7 @@ void _Slave_Ports_queue__list( Slave_Ports_Status_QUEUE_T* Slave_Ports_Status_QU
|
|
|
Serial.print(_Slave_Ports_queue_back);
|
|
Serial.print(_Slave_Ports_queue_back);
|
|
|
Serial.print(" _Slave_Ports_queue.peek(): ");
|
|
Serial.print(" _Slave_Ports_queue.peek(): ");
|
|
|
Serial.println(_Slave_Ports_queue_peek);
|
|
Serial.println(_Slave_Ports_queue_peek);
|
|
|
|
|
+ */
|
|
|
// LCD_print(LCDarray1, LCDarray2, LCDtim / 3 ) ;
|
|
// LCD_print(LCDarray1, LCDarray2, LCDtim / 3 ) ;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|