[jira] [Created] (CASSANDRA-15568) Message filtering should apply on the inboundSink in In-JVM dtest

["Yifan Cai (Jira)" <ji...@apache.org>]

Yifan Cai created CASSANDRA-15568:
-------------------------------------

             Summary: Message filtering should apply on the inboundSink in In-JVM dtest
                 Key: CASSANDRA-15568
                 URL: https://issues.apache.org/jira/browse/CASSANDRA-15568
             Project: Cassandra
          Issue Type: Improvement
          Components: Test/dtest
            Reporter: Yifan Cai
            Assignee: Yifan Cai


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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org