Hello, all, I am trying to add a new command into Cassandra.
According to my knowledge, to add a new command, i only need to add the new MessagingService.verb, specify the stage corresponding to this verb, setup the serializer/deserializer, and specify a receiveVerbHandler to process that command. However, after adding all these to Cassandra, I continuously got the timeout error saying this: ERROR 15:17:01 Unexpected exception during request; channel = [id: 0x22e0a7e4, /127.0.0.1:51069 => /127.0.0.1:9042] java.lang.AssertionError: Time out exception. I traced into the code and saw each step during sending the message. The message looks fine, it has the right verb type and reuse the Read Stage. But i can not got any message from the receive side. I am not quite sure about where Cassandra starts to process in-coming message at the first place, but i did check IncomingTcpConnection.handleModernVersion() method, and nothing returns or prints after the send-side code finishes (OutboundTcpConnection.writeConnected() function). Could anybody give me some advices? I must miss something here since other command execute well. thanks, - Dong
