diff options
Diffstat (limited to 'p2pvr/lib/maintenance/programAssociations.cpp')
| -rw-r--r-- | p2pvr/lib/maintenance/programAssociations.cpp | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/p2pvr/lib/maintenance/programAssociations.cpp b/p2pvr/lib/maintenance/programAssociations.cpp index 47e48b3..e5913a3 100644 --- a/p2pvr/lib/maintenance/programAssociations.cpp +++ b/p2pvr/lib/maintenance/programAssociations.cpp @@ -65,6 +65,7 @@ Maintenance::UpdateProgramAssociations(short type, const Ice::Current & ice) } } + TxHelper tx(this); SqlMergeTask mergeServices("postgres", "services"); CreatePATColumns(boost::bind(SqlMergeColumnsInserter, &mergeServices, _1, _2)); // Don't change the list of services available from the network @@ -74,8 +75,5 @@ Maintenance::UpdateProgramAssociations(short type, const Ice::Current & ice) mergeServices.sources.insert(new MapIterator<ProgramAssociationMap>(CreatePATColumns, &siparser->map)); mergeServices.loadComplete(this); mergeServices.execute(NULL); - BOOST_FOREACH(const CommonObjects::DataSources::value_type & ds, CommonObjects::datasources) { - ds.second->commit(); - } } |