From 5c0ed1cb1cd6d5e3b450d634bb71444c64a2478c Mon Sep 17 00:00:00 2001
From: Christian Buck <cbuck@google.com>
Date: Tue, 31 May 2016 17:56:06 +0200
Subject: [PATCH] Fix writing of alignment score in multithreading

---
 src/fast_align.cc | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/fast_align.cc b/src/fast_align.cc
index f5b594c..637af26 100644
--- a/src/fast_align.cc
+++ b/src/fast_align.cc
@@ -146,6 +146,7 @@ void UpdateFromPairs(const vector<string>& lines, const int lc, const int iter,
     ostringstream oss; // collect output in last iteration
     vector<double> probs(src.size() + 1);
     bool first_al = true;  // used when printing alignments
+    double local_likelihood = 0.0;
     for (unsigned j = 0; j < trg.size(); ++j) {
       const unsigned& f_j = trg[j];
       double sum = 0;
@@ -202,12 +203,13 @@ void UpdateFromPairs(const vector<string>& lines, const int lc, const int iter,
           emp_feat_ += DiagonalAlignment::Feature(j, i, trg.size(), src.size()) * p;
         }
       }
-      likelihood_ += log(sum);
+      local_likelihood += log(sum);
     }
+    likelihood_ += local_likelihood;
     if (final_iteration) {
       if (print_scores) {
         double log_prob = Md::log_poisson(trg.size(), 0.05 + src.size() * mean_srclen_multiplier);
-        log_prob += likelihood_;
+        log_prob += local_likelihood;
         oss << " ||| " << log_prob;
       }
       oss << endl;