Skip to content

Commit f3aa914

Browse files
committed
51433: Handle TransactionBacklog events in RsrAsyncMournHandler.
1 parent c533fb4 commit f3aa914

1 file changed

Lines changed: 7 additions & 4 deletions

File tree

src/RemoteServiceReplication-GemStone/RsrAsyncMournHandler.class.st

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -58,22 +58,25 @@ RsrAsyncMournHandler >> process [
5858
^process
5959
]
6060

61-
{ #category : 'other' }
61+
{ #category : 'lifecycle' }
6262
RsrAsyncMournHandler >> runLoop [
6363

6464
[[self isActive]
6565
whileTrue:
6666
[[notifier readNotification]
67-
on: GcFinalizeNotification
68-
do: [:ex | ex _finalizeEphemerons]]]
67+
onException: { GcFinalizeNotification. TransactionBacklog. }
68+
do: {
69+
[:ex | ex _finalizeEphemerons].
70+
[:ex | System abortTransaction].
71+
}]]
6972
on: SocketError
7073
do: [:ex | ex return]
7174
]
7275

7376
{ #category : 'lifecycle' }
7477
RsrAsyncMournHandler >> start [
7578

76-
[notifier := GsSignalingSocket newForAsyncExceptions: {GcFinalizeNotification }.
79+
[notifier := GsSignalingSocket newForAsyncExceptions: {GcFinalizeNotification. TransactionBacklog. }.
7780
notifier interrupting: true]
7881
on: SocketError
7982
do:

0 commit comments

Comments
 (0)