| 139 | self.delayed_queue.append(("insertOrUpdate", (args, kwargs))) |
| 140 | |
| 141 | def processDelayed(self): |
| 142 | if not self.delayed_queue: |
| 143 | self.log.debug("processDelayed aborted") |
| 144 | return |
| 145 | if not self.conn: |
| 146 | self.connect() |
| 147 | |
| 148 | s = time.time() |
| 149 | cur = self.getCursor() |
| 150 | for command, params in self.delayed_queue: |
| 151 | if command == "insertOrUpdate": |
| 152 | cur.insertOrUpdate(*params[0], **params[1]) |
| 153 | else: |
| 154 | cur.execute(*params[0], **params[1]) |
| 155 | |
| 156 | if len(self.delayed_queue) > 10: |
| 157 | self.log.debug("Processed %s delayed queue in %.3fs" % (len(self.delayed_queue), time.time() - s)) |
| 158 | self.delayed_queue = [] |
| 159 | self.delayed_queue_thread = None |
| 160 | |
| 161 | def close(self): |
| 162 | s = time.time() |