WIP: A new steps/data/reverberate_data_dir.py script

egs/aspire/s5/local/multi_condition/aspire_prep_rir_noise_list.py

@@ -0,0 +1,79 @@
+#!/usr/bin/env python
+# Copyright 2016  Tom Ko
+# Apache 2.0
+# script to generate rir_list and noise_list in aspire
+
+# we're using python 3.x style print but want it to work in python 2.x,
+from __future__ import print_function
+import argparse, glob, math, os, sys
+
+
+def GetArgs():
+    parser = argparse.ArgumentParser(description="Prepare rir_list and noise_list for Aspire  "
+                                                 "Usage: reverberate_data_dir.py [options...] <in-data-dir> <out-data-dir> "
+                                                 "E.g. reverberate_data_dir.py "
+                                                 "data/impulses_noises data/impulses_noises/info",
+                                     formatter_class=argparse.ArgumentDefaultsHelpFormatter)
+
+    parser.add_argument("input_dir", help="Input data directory")
+    parser.add_argument("output_dir", help="Output data directory")
+    print(' '.join(sys.argv))
+    args = parser.parse_args()
+
+    return args
+
+
+# This function generate the rir_list file for the aspire real RIR
+def GenerateRirListFile(input_dir, output_dir):
+  rir_list_file = open(output_dir + "/rir_list", 'w')
+  rir_id = 1
+  room_id = 1
+  for db in ["RVB2014", "RWCP", "air"]:
+    rir_files = glob.glob(input_dir + "/{0}_*.wav".format(db))
+    for rir in rir_files:
+      filename = rir.split('/')[-1]
+      if "noise" not in filename:
+        rir_list_file.write('--rir-id {0} --room-id {1} {2}\n'.format(str(rir_id).zfill(5), str(room_id).zfill(3), rir))
+        rir_id += 1
+    room_id += 1
+  rir_list_file.close()
+
+
+# This function generate the noise_list file from the aspire noise-rir pair 
+def GenerateNoiseListFile(input_dir, output_dir):
+  noise_list_file = open(output_dir + "/noise_list", 'w')
+  noise_files = glob.glob(input_dir + "/*_type*_noise*.wav")
+  noise_id = 1
+  for noise_file in noise_files:
+    parts = noise_file.split('/')[-1].split('_')
+    db_name = parts[0]
+    type_num = parts[1]
+    noise_pattern = '_'.join(parts[3:len(parts)-1])
+    if db_name == "RWCP":
+      type_num = "type*"
+    matched_rir_files = glob.glob(input_dir + "/{0}_{1}_rir_{2}*.wav".format(db_name, type_num, noise_pattern))
+    noise_line = "--noise-id {0} --noise-type isotropic ".format(str(noise_id).zfill(5))
+    for rir in matched_rir_files:
+      noise_line += "--rir-linkage {0} ".format(rir)
+    noise_line += "{0}".format(noise_file)
+    noise_list_file.write("{0}\n".format(noise_line))
+    noise_id += 1
+  noise_list_file.close()
+
+
+def Main():
+  args = GetArgs()
+
+  if not os.path.exists(args.output_dir):
+    os.makedirs(args.output_dir)
+
+  # generating the rir_list file for the new steps/data/reverberate_data_dir.py
+  GenerateRirListFile(args.input_dir, args.output_dir)
+
+  # generating the noise_list file for the new steps/data/reverberate_data_dir.py
+  GenerateNoiseListFile(args.input_dir, args.output_dir)
+
+
+if __name__ == "__main__":
+    Main()
+

egs/aspire/s5/local/multi_condition/run_nnet2_common.sh

@@ -7,6 +7,8 @@
 
 stage=1
 snrs="20:10:15:5:0"
+foreground_snrs="20:10:15:5:0"
+background_snrs="20:10:15:5:0"
 num_data_reps=3
 ali_dir=exp/
 db_string="'air' 'rwcp' 'rvb2014'" # RIR dbs to be used in the experiment
@@ -31,24 +33,29 @@ if [ $stage -le 1 ]; then
     --RIR-home $RIR_home \
     data/impulses_noises || exit 1;
 
+  # Generate the rir_list and noise_list for the reverberate_data_dir.py to corrupt the data
+  python local/multi_condition/aspire_prep_rir_noise_list.py data/impulses_noises data/impulses_noises/info
+
   # corrupt the fisher data to generate multi-condition data 
-  # for data_dir in train dev test; do
   for data_dir in train dev test; do
     if [ "$data_dir" == "train" ]; then
       num_reps=$num_data_reps
     else
       num_reps=1
     fi
-    reverb_data_dirs=
-    for i in `seq 1 $num_reps`; do
-      cur_dest_dir=" data/temp_${data_dir}_${i}" 
-      local/multi_condition/reverberate_data_dir.sh --random-seed $i \
-        --snrs "$snrs" --log-dir exp/make_corrupted_wav \
-        data/${data_dir}  data/impulses_noises $cur_dest_dir
-      reverb_data_dirs+=" $cur_dest_dir" 
-    done
-    utils/combine_data.sh --extra-files utt2uniq data/${data_dir}_rvb $reverb_data_dirs
-    rm -rf $reverb_data_dirs
+    python steps/data/reverberate_data_dir.py \
+      --prefix "rev" \
+      --rir-list-file data/impulses_noises/info/rir_list \
+      --noise-list-file data/impulses_noises/info/noise_list \
+      --foreground-snrs $foreground_snrs \
+      --background-snrs $background_snrs \
+      --speech-rvb-probability 1 \
+      --pointsource-noise-addition-probability 1 \
+      --isotropic-noise-addition-probability 1 \
+      --num-replications $num_reps \
+      --max-noises-per-minute 1 \
+      --random-seed 1 \
+      data/${data_dir} data/${data_dir}_rvb
   done
 
   # create the dev, test and eval sets from the aspire recipe

egs/wsj/s5/steps/data/data_dir_manipulation_lib.py

@@ -0,0 +1,18 @@
+import subprocess
+
+def RunKaldiCommand(command, wait = True):
+    """ Runs commands frequently seen in Kaldi scripts. These are usually a
+        sequence of commands connected by pipes, so we use shell=True """
+    #logger.info("Running the command\n{0}".format(command))
+    p = subprocess.Popen(command, shell = True,
+                         stdout = subprocess.PIPE,
+                         stderr = subprocess.PIPE)
+
+    if wait:
+        [stdout, stderr] = p.communicate()
+        if p.returncode is not 0:
+            raise Exception("There was an error while running the command {0}\n".format(command)+"-"*10+"\n"+stderr)
+        return stdout, stderr
+    else:
+        return p
+