equal
deleted
inserted
replaced
174 def pool_reset(self, cnx): |
174 def pool_reset(self, cnx): |
175 """the pool using the given connection is being reseted from its current |
175 """the pool using the given connection is being reseted from its current |
176 attached session: release the connection lock if the connection wrapper |
176 attached session: release the connection lock if the connection wrapper |
177 has a connection set |
177 has a connection set |
178 """ |
178 """ |
179 if cnx._cnx is not None: |
179 # reset _cnx to ensure next thread using cnx will get a new |
180 # reset _cnx to ensure next thread using cnx will get a new |
180 # connection |
181 # connection |
181 cnx.close() |
182 cnx.close() |
|
183 |
182 |
184 def syntax_tree_search(self, session, union, |
183 def syntax_tree_search(self, session, union, |
185 args=None, cachekey=None, varmap=None, debug=0): |
184 args=None, cachekey=None, varmap=None, debug=0): |
186 """return result from this source for a rql query (actually from a rql |
185 """return result from this source for a rql query (actually from a rql |
187 syntax tree and a solution dictionary mapping each used variable to a |
186 syntax tree and a solution dictionary mapping each used variable to a |