| OLD | NEW |
| 1 # This file is part of Buildbot. Buildbot is free software: you can | 1 # This file is part of Buildbot. Buildbot is free software: you can |
| 2 # redistribute it and/or modify it under the terms of the GNU General Public | 2 # redistribute it and/or modify it under the terms of the GNU General Public |
| 3 # License as published by the Free Software Foundation, version 2. | 3 # License as published by the Free Software Foundation, version 2. |
| 4 # | 4 # |
| 5 # This program is distributed in the hope that it will be useful, but WITHOUT | 5 # This program is distributed in the hope that it will be useful, but WITHOUT |
| 6 # ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS | 6 # ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS |
| 7 # FOR A PARTICULAR PURPOSE. See the GNU General Public License for more | 7 # FOR A PARTICULAR PURPOSE. See the GNU General Public License for more |
| 8 # details. | 8 # details. |
| 9 # | 9 # |
| 10 # You should have received a copy of the GNU General Public License along with | 10 # You should have received a copy of the GNU General Public License along with |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 47 maxthreads=pool_size, | 47 maxthreads=pool_size, |
| 48 name='DBThreadPool') | 48 name='DBThreadPool') |
| 49 self.engine = engine | 49 self.engine = engine |
| 50 if engine.dialect.name == 'sqlite': | 50 if engine.dialect.name == 'sqlite': |
| 51 vers = self.get_sqlite_version() | 51 vers = self.get_sqlite_version() |
| 52 log.msg("Using SQLite Version %s" % (vers,)) | 52 log.msg("Using SQLite Version %s" % (vers,)) |
| 53 if vers < (3,7): | 53 if vers < (3,7): |
| 54 log.msg("NOTE: this old version of SQLite does not support " | 54 log.msg("NOTE: this old version of SQLite does not support " |
| 55 "WAL journal mode; a busy master may encounter " | 55 "WAL journal mode; a busy master may encounter " |
| 56 "'Database is locked' errors. Consider upgrading.") | 56 "'Database is locked' errors. Consider upgrading.") |
| 57 if vers < (3,3,17): | 57 if vers < (3,4): |
| 58 log.msg("NOTE: this old version of SQLite does not support " | 58 log.msg("NOTE: this old version of SQLite is not supported. " |
| 59 "multiple simultaneous accesses to the database; " | 59 "It fails for multiple simultaneous accesses to the " |
| 60 "add the 'pool_size=1' argument to your db url") | 60 "database: try adding the 'pool_size=1' argument to " |
| 61 "your db url. ") |
| 61 brkn = self.__broken_sqlite = self.detect_bug1810() | 62 brkn = self.__broken_sqlite = self.detect_bug1810() |
| 62 if brkn: | 63 if brkn: |
| 63 log.msg("Applying SQLite workaround from Buildbot bug #1810") | 64 log.msg("Applying SQLite workaround from Buildbot bug #1810") |
| 64 self._start_evt = reactor.callWhenRunning(self._start) | 65 self._start_evt = reactor.callWhenRunning(self._start) |
| 65 | 66 |
| 66 def _start(self): | 67 def _start(self): |
| 67 self._start_evt = None | 68 self._start_evt = None |
| 68 if not self.running: | 69 if not self.running: |
| 69 self.start() | 70 self.start() |
| 70 self._stop_evt = reactor.addSystemEventTrigger( | 71 self._stop_evt = reactor.addSystemEventTrigger( |
| (...skipping 131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 202 except: | 203 except: |
| 203 return (0,) | 204 return (0,) |
| 204 | 205 |
| 205 if vers_row: | 206 if vers_row: |
| 206 try: | 207 try: |
| 207 return tuple(map(int, vers_row[0].split('.'))) | 208 return tuple(map(int, vers_row[0].split('.'))) |
| 208 except (TypeError, ValueError): | 209 except (TypeError, ValueError): |
| 209 return (0,) | 210 return (0,) |
| 210 else: | 211 else: |
| 211 return (0,) | 212 return (0,) |
| OLD | NEW |