jinmeiliao commented on a change in pull request #7267:
URL: https://github.com/apache/geode/pull/7267#discussion_r785043634
##########
File path:
geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientProxy.java
##########
@@ -1673,13 +1673,16 @@ MessageDispatcher createMessageDispatcher(String name) {
return messageDispatcherFactory.create(this, name, statisticsClock);
}
- protected void startOrResumeMessageDispatcher(boolean processedMarker) {
+ protected void startOrResumeMessageDispatcher(boolean sendMarkerDirectly) {
// Only start or resume the dispatcher if it is Primary
if (isPrimary) {
// Add the marker to the queue
- if (!processedMarker) {
- EventID eventId = new EventID(_cache.getDistributedSystem());
- _messageDispatcher.enqueueMarker(new ClientMarkerMessageImpl(eventId));
+ EventID eventId = new EventID(_cache.getDistributedSystem());
+ ClientMarkerMessageImpl clientMarkerMessage = new
ClientMarkerMessageImpl(eventId);
+ if (sendMarkerDirectly) {
+ sendMessageDirectly(clientMarkerMessage);
Review comment:
I can't see any bad consequence. It's just a marker message that is
supposed to go to the client anyway.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@geode.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
