Conveyor::Conveyor(){
this->current_block = NULL;
this->looking_for_new_block = false;
- flush_blocks = 0;
+ queue.resize(32);
+ gc_pending = queue.tail_i;
}
void Conveyor::on_module_loaded(){
// Delete blocks here, because they can't be deleted in interrupt context ( see Block.cpp:release )
void Conveyor::on_idle(void* argument){
- while (flush_blocks > 0){
+ while (queue.tail_i != gc_pending)
+ {
// Cleanly delete block
- Block* block = queue.get_tail_ref();
+ Block* block = queue.tail_ref();
block->gcodes.clear();
- queue.delete_tail();
- __disable_irq();
- flush_blocks--;
- __enable_irq();
+ queue.consume_tail();
}
}
void Conveyor::append_gcode(Gcode* gcode)
{
gcode->mark_as_taken();
- if (queue.size() == 0)
+ if (queue.is_empty())
THEKERNEL->call_event(ON_GCODE_EXECUTE, gcode);
else
- queue.get_ref(queue.size() - 1)->append_gcode(gcode);
+ queue.head_ref()->append_gcode(gcode);
}
// Append a block to the list
Block* Conveyor::new_block(){
// Take the next untaken block on the queue ( the one after the last one )
- Block* block = this->queue.get_head_ref();
+ Block* block = this->queue.head_ref();
// Then clean it up
block->clear();
block->final_rate = -2;
// Create a new virgin Block in the queue
- this->queue.push_back(Block());
+ queue.produce_head();
return block;
}
if( this->current_block != NULL ){ this->looking_for_new_block = false; return; }
// Return if queue is empty
- if( this->queue.size() == 0 ){
+ if( queue.is_empty() ){
this->current_block = NULL;
// TODO : ON_QUEUE_EMPTY event
this->looking_for_new_block = false;
}
// Get a new block
- this->current_block = this->queue.get_ref(0);
+ this->current_block = this->queue.tail_ref();
// Tell all modules about it
THEKERNEL->call_event(ON_BLOCK_BEGIN, this->current_block);
}
// Wait for the queue to have a given number of free blocks
-void Conveyor::wait_for_queue(int free_blocks){
- while( this->queue.size() >= this->queue.capacity()-free_blocks ){
+void Conveyor::wait_for_queue(int free_blocks)
+{
+ while (queue.is_full())
THEKERNEL->call_event(ON_IDLE);
- }
}
// Wait for the queue to be empty
-void Conveyor::wait_for_empty_queue(){
- while( this->queue.size() > 0){
+void Conveyor::wait_for_empty_queue()
+{
+ while (!queue.is_empty())
THEKERNEL->call_event(ON_IDLE);
- }
}
// Return true if the queue is empty
-bool Conveyor::is_queue_empty(){
- return (this->queue.size() == 0);
+bool Conveyor::is_queue_empty()
+{
+ return queue.is_empty();
}
+
+// feels hacky, but apparently the way to do it
+#include "HeapRing.cpp"
+template class HeapRing<Block>;