File tree Expand file tree Collapse file tree 9 files changed +2
-30
lines changed
Expand file tree Collapse file tree 9 files changed +2
-30
lines changed Original file line number Diff line number Diff line change @@ -297,19 +297,9 @@ struct pending_threaded_processor : public middle_t::pending_processor
297297 ids_queued = 0 ;
298298 ids_done = 0 ;
299299
300- // collect all the new rels that became pending from each
301- // output in each thread back to their respective main outputs
302300 for (auto const &clone : clones) {
303- // for each clone/original output
304- for (output_vec_t ::const_iterator original_output = outs.begin (),
305- clone_output = clone.begin ();
306- original_output != outs.end () && clone_output != clone.end ();
307- ++original_output, ++clone_output) {
308- // done copying ways for now
309- clone_output->get ()->commit ();
310- // merge the pending from this threads copy of output back
311- original_output->get ()->merge_pending_relations (
312- clone_output->get ());
301+ for (auto const &clone_output : clone) {
302+ clone_output.get ()->commit ();
313303 }
314304 }
315305 }
Original file line number Diff line number Diff line change @@ -1403,10 +1403,6 @@ void output_flex_t::stage2_proc()
14031403 }
14041404}
14051405
1406- void output_flex_t::merge_pending_relations (output_t *)
1407- {
1408- }
1409-
14101406void output_flex_t::merge_expire_trees (output_t *other)
14111407{
14121408 auto *opgsql = dynamic_cast <output_flex_t *>(other);
Original file line number Diff line number Diff line change @@ -79,7 +79,6 @@ class output_flex_t : public output_t
7979 void way_delete (osmid_t id) override ;
8080 void relation_delete (osmid_t id) override ;
8181
82- void merge_pending_relations (output_t *other) override ;
8382 void merge_expire_trees (output_t *other) override ;
8483
8584 int app_define_table ();
Original file line number Diff line number Diff line change @@ -330,10 +330,6 @@ void output_multi_t::delete_from_output(osmid_t id)
330330 }
331331}
332332
333- void output_multi_t::merge_pending_relations (output_t *)
334- {
335- }
336-
337333void output_multi_t::merge_expire_trees (output_t *other)
338334{
339335 auto *const omulti = dynamic_cast <output_multi_t *>(other);
Original file line number Diff line number Diff line change @@ -64,7 +64,6 @@ class output_multi_t : public output_t
6464 void way_delete (osmid_t id) override ;
6565 void relation_delete (osmid_t id) override ;
6666
67- void merge_pending_relations (output_t *other) override ;
6867 void merge_expire_trees (output_t *other) override ;
6968
7069protected:
Original file line number Diff line number Diff line change @@ -425,10 +425,6 @@ output_pgsql_t::output_pgsql_t(
425425
426426output_pgsql_t ::~output_pgsql_t () = default ;
427427
428- void output_pgsql_t::merge_pending_relations (output_t *)
429- {
430- }
431-
432428void output_pgsql_t::merge_expire_trees (output_t *other)
433429{
434430 auto *const opgsql = dynamic_cast <output_pgsql_t *>(other);
Original file line number Diff line number Diff line change @@ -64,7 +64,6 @@ class output_pgsql_t : public output_t
6464 void way_delete (osmid_t id) override ;
6565 void relation_delete (osmid_t id) override ;
6666
67- void merge_pending_relations (output_t *other) override ;
6867 void merge_expire_trees (output_t *other) override ;
6968
7069protected:
Original file line number Diff line number Diff line change @@ -199,6 +199,4 @@ output_t::~output_t() = default;
199199
200200options_t const *output_t::get_options () const { return &m_options; }
201201
202- void output_t::merge_pending_relations (output_t *) {}
203-
204202void output_t::merge_expire_trees (output_t *) {}
Original file line number Diff line number Diff line change @@ -75,7 +75,6 @@ class output_t
7575
7676 const options_t *get_options () const ;
7777
78- virtual void merge_pending_relations (output_t *other);
7978 virtual void merge_expire_trees (output_t *other);
8079
8180protected:
You can’t perform that action at this time.
0 commit comments