diff options
author | Kegan Dougal <kegan@matrix.org> | 2015-03-06 16:16:14 +0000 |
---|---|---|
committer | Kegan Dougal <kegan@matrix.org> | 2015-03-06 16:16:14 +0000 |
commit | 2602ddc379f9bede21cafc8c8f7f57dec44cf69d (patch) | |
tree | 9c16e02b77a60ca1f7987a55a68a83336ff09165 /synapse | |
parent | Finish synapse.appservice.scheduler implementation. (diff) | |
download | synapse-2602ddc379f9bede21cafc8c8f7f57dec44cf69d.tar.xz |
Apply clarity and docstrings
Diffstat (limited to 'synapse')
-rw-r--r-- | synapse/appservice/scheduler.py | 2 | ||||
-rw-r--r-- | synapse/storage/appservice.py | 14 |
2 files changed, 14 insertions, 2 deletions
diff --git a/synapse/appservice/scheduler.py b/synapse/appservice/scheduler.py index 50ad3b8e83..514148c947 100644 --- a/synapse/appservice/scheduler.py +++ b/synapse/appservice/scheduler.py @@ -224,5 +224,5 @@ class _Recoverer(object): @defer.inlineCallbacks def _get_oldest_txn(self): - txn = yield self.store.get_oldest_txn(self.service) + txn = yield self.store.get_oldest_unsent_txn(self.service) defer.returnValue(txn) diff --git a/synapse/storage/appservice.py b/synapse/storage/appservice.py index 6fde7dcc66..4447c8a2e1 100644 --- a/synapse/storage/appservice.py +++ b/synapse/storage/appservice.py @@ -383,7 +383,7 @@ class ApplicationServiceTransactionStore(SQLBaseStore): service(ApplicationService): The service who the transaction is for. events(list<Event>): A list of events to put in the transaction. Returns: - ApplicationServiceTransaction: A new transaction. + AppServiceTransaction: A new transaction. """ pass @@ -399,3 +399,15 @@ class ApplicationServiceTransactionStore(SQLBaseStore): successfully. """ pass + + def get_oldest_unsent_txn(self, service): + """Get the oldest transaction which has not been sent for this + service. + + Args: + service(ApplicationService): The app service to get the oldest txn. + Returns: + A Deferred which resolves to an AppServiceTransaction or + None. + """ + pass |