diff options
| author | Mark Longair <mhl@pobox.com> | 2013-04-12 18:48:52 +0100 | 
|---|---|---|
| committer | Mark Longair <mhl@pobox.com> | 2013-04-18 10:20:49 +0100 | 
| commit | 0287ca92fb6bd39bade5bfb44f52ac6e006139d0 (patch) | |
| tree | 18dd3a3a26df131de8d285c0fd8ec3fb4a242eff /lib/tasks/temp.rake | |
| parent | a47237d6843f14a2270e2c4e80fd1a41a661974a (diff) | |
Fix the deadlock on dealing with incoming email
Fixes #336
There was an occasional deadlock when two emails for the
same request came in near-simultaneously; two processes
would be started via script/mailin, each to deal with one
email which are both updating the same InfoRequest.
The error would look like:
   2013-04-07 09:19:03 BST [13398]: [2-1] DETAIL:  Process 13398 waits for ShareLock on transaction 36193647; blocked by process 13397.
   Process 13397 waits for ExclusiveLock on tuple (390,35) of relation 32918788 of database 32918687; blocked by process 13398.
   Process 13398: UPDATE "info_requests" SET "updated_at" = '2013-04-07 08:19:02.139515', "awaiting_description" = 't' WHERE "id" = 156200
   Process 13397: UPDATE "info_requests" SET "updated_at" = '2013-04-07 08:19:02.143624', "awaiting_description" = 't' WHERE "id" = 156200
This arose from the following section of code:
    ActiveRecord::Base.transaction do
        raw_email = RawEmail.new
        incoming_message.raw_email = raw_email
        incoming_message.info_request = self
        incoming_message.save!
        raw_email.data = raw_email_data
        raw_email.save!
        self.awaiting_description = true
        params = { :incoming_message_id => incoming_message.id }
        if !rejected_reason.empty?
            params[:rejected_reason] = rejected_reason.to_str
        end
        self.log_event("response", params)
        self.save!
    end
Matthew Somerville explained what was happening here in the
issue report; to repeat his explanation from the bug report,
both processes enter the transaction block and acquire a
ShareLock on self with:
   incoming_message.info_request = self
   incoming_message.save!
However, in order to update the self.awaiting_description field
of the InfoRequest, with:
   self.awaiting_description = true
   [...]
   self.save!
... the ShareLock needs to be upgraded to an ExclusiveLock,
but both will wait until the other's ShareLock is released,
which would only happen at the end of the transaction.
We can avoid this deadlock by using SELECT ... FOR UPDATE
for the row in info_requests.  In Rails 3.2.0 there is
ActiveRecord support for this (via with_lock and lock! on
a model instance) but so as not to require upgrading rails,
I'm just using raw SQL.
Diffstat (limited to 'lib/tasks/temp.rake')
0 files changed, 0 insertions, 0 deletions
