equal
deleted
inserted
replaced
196 def __iter__(self): |
196 def __iter__(self): |
197 for cnxset in self._cnxsets: |
197 for cnxset in self._cnxsets: |
198 yield cnxset |
198 yield cnxset |
199 |
199 |
200 def close(self): |
200 def close(self): |
201 while not self._queue.empty(): |
201 while True: |
202 cnxset = self._queue.get_nowait() |
202 try: |
203 |
203 cnxset = self._queue.get_nowait() |
|
204 except queue.Empty: |
|
205 break |
204 try: |
206 try: |
205 cnxset.close(True) |
207 cnxset.close(True) |
206 except Exception as e: |
208 except Exception as e: |
207 self.exception('error while closing %s, error: %s' % (cnxset, e)) |
209 self.exception('error while closing %s, error: %s' % (cnxset, e)) |
208 |
210 |