in cppcache/src/TcrMessage.cpp [98:125]
bool TcrMessage::isUserInitiativeOps(const TcrMessage& msg) {
int32_t msgType = msg.getMessageType();
if (!msg.isMetaRegion() &&
!(msgType == TcrMessage::PING || msgType == TcrMessage::PERIODIC_ACK ||
msgType == TcrMessage::MAKE_PRIMARY ||
msgType == TcrMessage::CLOSE_CONNECTION ||
msgType == TcrMessage::CLIENT_READY || msgType == TcrMessage::INVALID ||
msgType == TcrMessage::MONITORCQ_MSG_TYPE ||
msgType == TcrMessage::GETCQSTATS_MSG_TYPE ||
msgType == TcrMessage::REQUEST_EVENT_VALUE ||
msgType == TcrMessage::GET_CLIENT_PR_METADATA ||
msgType == TcrMessage::GET_CLIENT_PARTITION_ATTRIBUTES ||
msgType == TcrMessage::GET_PDX_ID_FOR_TYPE ||
msgType == TcrMessage::GET_PDX_TYPE_BY_ID ||
msgType == TcrMessage::ADD_PDX_TYPE || msgType == TcrMessage::SIZE ||
msgType == TcrMessage::TX_FAILOVER ||
msgType == TcrMessage::GET_ENTRY ||
msgType == TcrMessage::TX_SYNCHRONIZATION ||
msgType == TcrMessage::GET_FUNCTION_ATTRIBUTES ||
msgType == TcrMessage::ADD_PDX_ENUM ||
msgType == TcrMessage::GET_PDX_ENUM_BY_ID ||
msgType == TcrMessage::GET_PDX_ID_FOR_ENUM ||
msgType == TcrMessage::COMMIT || msgType == TcrMessage::ROLLBACK)) {
return true;
}
return false;
}