diff options
Diffstat (limited to 'p2pvr/daemon/schedules.cpp')
| -rw-r--r-- | p2pvr/daemon/schedules.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/p2pvr/daemon/schedules.cpp b/p2pvr/daemon/schedules.cpp index 674dd87..5e3881d 100644 --- a/p2pvr/daemon/schedules.cpp +++ b/p2pvr/daemon/schedules.cpp @@ -14,6 +14,7 @@ #include "sqlSelectDeserializer.h" #include <slicer/slicer.h> #include <p2pvr-int.h> +#include <privateExecContext.h> ResourceString(Schedules_getCandidates, sql_Schedules_getCandidates); ResourceString(Schedules_insert, sql_Schedules_insert); @@ -284,11 +285,12 @@ Schedules::DoReschedule(const Ice::Current & ice) } TxHelper tx(this); + PrivateExecContext ec; SqlMergeTask mergeRecords("postgres", "record"); auto rcs = CreateColumns<P2PVR::ScheduledToRecordPtr>(boost::bind(&DatabaseClient::SqlMergeColumnsInserter, &mergeRecords, _1, _2)); mergeRecords.sources.insert(new ContainerIterator<P2PVR::ScheduledToRecordList>(&records, rcs)); mergeRecords.loadComplete(this); - mergeRecords.execute(NULL); + mergeRecords.execute(&ec); tx.Commit(); auto recorder = P2PVR::RecorderPrx::checkedCast(ice.adapter->createProxy(ice.adapter->getCommunicator()->stringToIdentity("Recorder"))); |