activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Allen Yu (JIRA)" <j...@apache.org>
Subject [jira] Updated: (AMQ-1805) Persistent message leak when broker run out of disk space
Date Tue, 17 Jun 2008 16:23:00 GMT

     [ https://issues.apache.org/activemq/browse/AMQ-1805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Allen Yu updated AMQ-1805:
--------------------------

    Attachment: amq-1805.diff

>From the above 5.1 source code, it seems like allocateLocation should actually make sure
that there is enough disk space for the particular message. However, it actually only create
the File handle without actually allocating any disk space So to fix this problem, we added

nextWriteFile.closeRandomAccessFile(nextWriteFile.openRandomAccessFile(true));

in the AsyncDataManager.allocateLocation method to try and pre allocate the disk space. We
believe that this will not have much impact on the performance as data file is 32MB default,
but please feel free to advice otherwise as this is our first time looking at ActiveMQ source
code. 

> Persistent message leak when broker run out of disk space
> ---------------------------------------------------------
>
>                 Key: AMQ-1805
>                 URL: https://issues.apache.org/activemq/browse/AMQ-1805
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.1.0
>         Environment: ActiveMQ 5.1 (AMQStore w/o SystemUsage configuration)
> Windows XP SP2
> ActiveMQ CPP 2.1.3
>            Reporter: Allen Yu
>         Attachments: amq-1805.diff
>
>
> In our environment, we have several ActvieMQ CPP clients sending persistent messages
continuously to a ActiveMQ 5.1 broker. In normal condition the broker works fine until it
ran out of disk space. At that point the client would receive out of disk space advisory message
AFTER sending the message, therefore the message should be removed from broker, however, the
message are kept in the memory due to a problem in the DataFileAppender & AsyncDatamanager,
when the disk is full, the message is saved in the inflightWrites map but never taken out
since the enqueue will fail due to IOException.
>         synchronized (this) {
>             // Find the position where this item will land at.
>             DataFile dataFile = dataManager.allocateLocation(location);
>             if( !sync ) {
>                 inflightWrites.put(new WriteKey(location), write);
>             }
>             batch = enqueue(dataFile, write);
>         }
> and
>         synchronized (this) {
>             // Find the position where this item will land at.
>             DataFile dataFile = dataManager.allocateLocation(location);
>             inflightWrites.put(new WriteKey(location), write);
>             batch = enqueue(dataFile, write);
>         }

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message