Skip to content
Snippets Groups Projects
Commit 131403b7 authored by Madeline Wade's avatar Madeline Wade
Browse files

Temporary fix to calibration pipeline to deal with ldas-tools incompatibility,...

Temporary fix to calibration pipeline to deal with ldas-tools incompatibility, and temporary fix to lal_logical_undersampler to deal with 0-length hearbeat buffers
parent be73f3f6
No related branches found
No related tags found
No related merge requests found
......@@ -158,7 +158,8 @@ if options.data_source != "white":
channel_list = gw_data_source.channel_dict.items()
dq_channel_list = (instrument, gw_data_source.dq_channel_dict[instrument])
channel_list.append(dq_channel_list)
demux = pipeparts.mkframecppchanneldemux(pipeline, src, do_file_checksum = True, skip_bad_files = True, channel_list = map("%s:%s".__mod__, channel_list))
#demux = pipeparts.mkframecppchanneldemux(pipeline, src, do_file_checksum = True, skip_bad_files = True, channel_list = map("%s:%s".__mod__, channel_list))
demux = pipeparts.mkframecppchanneldemux(pipeline, src, skip_bad_files = True, channel_list = map("%s:%s".__mod__, channel_list))
# Write the pipeline graph after pads have been hooked up to the demuxer
if options.write_pipeline is not None:
demux.connect("no-more-pads", write_graph)
......
......@@ -299,6 +299,9 @@ class lal_logical_undersampler(gst.BaseTransform):
gst.Buffer.flag_unset(buf, gst.BUFFER_FLAG_GAP)
def do_transform(self, inbuf, outbuf):
# FIXME: I'm not sure this is the right fix for hearbeat buffers, so I need to check this!
if len(inbuf) == 0:
gst.Buffer.flag_set(inbuf, gst.BUFFER_FLAG_GAP)
if gst.Buffer.flag_is_set(inbuf, gst.BUFFER_FLAG_DISCONT) or inbuf.offset != self.next_in_offset or self.t0 == gst.CLOCK_TIME_NONE:
self.t0 = inbuf.timestamp
self.offset0 = self.next_out_offset = gst.util_uint64_scale_int_ceil(inbuf.offset, self.rate_out, self.rate_in)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment