diff options
| author | Xinhui | 2016-08-31 14:34:52 +0200 |
|---|---|---|
| committer | Xinhui | 2016-08-31 14:34:52 +0200 |
| commit | c3d262e691c3301243be89e498c8d8034c9f4b53 (patch) | |
| tree | df453b6b0cddd45218d3b719dec821670baae768 | |
| parent | ae25f7bdd87a8f90cfede723e87f8291855d3d19 (diff) | |
| download | chouette-core-c3d262e691c3301243be89e498c8d8034c9f4b53.tar.bz2 | |
Fix memory leak reflex:sync task
| -rw-r--r-- | lib/stif/reflex_synchronization.rb | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/lib/stif/reflex_synchronization.rb b/lib/stif/reflex_synchronization.rb index 8886fea8e..fd2f497e2 100644 --- a/lib/stif/reflex_synchronization.rb +++ b/lib/stif/reflex_synchronization.rb @@ -13,18 +13,21 @@ module Stif def synchronize client = Reflex::API.new ['getOR', 'getOP'].each do |method| - results = client.process method - processed = [] + results = client.process method + stop_areas = results[:Quay].merge(results[:StopPlace]) results[:StopPlaceEntrance].each do |id, entry| self.create_or_update_access_point entry end - results[:Quay].merge(results[:StopPlace]).each do |id, entry| - processed << self.create_or_update_stop_area(entry) + Rails.logger.debug "Reflex:sync - StopPlaceEntrance sync done !" + stop_areas.each do |id, entry| + self.create_or_update_stop_area entry end - processed.each do |entry| + Rails.logger.debug "Reflex:sync - StopAreas sync done !" + stop_areas.each do |id, entry| self.stop_area_set_parent entry end + Rails.logger.debug "Reflex:sync - StopAreas : set parents sync done !" end end |
