Uploaded image for project: 'Cassandra'
  1. Cassandra
  2. CASSANDRA-15568

Message filtering should apply on the inboundSink in In-JVM dtest

    XMLWordPrintableJSON

    Details

    • Platform:
      All
    • Impacts:
      None

      Description

      The message filtering mechanism in the in-jvm dtest helps to simulate network partition/delay.
      The problem of the current approach that adds all filters to the MessagingService#outboundSink is that a blocking filter blocks the following filters to be evaluated since there is only a single thread that evaluates them. It further blocks the other outing messages. The typical internode messaging pattern is that the coordinator node sends out multiple messages to other nodes upon receiving a query. The described blocking messages can happen quite often.
      The problem can be solved by moving the message filtering to the MessagingService#inboundSink, so that each inbounding message is naturally filtered in parallel.

        Attachments

          Activity

            People

            • Assignee:
              yifanc Yifan Cai
              Reporter:
              yifanc Yifan Cai
              Authors:
              Yifan Cai
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: