Remove commit() function on middle

This can now be handled by the after_relations() function.

Author: joto

src/middle-pgsql.cpp

@@ -629,6 +629,9 @@ void middle_pgsql_t::after_relations()
     m_db_copy.sync();
     auto const &table = m_tables[REL_TABLE];
     analyze_table(m_db_connection, table.schema(), table.name());
+
+    // release the copy thread and its database connection
+    m_copy_thread->finish();
 }
 
 middle_query_pgsql_t::middle_query_pgsql_t(
@@ -668,13 +671,6 @@ void middle_pgsql_t::start()
     }
 }
 
-void middle_pgsql_t::commit()
-{
-    m_db_copy.sync();
-    // release the copy thread and its query connection
-    m_copy_thread->finish();
-}
-
 void middle_pgsql_t::stop(thread_pool_t &pool)
 {
     m_cache.reset();

src/middle-pgsql.hpp

@@ -60,7 +60,6 @@ struct middle_pgsql_t : public middle_t
 
     void start() override;
     void stop(thread_pool_t &pool) override;
-    void commit() override;
 
     void node(osmium::Node const &node) override;
     void way(osmium::Way const &way) override;

src/middle-ram.hpp

@@ -96,7 +96,6 @@ struct middle_ram_t : public middle_t, public middle_query_t
 
     void start() override {}
     void stop(thread_pool_t &pool) override;
-    void commit() override {}
 
     void node(osmium::Node const &node) override;
     void way(osmium::Way const &way) override;

src/middle.hpp

@@ -74,7 +74,6 @@ struct middle_t
 
     virtual void start() = 0;
     virtual void stop(thread_pool_t &pool) = 0;
-    virtual void commit() = 0;
 
     /// This is called for every added, changed or deleted node.
     virtual void node(osmium::Node const &node) = 0;

src/osmdata.cpp

@@ -445,11 +445,6 @@ void osmdata_t::postprocess_database() const
 
 void osmdata_t::stop() const
 {
-    /* Commit the transactions, so that multiple processes can
-     * access the data simultaneously to process the rest in parallel
-     * as well as see the newly created tables.
-     */
-    m_mid->commit();
     for (auto &out : m_outs) {
         out->sync();
     }