Enable Multiple Channel Output in Online Streamer

gstlal-ugly/bin/gstlal_ll_inj_stream

@@ -65,6 +65,10 @@ def parse_command_line():
 	parser.add_option("--frame-type", metavar = "name", type="string", action = "append", help = "Frame type to be included in the name of the output frame files. Must be provided once for each ifo anlyzed as {IFO}={FRAME_TYPE}.")
 	parser.add_option("--gps-end-time", metavar = "s", default = 2000000000, help = "The time at which to stop looking for data in frame cache if different from legnth of cache. Script will terminate at this time. Default is to take all times in frame cache. e.g. GPS=200000000")
 	parser.add_option("--history-len", metavar = "s", type=int, default = 300, help = "Length of time (in seconds) to keep files for in output-dir. Files written more than history-len in the past, will be deleted from output-dir. Default: 300s")
+
+	# Add output options
+	parser.add_option("--output-channel-tag", metavar = "channel_name", type = "str", help = "Add a tag for the output channel name of injection channel to distinguish sources. ") 
+
 	parser.add_option("-v", "--verbose", action = "store_true", help = "Be verbose (optional).")
 
 	options, filenames = parser.parse_args()
@@ -316,7 +320,10 @@ with tempfile.NamedTemporaryFile(mode='w',suffix='.cache') as f:
 
 			# add injections to hoft
 			# note that the adder sinks the streams
-			inj_strain_dict[channel+'_INJ'] = pipeparts.mkadder(pipeline, [hoft_strain, this_inj_strain], sync=True, mix_mode="sum")
+			if options.output_channel_tag:
+				inj_strain_dict[channel + '_' + options.output_channel_tag + '_INJ'] = pipeparts.mkadder(pipeline, [hoft_strain, this_inj_strain], sync=True, mix_mode="sum")
+			else:
+				inj_strain_dict[channel + '_INJ'] = pipeparts.mkadder(pipeline, [hoft_strain, this_inj_strain], sync=True, mix_mode="sum")
 
 
 		# want to mux hoft, inj + hoft, and passthrough channels