From: miker <miker@dcc99617-32d9-48b4-a31d-7c20da2025e4>
Date: Thu, 17 Aug 2006 20:31:11 +0000 (+0000)
Subject: protecting against insert/update race condition
X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=610499e5e07391c5f45e12803ed5d60350b4bfdc;p=evergreen%2Fpines.git

protecting against insert/update race condition


git-svn-id: svn://svn.open-ils.org/ILS/trunk@5573 dcc99617-32d9-48b4-a31d-7c20da2025e4
---

diff --git a/Open-ILS/src/perlmods/OpenILS/Application/Ingest.pm b/Open-ILS/src/perlmods/OpenILS/Application/Ingest.pm
index 9de9eab1ad..f273597b21 100644
--- a/Open-ILS/src/perlmods/OpenILS/Application/Ingest.pm
+++ b/Open-ILS/src/perlmods/OpenILS/Application/Ingest.pm
@@ -227,10 +227,13 @@ sub rw_biblio_ingest_single_record {
 	my $rec = shift;
 
 	OpenILS::Application::Ingest->post_init();
-	my $r = OpenSRF::AppSession
-			->create('open-ils.cstore')
-			->request( 'open-ils.cstore.direct.biblio.record_entry.retrieve' => $rec )
-			->gather(1);
+	my $cstore = OpenSRF::AppSession->connect( 'open-ils.cstore' );
+	$cstore->request('open-ils.cstore.transaction.begin')->gather(1);
+
+	my $r = $cstore->request( 'open-ils.cstore.direct.biblio.record_entry.retrieve' => $rec )->gather(1);
+
+	$cstore->request('open-ils.cstore.transaction.rollback')->gather(1);
+	$cstore->disconnect;
 
 	return undef unless ($r and @$r);