mirror of
https://github.com/cyberboy666/r_e_c_u_r.git
synced 2025-12-11 10:50:03 +01:00
101 lines
3.8 KiB
Python
101 lines
3.8 KiB
Python
from video_centre.video_player import video_player, fake_video_player # <== for deving only
|
|
|
|
|
|
class VideoDriver(object):
|
|
def __init__(self, root, message_handler, data):
|
|
self.root = root
|
|
self.message_handler = message_handler
|
|
self.data = data
|
|
self.delay = 50
|
|
self.has_omx = self.data.has_omx
|
|
self.in_first_load_cycle = False
|
|
self.in_current_playing_cycle = False
|
|
self.in_next_load_cycle = False
|
|
print(self.has_omx)
|
|
if self.has_omx:
|
|
self.last_player = video_player(self.root, self.message_handler, self.data, 'a.a')
|
|
self.current_player = video_player(self.root,self.message_handler, self.data, 'b.b')
|
|
self.next_player = video_player(self.root, self.message_handler, self.data, 'c.c')
|
|
#self.print_status()
|
|
self.root.after(self.delay, self.begin_playing)
|
|
else:
|
|
self.last_player = fake_video_player()
|
|
self.current_player = fake_video_player()
|
|
self.next_player = fake_video_player()
|
|
|
|
|
|
def print_status(self):
|
|
print('l({}):{}, c({}):{}, n({}):{}'.format(self.last_player.name, self.last_player.status, self.current_player.name, self.current_player.status, self.next_player.name, self.next_player.status,))
|
|
self.root.after(1000,self.print_status)
|
|
|
|
def begin_playing(self):
|
|
# TODO: the first clip will be a demo
|
|
if self.current_player.try_load():
|
|
self.in_first_load_cycle = True
|
|
self.wait_for_first_load()
|
|
else:
|
|
print('load failed')
|
|
|
|
def wait_for_first_load(self):
|
|
if self.in_first_load_cycle:
|
|
if self.current_player.is_loaded():
|
|
self.in_first_load_cycle = False
|
|
self.play_video()
|
|
else:
|
|
self.root.after(self.delay, self.wait_for_first_load)
|
|
|
|
def switch_players_and_play_video(self):
|
|
self.in_first_load_cycle = False
|
|
self.in_current_playing_cycle = False
|
|
self.in_next_load_cycle = True
|
|
|
|
self.switch_if_next_is_loaded()
|
|
|
|
def switch_players(self):
|
|
temp_player = self.last_player
|
|
self.last_player = self.current_player
|
|
self.current_player = self.next_player
|
|
self.next_player = temp_player
|
|
#self.last_player.exit()
|
|
|
|
def play_video(self):
|
|
self.current_player.play()
|
|
self.last_player.exit()
|
|
self.next_player.try_load()
|
|
self.in_current_playing_cycle = True
|
|
self.wait_for_next_cycle()
|
|
|
|
def wait_for_next_cycle(self):
|
|
if self.in_current_playing_cycle:
|
|
if self.current_player.is_finished():
|
|
self.in_current_playing_cycle = False
|
|
self.in_next_load_cycle = True
|
|
self.switch_if_next_is_loaded()
|
|
else:
|
|
self.root.after(self.delay, self.wait_for_next_cycle)
|
|
|
|
def switch_if_next_is_loaded(self):
|
|
if self.in_next_load_cycle:
|
|
if self.next_player.is_loaded():
|
|
self.in_next_load_cycle = False
|
|
self.switch_players()
|
|
self.play_video()
|
|
else:
|
|
if self.next_player.status != 'ERROR':
|
|
self.root.after(self.delay, self.switch_if_next_is_loaded)
|
|
else:
|
|
self.in_next_load_cycle = False
|
|
|
|
def get_info_for_player_display(self):
|
|
if self.has_omx:
|
|
return self.current_player.bankslot_number, self.current_player.status, self.next_player.bankslot_number, \
|
|
self.next_player.status, self.current_player.get_position(), self.current_player.crop_length, \
|
|
self.current_player.start, self.current_player.end
|
|
else:
|
|
return 0, 'test', 1, 'test', 5, 10, 2, 8
|
|
|
|
def exit_all_players(self):
|
|
self.next_player.exit()
|
|
self.current_player.exit()
|
|
|