cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stu Hood (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CASSANDRA-3005) OutboundTcpConnection's sending queue goes unboundedly without any backpressure logic
Date Fri, 12 Aug 2011 06:30:27 GMT

    [ https://issues.apache.org/jira/browse/CASSANDRA-3005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13083974#comment-13083974
] 

Stu Hood commented on CASSANDRA-3005:
-------------------------------------

Rather than nesting the Pair objects, you should probably create {code}class Entry { Message
message; String id; long timestamp }{code} which will allow you to avoid boxing the long and
the extra Pair.

> OutboundTcpConnection's sending queue goes unboundedly without any backpressure logic
> -------------------------------------------------------------------------------------
>
>                 Key: CASSANDRA-3005
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-3005
>             Project: Cassandra
>          Issue Type: Improvement
>            Reporter: Melvin Wang
>            Assignee: Melvin Wang
>         Attachments: c3005.patch
>
>
> OutboundTcpConnection's sending queue unconditionally queues up the request and process
them in sequence. Thinking about tagging the message coming in with timestamp and drop them
before actually sending it if the message stays in the queue for too long, which is defined
by the message's own time out value.

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Mime
View raw message