This is an automated email from the ASF dual-hosted git repository.
zhouxj pushed a commit to branch feature/GEM-883
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEM-883 by this push:
new 744c74d GEODE-3967: add more trace
744c74d is described below
commit 744c74dbaf2a348d67e06ee34b7d4c2ad9b01da2
Author: zhouxh <[email protected]>
AuthorDate: Thu Nov 16 21:33:26 2017 -0800
GEODE-3967: add more trace
---
.../cache/wan/serial/SerialGatewaySenderEventProcessor.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java
b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java
index e9c4d28..7ecb233 100644
---
a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java
+++
b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderEventProcessor.java
@@ -379,6 +379,7 @@ public class SerialGatewaySenderEventProcessor extends
AbstractGatewaySenderEven
if (m != null) {
for (EventWrapper ew : m.values()) {
GatewaySenderEventImpl gatewayEvent = ew.event;
+ logger.info("GGG:releaseUnprocessedEvents:" + gatewayEvent);
gatewayEvent.release();
}
this.unprocessedEvents = null;
@@ -711,8 +712,13 @@ public class SerialGatewaySenderEventProcessor extends
AbstractGatewaySenderEven
// @todo add an assertion that !getPrimary()
// now we can safely use the unprocessedEvents field
Long v = this.unprocessedTokens.remove(gatewayEvent.getEventId());
+ if (v != null && gatewayEvent.isConcurrencyConflict) {
+ logger.info("GGG:secondary after removed:" + v + ":" + gatewayEvent);
+ }
if (v == null && !gatewayEvent.isConcurrencyConflict) {
+ // only when isConcurrencyConflict is false, add the event into
unprocessedEvents
+ logger.info("GGG:secondary before add to:" + gatewayEvent, new
Exception());
// first time for the event
if (logger.isTraceEnabled()) {
logger.trace("{}: fromSecondary event {}:{}->{} added from
unprocessed events map",
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
