On Mon, Jan 27, 2014 at 11:40 PM, Lu, Boying <boying...@emc.com> wrote:
> When I read the codes of OutboundTcpConnection.expireMessages(), I found > the following snippet in a loop: > > if (qm.timestamp >= System.currentTimeMillis() - > qm.message.getTimeout()) > > *return*; > > > > My understanding is that this method is to remove all the expired messages > from the backlog queue, so > > I think the '*return*' statement should be changed to "*continue*". > > > > Is that correct? > This question is probably better suited for the cassandra-dev mailing list or #cassandra-dev IRC channel, or the Apache Cassandra JIRA. =Rob
