import time import copy from pp_utils import Monitor class Animate(object): """ allows players to put events, which request the change of state of pins, into a queue. Events are executed at the required time. using the interface to an output driver. """ # constants for sequencer events list name = 0 # GPIO pin number, the xx in P1-xx param_type = 1 param_values = 2 # off , on time = 3 # time since the epoch in seconds tag = 4 # tag used to delete all matching events, usually a track reference. event_template=['','','',0,None] # CLASS VARIABLES (Animate.) events=[] last_poll_time=0 # executed by main program and by each object using animate def __init__(self): self.mon=Monitor() # executed once from main program def init(self,pp_dir,pp_home,pp_profile,widget,sequencer_tick,event_callback): # instantiate arguments self.widget=widget #something to hang 'after' on self.pp_dir=pp_dir self.pp_profile=pp_profile self.pp_home=pp_home self.sequencer_tick=sequencer_tick self.event_callback=event_callback # Initialise time used by sequencer Animate.sequencer_time=long(time.time()) # init timer self.sequencer_tick_timer=None # called by main program only def terminate(self): if self.sequencer_tick_timer is not None: self.widget.after_cancel(self.sequencer_tick_timer) self.clear_events_list(None) # ************************************************ # output sequencer # ************************************************ # called by main program only def poll(self): poll_time=long(time.time()) # is current time greater than last time the scheduler was run (previous second or more) # run in a loop to catch up because root.after can get behind when images are being rendered etc. while Animate.sequencer_time<=poll_time: # kick off output pin sequencer self.do_sequencer() Animate.sequencer_time +=1 # and loop the polling self.sequencer_tick_timer=self.widget.after(self.sequencer_tick,self.poll) # execute events at the appropriate time and remove from list (runs from main program only) # runs through list a number of times because of problems with pop messing up list def do_sequencer(self): # print 'sequencer run for: ' + str(sequencer_time) + ' at ' + str(long(time.time())) while True: event_found=False for index, item in enumerate(Animate.events): if item[Animate.time]<=Animate.sequencer_time: event=Animate.events.pop(index) event_found=True self.send_event(event[Animate.name],event[Animate.param_type],event[Animate.param_values],item[Animate.time]) break if event_found is False: break def send_event(self,name,param_type,param_values,req_time): self.event_callback(name,param_type,param_values,req_time) self.mon.log(self, 'send event '+ name) # ************************************************ # output sequencer interface methods # these can be called from many classes so need to operate on class variables # ************************************************ def animate(self,text,tag): lines = text.split("\n") for line in lines: reason,message,delay,name,param_type,param_values=self.parse_animate_fields(line) if reason == 'error': return 'error',message if name !='': self.add_event(name,param_type,param_values,delay,tag) # self.print_events() return 'normal','events processed' def add_event(self,name,param_type,param_values,delay,tag): poll_time=long(time.time()) # prepare the event event=Animate.event_template event[Animate.name]=name event[Animate.param_type]=param_type event[Animate.param_values]=param_values event[Animate.time]=delay+poll_time #+1? event[Animate.tag]=tag # print 'add event ',event # find the place in the events list and insert # first item in the list is earliest, if two have the same time then last to be added is fired last. # events are fired from top of list abs_time=poll_time+delay # print 'new event',abs_time copy_event= copy.deepcopy(event) length=len(Animate.events) if length ==0: Animate.events.append(copy_event) # print 'append to empty ist',abs_time return copy_event else: index=length-1 if abs_time>Animate.events[index][Animate.time]: Animate.events.append(copy_event) # print 'append to end of list if greater than last item',abs_time return copy_event while index!=-1: if abs_time==Animate.events[index][Animate.time]: Animate.events.insert(index+1,copy_event) # print 'insert after if equal',abs_time return copy_event if abs_time>Animate.events[index][Animate.time]: Animate.events.insert(index+1,copy_event) # print 'insert after if later',abs_time return copy_event if index==0: Animate.events.insert(index,copy_event) # print 'insert before if at start of list',abs_time return copy_event index -=1 # print 'error at start of list',abs_time def print_events(self): print '\nevents list' for event in Animate.events: print event # remove all the events with the same tag, usually a track reference def remove_events(self,tag): left=[] for item in Animate.events: if tag != item[Animate.tag]: left.append(item) Animate.events= left # self.print_events() # clear event list def clear_events_list(self,tag): self.mon.log(self,'clear events list ') # empty event list Animate.events=[] # [delay],symbol,type,state def parse_animate_fields(self,line): fields= line.split() if len(fields) == 0: return 'normal','no fields','','',[],0 elif len(fields) < 4: return 'error','Wrong number of fields in : '+ line,'','',[],0 delay_text=fields[0] name=fields[1] param_type=fields[2] start_params = 3 # check each field if not delay_text.isdigit(): return 'error','Delay is not an integer in : '+ line,'','',[],0 else: delay=int(delay_text) #only one param type at the moment. if param_type != 'state': return 'error','uknown parameter type in : '+ line,'','',[],0 else: params_length = 1 params_check = ('on','off') params=[] for index in range(start_params, start_params+ params_length): param=fields[index] if not param in params_check: return 'error','unknown parameter value in : '+ line,'','',[],0 params.append(param) return 'normal','event parsed OK',delay,name,param_type,params