diff options
| author | Sebastian Koslowski <sebastian.koslowski@gmail.com> | 2017-09-30 19:30:30 +0200 |
|---|---|---|
| committer | Sebastian Koslowski <sebastian.koslowski@gmail.com> | 2017-09-30 19:37:23 +0200 |
| commit | 84fb83901caf1ba9872ebe161d16a6827e0bc3df (patch) | |
| tree | ec84c3ba28413bf5787abd0599dc78b42605401e /grc/core/blocks/block.py | |
| parent | 0a1d807511cd6707456a54bdde90fc915c67db7f (diff) | |
[grc] python3: fix stream port indexes (fixes 4340e4fe836d525ce30cd0a884400b77222a1848)
Diffstat (limited to 'grc/core/blocks/block.py')
| -rw-r--r-- | grc/core/blocks/block.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/grc/core/blocks/block.py b/grc/core/blocks/block.py index e0858957ab..0d8a779486 100644 --- a/grc/core/blocks/block.py +++ b/grc/core/blocks/block.py @@ -127,11 +127,10 @@ class Block(Element): port_factory = self.parent_platform.make_port port_ids = set() - def make_stream_port_id(_pool=itertools.count()): - return {'sink': 'in', 'source': 'out'}[direction] + str(next(_pool)) + stream_port_ids = itertools.count() for i, port_data in enumerate(ports_n): - port_id = port_data.setdefault('id', make_stream_port_id()) + port_id = port_data.setdefault('id', str(next(stream_port_ids))) if port_id in port_ids: raise Exception('Port id "{}" already exists in {}s'.format(port_id, direction)) port_ids.add(port_id) |