Skip to content

Commit 1a424f5

Browse files
committed
Do not store append option separately, its already in m_options
1 parent fc46609 commit 1a424f5

File tree

2 files changed

+7
-8
lines changed

2 files changed

+7
-8
lines changed

src/middle-pgsql.cpp

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -329,7 +329,7 @@ size_t middle_query_pgsql_t::nodes_get_list(osmium::WayNodeList *nodes) const
329329

330330
void middle_pgsql_t::node_delete(osmid_t osm_id)
331331
{
332-
assert(m_append);
332+
assert(m_options->append);
333333

334334
if (m_options->flat_node_cache_enabled) {
335335
m_persistent_cache->set(osm_id, osmium::Location{});
@@ -460,7 +460,7 @@ middle_query_pgsql_t::rel_way_members_get(osmium::Relation const &rel,
460460

461461
void middle_pgsql_t::way_delete(osmid_t osm_id)
462462
{
463-
assert(m_append);
463+
assert(m_options->append);
464464
m_db_copy.new_line(m_tables[WAY_TABLE].m_copy_target);
465465
m_db_copy.delete_object(osm_id);
466466
}
@@ -533,7 +533,7 @@ bool middle_query_pgsql_t::relation_get(osmid_t id,
533533

534534
void middle_pgsql_t::relation_delete(osmid_t osm_id)
535535
{
536-
assert(m_append);
536+
assert(m_options->append);
537537

538538
m_db_copy.new_line(m_tables[REL_TABLE].m_copy_target);
539539
m_db_copy.delete_object(osm_id);
@@ -559,7 +559,7 @@ middle_query_pgsql_t::middle_query_pgsql_t(
559559

560560
void middle_pgsql_t::start()
561561
{
562-
if (m_append) {
562+
if (m_options->append) {
563563
// Disable JIT and parallel workers as they are known to cause
564564
// problems when accessing the intarrays.
565565
m_db_connection.set_config("jit_above_cost", "-1");
@@ -609,13 +609,13 @@ void middle_pgsql_t::stop(thread_pool_t &pool)
609609
// that the space is freed before creating the other indices.
610610
for (auto &table : m_tables) {
611611
table.stop(m_options->database_options.conninfo(),
612-
m_options->droptemp, !m_append);
612+
m_options->droptemp, !m_options->append);
613613
}
614614
} else {
615615
for (auto &table : m_tables) {
616616
pool.submit(std::bind(&middle_pgsql_t::table_desc::stop, &table,
617617
m_options->database_options.conninfo(),
618-
m_options->droptemp, !m_append));
618+
m_options->droptemp, !m_options->append));
619619
}
620620
}
621621
}
@@ -743,7 +743,7 @@ static bool check_bucket_index(pg_conn_t *db_connection,
743743
}
744744

745745
middle_pgsql_t::middle_pgsql_t(options_t const *options)
746-
: m_append(options->append), m_options(options),
746+
: m_options(options),
747747
m_cache(new node_ram_cache{options->alloc_chunkwise | ALLOC_LOSSY,
748748
options->cache}),
749749
m_db_connection(m_options->database_options.conninfo()),

src/middle-pgsql.hpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,6 @@ struct middle_pgsql_t : public slim_middle_t
112112

113113
table_desc m_tables[NUM_TABLES];
114114

115-
bool m_append;
116115
options_t const *m_options;
117116

118117
std::shared_ptr<node_ram_cache> m_cache;

0 commit comments

Comments
 (0)