From 91624587569b2bd587d0d573c86d00a448ff2238 Mon Sep 17 00:00:00 2001
From: Andreas Kloeckner <inform@tiker.net>
Date: Wed, 2 Apr 2008 13:17:51 -0400
Subject: [PATCH] Fix parallel logging.
---
src/log.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/log.py b/src/log.py
index 5fc4317..8f30bc2 100644
--- a/src/log.py
+++ b/src/log.py
@@ -205,7 +205,7 @@ class LogManager(object):
self.next_watch_tick = 1
# database binding
- if filename is not None:
+ if filename is not None and self.rank == self.head_rank:
import sqlite3
self.db_conn = sqlite3.connect(filename, timeout=30)
@@ -421,8 +421,8 @@ class LogManager(object):
self.get_table(name).insert_rows(rows)
if self.db_conn is not None:
for row in rows:
- self.db_conn.execute("insert into ? values (?,?,?)",
- (name,) + row)
+ self.db_conn.execute(
+ "insert into %s values (?,?,?)" % name, row)
else:
# send non-head data away
gather(self.mpi_comm,
--
GitLab