Changeset 401
- Timestamp:
- 04/20/09 20:31:59 (10 years ago)
- Files:
-
- 1 modified
Legend:
- Unmodified
- Added
- Removed
-
Explorator/trunk/vendor/plugins/active_rdf/lib/active_rdf/federation/connection_pool.rb
r387 r401 41 41 self.write_adapter = nil 42 42 end 43 44 @@void43 def ConnectionPool.void 44 @@void 45 45 end 46 46 def ConnectionPool.adapters … … 70 70 71 71 # returns adapter-instance for given parameters (either existing or new) 72 def ConnectionPool.add_data_source(connection_params )72 def ConnectionPool.add_data_source(connection_params ) 73 73 $activerdflog.info "ConnectionPool: add_data_source with params: #{connection_params.inspect}" 74 74 … … 82 82 $activerdflog.debug("Create a new adapter for parameters #{connection_params.inspect}") 83 83 adapter = create_adapter(connection_params) 84 @@adapter_parameters << connection_params 85 @@adapter_pool << adapter 84 # this is necessary because activerdf search in the order repositories were added 85 if adapter.title == 'INTERNAL' 86 87 @@adapter_parameters << connection_params 88 @@adapter_pool << adapter 89 else 90 @@adapter_parameters.insert(0,connection_params) 91 @@adapter_pool.insert(0,adapter) 92 end 86 93 else 87 94 # if adapter parametrs registered already, … … 102 109 def ConnectionPool.remove_data_source(adapter) 103 110 RDFS::Resource.reset_cache() 104 111 105 112 $activerdflog.info "ConnectionPool: remove_data_source with params: #{adapter.to_s}" 106 113 … … 111 118 @@adapter_parameters.delete_at(index) 112 119 @@adapter_pool.delete_at(index) 113 # if self.write_adapters.empty?114 # self.write_adapter = nil115 # else116 # self.write_adapter = self.write_adapters.first117 # end120 # if self.write_adapters.empty? 121 # self.write_adapter = nil 122 # else 123 # self.write_adapter = self.write_adapters.first 124 # end 118 125 119 126 end … … 141 148 #find an sparql adapter by its uri 142 149 def ConnectionPool.find_by_uri(uri) 143 150 144 151 @@adapter_pool.each {|x| 145 if x.instance_of? SparqlAdapter146 147 if x.url == uri148 return x149 end150 end152 if x.instance_of? SparqlAdapter 153 154 if x.url == uri 155 return x 156 end 157 end 151 158 } 152 159 return nil 153 160 154 161 end 155 162 # adapter-types can register themselves with connection pool by