From 610499e5e07391c5f45e12803ed5d60350b4bfdc Mon Sep 17 00:00:00 2001 From: miker Date: Thu, 17 Aug 2006 20:31:11 +0000 Subject: [PATCH] protecting against insert/update race condition git-svn-id: svn://svn.open-ils.org/ILS/trunk@5573 dcc99617-32d9-48b4-a31d-7c20da2025e4 --- Open-ILS/src/perlmods/OpenILS/Application/Ingest.pm | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) 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); -- 2.43.2