You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2016/03/01 01:09:24 UTC
[15/34] incubator-geode git commit: avoid blocking a thread that is
sending an Alert via UDP
avoid blocking a thread that is sending an Alert via UDP
This avoids the View Creator thread becoming blocked if there are problems
in view creation and flow-control limits are reached. We already disable
flow-control for high-priority messages - this disables flow-control for
alert messages as well.
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/e40962cf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/e40962cf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/e40962cf
Branch: refs/heads/feature/GEODE-949-2
Commit: e40962cf67136db83e4fc38b5bba6d53ff2a1345
Parents: 2f69575
Author: Bruce Schuchardt <bs...@pivotal.io>
Authored: Fri Feb 26 09:44:43 2016 -0800
Committer: Bruce Schuchardt <bs...@pivotal.io>
Committed: Fri Feb 26 09:47:46 2016 -0800
----------------------------------------------------------------------
.../internal/membership/gms/messenger/JGroupsMessenger.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e40962cf/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/messenger/JGroupsMessenger.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/messenger/JGroupsMessenger.java b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/messenger/JGroupsMessenger.java
index f3ba7a2..1db0c42 100755
--- a/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/messenger/JGroupsMessenger.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/distributed/internal/membership/gms/messenger/JGroupsMessenger.java
@@ -92,6 +92,7 @@ import com.gemstone.gemfire.internal.admin.remote.RemoteTransportConfig;
import com.gemstone.gemfire.internal.cache.DirectReplyMessage;
import com.gemstone.gemfire.internal.cache.DistributedCacheOperation;
import com.gemstone.gemfire.internal.i18n.LocalizedStrings;
+import com.gemstone.gemfire.internal.logging.log4j.AlertAppender;
import com.gemstone.gemfire.internal.logging.log4j.LocalizedMessage;
import com.gemstone.gemfire.internal.tcp.MemberShunnedException;
@@ -787,9 +788,9 @@ public class JGroupsMessenger implements Messenger {
// which is fairly rare
msg.setFlag(Flag.DONT_BUNDLE);
- //log.info("Creating message with payload " + gfmsg);
if (gfmsg.getProcessorType() == DistributionManager.HIGH_PRIORITY_EXECUTOR
- || gfmsg instanceof HighPriorityDistributionMessage) {
+ || gfmsg instanceof HighPriorityDistributionMessage
+ || AlertAppender.isThreadAlerting()) {
msg.setFlag(Flag.NO_FC);
msg.setFlag(Flag.SKIP_BARRIER);
}