Merge branch 'cassandra-3.0' into trunk

This commit is contained in:
Yuki Morishita 2015-09-29 12:02:07 -05:00
commit ed65ff99c1
2 changed files with 3 additions and 0 deletions

View File

@ -35,6 +35,7 @@ Merged from 2.2:
* Defer default role manager setup until all nodes are on 2.2+ (CASSANDRA-9761)
* Handle missing RoleManager in config after upgrade to 2.2 (CASSANDRA-10209)
Merged from 2.1:
* Fix dropping undroppable when message queue is full (CASSANDRA-10113)
* Fix potential ClassCastException during paging (CASSANDRA-10352)
* Prevent ALTER TYPE from creating circular references (CASSANDRA-10339)
* Fix cache handling of 2i and base tables (CASSANDRA-10155, 10359)

View File

@ -527,6 +527,8 @@ public class OutboundTcpConnection extends Thread
while (iter.hasNext())
{
QueuedMessage qm = iter.next();
if (!qm.droppable)
continue;
if (qm.timestampNanos >= System.nanoTime() - qm.message.getTimeout())
return;
iter.remove();