29 from gstlal
import pipeparts
30 from gstlal.pipeparts
import gst
51 def whiten_test_01a(pipeline, name):
61 def psd_resolution_changed(elem, pspec, ignored):
62 delta_f = elem.get_property(
"delta-f")
63 f_nyquist = elem.get_property(
"f-nyquist")
64 n = int(round(f_nyquist / delta_f) + 1)
65 elem.set_property(
"mean-psd", numpy.ones((n,), dtype =
"double") / (n * delta_f))
81 head =
test_common.test_src(pipeline, buffer_length = buffer_length, rate = rate, test_duration = test_duration, wave = 9)
82 head = pipeparts.mkgeneric(pipeline, head,
"audiocheblimit", mode = 1, cutoff = 0.25)
83 head = tee = pipeparts.mktee(pipeline, head)
84 head = pipeparts.mkwhiten(pipeline, head, psd_mode = 1, zero_pad = zero_pad, fft_length = fft_length)
85 head.connect_after(
"notify::f-nyquist", psd_resolution_changed,
None)
86 head.connect_after(
"notify::delta-f", psd_resolution_changed,
None)
87 head = pipeparts.mkchecktimestamps(pipeline, head)
88 pipeparts.mknxydumpsink(pipeline, pipeparts.mkqueue(pipeline, head),
"%s_out.dump" % name)
89 pipeparts.mknxydumpsink(pipeline, pipeparts.mkqueue(pipeline, tee, max_size_time = int(fft_length * gst.SECOND)),
"%s_in.dump" % name)
104 def whiten_test_01b(pipeline, name):
113 test_duration = 10000.0
119 head =
test_common.test_src(pipeline, buffer_length = buffer_length, rate = rate, test_duration = test_duration, wave = 6)
120 head = pipeparts.mkwhiten(pipeline, head, psd_mode = 0, zero_pad = zero_pad, fft_length = fft_length)
121 head = pipeparts.mkchecktimestamps(pipeline, head)
122 pipeparts.mknxydumpsink(pipeline, pipeparts.mkqueue(pipeline, head),
"%s_out.dump" % name)
143 cmp_nxydumps.compare(
"whiten_test_01a_in.dump",
"whiten_test_01a_out.dump", transients = (2.0, 2.0), sample_fuzz = 1e-2)