diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-08-25 13:07:32 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-08-25 13:07:32 +0100 |
| commit | 846b176a7c02e245b5580e56900a69e34b691f2f (patch) | |
| tree | 67c119e8ac1ecfca74a48b89713f4afe162e5f66 | |
| parent | 8cc0432c21604729c4d5444194d685e3b6e3f337 (diff) | |
| download | rabbitmq-server-git-846b176a7c02e245b5580e56900a69e34b691f2f.tar.gz | |
s/erlang:length/length
| -rw-r--r-- | src/rabbit_mixed_queue.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_mixed_queue.erl b/src/rabbit_mixed_queue.erl index 60920b21a7..031ca914b1 100644 --- a/src/rabbit_mixed_queue.erl +++ b/src/rabbit_mixed_queue.erl @@ -424,7 +424,7 @@ tx_commit(Publishes, MsgsWithAcks, true -> rabbit_disk_queue:tx_commit(Q, only_msg_ids(Publishes), RealAcks) end, - Len = erlang:length(Publishes), + Len = length(Publishes), {ok, lose_memory(ASize, State #mqstate { length = Length + Len, msg_buf = inc_queue_length(MsgBuf, Len) })}; @@ -450,7 +450,7 @@ tx_commit(Publishes, MsgsWithAcks, end, {ok, lose_memory(ASize, State #mqstate { msg_buf = MsgBuf1, - length = Length + erlang:length(Publishes) })}. + length = Length + length(Publishes) })}. tx_cancel(Publishes, State = #mqstate { mode = disk }) -> {MsgIds, CSize} = @@ -502,7 +502,7 @@ requeue(MessagesWithAckTags, State = #mqstate { mode = disk, queue = Q, [] end, [], MessagesWithAckTags), ok = rabbit_disk_queue:requeue(Q, lists:reverse(Requeue)), - Len = erlang:length(MessagesWithAckTags), + Len = length(MessagesWithAckTags), {ok, State #mqstate { length = Length + Len, msg_buf = inc_queue_length(MsgBuf, Len) }}; requeue(MessagesWithAckTags, State = #mqstate { mode = mixed, queue = Q, @@ -525,7 +525,7 @@ requeue(MessagesWithAckTags, State = #mqstate { mode = mixed, queue = Q, _ -> rabbit_disk_queue:requeue(Q, lists:reverse(PersistentPubs)) end, {ok, State #mqstate {msg_buf = MsgBuf1, - length = Length + erlang:length(MessagesWithAckTags)}}. + length = Length + length(MessagesWithAckTags)}}. purge(State = #mqstate { queue = Q, mode = disk, length = Count, memory_size = QSize }) -> |