Skip to content

Commit

Permalink
Made helpers.py and testsource.py pythonic
Browse files Browse the repository at this point in the history
  • Loading branch information
hyades committed Jul 18, 2013
1 parent abecf31 commit 18608b8
Show file tree
Hide file tree
Showing 2 changed files with 25 additions and 80 deletions.
28 changes: 11 additions & 17 deletions python-api/gstswitch/helpers.py
Expand Up @@ -12,46 +12,40 @@ class TestSources(object):

def __init__(self, video_port):
super(TestSources, self).__init__()
self.TESTS = []
self.set_video_port(video_port)

def set_video_port(self, video_port):
self.VIDEO_PORT = video_port

def get_video_port(self):
return self.VIDEO_PORT
self.running_tests = []
self.video_port = video_port

def new_test_video(self, width=300, height=200, pattern=None, timeoverlay=False, clockoverlay=False):
"""Start a new test source
"""
print 'Adding new test video source'
testsrc = VideoSrc(self.get_video_port(), width, height, pattern, timeoverlay, clockoverlay)
testsrc = VideoSrc(self.video_port, width, height, pattern, timeoverlay, clockoverlay)
if testsrc is None:
pass
self.TESTS.append(testsrc)
self.running_tests.append(testsrc)

def get_test_video(self):
"""Returns a list of processes acting as test inputs
"""
i = 0
for x in self.TESTS:
for x in self.running_tests:
print i, "pattern:", x.pattern
i += 1
return self.TESTS
return self.running_tests

def terminate_index(self, index):
"""
"""
testsrc = self.TESTS[index]
print 'End source with pattern %s' % (str(testsrc.get_pattern()))
testsrc = self.running_tests[index]
print 'End source with pattern %s' % (str(testsrc.pattern))
testsrc.end()
self.TESTS.remove(self.TESTS[index])
self.running_tests.remove(self.running_tests[index])

def terminate(self):
"""
"""
print 'TESTS:', self.TESTS
for x in range(len(self.TESTS)):
print 'TESTS:', self.running_tests
for x in range(len(self.running_tests)):
self.terminate_index(0)


Expand Down
77 changes: 14 additions & 63 deletions python-api/gstswitch/testsource.py
Expand Up @@ -117,8 +117,8 @@ class PreviewPipeline(BasePipeline):
"""docstring for PreviewPipeline"""
def __init__(self, port):
super(PreviewPipeline, self).__init__()
self.set_host('127.0.0.1')
self.set_port(port)
self.host = '127.0.0.1'
self.preview_port = port
src = self.make_tcpclientsrc(port)
self.add(src)
gdpdepay = self.make_gdpdepay()
Expand All @@ -128,16 +128,10 @@ def __init__(self, port):
self.add(sink)
gdpdepay.link(sink)

def set_host(self, host):
self.HOST = host

def set_port(self, port):
self.PORT = port

def make_tcpclientsrc(self, port):
element = self.make('tcpclientsrc', 'tcpclientsrc')
element.set_property('host', self.HOST)
element.set_property('port', self.PORT)
element.set_property('host', self.host)
element.set_property('port', self.preview_port)
return element

def make_gdpdepay(self):
Expand All @@ -155,52 +149,16 @@ class VideoSrc(object):

def __init__(self, port, width=300, height=200, pattern=None, timeoverlay=False, clockoverlay=False):
super(VideoSrc, self).__init__()
self.set_port(port)
self.set_width(width)
self.set_height(height)
self.set_pattern(self.generate_pattern(pattern))
self.set_timeoverlay(timeoverlay)
self.set_clockoverlay(clockoverlay)

self.pipeline = VideoPipeline(self.PORT, self.WIDTH, self.HEIGHT, self.PATTERN, self.TIMEOVERLAY, self.CLOCKOVERLAY)
self.port = port
self.width = width
self.height = height
self.pattern = self.generate_pattern(pattern)
self.timeoverlay = timeoverlay
self.clockoverlay = clockoverlay

self.pipeline = VideoPipeline(self.port, self.width, self.height, self.pattern, self.timeoverlay, self.clockoverlay)
self.run()

def set_port(self, port):
self.PORT = port

def set_width(self, width):
self.WIDTH = width

def set_height(self, height):
self.HEIGHT = height

def set_pattern(self, pattern):
self.PATTERN = pattern

def set_timeoverlay(self, timeoverlay):
self.TIMEOVERLAY = timeoverlay

def set_clockoverlay(self, clockoverlay):
self.CLOCKOVERLAY = clockoverlay

def get_port(self):
return self.PORT

def get_width(self):
return self.WIDTH

def get_height(self):
return self.HEIGHT

def get_pattern(self):
return self.PATTERN

def get_timeoverlay(self):
return self.TIMEOVERLAY

def get_clockoverlay(self):
return self.CLOCKOVERLAY

def run(self):
self.pipeline.play()

Expand All @@ -216,22 +174,15 @@ def generate_pattern(self, pattern):
if pattern is None:
pattern = random.randint(0, 20)
pattern = str(pattern)
self.PATTERN = pattern
return pattern


class Preview(object):
"""docstring for Preview"""
def __init__(self, port):
super(Preview, self).__init__()
self.set_preview_port(int(port))
self.pipeline = PreviewPipeline(self.get_preview_port())

def set_preview_port(self, port):
self.PORT = port

def get_preview_port(self):
return self.PORT
self.preview_port = int(port)
self.pipeline = PreviewPipeline(self.preview_port)

def run(self):
self.pipeline.play()
Expand Down

0 comments on commit 18608b8

Please sign in to comment.