Bases: TSTransform
Uses one sink pad's buffers to control the state of anothers. The control buffer
state is defined by either being gap or not. The actual content of the data is
ignored otherwise.
Parameters:
| Name |
Type |
Description |
Default |
control
|
str
|
str, the name of the pad to use as a control signal
|
''
|
Source code in sgnts/transforms/gate.py
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53 | @dataclass
class Gate(TSTransform):
"""Uses one sink pad's buffers to control the state of anothers. The control buffer
state is defined by either being gap or not. The actual content of the data is
ignored otherwise.
Args:
control:
str, the name of the pad to use as a control signal
"""
control: str = ""
def __post_init__(self):
assert self.control and self.control in self.sink_pad_names, (
f"Control pad '{self.control}' must be specified and exist "
f"in sink_pad_names: {self.sink_pad_names}"
)
super().__post_init__()
assert (
len(self.sink_pads) == 2
), f"Gate requires exactly 2 sink pads, got {len(self.sink_pads)}"
assert (
len(self.source_pads) == 1
), f"Gate requires exactly 1 source pad, got {len(self.source_pads)}"
self.controlpad = self.sink_pad_dict["%s:snk:%s" % (self.name, self.control)]
self.sinkpad = self.sink_pad_dict[
"%s:snk:%s"
% (self.name, list(set(self.sink_pad_names) - set([self.control]))[0])
]
def new(self, pad: SourcePad) -> TSFrame:
nongap_slices = TSSlices(
[b.slice for b in self.preparedframes[self.controlpad] if b]
)
out = sorted(
[
b
for bs in [
buf.split(nongap_slices.search(buf.slice), contiguous=True)
for buf in self.preparedframes[self.sinkpad]
]
for b in bs
]
)
return TSFrame(buffers=out, EOS=self.at_EOS)
|