@@ -110,7 +110,7 @@ def set_junction(self, start_v2, cruise_v2, end_v2):
110
110
111
111
# Class to track a list of pending move requests and to facilitate
112
112
# "look-ahead" across moves to reduce acceleration between moves.
113
- class MoveQueue :
113
+ class LookAheadQueue :
114
114
def __init__ (self , toolhead ):
115
115
self .toolhead = toolhead
116
116
self .queue = []
@@ -211,8 +211,8 @@ def __init__(self, config):
211
211
self .all_mcus = [
212
212
m for n , m in self .printer .lookup_objects (module = 'mcu' )]
213
213
self .mcu = self .all_mcus [0 ]
214
- self .move_queue = MoveQueue (self )
215
- self .move_queue .set_flush_time (BUFFER_TIME_HIGH )
214
+ self .lookahead = LookAheadQueue (self )
215
+ self .lookahead .set_flush_time (BUFFER_TIME_HIGH )
216
216
self .commanded_pos = [0. , 0. , 0. , 0. ]
217
217
# Velocity and acceleration control
218
218
self .max_velocity = config .getfloat ('max_velocity' , above = 0. )
@@ -354,10 +354,10 @@ def _process_moves(self, moves):
354
354
self ._advance_move_time (next_move_time )
355
355
def _flush_lookahead (self ):
356
356
# Transit from "NeedPrime"/"Priming"/"Drip"/main state to "NeedPrime"
357
- self .move_queue .flush ()
357
+ self .lookahead .flush ()
358
358
self .special_queuing_state = "NeedPrime"
359
359
self .need_check_pause = - 1.
360
- self .move_queue .set_flush_time (BUFFER_TIME_HIGH )
360
+ self .lookahead .set_flush_time (BUFFER_TIME_HIGH )
361
361
self .check_stall_time = 0.
362
362
def flush_step_generation (self ):
363
363
self ._flush_lookahead ()
@@ -368,7 +368,7 @@ def get_last_move_time(self):
368
368
self ._flush_lookahead ()
369
369
self ._calc_print_time ()
370
370
else :
371
- self .move_queue .flush ()
371
+ self .lookahead .flush ()
372
372
return self .print_time
373
373
def _check_pause (self ):
374
374
eventtime = self .reactor .monotonic ()
@@ -462,7 +462,7 @@ def move(self, newpos, speed):
462
462
if move .axes_d [3 ]:
463
463
self .extruder .check_move (move )
464
464
self .commanded_pos [:] = move .end_pos
465
- self .move_queue .add_move (move )
465
+ self .lookahead .add_move (move )
466
466
if self .print_time > self .need_check_pause :
467
467
self ._check_pause ()
468
468
def manual_move (self , coord , speed ):
@@ -509,12 +509,12 @@ def _update_drip_move_time(self, next_print_time):
509
509
def drip_move (self , newpos , speed , drip_completion ):
510
510
self .dwell (self .kin_flush_delay )
511
511
# Transition from "NeedPrime"/"Priming"/main state to "Drip" state
512
- self .move_queue .flush ()
512
+ self .lookahead .flush ()
513
513
self .special_queuing_state = "Drip"
514
514
self .need_check_pause = self .reactor .NEVER
515
515
self .reactor .update_timer (self .flush_timer , self .reactor .NEVER )
516
516
self .do_kick_flush_timer = False
517
- self .move_queue .set_flush_time (BUFFER_TIME_HIGH )
517
+ self .lookahead .set_flush_time (BUFFER_TIME_HIGH )
518
518
self .check_stall_time = 0.
519
519
self .drip_completion = drip_completion
520
520
# Submit move
@@ -526,9 +526,9 @@ def drip_move(self, newpos, speed, drip_completion):
526
526
raise
527
527
# Transmit move in "drip" mode
528
528
try :
529
- self .move_queue .flush ()
529
+ self .lookahead .flush ()
530
530
except DripModeEndSignal as e :
531
- self .move_queue .reset ()
531
+ self .lookahead .reset ()
532
532
self .trapq_finalize_moves (self .trapq , self .reactor .NEVER , 0 )
533
533
# Exit "Drip" state
534
534
self .reactor .update_timer (self .flush_timer , self .reactor .NOW )
@@ -548,7 +548,7 @@ def stats(self, eventtime):
548
548
self .print_time , max (buffer_time , 0. ), self .print_stall )
549
549
def check_busy (self , eventtime ):
550
550
est_print_time = self .mcu .estimated_print_time (eventtime )
551
- lookahead_empty = not self .move_queue .queue
551
+ lookahead_empty = not self .lookahead .queue
552
552
return self .print_time , est_print_time , lookahead_empty
553
553
def get_status (self , eventtime ):
554
554
print_time = self .print_time
@@ -566,7 +566,7 @@ def get_status(self, eventtime):
566
566
return res
567
567
def _handle_shutdown (self ):
568
568
self .can_pause = False
569
- self .move_queue .reset ()
569
+ self .lookahead .reset ()
570
570
def get_kinematics (self ):
571
571
return self .kin
572
572
def get_trapq (self ):
@@ -583,7 +583,7 @@ def note_step_generation_scan_time(self, delay, old_delay=0.):
583
583
new_delay = max (self .kin_flush_times + [SDS_CHECK_TIME ])
584
584
self .kin_flush_delay = new_delay
585
585
def register_lookahead_callback (self , callback ):
586
- last_move = self .move_queue .get_last ()
586
+ last_move = self .lookahead .get_last ()
587
587
if last_move is None :
588
588
callback (self .get_last_move_time ())
589
589
return
0 commit comments