(self)
| 35 | objects (msg, broadcast, pubkey, getpubkey) from the receiveDataThreads. |
| 36 | """ |
| 37 | def __init__(self): |
| 38 | threading.Thread.__init__(self, name="objectProcessor") |
| 39 | """ |
| 40 | It may be the case that the last time Bitmessage was running, the user |
| 41 | closed it before it finished processing everything in the |
| 42 | objectProcessorQueue. Assuming that Bitmessage wasn't closed forcefully, |
| 43 | it should have saved the data in the queue into the objectprocessorqueue |
| 44 | table. Let's pull it out. |
| 45 | """ |
| 46 | queryreturn = sqlQuery( |
| 47 | '''SELECT objecttype, data FROM objectprocessorqueue''') |
| 48 | for row in queryreturn: |
| 49 | objectType, data = row |
| 50 | queues.objectProcessorQueue.put((objectType,data)) |
| 51 | sqlExecute('''DELETE FROM objectprocessorqueue''') |
| 52 | logger.debug('Loaded %s objects from disk into the objectProcessorQueue.' % str(len(queryreturn))) |
| 53 | |
| 54 | |
| 55 | def run(self): |
nothing calls this directly
no test coverage detected