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 2017/05/19 22:23:36 UTC
[1/3] geode git commit: Run spotlessApply
Repository: geode
Updated Branches:
refs/heads/feature/GEODE-2632-16 060faa5e3 -> b6527b31c
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterDataSerializers.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterDataSerializers.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterDataSerializers.java
index d1c101f..053b2a8 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterDataSerializers.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterDataSerializers.java
@@ -41,7 +41,8 @@ public class RegisterDataSerializers extends BaseCommand {
throws IOException, ClassNotFoundException {
if (logger.isDebugEnabled()) {
logger.debug("{}: Received register dataserializer request ({} parts) from {}",
- serverConnection.getName(), clientMessage.getNumberOfParts(), serverConnection.getSocketString());
+ serverConnection.getName(), clientMessage.getNumberOfParts(),
+ serverConnection.getSocketString());
}
int noOfParts = clientMessage.getNumberOfParts();
@@ -49,10 +50,12 @@ public class RegisterDataSerializers extends BaseCommand {
int noOfDataSerializers = (noOfParts - 1) / 2;
// retrieve eventID from the last Part
- ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(clientMessage.getPart(noOfParts - 1).getSerializedForm());
+ ByteBuffer eventIdPartsBuffer =
+ ByteBuffer.wrap(clientMessage.getPart(noOfParts - 1).getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
byte[][] serializedDataSerializers = new byte[noOfDataSerializers * 2][];
boolean caughtCNFE = false;
@@ -101,7 +104,8 @@ public class RegisterDataSerializers extends BaseCommand {
}
if (logger.isDebugEnabled()) {
- logger.debug("Registered dataserializer for MembershipId = {}", serverConnection.getMembershipID());
+ logger.debug("Registered dataserializer for MembershipId = {}",
+ serverConnection.getMembershipID());
}
}
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInstantiators.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInstantiators.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInstantiators.java
index 2b63337..df5a46c 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInstantiators.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInstantiators.java
@@ -53,7 +53,8 @@ public class RegisterInstantiators extends BaseCommand {
throws IOException, ClassNotFoundException {
if (logger.isDebugEnabled()) {
logger.debug("{}: Received register instantiator request ({} parts) from {}",
- serverConnection.getName(), clientMessage.getNumberOfParts(), serverConnection.getSocketString());
+ serverConnection.getName(), clientMessage.getNumberOfParts(),
+ serverConnection.getSocketString());
}
int noOfParts = clientMessage.getNumberOfParts();
// Assert parts
@@ -62,10 +63,12 @@ public class RegisterInstantiators extends BaseCommand {
int noOfInstantiators = (noOfParts - 1) / 3;
// retrieve eventID from the last Part
- ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(clientMessage.getPart(noOfParts - 1).getSerializedForm());
+ ByteBuffer eventIdPartsBuffer =
+ ByteBuffer.wrap(clientMessage.getPart(noOfParts - 1).getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
byte[][] serializedInstantiators = new byte[noOfInstantiators * 3][];
boolean caughtCNFE = false;
@@ -102,7 +105,7 @@ public class RegisterInstantiators extends BaseCommand {
}
} catch (Exception e) {
logger.warn(LocalizedMessage.create(LocalizedStrings.RegisterInstantiators_BAD_CLIENT,
- new Object[] { serverConnection.getMembershipID(), e.getLocalizedMessage()}));
+ new Object[] {serverConnection.getMembershipID(), e.getLocalizedMessage()}));
writeException(clientMessage, e, false, serverConnection);
serverConnection.setAsTrue(RESPONDED);
}
@@ -134,7 +137,8 @@ public class RegisterInstantiators extends BaseCommand {
}
if (logger.isDebugEnabled()) {
- logger.debug("Registered instantiators for MembershipId = {}", serverConnection.getMembershipID());
+ logger.debug("Registered instantiators for MembershipId = {}",
+ serverConnection.getMembershipID());
}
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest.java
index afb0f2c..edd917a 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest.java
@@ -112,7 +112,8 @@ public class RegisterInterest extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug("{}: Received register interest request ({} bytes) from {} for region {} key {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName, key);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName, key);
}
// Process the register interest request
@@ -138,7 +139,7 @@ public class RegisterInterest extends BaseCommand {
if (region == null) {
logger.info(LocalizedMessage.create(
LocalizedStrings.RegisterInterest_0_REGION_NAMED_1_WAS_NOT_FOUND_DURING_REGISTER_INTEREST_REQUEST,
- new Object[] { serverConnection.getName(), regionName}));
+ new Object[] {serverConnection.getName(), regionName}));
// writeChunkedErrorResponse(msg,
// MessageType.REGISTER_INTEREST_DATA_ERROR, message);
// responded = true;
@@ -159,8 +160,9 @@ public class RegisterInterest extends BaseCommand {
key = registerContext.getKey();
}
}
- serverConnection.getAcceptor().getCacheClientNotifier().registerClientInterest(regionName, key,
- serverConnection.getProxyID(), interestType, isDurable, sendUpdatesAsInvalidates, false, 0, true);
+ serverConnection.getAcceptor().getCacheClientNotifier().registerClientInterest(regionName,
+ key, serverConnection.getProxyID(), interestType, isDurable, sendUpdatesAsInvalidates,
+ false, 0, true);
} catch (Exception e) {
// If an interrupted exception is thrown , rethrow it
checkForInterrupt(serverConnection, e);
@@ -177,8 +179,8 @@ public class RegisterInterest extends BaseCommand {
// DistributionStats.getStatTime() - start);
// start = DistributionStats.getStatTime();
- CacheClientProxy ccp =
- serverConnection.getAcceptor().getCacheClientNotifier().getClientProxy(serverConnection.getProxyID());
+ CacheClientProxy ccp = serverConnection.getAcceptor().getCacheClientNotifier()
+ .getClientProxy(serverConnection.getProxyID());
if (ccp == null) {
// fix for 37593
IOException ioex = new IOException(
@@ -212,7 +214,8 @@ public class RegisterInterest extends BaseCommand {
// Send chunk response
try {
- fillAndSendRegisterInterestResponseChunks(region, key, interestType, policy, serverConnection);
+ fillAndSendRegisterInterestResponseChunks(region, key, interestType, policy,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
} catch (Exception e) {
writeChunkedException(clientMessage, e, serverConnection, chunkedResponseMsg);
@@ -224,8 +227,8 @@ public class RegisterInterest extends BaseCommand {
// logger.debug(getName() + ": Sent chunk (1 of 1) of register interest
// response (" + chunkedResponseMsg.getBufferLength() + " bytes) for
// region " + regionName + " key " + key);
- logger.debug("{}: Sent register interest response for region {} key {}", serverConnection.getName(),
- regionName, key);
+ logger.debug("{}: Sent register interest response for region {} key {}",
+ serverConnection.getName(), regionName, key);
}
// bserverStats.incLong(writeDestroyResponseTimeId,
// DistributionStats.getStatTime() - start);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest61.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest61.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest61.java
index af423ca..bad3bed 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest61.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterest61.java
@@ -143,7 +143,8 @@ public class RegisterInterest61 extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Received register interest 61 request ({} bytes) from {} for region {} key {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName, key);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName, key);
}
// test hook to trigger vMotion during register Interest
@@ -176,7 +177,7 @@ public class RegisterInterest61 extends BaseCommand {
if (region == null) {
logger.info(LocalizedMessage.create(
LocalizedStrings.RegisterInterest_0_REGION_NAMED_1_WAS_NOT_FOUND_DURING_REGISTER_INTEREST_REQUEST,
- new Object[] { serverConnection.getName(), regionName}));
+ new Object[] {serverConnection.getName(), regionName}));
// writeChunkedErrorResponse(msg,
// MessageType.REGISTER_INTEREST_DATA_ERROR, message);
// responded = true;
@@ -198,9 +199,9 @@ public class RegisterInterest61 extends BaseCommand {
key = registerContext.getKey();
}
}
- serverConnection.getAcceptor().getCacheClientNotifier().registerClientInterest(regionName, key,
- serverConnection.getProxyID(), interestType, isDurable, sendUpdatesAsInvalidates, true,
- regionDataPolicyPartBytes[0], true);
+ serverConnection.getAcceptor().getCacheClientNotifier().registerClientInterest(regionName,
+ key, serverConnection.getProxyID(), interestType, isDurable, sendUpdatesAsInvalidates,
+ true, regionDataPolicyPartBytes[0], true);
} catch (Exception e) {
// If an interrupted exception is thrown , rethrow it
checkForInterrupt(serverConnection, e);
@@ -217,8 +218,8 @@ public class RegisterInterest61 extends BaseCommand {
// DistributionStats.getStatTime() - start);
// start = DistributionStats.getStatTime();
- CacheClientProxy ccp =
- serverConnection.getAcceptor().getCacheClientNotifier().getClientProxy(serverConnection.getProxyID());
+ CacheClientProxy ccp = serverConnection.getAcceptor().getCacheClientNotifier()
+ .getClientProxy(serverConnection.getProxyID());
if (ccp == null) {
// fix for 37593
IOException ioex = new IOException(
@@ -265,8 +266,8 @@ public class RegisterInterest61 extends BaseCommand {
// logger.debug(getName() + ": Sent chunk (1 of 1) of register interest
// response (" + chunkedResponseMsg.getBufferLength() + " bytes) for
// region " + regionName + " key " + key);
- logger.debug("{}: Sent register interest response for region {} key {}", serverConnection.getName(),
- regionName, key);
+ logger.debug("{}: Sent register interest response for region {} key {}",
+ serverConnection.getName(), regionName, key);
}
// bserverStats.incLong(writeDestroyResponseTimeId,
// DistributionStats.getStatTime() - start);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList.java
index 4206e19..5f5fafa 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList.java
@@ -124,8 +124,8 @@ public class RegisterInterestList extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Received register interest request ({} bytes) from {} for the following {} keys in region {}: {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), numberOfKeys,
- regionName, keys);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), numberOfKeys, regionName, keys);
}
/*
@@ -155,7 +155,8 @@ public class RegisterInterestList extends BaseCommand {
}
String s = errMessage.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), s);
- writeChunkedErrorResponse(clientMessage, MessageType.REGISTER_INTEREST_DATA_ERROR, s, serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.REGISTER_INTEREST_DATA_ERROR, s,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -165,7 +166,7 @@ public class RegisterInterestList extends BaseCommand {
if (region == null) {
logger.info(LocalizedMessage.create(
LocalizedStrings.RegisterInterestList_0_REGION_NAMED_1_WAS_NOT_FOUND_DURING_REGISTER_INTEREST_LIST_REQUEST,
- new Object[] { serverConnection.getName(), regionName}));
+ new Object[] {serverConnection.getName(), regionName}));
// writeChunkedErrorResponse(msg,
// MessageType.REGISTER_INTEREST_DATA_ERROR, message);
// responded = true;
@@ -181,8 +182,8 @@ public class RegisterInterestList extends BaseCommand {
}
}
// Register interest
- serverConnection.getAcceptor().getCacheClientNotifier().registerClientInterest(regionName, keys,
- serverConnection.getProxyID(), isDurable, sendUpdatesAsInvalidates, false, 0, true);
+ serverConnection.getAcceptor().getCacheClientNotifier().registerClientInterest(regionName,
+ keys, serverConnection.getProxyID(), isDurable, sendUpdatesAsInvalidates, false, 0, true);
} catch (Exception ex) {
// If an interrupted exception is thrown , rethrow it
checkForInterrupt(serverConnection, ex);
@@ -198,7 +199,7 @@ public class RegisterInterestList extends BaseCommand {
// start = DistributionStats.getStatTime();
boolean isPrimary = serverConnection.getAcceptor().getCacheClientNotifier()
- .getClientProxy(serverConnection.getProxyID()).isPrimary();
+ .getClientProxy(serverConnection.getProxyID()).isPrimary();
if (!isPrimary) {
chunkedResponseMsg.setMessageType(MessageType.RESPONSE_FROM_SECONDARY);
chunkedResponseMsg.setTransactionId(clientMessage.getTransactionId());
@@ -218,7 +219,8 @@ public class RegisterInterestList extends BaseCommand {
// Send chunk response
try {
- fillAndSendRegisterInterestResponseChunks(region, keys, InterestType.KEY, policy, serverConnection);
+ fillAndSendRegisterInterestResponseChunks(region, keys, InterestType.KEY, policy,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
} catch (Exception e) {
// If an interrupted exception is thrown , rethrow it
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList61.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList61.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList61.java
index 8eb6c4a..40a3c25 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList61.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList61.java
@@ -134,8 +134,8 @@ public class RegisterInterestList61 extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Received register interest 61 request ({} bytes) from {} for the following {} keys in region {}: {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), numberOfKeys,
- regionName, keys);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), numberOfKeys, regionName, keys);
}
/*
@@ -165,7 +165,8 @@ public class RegisterInterestList61 extends BaseCommand {
}
String s = errMessage.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), s);
- writeChunkedErrorResponse(clientMessage, MessageType.REGISTER_INTEREST_DATA_ERROR, s, serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.REGISTER_INTEREST_DATA_ERROR, s,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -175,7 +176,7 @@ public class RegisterInterestList61 extends BaseCommand {
if (region == null) {
logger.info(LocalizedMessage.create(
LocalizedStrings.RegisterInterestList_0_REGION_NAMED_1_WAS_NOT_FOUND_DURING_REGISTER_INTEREST_LIST_REQUEST,
- new Object[] { serverConnection.getName(), regionName}));
+ new Object[] {serverConnection.getName(), regionName}));
// writeChunkedErrorResponse(msg,
// MessageType.REGISTER_INTEREST_DATA_ERROR, message);
// responded = true;
@@ -191,8 +192,8 @@ public class RegisterInterestList61 extends BaseCommand {
}
}
// Register interest
- serverConnection.getAcceptor().getCacheClientNotifier().registerClientInterest(regionName, keys,
- serverConnection.getProxyID(), isDurable, sendUpdatesAsInvalidates, true,
+ serverConnection.getAcceptor().getCacheClientNotifier().registerClientInterest(regionName,
+ keys, serverConnection.getProxyID(), isDurable, sendUpdatesAsInvalidates, true,
regionDataPolicyPartBytes[0], true);
} catch (Exception ex) {
// If an interrupted exception is thrown , rethrow it
@@ -209,7 +210,7 @@ public class RegisterInterestList61 extends BaseCommand {
// start = DistributionStats.getStatTime();
boolean isPrimary = serverConnection.getAcceptor().getCacheClientNotifier()
- .getClientProxy(serverConnection.getProxyID()).isPrimary();
+ .getClientProxy(serverConnection.getProxyID()).isPrimary();
if (!isPrimary) {
chunkedResponseMsg.setMessageType(MessageType.RESPONSE_FROM_SECONDARY);
chunkedResponseMsg.setTransactionId(clientMessage.getTransactionId());
@@ -229,7 +230,8 @@ public class RegisterInterestList61 extends BaseCommand {
// Send chunk response
try {
- fillAndSendRegisterInterestResponseChunks(region, keys, InterestType.KEY, policy, serverConnection);
+ fillAndSendRegisterInterestResponseChunks(region, keys, InterestType.KEY, policy,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
} catch (Exception e) {
// If an interrupted exception is thrown , rethrow it
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList66.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList66.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList66.java
index 14198cc..6a2ad95 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList66.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RegisterInterestList66.java
@@ -135,8 +135,8 @@ public class RegisterInterestList66 extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Received register interest 66 request ({} bytes) from {} for the following {} keys in region {}: {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), numberOfKeys,
- regionName, keys);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), numberOfKeys, regionName, keys);
}
/*
@@ -166,7 +166,8 @@ public class RegisterInterestList66 extends BaseCommand {
}
String s = errMessage.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), s);
- writeChunkedErrorResponse(clientMessage, MessageType.REGISTER_INTEREST_DATA_ERROR, s, serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.REGISTER_INTEREST_DATA_ERROR, s,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
}
@@ -175,7 +176,7 @@ public class RegisterInterestList66 extends BaseCommand {
if (region == null) {
logger.info(LocalizedMessage.create(
LocalizedStrings.RegisterInterestList_0_REGION_NAMED_1_WAS_NOT_FOUND_DURING_REGISTER_INTEREST_LIST_REQUEST,
- new Object[] { serverConnection.getName(), regionName}));
+ new Object[] {serverConnection.getName(), regionName}));
// writeChunkedErrorResponse(msg,
// MessageType.REGISTER_INTEREST_DATA_ERROR, message);
// responded = true;
@@ -191,8 +192,8 @@ public class RegisterInterestList66 extends BaseCommand {
}
}
// Register interest
- serverConnection.getAcceptor().getCacheClientNotifier().registerClientInterest(regionName, keys,
- serverConnection.getProxyID(), isDurable, sendUpdatesAsInvalidates, true,
+ serverConnection.getAcceptor().getCacheClientNotifier().registerClientInterest(regionName,
+ keys, serverConnection.getProxyID(), isDurable, sendUpdatesAsInvalidates, true,
regionDataPolicyPartBytes[0], true);
} catch (Exception ex) {
// If an interrupted exception is thrown , rethrow it
@@ -209,7 +210,7 @@ public class RegisterInterestList66 extends BaseCommand {
// start = DistributionStats.getStatTime();
boolean isPrimary = serverConnection.getAcceptor().getCacheClientNotifier()
- .getClientProxy(serverConnection.getProxyID()).isPrimary();
+ .getClientProxy(serverConnection.getProxyID()).isPrimary();
if (!isPrimary) {
chunkedResponseMsg.setMessageType(MessageType.RESPONSE_FROM_SECONDARY);
chunkedResponseMsg.setTransactionId(clientMessage.getTransactionId());
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RemoveAll.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RemoveAll.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RemoveAll.java
index 52a1df3..a295c54 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RemoveAll.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RemoveAll.java
@@ -95,9 +95,10 @@ public class RemoveAll extends BaseCommand {
LocalizedStrings.RemoveAll_THE_INPUT_REGION_NAME_FOR_THE_REMOVEALL_REQUEST_IS_NULL
.toLocalizedString();
logger.warn(LocalizedMessage.create(LocalizedStrings.TWO_ARG_COLON,
- new Object[] { serverConnection.getName(), txt}));
+ new Object[] {serverConnection.getName(), txt}));
errMessage.append(txt);
- writeChunkedErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -114,7 +115,8 @@ public class RemoveAll extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
Breadcrumbs.setEventId(eventId);
@@ -133,9 +135,9 @@ public class RemoveAll extends BaseCommand {
if (logger.isDebugEnabled()) {
StringBuilder buffer = new StringBuilder();
buffer.append(serverConnection.getName()).append(": Received removeAll request from ")
- .append(serverConnection.getSocketString()).append(" for region ").append(regionName)
- .append(callbackArg != null ? (" callbackArg " + callbackArg) : "").append(" with ")
- .append(numberOfKeys).append(" keys.");
+ .append(serverConnection.getSocketString()).append(" for region ").append(regionName)
+ .append(callbackArg != null ? (" callbackArg " + callbackArg) : "").append(" with ")
+ .append(numberOfKeys).append(" keys.");
logger.debug(buffer);
}
ArrayList<Object> keys = new ArrayList<Object>(numberOfKeys);
@@ -148,9 +150,10 @@ public class RemoveAll extends BaseCommand {
LocalizedStrings.RemoveAll_ONE_OF_THE_INPUT_KEYS_FOR_THE_REMOVEALL_REQUEST_IS_NULL
.toLocalizedString();
logger.warn(LocalizedMessage.create(LocalizedStrings.TWO_ARG_COLON,
- new Object[] { serverConnection.getName(), txt}));
+ new Object[] {serverConnection.getName(), txt}));
errMessage.append(txt);
- writeChunkedErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR,
+ errMessage.toString(), serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -180,8 +183,9 @@ public class RemoveAll extends BaseCommand {
keys.add(key);
} // for
- if (clientMessage.getNumberOfParts() == (5 + numberOfKeys + 1)) {// it means optional timeout has been
- // added
+ if (clientMessage.getNumberOfParts() == (5 + numberOfKeys + 1)) {// it means optional timeout
+ // has been
+ // added
int timeout = clientMessage.getPart(5 + numberOfKeys).getInt();
serverConnection.setRequestSpecificTimeout(timeout);
}
@@ -199,8 +203,8 @@ public class RemoveAll extends BaseCommand {
}
}
- response = region.basicBridgeRemoveAll(keys, retryVersions, serverConnection.getProxyID(), eventId,
- callbackArg);
+ response = region.basicBridgeRemoveAll(keys, retryVersions, serverConnection.getProxyID(),
+ eventId, callbackArg);
if (!region.getConcurrencyChecksEnabled() || clientIsEmpty || !clientHasCCEnabled) {
// the client only needs this if versioning is being used and the client
// has storage
@@ -215,7 +219,8 @@ public class RemoveAll extends BaseCommand {
if (region instanceof PartitionedRegion) {
PartitionedRegion pr = (PartitionedRegion) region;
if (pr.getNetworkHopType() != PartitionedRegion.NETWORK_HOP_NONE) {
- writeReplyWithRefreshMetadata(clientMessage, response, serverConnection, pr, pr.getNetworkHopType());
+ writeReplyWithRefreshMetadata(clientMessage, response, serverConnection, pr,
+ pr.getNetworkHopType());
pr.clearNetworkHopData();
replyWithMetaData = true;
}
@@ -250,8 +255,9 @@ public class RemoveAll extends BaseCommand {
stats.incProcessRemoveAllTime(start - oldStart);
}
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending removeAll response back to {} for region {}{}", serverConnection.getName(),
- serverConnection.getSocketString(), regionName, (logger.isTraceEnabled() ? ": " + response : ""));
+ logger.debug("{}: Sending removeAll response back to {} for region {}{}",
+ serverConnection.getName(), serverConnection.getSocketString(), regionName,
+ (logger.isTraceEnabled() ? ": " + response : ""));
}
// Increment statistics and write the reply
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RemoveUserAuth.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RemoveUserAuth.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RemoveUserAuth.java
index 16333ac..cc42e0d 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RemoveUserAuth.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RemoveUserAuth.java
@@ -53,7 +53,7 @@ public class RemoveUserAuth extends BaseCommand {
} catch (GemFireSecurityException gfse) {
if (serverConnection.getSecurityLogWriter().warningEnabled()) {
serverConnection.getSecurityLogWriter().warning(LocalizedStrings.ONE_ARG,
- serverConnection.getName() + ": Security exception: " + gfse.getMessage());
+ serverConnection.getName() + ": Security exception: " + gfse.getMessage());
}
writeException(clientMessage, gfse, false, serverConnection);
} catch (Exception ex) {
@@ -61,7 +61,7 @@ public class RemoveUserAuth extends BaseCommand {
if (serverConnection.getLogWriter().warningEnabled()) {
serverConnection.getLogWriter().warning(
LocalizedStrings.CacheClientNotifier_AN_EXCEPTION_WAS_THROWN_FOR_CLIENT_0_1,
- new Object[] { serverConnection.getProxyID(), ""}, ex);
+ new Object[] {serverConnection.getProxyID(), ""}, ex);
}
writeException(clientMessage, ex, false, serverConnection);
} finally {
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Request.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Request.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Request.java
index 964b7a4..6f97d31 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Request.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Request.java
@@ -52,7 +52,8 @@ public class Request extends BaseCommand {
Request() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
Part regionNamePart = null, keyPart = null, valuePart = null;
String regionName = null;
Object callbackArg = null, key = null;
@@ -94,8 +95,8 @@ public class Request extends BaseCommand {
}
if (logger.isDebugEnabled()) {
logger.debug("{}: Received get request ({} bytes) from {} for region {} key {} txId {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName, key,
- clientMessage.getTransactionId());
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName, key, clientMessage.getTransactionId());
}
// Process the get request
@@ -179,8 +180,8 @@ public class Request extends BaseCommand {
if (region instanceof PartitionedRegion) {
PartitionedRegion pr = (PartitionedRegion) region;
if (pr.getNetworkHopType() != PartitionedRegion.NETWORK_HOP_NONE) {
- writeResponseWithRefreshMetadata(data, callbackArg, clientMessage, isObject, serverConnection, pr,
- pr.getNetworkHopType());
+ writeResponseWithRefreshMetadata(data, callbackArg, clientMessage, isObject,
+ serverConnection, pr, pr.getNetworkHopType());
pr.clearNetworkHopData();
} else {
writeResponse(data, callbackArg, clientMessage, isObject, serverConnection);
@@ -192,7 +193,8 @@ public class Request extends BaseCommand {
serverConnection.setAsTrue(RESPONDED);
if (logger.isDebugEnabled()) {
logger.debug("{}: Wrote get response back to {} for region {} key {} value: {}",
- serverConnection.getName(), serverConnection.getSocketString(), regionName, key, data);
+ serverConnection.getName(), serverConnection.getSocketString(), regionName, key,
+ data);
}
stats.incWriteGetResponseTime(DistributionStats.getStatTime() - start);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RequestEventValue.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RequestEventValue.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RequestEventValue.java
index 3753ed6..a6d6578 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RequestEventValue.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/RequestEventValue.java
@@ -49,7 +49,8 @@ public class RequestEventValue extends BaseCommand {
private RequestEventValue() {}
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
Part eventIDPart = null, valuePart = null;
EventID event = null;
Object callbackArg = null;
@@ -67,7 +68,8 @@ public class RequestEventValue extends BaseCommand {
LocalizedStrings.RequestEventValue_0_THE_EVENT_ID_FOR_THE_GET_EVENT_VALUE_REQUEST_IS_NULL,
serverConnection.getName()));
errMessage.append(" The event id for the get event value request is null.");
- writeErrorResponse(clientMessage, MessageType.REQUESTDATAERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.REQUESTDATAERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
} else {
try {
@@ -90,8 +92,9 @@ public class RequestEventValue extends BaseCommand {
}
}
if (logger.isTraceEnabled()) {
- logger.trace("{}: Received get event value request ({} bytes) from {}", serverConnection.getName(),
- clientMessage.getPayloadLength(), serverConnection.getSocketString());
+ logger.trace("{}: Received get event value request ({} bytes) from {}",
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString());
}
CacheClientNotifier ccn = serverConnection.getAcceptor().getCacheClientNotifier();
// Get the ha container.
@@ -110,7 +113,8 @@ public class RequestEventValue extends BaseCommand {
LocalizedStrings.RequestEventValue_UNABLE_TO_FIND_A_CLIENT_UPDATE_MESSAGE_FOR_0,
event));
String msgStr = "No value found for " + event + " in " + haContainer.getName();
- writeErrorResponse(clientMessage, MessageType.REQUEST_EVENT_VALUE_ERROR, msgStr, serverConnection);
+ writeErrorResponse(clientMessage, MessageType.REQUEST_EVENT_VALUE_ERROR, msgStr,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
} else {
@@ -140,10 +144,12 @@ public class RequestEventValue extends BaseCommand {
writeResponse(data, callbackArg, clientMessage, isObject, serverConnection);
serverConnection.setAsTrue(RESPONDED);
- ccn.getClientProxy(serverConnection.getProxyID()).getStatistics().incDeltaFullMessagesSent();
+ ccn.getClientProxy(serverConnection.getProxyID()).getStatistics()
+ .incDeltaFullMessagesSent();
if (logger.isDebugEnabled()) {
logger.debug("{}: Wrote get event value response back to {} for ha container {}",
- serverConnection.getName(), serverConnection.getSocketString(), haContainer.getName());
+ serverConnection.getName(), serverConnection.getSocketString(),
+ haContainer.getName());
}
}
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Size.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Size.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Size.java
index 42e14a3..c4515ab 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Size.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Size.java
@@ -76,7 +76,8 @@ public class Size extends BaseCommand {
errMessage
.append(LocalizedStrings.BaseCommand__THE_INPUT_REGION_NAME_FOR_THE_0_REQUEST_IS_NULL
.toLocalizedString("size"));
- writeErrorResponse(clientMessage, MessageType.SIZE_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.SIZE_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -114,7 +115,8 @@ public class Size extends BaseCommand {
}
} finally {
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sent size response for region {}", serverConnection.getName(), regionName);
+ logger.debug("{}: Sent size response for region {}", serverConnection.getName(),
+ regionName);
}
serverConnection.setAsTrue(RESPONDED);
stats.incWriteSizeResponseTime(DistributionStats.getStatTime() - start);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/TXSynchronizationCommand.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/TXSynchronizationCommand.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/TXSynchronizationCommand.java
index c5b9fc5..03270d6 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/TXSynchronizationCommand.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/TXSynchronizationCommand.java
@@ -53,7 +53,8 @@ public class TXSynchronizationCommand extends BaseCommand {
* org.apache.geode.internal.cache.tier.sockets.ServerConnection)
*/
@Override
- protected boolean shouldMasqueradeForTx(Message clientMessage, ServerConnection serverConnection) {
+ protected boolean shouldMasqueradeForTx(Message clientMessage,
+ ServerConnection serverConnection) {
// masquerading is done in the waiting thread pool
return false;
}
@@ -67,13 +68,14 @@ public class TXSynchronizationCommand extends BaseCommand {
* long)
*/
@Override
- public void cmdExecute(final Message clientMessage, final ServerConnection serverConnection, long start)
- throws IOException, ClassNotFoundException, InterruptedException {
+ public void cmdExecute(final Message clientMessage, final ServerConnection serverConnection,
+ long start) throws IOException, ClassNotFoundException, InterruptedException {
serverConnection.setAsTrue(REQUIRES_RESPONSE);
CompletionType type = CompletionType.values()[clientMessage.getPart(0).getInt()];
- /* int txIdInt = */ clientMessage.getPart(1).getInt(); // [bruce] not sure if we need to transmit this
+ /* int txIdInt = */ clientMessage.getPart(1).getInt(); // [bruce] not sure if we need to
+ // transmit this
final Part statusPart;
if (type == CompletionType.AFTER_COMPLETION) {
statusPart = clientMessage.getPart(2);
@@ -81,7 +83,8 @@ public class TXSynchronizationCommand extends BaseCommand {
statusPart = null;
}
- final TXManagerImpl txMgr = (TXManagerImpl) serverConnection.getCache().getCacheTransactionManager();
+ final TXManagerImpl txMgr =
+ (TXManagerImpl) serverConnection.getCache().getCacheTransactionManager();
final InternalDistributedMember member =
(InternalDistributedMember) serverConnection.getProxyID().getDistributedMember();
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UnregisterInterest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UnregisterInterest.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UnregisterInterest.java
index 597f92b..199ac18 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UnregisterInterest.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UnregisterInterest.java
@@ -81,7 +81,8 @@ public class UnregisterInterest extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Received unregister interest request ({} bytes) from {} for region {} key {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName, key);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName, key);
}
// Process the unregister interest request
@@ -96,7 +97,8 @@ public class UnregisterInterest extends BaseCommand {
LocalizedStrings.UnRegisterInterest_THE_INPUT_REGION_NAME_FOR_THE_UNREGISTER_INTEREST_REQUEST_IS_NULL;
String s = errMessage.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), s);
- writeErrorResponse(clientMessage, MessageType.UNREGISTER_INTEREST_DATA_ERROR, s, serverConnection);
+ writeErrorResponse(clientMessage, MessageType.UNREGISTER_INTEREST_DATA_ERROR, s,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -141,8 +143,8 @@ public class UnregisterInterest extends BaseCommand {
*/
// Unregister interest irrelevent of whether the region is present it or
// not
- serverConnection.getAcceptor().getCacheClientNotifier().unregisterClientInterest(regionName, key,
- interestType, isClosing, serverConnection.getProxyID(), keepalive);
+ serverConnection.getAcceptor().getCacheClientNotifier().unregisterClientInterest(regionName,
+ key, interestType, isClosing, serverConnection.getProxyID(), keepalive);
// Update the statistics and write the reply
// bserverStats.incLong(processDestroyTimeId,
@@ -151,8 +153,8 @@ public class UnregisterInterest extends BaseCommand {
writeReply(clientMessage, serverConnection);
serverConnection.setAsTrue(RESPONDED);
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sent unregister interest response for region {} key {}", serverConnection.getName(),
- regionName, key);
+ logger.debug("{}: Sent unregister interest response for region {} key {}",
+ serverConnection.getName(), regionName, key);
}
// bserverStats.incLong(writeDestroyResponseTimeId,
// DistributionStats.getStatTime() - start);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UnregisterInterestList.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UnregisterInterestList.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UnregisterInterestList.java
index 76cbba2..1968bff 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UnregisterInterestList.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UnregisterInterestList.java
@@ -95,8 +95,8 @@ public class UnregisterInterestList extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Received unregister interest request ({} bytes) from {} for the following {} keys in region {}: {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), numberOfKeys,
- regionName, keys);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), numberOfKeys, regionName, keys);
}
// Process the unregister interest request
@@ -114,7 +114,8 @@ public class UnregisterInterestList extends BaseCommand {
}
String s = errMessage.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), s);
- writeErrorResponse(clientMessage, MessageType.UNREGISTER_INTEREST_DATA_ERROR, s, serverConnection);
+ writeErrorResponse(clientMessage, MessageType.UNREGISTER_INTEREST_DATA_ERROR, s,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -155,8 +156,8 @@ public class UnregisterInterestList extends BaseCommand {
* responded = true; } else {
*/
// Register interest
- serverConnection.getAcceptor().getCacheClientNotifier().unregisterClientInterest(regionName, keys,
- isClosingList, serverConnection.getProxyID(), keepalive);
+ serverConnection.getAcceptor().getCacheClientNotifier().unregisterClientInterest(regionName,
+ keys, isClosingList, serverConnection.getProxyID(), keepalive);
// Update the statistics and write the reply
// bserverStats.incLong(processDestroyTimeId,
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UpdateClientNotification.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UpdateClientNotification.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UpdateClientNotification.java
index b870a96..2f434fb 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UpdateClientNotification.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/UpdateClientNotification.java
@@ -35,7 +35,8 @@ public class UpdateClientNotification extends BaseCommand {
private UpdateClientNotification() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
CacheServerStats stats = serverConnection.getCacheServerStats();
{
long oldStart = start;
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CloseCQ.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CloseCQ.java b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CloseCQ.java
index 72719b2..18929eb 100644
--- a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CloseCQ.java
+++ b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CloseCQ.java
@@ -44,7 +44,8 @@ public class CloseCQ extends BaseCQCommand {
private CloseCQ() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
CachedRegionHelper crHelper = serverConnection.getCachedRegionHelper();
ClientProxyMembershipID id = serverConnection.getProxyID();
CacheServerStats stats = serverConnection.getCacheServerStats();
@@ -67,7 +68,8 @@ public class CloseCQ extends BaseCQCommand {
if (cqName == null) {
String err =
LocalizedStrings.CloseCQ_THE_CQNAME_FOR_THE_CQ_CLOSE_REQUEST_IS_NULL.toLocalizedString();
- sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(), null, serverConnection);
+ sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(), null,
+ serverConnection);
return;
}
@@ -104,19 +106,21 @@ public class CloseCQ extends BaseCQCommand {
if (cqQuery != null)
serverConnection.removeCq(cqName, cqQuery.isDurable());
} catch (CqException cqe) {
- sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe, serverConnection);
+ sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe,
+ serverConnection);
return;
} catch (Exception e) {
String err =
LocalizedStrings.CloseCQ_EXCEPTION_WHILE_CLOSING_CQ_CQNAME_0.toLocalizedString(cqName);
- sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, err, clientMessage.getTransactionId(), e, serverConnection);
+ sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, err, clientMessage.getTransactionId(), e,
+ serverConnection);
return;
}
// Send OK to client
sendCqResponse(MessageType.REPLY,
- LocalizedStrings.CloseCQ_CQ_CLOSED_SUCCESSFULLY.toLocalizedString(), clientMessage.getTransactionId(),
- null, serverConnection);
+ LocalizedStrings.CloseCQ_CQ_CLOSED_SUCCESSFULLY.toLocalizedString(),
+ clientMessage.getTransactionId(), null, serverConnection);
serverConnection.setAsTrue(RESPONDED);
{
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteCQ.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteCQ.java b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteCQ.java
index d2a4453..86d53f5 100644
--- a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteCQ.java
+++ b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteCQ.java
@@ -71,9 +71,9 @@ public class ExecuteCQ extends BaseCQCommand {
byte[] isDurableByte = isDurablePart.getSerializedForm();
boolean isDurable = (isDurableByte == null || isDurableByte[0] == 0) ? false : true;
if (logger.isDebugEnabled()) {
- logger.debug("{}: Received {} request from {} CqName: {} queryString: {}", serverConnection.getName(),
- MessageType.getString(clientMessage.getMessageType()), serverConnection.getSocketString(), cqName,
- cqQueryString);
+ logger.debug("{}: Received {} request from {} CqName: {} queryString: {}",
+ serverConnection.getName(), MessageType.getString(clientMessage.getMessageType()),
+ serverConnection.getSocketString(), cqName, cqQueryString);
}
DefaultQueryService qService = null;
@@ -108,7 +108,8 @@ public class ExecuteCQ extends BaseCQCommand {
cqQuery = cqServiceForExec.executeCq(cqName, cqQueryString, cqState, id,
acceptor.getCacheClientNotifier(), isDurable, false, 0, null);
} catch (CqException cqe) {
- sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe, serverConnection);
+ sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe,
+ serverConnection);
return;
} catch (Exception e) {
writeChunkedException(clientMessage, e, serverConnection);
@@ -130,8 +131,8 @@ public class ExecuteCQ extends BaseCQCommand {
cqRegionNames = ((DefaultQuery) query).getRegionsInQuery(null);
}
((DefaultQuery) query).setIsCqQuery(true);
- successQuery = processQuery(clientMessage, query, cqQueryString, cqRegionNames, start, cqQuery,
- executeCQContext, serverConnection, sendResults);
+ successQuery = processQuery(clientMessage, query, cqQueryString, cqRegionNames, start,
+ cqQuery, executeCQContext, serverConnection, sendResults);
// Update the CQ statistics.
cqQuery.getVsdStats().setCqInitialResultsTime((DistributionStats.getStatTime()) - oldstart);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteCQ61.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteCQ61.java b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteCQ61.java
index 805ee48..fcc45de 100755
--- a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteCQ61.java
+++ b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteCQ61.java
@@ -82,9 +82,9 @@ public class ExecuteCQ61 extends BaseCQCommand {
Part regionDataPolicyPart = clientMessage.getPart(clientMessage.getNumberOfParts() - 1);
byte[] regionDataPolicyPartBytes = regionDataPolicyPart.getSerializedForm();
if (logger.isDebugEnabled()) {
- logger.debug("{}: Received {} request from {} CqName: {} queryString: {}", serverConnection.getName(),
- MessageType.getString(clientMessage.getMessageType()), serverConnection.getSocketString(), cqName,
- cqQueryString);
+ logger.debug("{}: Received {} request from {} CqName: {} queryString: {}",
+ serverConnection.getName(), MessageType.getString(clientMessage.getMessageType()),
+ serverConnection.getSocketString(), cqName, cqQueryString);
}
// Check if the Server is running in NotifyBySubscription=true mode.
@@ -96,7 +96,8 @@ public class ExecuteCQ61 extends BaseCQCommand {
String err =
LocalizedStrings.ExecuteCQ_SERVER_NOTIFYBYSUBSCRIPTION_MODE_IS_SET_TO_FALSE_CQ_EXECUTION_IS_NOT_SUPPORTED_IN_THIS_MODE
.toLocalizedString();
- sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(), null, serverConnection);
+ sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(),
+ null, serverConnection);
return;
}
}
@@ -144,7 +145,8 @@ public class ExecuteCQ61 extends BaseCQCommand {
cqQuery = (ServerCQImpl) cqServiceForExec.executeCq(cqName, cqQueryString, cqState, id, ccn,
isDurable, true, regionDataPolicyPartBytes[0], null);
} catch (CqException cqe) {
- sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe, serverConnection);
+ sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe,
+ serverConnection);
serverConnection.removeCq(cqName, isDurable);
return;
} catch (Exception e) {
@@ -172,8 +174,8 @@ public class ExecuteCQ61 extends BaseCQCommand {
cqRegionNames = ((DefaultQuery) query).getRegionsInQuery(null);
}
((DefaultQuery) query).setIsCqQuery(true);
- successQuery = processQuery(clientMessage, query, cqQueryString, cqRegionNames, start, cqQuery,
- executeCQContext, serverConnection, sendResults);
+ successQuery = processQuery(clientMessage, query, cqQueryString, cqRegionNames, start,
+ cqQuery, executeCQContext, serverConnection, sendResults);
// Update the CQ statistics.
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetCQStats.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetCQStats.java b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetCQStats.java
index b1faeee..0fab303 100644
--- a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetCQStats.java
+++ b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetCQStats.java
@@ -36,7 +36,8 @@ public class GetCQStats extends BaseCQCommand {
private GetCQStats() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
CachedRegionHelper crHelper = serverConnection.getCachedRegionHelper();
CacheServerStats stats = serverConnection.getCacheServerStats();
@@ -61,7 +62,8 @@ public class GetCQStats extends BaseCQCommand {
// Process the query request
if (cqName == null) {
String err = "The cqName for the cq stats request is null";
- sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(), null, serverConnection);
+ sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(), null,
+ serverConnection);
return;
}
@@ -74,11 +76,13 @@ public class GetCQStats extends BaseCQCommand {
cqService.start();
} catch (Exception e) {
String err = "Exception while Getting the CQ Statistics. ";
- sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, err, clientMessage.getTransactionId(), e, serverConnection);
+ sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, err, clientMessage.getTransactionId(), e,
+ serverConnection);
return;
}
// Send OK to client
- sendCqResponse(MessageType.REPLY, "cq stats sent successfully.", clientMessage.getTransactionId(), null, serverConnection);
+ sendCqResponse(MessageType.REPLY, "cq stats sent successfully.",
+ clientMessage.getTransactionId(), null, serverConnection);
serverConnection.setAsTrue(RESPONDED);
{
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetDurableCQs.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetDurableCQs.java b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetDurableCQs.java
index e39c8e1..c14bd72 100755
--- a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetDurableCQs.java
+++ b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetDurableCQs.java
@@ -56,7 +56,8 @@ public class GetDurableCQs extends BaseCQCommand {
if (logger.isDebugEnabled()) {
logger.debug("{}: Received {} request from {}", serverConnection.getName(),
- MessageType.getString(clientMessage.getMessageType()), serverConnection.getSocketString());
+ MessageType.getString(clientMessage.getMessageType()),
+ serverConnection.getSocketString());
}
DefaultQueryService qService = null;
@@ -87,8 +88,8 @@ public class GetDurableCQs extends BaseCQCommand {
Object durableCqName = it.next();
durableCqList.add(durableCqName);
if (isTraceEnabled) {
- logger.trace("{}: getDurableCqsResponse <{}>; list size was {}", serverConnection.getName(),
- durableCqName, durableCqList.size());
+ logger.trace("{}: getDurableCqsResponse <{}>; list size was {}",
+ serverConnection.getName(), durableCqName, durableCqList.size());
}
if (durableCqList.size() == MAXIMUM_CHUNK_SIZE) {
// Send the chunk and clear the list
@@ -100,7 +101,8 @@ public class GetDurableCQs extends BaseCQCommand {
sendDurableCqsResponseChunk(durableCqList, true, serverConnection);
} catch (CqException cqe) {
- sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe, serverConnection);
+ sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe,
+ serverConnection);
return;
} catch (Exception e) {
writeChunkedException(clientMessage, e, serverConnection);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/MonitorCQ.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/MonitorCQ.java b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/MonitorCQ.java
index 5393e81..5f0118b 100644
--- a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/MonitorCQ.java
+++ b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/MonitorCQ.java
@@ -36,7 +36,8 @@ public class MonitorCQ extends BaseCQCommand {
private MonitorCQ() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
CachedRegionHelper crHelper = serverConnection.getCachedRegionHelper();
serverConnection.setAsTrue(REQUIRES_RESPONSE);
serverConnection.setAsTrue(REQUIRES_CHUNKED_RESPONSE);
@@ -47,7 +48,8 @@ public class MonitorCQ extends BaseCQCommand {
// This should have been taken care at the client - remove?
String err = LocalizedStrings.MonitorCQ__0_THE_MONITORCQ_OPERATION_IS_INVALID
.toLocalizedString(serverConnection.getName());
- sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(), null, serverConnection);
+ sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(), null,
+ serverConnection);
return;
}
@@ -60,14 +62,16 @@ public class MonitorCQ extends BaseCQCommand {
String err =
LocalizedStrings.MonitorCQ__0_A_NULL_REGION_NAME_WAS_PASSED_FOR_MONITORCQ_OPERATION
.toLocalizedString(serverConnection.getName());
- sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(), null, serverConnection);
+ sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(),
+ null, serverConnection);
return;
}
}
if (logger.isDebugEnabled()) {
logger.debug("{}: Received MonitorCq request from {} op: {}{}", serverConnection.getName(),
- serverConnection.getSocketString(), op, (regionName != null) ? " RegionName: " + regionName : "");
+ serverConnection.getSocketString(), op,
+ (regionName != null) ? " RegionName: " + regionName : "");
}
this.securityService.authorizeClusterRead();
@@ -84,12 +88,14 @@ public class MonitorCQ extends BaseCQCommand {
throw new CqException(
LocalizedStrings.CqService_INVALID_CQ_MONITOR_REQUEST_RECEIVED.toLocalizedString());
} catch (CqException cqe) {
- sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe, serverConnection);
+ sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe,
+ serverConnection);
return;
} catch (Exception e) {
String err = LocalizedStrings.MonitorCQ_EXCEPTION_WHILE_HANDLING_THE_MONITOR_REQUEST_OP_IS_0
.toLocalizedString(Integer.valueOf(op));
- sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, err, clientMessage.getTransactionId(), e, serverConnection);
+ sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, err, clientMessage.getTransactionId(), e,
+ serverConnection);
return;
}
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/StopCQ.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/StopCQ.java b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/StopCQ.java
index 070cb04..99fbef1 100644
--- a/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/StopCQ.java
+++ b/geode-cq/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/StopCQ.java
@@ -44,7 +44,8 @@ public class StopCQ extends BaseCQCommand {
private StopCQ() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
CachedRegionHelper crHelper = serverConnection.getCachedRegionHelper();
ClientProxyMembershipID id = serverConnection.getProxyID();
CacheServerStats stats = serverConnection.getCacheServerStats();
@@ -67,7 +68,8 @@ public class StopCQ extends BaseCQCommand {
if (cqName == null) {
String err =
LocalizedStrings.StopCQ_THE_CQNAME_FOR_THE_CQ_STOP_REQUEST_IS_NULL.toLocalizedString();
- sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(), null, serverConnection);
+ sendCqResponse(MessageType.CQDATAERROR_MSG_TYPE, err, clientMessage.getTransactionId(), null,
+ serverConnection);
return;
}
@@ -102,19 +104,21 @@ public class StopCQ extends BaseCQCommand {
if (cqQuery != null)
serverConnection.removeCq(cqName, cqQuery.isDurable());
} catch (CqException cqe) {
- sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe, serverConnection);
+ sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, "", clientMessage.getTransactionId(), cqe,
+ serverConnection);
return;
} catch (Exception e) {
String err =
LocalizedStrings.StopCQ_EXCEPTION_WHILE_STOPPING_CQ_NAMED_0.toLocalizedString(cqName);
- sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, err, clientMessage.getTransactionId(), e, serverConnection);
+ sendCqResponse(MessageType.CQ_EXCEPTION_TYPE, err, clientMessage.getTransactionId(), e,
+ serverConnection);
return;
}
// Send OK to client
sendCqResponse(MessageType.REPLY,
- LocalizedStrings.StopCQ_CQ_STOPPED_SUCCESSFULLY.toLocalizedString(), clientMessage.getTransactionId(),
- null, serverConnection);
+ LocalizedStrings.StopCQ_CQ_STOPPED_SUCCESSFULLY.toLocalizedString(),
+ clientMessage.getTransactionId(), null, serverConnection);
serverConnection.setAsTrue(RESPONDED);
[2/3] geode git commit: Run spotlessApply
Posted by kl...@apache.org.
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GatewayReceiverCommand.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GatewayReceiverCommand.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GatewayReceiverCommand.java
index 704f2da..d489b88 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GatewayReceiverCommand.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GatewayReceiverCommand.java
@@ -188,7 +188,7 @@ public class GatewayReceiverCommand extends BaseCommand {
int dsid = clientMessage.getPart(partNumber++).getInt();
boolean removeOnException =
- clientMessage.getPart(partNumber++).getSerializedForm()[0] == 1 ? true : false;
+ clientMessage.getPart(partNumber++).getSerializedForm()[0] == 1 ? true : false;
// Keep track of whether a response has been written for
// exceptions
@@ -218,8 +218,7 @@ public class GatewayReceiverCommand extends BaseCommand {
} catch (Exception e) {
logger.warn(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_CAUGHT_EXCEPTION_PROCESSING_BATCH_REQUEST_1_CONTAINING_2_EVENTS,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(batchId),
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId),
Integer.valueOf(numberOfEvents)}),
e);
throw e;
@@ -252,8 +251,7 @@ public class GatewayReceiverCommand extends BaseCommand {
} catch (Exception e) {
logger.warn(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_CAUGHT_EXCEPTION_PROCESSING_BATCH_REQUEST_1_CONTAINING_2_EVENTS,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(batchId),
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId),
Integer.valueOf(numberOfEvents)}),
e);
throw e;
@@ -266,8 +264,7 @@ public class GatewayReceiverCommand extends BaseCommand {
} catch (Exception e) {
logger.warn(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_CAUGHT_EXCEPTION_PROCESSING_BATCH_REQUEST_1_CONTAINING_2_EVENTS,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(batchId),
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId),
Integer.valueOf(numberOfEvents)}),
e);
throw e;
@@ -303,8 +300,7 @@ public class GatewayReceiverCommand extends BaseCommand {
} catch (Exception e) {
logger.warn(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_CAUGHT_EXCEPTION_PROCESSING_BATCH_CREATE_REQUEST_1_FOR_2_EVENTS,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(batchId),
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId),
Integer.valueOf(numberOfEvents)}),
e);
throw e;
@@ -313,14 +309,15 @@ public class GatewayReceiverCommand extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Processing batch create request {} on {} for region {} key {} value {} callbackArg {}, eventId={}",
- serverConnection.getName(), batchId, serverConnection.getSocketString(), regionName, key,
- valuePart, callbackArg, eventId);
+ serverConnection.getName(), batchId, serverConnection.getSocketString(),
+ regionName, key, valuePart, callbackArg, eventId);
}
versionTimeStamp = clientMessage.getPart(index++).getLong();
// Process the create request
if (key == null || regionName == null) {
StringId message = null;
- Object[] messageArgs = new Object[] { serverConnection.getName(), Integer.valueOf(batchId)};
+ Object[] messageArgs =
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId)};
if (key == null) {
message =
LocalizedStrings.ProcessBatch_0_THE_INPUT_REGION_NAME_FOR_THE_BATCH_CREATE_REQUEST_1_IS_NULL;
@@ -381,15 +378,13 @@ public class GatewayReceiverCommand extends BaseCommand {
// This exception will be logged in the catch block below
throw new Exception(
LocalizedStrings.ProcessBatch_0_FAILED_TO_CREATE_OR_UPDATE_ENTRY_FOR_REGION_1_KEY_2_VALUE_3_CALLBACKARG_4
- .toLocalizedString(new Object[] {
- serverConnection.getName(), regionName, key,
- valuePart, callbackArg}));
+ .toLocalizedString(new Object[] {serverConnection.getName(), regionName,
+ key, valuePart, callbackArg}));
}
} catch (Exception e) {
logger.warn(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_CAUGHT_EXCEPTION_PROCESSING_BATCH_CREATE_REQUEST_1_FOR_2_EVENTS,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(batchId),
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId),
Integer.valueOf(numberOfEvents)}),
e);
throw e;
@@ -425,8 +420,7 @@ public class GatewayReceiverCommand extends BaseCommand {
} catch (Exception e) {
logger.warn(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_CAUGHT_EXCEPTION_PROCESSING_BATCH_UPDATE_REQUEST_1_CONTAINING_2_EVENTS,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(batchId),
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId),
Integer.valueOf(numberOfEvents)}),
e);
throw e;
@@ -436,13 +430,14 @@ public class GatewayReceiverCommand extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Processing batch update request {} on {} for region {} key {} value {} callbackArg {}",
- serverConnection.getName(), batchId, serverConnection.getSocketString(), regionName, key,
- valuePart, callbackArg);
+ serverConnection.getName(), batchId, serverConnection.getSocketString(),
+ regionName, key, valuePart, callbackArg);
}
// Process the update request
if (key == null || regionName == null) {
StringId message = null;
- Object[] messageArgs = new Object[] { serverConnection.getName(), Integer.valueOf(batchId)};
+ Object[] messageArgs =
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId)};
if (key == null) {
message =
LocalizedStrings.ProcessBatch_0_THE_INPUT_KEY_FOR_THE_BATCH_UPDATE_REQUEST_1_IS_NULL;
@@ -490,8 +485,8 @@ public class GatewayReceiverCommand extends BaseCommand {
serverConnection.setModificationInfo(true, regionName, key);
stats.incUpdateRequest();
} else {
- final Object[] msgArgs =
- new Object[] { serverConnection.getName(), regionName, key, valuePart, callbackArg};
+ final Object[] msgArgs = new Object[] {serverConnection.getName(), regionName,
+ key, valuePart, callbackArg};
final StringId message =
LocalizedStrings.ProcessBatch_0_FAILED_TO_UPDATE_ENTRY_FOR_REGION_1_KEY_2_VALUE_3_AND_CALLBACKARG_4;
String s = message.toLocalizedString(msgArgs);
@@ -501,11 +496,12 @@ public class GatewayReceiverCommand extends BaseCommand {
} catch (CancelException e) {
// FIXME better exception hierarchy would avoid this check
if (serverConnection.getCachedRegionHelper().getCache().getCancelCriterion()
- .isCancelInProgress()) {
+ .isCancelInProgress()) {
if (logger.isDebugEnabled()) {
logger.debug(
"{} ignoring message of type {} from client {} because shutdown occurred during message processing.",
- serverConnection.getName(), MessageType.getString(clientMessage.getMessageType()),
+ serverConnection.getName(),
+ MessageType.getString(clientMessage.getMessageType()),
serverConnection.getProxyID());
}
serverConnection.setFlagProcessMessagesAsFalse();
@@ -518,8 +514,7 @@ public class GatewayReceiverCommand extends BaseCommand {
// Preserve the connection under all circumstances
logger.warn(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_CAUGHT_EXCEPTION_PROCESSING_BATCH_UPDATE_REQUEST_1_CONTAINING_2_EVENTS,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(batchId),
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId),
Integer.valueOf(numberOfEvents)}),
e);
throw e;
@@ -540,8 +535,7 @@ public class GatewayReceiverCommand extends BaseCommand {
} catch (Exception e) {
logger.warn(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_CAUGHT_EXCEPTION_PROCESSING_BATCH_DESTROY_REQUEST_1_CONTAINING_2_EVENTS,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(batchId),
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId),
Integer.valueOf(numberOfEvents)}),
e);
throw e;
@@ -551,7 +545,8 @@ public class GatewayReceiverCommand extends BaseCommand {
versionTimeStamp = clientMessage.getPart(index++).getLong();
if (logger.isDebugEnabled()) {
logger.debug("{}: Processing batch destroy request {} on {} for region {} key {}",
- serverConnection.getName(), batchId, serverConnection.getSocketString(), regionName, key);
+ serverConnection.getName(), batchId, serverConnection.getSocketString(),
+ regionName, key);
}
// Process the destroy request
@@ -565,7 +560,8 @@ public class GatewayReceiverCommand extends BaseCommand {
message =
LocalizedStrings.ProcessBatch_0_THE_INPUT_REGION_NAME_FOR_THE_BATCH_DESTROY_REQUEST_1_IS_NULL;
}
- Object[] messageArgs = new Object[] { serverConnection.getName(), Integer.valueOf(batchId)};
+ Object[] messageArgs =
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId)};
String s = message.toLocalizedString(messageArgs);
logger.warn(s);
throw new Exception(s);
@@ -598,7 +594,7 @@ public class GatewayReceiverCommand extends BaseCommand {
} catch (EntryNotFoundException e) {
logger.info(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_DURING_BATCH_DESTROY_NO_ENTRY_WAS_FOUND_FOR_KEY_1,
- new Object[] { serverConnection.getName(), key}));
+ new Object[] {serverConnection.getName(), key}));
// throw new Exception(e);
}
}
@@ -633,8 +629,7 @@ public class GatewayReceiverCommand extends BaseCommand {
} catch (Exception e) {
logger.warn(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_CAUGHT_EXCEPTION_PROCESSING_BATCH_UPDATE_VERSION_REQUEST_1_CONTAINING_2_EVENTS,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(batchId),
+ new Object[] {serverConnection.getName(), Integer.valueOf(batchId),
Integer.valueOf(numberOfEvents)}),
e);
throw e;
@@ -644,17 +639,16 @@ public class GatewayReceiverCommand extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Processing batch update-version request {} on {} for region {} key {} value {} callbackArg {}",
- serverConnection.getName(), batchId, serverConnection.getSocketString(), regionName, key,
- valuePart, callbackArg);
+ serverConnection.getName(), batchId, serverConnection.getSocketString(),
+ regionName, key, valuePart, callbackArg);
}
// Process the update time-stamp request
if (key == null || regionName == null) {
StringId message =
LocalizedStrings.ProcessBatch_0_CAUGHT_EXCEPTION_PROCESSING_BATCH_UPDATE_VERSION_REQUEST_1_CONTAINING_2_EVENTS;
- Object[] messageArgs = new Object[] {
- serverConnection.getName(), Integer.valueOf(batchId),
- Integer.valueOf(numberOfEvents)};
+ Object[] messageArgs = new Object[] {serverConnection.getName(),
+ Integer.valueOf(batchId), Integer.valueOf(numberOfEvents)};
String s = message.toLocalizedString(messageArgs);
logger.warn(s);
throw new Exception(s);
@@ -679,13 +673,13 @@ public class GatewayReceiverCommand extends BaseCommand {
// Update the version tag
try {
- region.basicBridgeUpdateVersionStamp(key, callbackArg, serverConnection.getProxyID(),
- false, clientEvent);
+ region.basicBridgeUpdateVersionStamp(key, callbackArg,
+ serverConnection.getProxyID(), false, clientEvent);
} catch (EntryNotFoundException e) {
logger.info(LocalizedMessage.create(
LocalizedStrings.ProcessBatch_0_DURING_BATCH_UPDATE_VERSION_NO_ENTRY_WAS_FOUND_FOR_KEY_1,
- new Object[] { serverConnection.getName(), key}));
+ new Object[] {serverConnection.getName(), key}));
// throw new Exception(e);
}
}
@@ -695,8 +689,7 @@ public class GatewayReceiverCommand extends BaseCommand {
default:
logger.fatal(LocalizedMessage.create(
LocalizedStrings.Processbatch_0_UNKNOWN_ACTION_TYPE_1_FOR_BATCH_FROM_2,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(actionType),
+ new Object[] {serverConnection.getName(), Integer.valueOf(actionType),
serverConnection.getSocketString()}));
stats.incUnknowsOperationsReceived();
}
@@ -718,7 +711,7 @@ public class GatewayReceiverCommand extends BaseCommand {
if (e.getCause() instanceof PdxRegistryMismatchException) {
fatalException = e.getCause();
logger.fatal(LocalizedMessage.create(LocalizedStrings.GatewayReceiver_PDX_CONFIGURATION,
- new Object[] { serverConnection.getMembershipID()}), e.getCause());
+ new Object[] {serverConnection.getMembershipID()}), e.getCause());
break;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Get70.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Get70.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Get70.java
index 7017aa8..2ca8804 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Get70.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Get70.java
@@ -98,8 +98,8 @@ public class Get70 extends BaseCommand {
}
if (logger.isDebugEnabled()) {
logger.debug("{}: Received 7.0 get request ({} bytes) from {} for region {} key {} txId {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName, key,
- clientMessage.getTransactionId());
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName, key, clientMessage.getTransactionId());
}
// Process the get request
@@ -197,14 +197,16 @@ public class Get70 extends BaseCommand {
if (region instanceof PartitionedRegion) {
PartitionedRegion pr = (PartitionedRegion) region;
if (pr.getNetworkHopType() != PartitionedRegion.NETWORK_HOP_NONE) {
- writeResponseWithRefreshMetadata(data, callbackArg, clientMessage, isObject, serverConnection, pr,
- pr.getNetworkHopType(), versionTag, keyNotPresent);
+ writeResponseWithRefreshMetadata(data, callbackArg, clientMessage, isObject,
+ serverConnection, pr, pr.getNetworkHopType(), versionTag, keyNotPresent);
pr.clearNetworkHopData();
} else {
- writeResponse(data, callbackArg, clientMessage, isObject, versionTag, keyNotPresent, serverConnection);
+ writeResponse(data, callbackArg, clientMessage, isObject, versionTag, keyNotPresent,
+ serverConnection);
}
} else {
- writeResponse(data, callbackArg, clientMessage, isObject, versionTag, keyNotPresent, serverConnection);
+ writeResponse(data, callbackArg, clientMessage, isObject, versionTag, keyNotPresent,
+ serverConnection);
}
} finally {
OffHeapHelper.release(originalData);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll.java
index 5f7cb29..01c5c9c 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll.java
@@ -69,8 +69,9 @@ public class GetAll extends BaseCommand {
if (logger.isDebugEnabled()) {
StringBuffer buffer = new StringBuffer();
buffer.append(serverConnection.getName()).append(": Received getAll request (")
- .append(clientMessage.getPayloadLength()).append(" bytes) from ").append(serverConnection.getSocketString())
- .append(" for region ").append(regionName).append(" keys ");
+ .append(clientMessage.getPayloadLength()).append(" bytes) from ")
+ .append(serverConnection.getSocketString()).append(" for region ").append(regionName)
+ .append(" keys ");
if (keys != null) {
for (int i = 0; i < keys.length; i++) {
buffer.append(keys[i]).append(" ");
@@ -92,7 +93,8 @@ public class GetAll extends BaseCommand {
.toLocalizedString();
}
logger.warn("{}: {}", serverConnection.getName(), message);
- writeChunkedErrorResponse(clientMessage, MessageType.GET_ALL_DATA_ERROR, message, serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.GET_ALL_DATA_ERROR, message,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll651.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll651.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll651.java
index b0a1915..ad8ef49 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll651.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll651.java
@@ -69,8 +69,9 @@ public class GetAll651 extends BaseCommand {
if (logger.isDebugEnabled()) {
StringBuffer buffer = new StringBuffer();
buffer.append(serverConnection.getName()).append(": Received getAll request (")
- .append(clientMessage.getPayloadLength()).append(" bytes) from ").append(serverConnection.getSocketString())
- .append(" for region ").append(regionName).append(" keys ");
+ .append(clientMessage.getPayloadLength()).append(" bytes) from ")
+ .append(serverConnection.getSocketString()).append(" for region ").append(regionName)
+ .append(" keys ");
if (keys != null) {
for (int i = 0; i < keys.length; i++) {
buffer.append(keys[i]).append(" ");
@@ -90,7 +91,8 @@ public class GetAll651 extends BaseCommand {
.toLocalizedString();
}
logger.warn("{}: {}", serverConnection.getName(), message);
- writeChunkedErrorResponse(clientMessage, MessageType.GET_ALL_DATA_ERROR, message, serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.GET_ALL_DATA_ERROR, message,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll70.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll70.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll70.java
index 579593f..267a5b2 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll70.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAll70.java
@@ -78,8 +78,9 @@ public class GetAll70 extends BaseCommand {
if (logger.isDebugEnabled()) {
StringBuffer buffer = new StringBuffer();
buffer.append(serverConnection.getName()).append(": Received getAll request (")
- .append(clientMessage.getPayloadLength()).append(" bytes) from ").append(serverConnection.getSocketString())
- .append(" for region ").append(regionName).append(" keys ");
+ .append(clientMessage.getPayloadLength()).append(" bytes) from ")
+ .append(serverConnection.getSocketString()).append(" for region ").append(regionName)
+ .append(" keys ");
if (keys != null) {
for (int i = 0; i < keys.length; i++) {
buffer.append(keys[i]).append(" ");
@@ -99,7 +100,8 @@ public class GetAll70 extends BaseCommand {
.toLocalizedString();
}
logger.warn("{}: {}", serverConnection.getName(), message);
- writeChunkedErrorResponse(clientMessage, MessageType.GET_ALL_DATA_ERROR, message, serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.GET_ALL_DATA_ERROR, message,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -120,7 +122,8 @@ public class GetAll70 extends BaseCommand {
// Send chunk response
try {
- fillAndSendGetAllResponseChunks(region, regionName, keys, serverConnection, requestSerializedValues);
+ fillAndSendGetAllResponseChunks(region, regionName, keys, serverConnection,
+ requestSerializedValues);
serverConnection.setAsTrue(RESPONDED);
} catch (Exception e) {
// If an interrupted exception is thrown , rethrow it
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAllWithCallback.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAllWithCallback.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAllWithCallback.java
index c6663de..db97d53 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAllWithCallback.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetAllWithCallback.java
@@ -91,9 +91,9 @@ public class GetAllWithCallback extends BaseCommand {
if (logger.isDebugEnabled()) {
StringBuffer buffer = new StringBuffer();
buffer.append(serverConnection.getName()).append(": Received getAll request (")
- .append(clientMessage.getPayloadLength()).append(" bytes) from ").append(serverConnection.getSocketString())
- .append(" for region ").append(regionName).append(" with callback ").append(callback)
- .append(" keys ");
+ .append(clientMessage.getPayloadLength()).append(" bytes) from ")
+ .append(serverConnection.getSocketString()).append(" for region ").append(regionName)
+ .append(" with callback ").append(callback).append(" keys ");
if (keys != null) {
for (int i = 0; i < keys.length; i++) {
buffer.append(keys[i]).append(" ");
@@ -113,8 +113,9 @@ public class GetAllWithCallback extends BaseCommand {
.toLocalizedString();
}
logger.warn(LocalizedMessage.create(LocalizedStrings.TWO_ARG_COLON,
- new Object[] { serverConnection.getName(), message}));
- writeChunkedErrorResponse(clientMessage, MessageType.GET_ALL_DATA_ERROR, message, serverConnection);
+ new Object[] {serverConnection.getName(), message}));
+ writeChunkedErrorResponse(clientMessage, MessageType.GET_ALL_DATA_ERROR, message,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetClientPRMetadataCommand.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetClientPRMetadataCommand.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetClientPRMetadataCommand.java
index bcdbd08..201b5c0 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetClientPRMetadataCommand.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetClientPRMetadataCommand.java
@@ -60,7 +60,8 @@ public class GetClientPRMetadataCommand extends BaseCommand {
.create(LocalizedStrings.GetClientPRMetadata_THE_INPUT_REGION_PATH_IS_NULL));
errMessage =
LocalizedStrings.GetClientPRMetadata_THE_INPUT_REGION_PATH_IS_NULL.toLocalizedString();
- writeErrorResponse(clientMessage, MessageType.GET_CLIENT_PR_METADATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.GET_CLIENT_PR_METADATA_ERROR,
+ errMessage.toString(), serverConnection);
serverConnection.setAsTrue(RESPONDED);
} else {
Region region = crHelper.getRegion(regionFullPath);
@@ -70,7 +71,8 @@ public class GetClientPRMetadataCommand extends BaseCommand {
regionFullPath));
errMessage = LocalizedStrings.GetClientPRMetadata_REGION_NOT_FOUND.toLocalizedString()
+ regionFullPath;
- writeErrorResponse(clientMessage, MessageType.GET_CLIENT_PR_METADATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.GET_CLIENT_PR_METADATA_ERROR,
+ errMessage.toString(), serverConnection);
serverConnection.setAsTrue(RESPONDED);
} else {
try {
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetClientPRMetadataCommand66.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetClientPRMetadataCommand66.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetClientPRMetadataCommand66.java
index 4c519a9..7b370fe 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetClientPRMetadataCommand66.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetClientPRMetadataCommand66.java
@@ -58,7 +58,8 @@ public class GetClientPRMetadataCommand66 extends BaseCommand {
.create(LocalizedStrings.GetClientPRMetadata_THE_INPUT_REGION_PATH_IS_NULL));
errMessage =
LocalizedStrings.GetClientPRMetadata_THE_INPUT_REGION_PATH_IS_NULL.toLocalizedString();
- writeErrorResponse(clientMessage, MessageType.GET_CLIENT_PR_METADATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.GET_CLIENT_PR_METADATA_ERROR,
+ errMessage.toString(), serverConnection);
serverConnection.setAsTrue(RESPONDED);
} else {
Region region = crHelper.getRegion(regionFullPath);
@@ -68,7 +69,8 @@ public class GetClientPRMetadataCommand66 extends BaseCommand {
regionFullPath));
errMessage = LocalizedStrings.GetClientPRMetadata_REGION_NOT_FOUND.toLocalizedString()
+ regionFullPath;
- writeErrorResponse(clientMessage, MessageType.GET_CLIENT_PR_METADATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.GET_CLIENT_PR_METADATA_ERROR,
+ errMessage.toString(), serverConnection);
serverConnection.setAsTrue(RESPONDED);
} else {
try {
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetFunctionAttribute.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetFunctionAttribute.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetFunctionAttribute.java
index f56a4d9..2c1f26c 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetFunctionAttribute.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetFunctionAttribute.java
@@ -34,7 +34,8 @@ public class GetFunctionAttribute extends BaseCommand {
}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
serverConnection.setAsTrue(REQUIRES_RESPONSE);
String functionId = clientMessage.getPart(0).getString();
if (functionId == null) {
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXEnumById.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXEnumById.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXEnumById.java
index cc7dd05..15215de 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXEnumById.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXEnumById.java
@@ -40,8 +40,9 @@ public class GetPDXEnumById extends BaseCommand {
throws IOException, ClassNotFoundException {
serverConnection.setAsTrue(REQUIRES_RESPONSE);
if (logger.isDebugEnabled()) {
- logger.debug("{}: Received get pdx enum by id request ({} parts) from {}", serverConnection.getName(),
- clientMessage.getNumberOfParts(), serverConnection.getSocketString());
+ logger.debug("{}: Received get pdx enum by id request ({} parts) from {}",
+ serverConnection.getName(), clientMessage.getNumberOfParts(),
+ serverConnection.getSocketString());
}
int enumId = clientMessage.getPart(0).getInt();
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXIdForEnum.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXIdForEnum.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXIdForEnum.java
index 7bf5b4f..40c62a7 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXIdForEnum.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXIdForEnum.java
@@ -41,7 +41,8 @@ public class GetPDXIdForEnum extends BaseCommand {
serverConnection.setAsTrue(REQUIRES_RESPONSE);
if (logger.isDebugEnabled()) {
logger.debug("{}: Received get pdx id for enum request ({} parts) from {}",
- serverConnection.getName(), clientMessage.getNumberOfParts(), serverConnection.getSocketString());
+ serverConnection.getName(), clientMessage.getNumberOfParts(),
+ serverConnection.getSocketString());
}
EnumInfo enumInfo = (EnumInfo) clientMessage.getPart(0).getObject();
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXIdForType.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXIdForType.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXIdForType.java
index e5dc5f0..c1de0fc 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXIdForType.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXIdForType.java
@@ -41,7 +41,8 @@ public class GetPDXIdForType extends BaseCommand {
serverConnection.setAsTrue(REQUIRES_RESPONSE);
if (logger.isDebugEnabled()) {
logger.debug("{}: Received get pdx id for type request ({} parts) from {}",
- serverConnection.getName(), clientMessage.getNumberOfParts(), serverConnection.getSocketString());
+ serverConnection.getName(), clientMessage.getNumberOfParts(),
+ serverConnection.getSocketString());
}
int noOfParts = clientMessage.getNumberOfParts();
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXTypeById.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXTypeById.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXTypeById.java
index 032e8b3..16e9dd0 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXTypeById.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/GetPDXTypeById.java
@@ -40,8 +40,9 @@ public class GetPDXTypeById extends BaseCommand {
throws IOException, ClassNotFoundException {
serverConnection.setAsTrue(REQUIRES_RESPONSE);
if (logger.isDebugEnabled()) {
- logger.debug("{}: Received get pdx type by id request ({} parts) from {}", serverConnection.getName(),
- clientMessage.getNumberOfParts(), serverConnection.getSocketString());
+ logger.debug("{}: Received get pdx type by id request ({} parts) from {}",
+ serverConnection.getName(), clientMessage.getNumberOfParts(),
+ serverConnection.getSocketString());
}
int pdxId = clientMessage.getPart(0).getInt();
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Invalid.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Invalid.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Invalid.java
index 314ba07..040e1c2 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Invalid.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Invalid.java
@@ -36,11 +36,12 @@ public class Invalid extends BaseCommand {
private Invalid() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
logger.error(
LocalizedMessage.create(LocalizedStrings.Invalid_0_INVALID_MESSAGE_TYPE_WITH_TX_1_FROM_2,
- new Object[] {
- serverConnection.getName(), Integer.valueOf(clientMessage.getTransactionId()),
+ new Object[] {serverConnection.getName(),
+ Integer.valueOf(clientMessage.getTransactionId()),
serverConnection.getSocketString()}));
writeErrorResponse(clientMessage, MessageType.INVALID, serverConnection);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Invalidate.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Invalidate.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Invalidate.java
index 22bf6f4..801b3ad 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Invalidate.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Invalidate.java
@@ -87,9 +87,9 @@ public class Invalidate extends BaseCommand {
return;
}
if (logger.isDebugEnabled()) {
- logger.debug(serverConnection.getName() + ": Received invalidate request (" + clientMessage.getPayloadLength()
- + " bytes) from " + serverConnection.getSocketString() + " for region " + regionName + " key "
- + key);
+ logger.debug(serverConnection.getName() + ": Received invalidate request ("
+ + clientMessage.getPayloadLength() + " bytes) from " + serverConnection.getSocketString()
+ + " for region " + regionName + " key " + key);
}
// Process the invalidate request
@@ -108,7 +108,8 @@ public class Invalidate extends BaseCommand {
.append(LocalizedStrings.BaseCommand__THE_INPUT_REGION_NAME_FOR_THE_0_REQUEST_IS_NULL
.toLocalizedString("invalidate"));
}
- writeErrorResponse(clientMessage, MessageType.DESTROY_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.DESTROY_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -124,7 +125,8 @@ public class Invalidate extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
Breadcrumbs.setEventId(eventId);
@@ -157,7 +159,8 @@ public class Invalidate extends BaseCommand {
}
}
- region.basicBridgeInvalidate(key, callbackArg, serverConnection.getProxyID(), true, clientEvent);
+ region.basicBridgeInvalidate(key, callbackArg, serverConnection.getProxyID(), true,
+ clientEvent);
tag = clientEvent.getVersionTag();
serverConnection.setModificationInfo(true, regionName, key);
} catch (EntryNotFoundException e) {
@@ -199,7 +202,8 @@ public class Invalidate extends BaseCommand {
if (region instanceof PartitionedRegion) {
PartitionedRegion pr = (PartitionedRegion) region;
if (pr.getNetworkHopType() != PartitionedRegion.NETWORK_HOP_NONE) {
- writeReplyWithRefreshMetadata(clientMessage, serverConnection, pr, pr.getNetworkHopType(), tag);
+ writeReplyWithRefreshMetadata(clientMessage, serverConnection, pr, pr.getNetworkHopType(),
+ tag);
pr.clearNetworkHopData();
} else {
writeReply(clientMessage, serverConnection, tag);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/KeySet.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/KeySet.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/KeySet.java
index a35c4b0..66de347 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/KeySet.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/KeySet.java
@@ -62,7 +62,8 @@ public class KeySet extends BaseCommand {
final boolean isDebugEnabled = logger.isDebugEnabled();
if (isDebugEnabled) {
logger.debug("{}: Received key set request ({} bytes) from {} for region {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName);
}
// Process the key set request
@@ -76,7 +77,8 @@ public class KeySet extends BaseCommand {
LocalizedStrings.KeySet_0_THE_INPUT_REGION_NAME_FOR_THE_KEY_SET_REQUEST_IS_NULL,
serverConnection.getName()));
}
- writeKeySetErrorResponse(clientMessage, MessageType.KEY_SET_DATA_ERROR, message, serverConnection);
+ writeKeySetErrorResponse(clientMessage, MessageType.KEY_SET_DATA_ERROR, message,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -128,7 +130,8 @@ public class KeySet extends BaseCommand {
checkForInterrupt(serverConnection, e);
// Otherwise, write an exception message and continue
- writeChunkedException(clientMessage, e, serverConnection, serverConnection.getChunkedResponseMessage());
+ writeChunkedException(clientMessage, e, serverConnection,
+ serverConnection.getChunkedResponseMessage());
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -137,7 +140,8 @@ public class KeySet extends BaseCommand {
// logger.fine(getName() + ": Sent chunk (1 of 1) of register interest
// response (" + chunkedResponseMsg.getBufferLength() + " bytes) for
// region " + regionName + " key " + key);
- logger.debug("{}: Sent key set response for the region {}", serverConnection.getName(), regionName);
+ logger.debug("{}: Sent key set response for the region {}", serverConnection.getName(),
+ regionName);
}
// bserverStats.incLong(writeDestroyResponseTimeId,
// DistributionStats.getStatTime() - start);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/MakePrimary.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/MakePrimary.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/MakePrimary.java
index 0786990..ac9901c 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/MakePrimary.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/MakePrimary.java
@@ -43,11 +43,12 @@ public class MakePrimary extends BaseCommand {
final boolean isDebugEnabled = logger.isDebugEnabled();
if (isDebugEnabled) {
logger.debug("{}: Received make primary request ({} bytes) isClientReady={}: from {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), isClientReady, serverConnection.getSocketString());
+ serverConnection.getName(), clientMessage.getPayloadLength(), isClientReady,
+ serverConnection.getSocketString());
}
try {
- serverConnection.getAcceptor().getCacheClientNotifier().makePrimary(serverConnection.getProxyID(),
- isClientReady);
+ serverConnection.getAcceptor().getCacheClientNotifier()
+ .makePrimary(serverConnection.getProxyID(), isClientReady);
writeReply(clientMessage, serverConnection);
serverConnection.setAsTrue(RESPONDED);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PeriodicAck.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PeriodicAck.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PeriodicAck.java
index e57385f..121ec37 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PeriodicAck.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PeriodicAck.java
@@ -37,8 +37,9 @@ public class PeriodicAck extends BaseCommand {
throws IOException, ClassNotFoundException {
serverConnection.setAsTrue(REQUIRES_RESPONSE);
if (logger.isDebugEnabled()) {
- logger.debug("{}: Received periodic ack request ({} bytes) from {}", serverConnection.getName(),
- clientMessage.getPayloadLength(), serverConnection.getSocketString());
+ logger.debug("{}: Received periodic ack request ({} bytes) from {}",
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString());
}
try {
int numEvents = clientMessage.getNumberOfParts();
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Ping.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Ping.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Ping.java
index 9755410..adcfd14 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Ping.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Ping.java
@@ -39,11 +39,13 @@ public class Ping extends BaseCommand {
private Ping() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
final boolean isDebugEnabled = logger.isDebugEnabled();
if (isDebugEnabled) {
- logger.debug("{}: rcv tx: {} from {} rcvTime: {}", serverConnection.getName(), clientMessage.getTransactionId(),
- serverConnection.getSocketString(), (DistributionStats.getStatTime() - start));
+ logger.debug("{}: rcv tx: {} from {} rcvTime: {}", serverConnection.getName(),
+ clientMessage.getTransactionId(), serverConnection.getSocketString(),
+ (DistributionStats.getStatTime() - start));
}
ClientHealthMonitor chm = ClientHealthMonitor.getInstance();
if (chm != null)
@@ -53,7 +55,8 @@ public class Ping extends BaseCommand {
writeReply(clientMessage, serverConnection);
serverConnection.setAsTrue(RESPONDED);
if (isDebugEnabled) {
- logger.debug("{}: Sent ping reply to {}", serverConnection.getName(), serverConnection.getSocketString());
+ logger.debug("{}: Sent ping reply to {}", serverConnection.getName(),
+ serverConnection.getSocketString());
}
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put.java
index d724f66..76c8184 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put.java
@@ -94,15 +94,16 @@ public class Put extends BaseCommand {
if (logger.isTraceEnabled()) {
logger.trace("{}: Received put request ({} bytes) from {} for region {} key {} value {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName, key,
- valuePart);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName, key, valuePart);
}
// Process the put request
if (key == null || regionName == null) {
if (key == null) {
logger.warn(LocalizedMessage.create(
- LocalizedStrings.Put_0_THE_INPUT_KEY_FOR_THE_PUT_REQUEST_IS_NULL, serverConnection.getName()));
+ LocalizedStrings.Put_0_THE_INPUT_KEY_FOR_THE_PUT_REQUEST_IS_NULL,
+ serverConnection.getName()));
errMessage =
LocalizedStrings.Put_THE_INPUT_KEY_FOR_THE_PUT_REQUEST_IS_NULL.toLocalizedString();
}
@@ -113,7 +114,8 @@ public class Put extends BaseCommand {
errMessage = LocalizedStrings.Put_THE_INPUT_REGION_NAME_FOR_THE_PUT_REQUEST_IS_NULL
.toLocalizedString();
}
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -131,7 +133,7 @@ public class Put extends BaseCommand {
// Invalid to 'put' a null value in an existing key
logger.info(LocalizedMessage.create(
LocalizedStrings.Put_0_ATTEMPTED_TO_PUT_A_NULL_VALUE_FOR_EXISTING_KEY_1,
- new Object[] { serverConnection.getName(), key}));
+ new Object[] {serverConnection.getName(), key}));
errMessage =
LocalizedStrings.Put_ATTEMPTED_TO_PUT_A_NULL_VALUE_FOR_EXISTING_KEY_0.toLocalizedString();
writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage, serverConnection);
@@ -142,7 +144,8 @@ public class Put extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
try {
byte[] value = valuePart.getSerializedForm();
@@ -173,8 +176,8 @@ public class Put extends BaseCommand {
// Create the null entry. Since the value is null, the value of the
// isObject
// the true after null doesn't matter and is not used.
- result = region.basicBridgeCreate(key, null, true, callbackArg, serverConnection.getProxyID(), true,
- new EventIDHolder(eventId), false);
+ result = region.basicBridgeCreate(key, null, true, callbackArg,
+ serverConnection.getProxyID(), true, new EventIDHolder(eventId), false);
} else {
// Put the entry
result = region.basicBridgePut(key, value, null, isObject, callbackArg,
@@ -184,7 +187,8 @@ public class Put extends BaseCommand {
serverConnection.setModificationInfo(true, regionName, key);
} else {
StringId message = LocalizedStrings.PUT_0_FAILED_TO_PUT_ENTRY_FOR_REGION_1_KEY_2_VALUE_3;
- Object[] messageArgs = new Object[] { serverConnection.getName(), regionName, key, valuePart};
+ Object[] messageArgs =
+ new Object[] {serverConnection.getName(), regionName, key, valuePart};
String s = message.toLocalizedString(messageArgs);
logger.info(s);
throw new Exception(s);
@@ -227,7 +231,8 @@ public class Put extends BaseCommand {
serverConnection.setAsTrue(RESPONDED);
if (logger.isDebugEnabled()) {
logger.debug("{}: Sent put response back to {} for region {} key {} value {}",
- serverConnection.getName(), serverConnection.getSocketString(), regionName, key, valuePart);
+ serverConnection.getName(), serverConnection.getSocketString(), regionName, key,
+ valuePart);
}
stats.incWritePutResponseTime(DistributionStats.getStatTime() - start);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put61.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put61.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put61.java
index 3f9a72e..6f1583a 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put61.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put61.java
@@ -130,7 +130,8 @@ public class Put61 extends BaseCommand {
}
errMessage.append(putMsg);
}
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -150,7 +151,8 @@ public class Put61 extends BaseCommand {
logger.debug("{}:{}", serverConnection.getName(), putMsg);
}
errMessage.append(putMsg);
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -160,7 +162,8 @@ public class Put61 extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
try {
Object value = null;
@@ -199,8 +202,8 @@ public class Put61 extends BaseCommand {
// Create the null entry. Since the value is null, the value of the
// isObject
// the true after null doesn't matter and is not used.
- result = region.basicBridgeCreate(key, null, true, callbackArg, serverConnection.getProxyID(), true,
- new EventIDHolder(eventId), false);
+ result = region.basicBridgeCreate(key, null, true, callbackArg,
+ serverConnection.getProxyID(), true, new EventIDHolder(eventId), false);
} else {
// Put the entry
byte[] delta = null;
@@ -213,8 +216,8 @@ public class Put61 extends BaseCommand {
if (result) {
serverConnection.setModificationInfo(true, regionName, key);
} else {
- String message = serverConnection.getName() + ": Failed to 6.1 put entry for region " + regionName
- + " key " + key + " value " + valuePart;
+ String message = serverConnection.getName() + ": Failed to 6.1 put entry for region "
+ + regionName + " key " + key + " value " + valuePart;
if (isDebugEnabled) {
logger.debug(message);
}
@@ -275,7 +278,8 @@ public class Put61 extends BaseCommand {
serverConnection.setAsTrue(RESPONDED);
if (isDebugEnabled) {
logger.debug("{}: Sent 6.1 put response back to {} for region {} key {} value {}",
- serverConnection.getName(), serverConnection.getSocketString(), regionName, key, valuePart);
+ serverConnection.getName(), serverConnection.getSocketString(), regionName, key,
+ valuePart);
}
stats.incWritePutResponseTime(DistributionStats.getStatTime() - start);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put65.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put65.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put65.java
index 581aec6..a078372 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put65.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Put65.java
@@ -146,7 +146,8 @@ public class Put65 extends BaseCommand {
logger.debug(
"{}: Received {}put request ({} bytes) from {} for region {} key {} txId {} posdup: {}",
serverConnection.getName(), (isDelta ? " delta " : " "), clientMessage.getPayloadLength(),
- serverConnection.getSocketString(), regionName, key, clientMessage.getTransactionId(), clientMessage.isRetry());
+ serverConnection.getSocketString(), regionName, key, clientMessage.getTransactionId(),
+ clientMessage.isRetry());
}
// Process the put request
@@ -165,7 +166,8 @@ public class Put65 extends BaseCommand {
}
errMessage.append(putMsg);
}
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -185,7 +187,8 @@ public class Put65 extends BaseCommand {
logger.debug("{}:{}", serverConnection.getName(), putMsg);
}
errMessage.append(putMsg);
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -194,8 +197,8 @@ public class Put65 extends BaseCommand {
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventIDHolder clientEvent =
- new EventIDHolder(new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId));
+ EventIDHolder clientEvent = new EventIDHolder(
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId));
Breadcrumbs.setEventId(clientEvent.getEventId());
@@ -267,8 +270,8 @@ public class Put65 extends BaseCommand {
}
// invoke basicBridgePutIfAbsent anyway to ensure that the event is distributed to all
// servers - bug #51664
- region.basicBridgePutIfAbsent(key, value, isObject, callbackArg, serverConnection.getProxyID(),
- true, clientEvent);
+ region.basicBridgePutIfAbsent(key, value, isObject, callbackArg,
+ serverConnection.getProxyID(), true, clientEvent);
oldValue = null;
} else {
oldValue = region.basicBridgePutIfAbsent(key, value, isObject, callbackArg,
@@ -356,8 +359,8 @@ public class Put65 extends BaseCommand {
// Create the null entry. Since the value is null, the value of the
// isObject
// the true after null doesn't matter and is not used.
- result = region.basicBridgeCreate(key, null, true, callbackArg, serverConnection.getProxyID(), true,
- clientEvent, false);
+ result = region.basicBridgeCreate(key, null, true, callbackArg,
+ serverConnection.getProxyID(), true, clientEvent, false);
if (clientMessage.isRetry() && clientEvent.isConcurrencyConflict()
&& clientEvent.getVersionTag() != null) {
result = true;
@@ -372,7 +375,8 @@ public class Put65 extends BaseCommand {
if (isDelta) {
delta = valuePart.getSerializedForm();
}
- TXManagerImpl txMgr = (TXManagerImpl) serverConnection.getCache().getCacheTransactionManager();
+ TXManagerImpl txMgr =
+ (TXManagerImpl) serverConnection.getCache().getCacheTransactionManager();
// bug 43068 - use create() if in a transaction and op is CREATE
if (txMgr.getTXState() != null && operation.isCreate()) {
result = region.basicBridgeCreate(key, (byte[]) value, isObject, callbackArg,
@@ -393,8 +397,8 @@ public class Put65 extends BaseCommand {
if (result) {
serverConnection.setModificationInfo(true, regionName, key);
} else {
- String message = serverConnection.getName() + ": Failed to put entry for region " + regionName
- + " key " + key + " value " + valuePart;
+ String message = serverConnection.getName() + ": Failed to put entry for region "
+ + regionName + " key " + key + " value " + valuePart;
if (isDebugEnabled) {
logger.debug(message);
}
@@ -443,8 +447,8 @@ public class Put65 extends BaseCommand {
if (region instanceof PartitionedRegion) {
PartitionedRegion pr = (PartitionedRegion) region;
if (pr.getNetworkHopType() != PartitionedRegion.NETWORK_HOP_NONE) {
- writeReplyWithRefreshMetadata(clientMessage, serverConnection, pr, sendOldValue, oldValueIsObject, oldValue,
- pr.getNetworkHopType(), clientEvent.getVersionTag());
+ writeReplyWithRefreshMetadata(clientMessage, serverConnection, pr, sendOldValue,
+ oldValueIsObject, oldValue, pr.getNetworkHopType(), clientEvent.getVersionTag());
pr.clearNetworkHopData();
} else {
writeReply(clientMessage, serverConnection, sendOldValue, oldValueIsObject, oldValue,
@@ -457,7 +461,8 @@ public class Put65 extends BaseCommand {
serverConnection.setAsTrue(RESPONDED);
if (isDebugEnabled) {
logger.debug("{}: Sent put response back to {} for region {} key {} value {}",
- serverConnection.getName(), serverConnection.getSocketString(), regionName, key, valuePart);
+ serverConnection.getName(), serverConnection.getSocketString(), regionName, key,
+ valuePart);
}
stats.incWritePutResponseTime(DistributionStats.getStatTime() - start);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll.java
index 281f737..ba8b145 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll.java
@@ -91,7 +91,8 @@ public class PutAll extends BaseCommand {
.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), putAllMsg);
errMessage.append(putAllMsg);
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -108,7 +109,8 @@ public class PutAll extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
// part 2: number of keys
numberOfKeysPart = clientMessage.getPart(2);
@@ -126,7 +128,8 @@ public class PutAll extends BaseCommand {
.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), putAllMsg);
errMessage.append(putAllMsg);
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -138,7 +141,8 @@ public class PutAll extends BaseCommand {
.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), putAllMsg);
errMessage.append(putAllMsg);
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -155,8 +159,9 @@ public class PutAll extends BaseCommand {
// isObjectMap.put(key, new Boolean(isObject));
} // for
- if (clientMessage.getNumberOfParts() == (3 + 2 * numberOfKeys + 1)) {// it means optional timeout has
- // been added
+ if (clientMessage.getNumberOfParts() == (3 + 2 * numberOfKeys + 1)) {// it means optional
+ // timeout has
+ // been added
int timeout = clientMessage.getPart(3 + 2 * numberOfKeys).getInt();
serverConnection.setRequestSpecificTimeout(timeout);
}
@@ -179,7 +184,8 @@ public class PutAll extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug("{}: Received putAll request ({} bytes) from {} for region {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName);
}
region.basicBridgePutAll(map, Collections.<Object, VersionTag>emptyMap(),
@@ -188,7 +194,8 @@ public class PutAll extends BaseCommand {
if (region instanceof PartitionedRegion) {
PartitionedRegion pr = (PartitionedRegion) region;
if (pr.getNetworkHopType() != PartitionedRegion.NETWORK_HOP_NONE) {
- writeReplyWithRefreshMetadata(clientMessage, serverConnection, pr, pr.getNetworkHopType());
+ writeReplyWithRefreshMetadata(clientMessage, serverConnection, pr,
+ pr.getNetworkHopType());
pr.clearNetworkHopData();
replyWithMetaData = true;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll70.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll70.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll70.java
index ae2de09..fb2bdb8 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll70.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll70.java
@@ -97,7 +97,8 @@ public class PutAll70 extends BaseCommand {
.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), putAllMsg);
errMessage.append(putAllMsg);
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -114,7 +115,8 @@ public class PutAll70 extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
// part 2: invoke callbacks (used by import)
Part callbacksPart = clientMessage.getPart(2);
@@ -137,7 +139,8 @@ public class PutAll70 extends BaseCommand {
.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), putAllMsg);
errMessage.append(putAllMsg);
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -149,7 +152,8 @@ public class PutAll70 extends BaseCommand {
.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), putAllMsg);
errMessage.append(putAllMsg);
- writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -198,8 +202,9 @@ public class PutAll70 extends BaseCommand {
// isObjectMap.put(key, new Boolean(isObject));
} // for
- if (clientMessage.getNumberOfParts() == (4 + 2 * numberOfKeys + 1)) {// it means optional timeout has
- // been added
+ if (clientMessage.getNumberOfParts() == (4 + 2 * numberOfKeys + 1)) {// it means optional
+ // timeout has
+ // been added
int timeout = clientMessage.getPart(4 + 2 * numberOfKeys).getInt();
serverConnection.setRequestSpecificTimeout(timeout);
}
@@ -231,11 +236,12 @@ public class PutAll70 extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug("{}: Received putAll request ({} bytes) from {} for region {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName);
}
- response = region.basicBridgePutAll(map, retryVersions, serverConnection.getProxyID(), eventId,
- skipCallbacks, null);
+ response = region.basicBridgePutAll(map, retryVersions, serverConnection.getProxyID(),
+ eventId, skipCallbacks, null);
if (!region.getConcurrencyChecksEnabled()) {
// the client only needs this if versioning is being used
response = null;
@@ -244,7 +250,8 @@ public class PutAll70 extends BaseCommand {
if (region instanceof PartitionedRegion) {
PartitionedRegion pr = (PartitionedRegion) region;
if (pr.getNetworkHopType() != PartitionedRegion.NETWORK_HOP_NONE) {
- writeReplyWithRefreshMetadata(clientMessage, response, serverConnection, pr, pr.getNetworkHopType());
+ writeReplyWithRefreshMetadata(clientMessage, response, serverConnection, pr,
+ pr.getNetworkHopType());
pr.clearNetworkHopData();
replyWithMetaData = true;
}
@@ -279,8 +286,8 @@ public class PutAll70 extends BaseCommand {
stats.incProcessPutAllTime(start - oldStart);
}
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending putAll70 response back to {} for region {}: {}", serverConnection.getName(),
- serverConnection.getSocketString(), regionName, response);
+ logger.debug("{}: Sending putAll70 response back to {} for region {}: {}",
+ serverConnection.getName(), serverConnection.getSocketString(), regionName, response);
}
// Starting in 7.0.1 we do not send the keys back
if (response != null && Version.GFE_70.compareTo(serverConnection.getClientVersion()) < 0) {
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll80.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll80.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll80.java
index aed5926..c6c26f7 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll80.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutAll80.java
@@ -111,7 +111,8 @@ public class PutAll80 extends BaseCommand {
.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), putAllMsg);
errMessage.append(putAllMsg);
- writeChunkedErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -131,7 +132,8 @@ public class PutAll80 extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
Breadcrumbs.setEventId(eventId);
@@ -152,10 +154,11 @@ public class PutAll80 extends BaseCommand {
if (logger.isDebugEnabled()) {
StringBuilder buffer = new StringBuilder();
- buffer.append(serverConnection.getName()).append(": Received ").append(this.putAllClassName())
- .append(" request from ").append(serverConnection.getSocketString()).append(" for region ")
- .append(regionName).append(callbackArg != null ? (" callbackArg " + callbackArg) : "")
- .append(" with ").append(numberOfKeys).append(" entries.");
+ buffer.append(serverConnection.getName()).append(": Received ")
+ .append(this.putAllClassName()).append(" request from ")
+ .append(serverConnection.getSocketString()).append(" for region ").append(regionName)
+ .append(callbackArg != null ? (" callbackArg " + callbackArg) : "").append(" with ")
+ .append(numberOfKeys).append(" entries.");
logger.debug(buffer.toString());
}
// building the map
@@ -171,7 +174,8 @@ public class PutAll80 extends BaseCommand {
.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), putAllMsg);
errMessage.append(putAllMsg);
- writeChunkedErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR,
+ errMessage.toString(), serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -183,7 +187,8 @@ public class PutAll80 extends BaseCommand {
.toLocalizedString();
logger.warn("{}: {}", serverConnection.getName(), putAllMsg);
errMessage.append(putAllMsg);
- writeChunkedErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeChunkedErrorResponse(clientMessage, MessageType.PUT_DATA_ERROR,
+ errMessage.toString(), serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -232,9 +237,10 @@ public class PutAll80 extends BaseCommand {
// isObjectMap.put(key, new Boolean(isObject));
} // for
- if (clientMessage.getNumberOfParts() == (BASE_PART_COUNT + 2 * numberOfKeys + 1)) {// it means optional
- // timeout has been
- // added
+ if (clientMessage.getNumberOfParts() == (BASE_PART_COUNT + 2 * numberOfKeys + 1)) {// it means
+ // optional
+ // timeout has been
+ // added
int timeout = clientMessage.getPart(BASE_PART_COUNT + 2 * numberOfKeys).getInt();
serverConnection.setRequestSpecificTimeout(timeout);
}
@@ -265,8 +271,8 @@ public class PutAll80 extends BaseCommand {
*/
}
- response = region.basicBridgePutAll(map, retryVersions, serverConnection.getProxyID(), eventId,
- skipCallbacks, callbackArg);
+ response = region.basicBridgePutAll(map, retryVersions, serverConnection.getProxyID(),
+ eventId, skipCallbacks, callbackArg);
if (!region.getConcurrencyChecksEnabled() || clientIsEmpty || !clientHasCCEnabled) {
// the client only needs this if versioning is being used and the client
// has storage
@@ -281,7 +287,8 @@ public class PutAll80 extends BaseCommand {
if (region instanceof PartitionedRegion) {
PartitionedRegion pr = (PartitionedRegion) region;
if (pr.getNetworkHopType() != PartitionedRegion.NETWORK_HOP_NONE) {
- writeReplyWithRefreshMetadata(clientMessage, response, serverConnection, pr, pr.getNetworkHopType());
+ writeReplyWithRefreshMetadata(clientMessage, response, serverConnection, pr,
+ pr.getNetworkHopType());
pr.clearNetworkHopData();
replyWithMetaData = true;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutUserCredentials.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutUserCredentials.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutUserCredentials.java
index dc3de67..ea5c875 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutUserCredentials.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/PutUserCredentials.java
@@ -51,16 +51,17 @@ public class PutUserCredentials extends BaseCommand {
writeResponse(uniqueId, null, clientMessage, false, serverConnection);
} catch (GemFireSecurityException gfse) {
if (serverConnection.getSecurityLogWriter().warningEnabled()) {
- serverConnection.getSecurityLogWriter().warning(LocalizedStrings.ONE_ARG, serverConnection.getName()
- + ": Security exception: " + gfse.toString()
- + (gfse.getCause() != null ? ", caused by: " + gfse.getCause().toString() : ""));
+ serverConnection.getSecurityLogWriter().warning(LocalizedStrings.ONE_ARG,
+ serverConnection.getName() + ": Security exception: " + gfse.toString()
+ + (gfse.getCause() != null ? ", caused by: " + gfse.getCause().toString()
+ : ""));
}
writeException(clientMessage, gfse, false, serverConnection);
} catch (Exception ex) {
if (serverConnection.getLogWriter().warningEnabled()) {
serverConnection.getLogWriter().warning(
LocalizedStrings.CacheClientNotifier_AN_EXCEPTION_WAS_THROWN_FOR_CLIENT_0_1,
- new Object[] { serverConnection.getProxyID(), ""}, ex);
+ new Object[] {serverConnection.getProxyID(), ""}, ex);
}
writeException(clientMessage, ex, false, serverConnection);
} finally {
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Query.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Query.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Query.java
index 8b5b35e..b7d2810 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Query.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Query.java
@@ -88,7 +88,8 @@ public class Query extends BaseCommandQuery {
}
}
- processQuery(clientMessage, query, queryString, regionNames, start, null, queryContext, serverConnection, true);
+ processQuery(clientMessage, query, queryString, regionNames, start, null, queryContext,
+ serverConnection, true);
} catch (QueryInvalidException e) {
throw new QueryInvalidException(e.getMessage() + queryString);
} catch (QueryExecutionLowMemoryException e) {
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Query651.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Query651.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Query651.java
index 97f5d56..e52fa3f 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Query651.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Query651.java
@@ -61,8 +61,9 @@ public class Query651 extends BaseCommandQuery {
int params = clientMessage.getPart(1).getInt(); // Number of parameters.
// In case of native client there will be extra two parameters at 2 and 3 index.
int paramStartIndex = 2;
- if (clientMessage.getNumberOfParts() > (1 /* type */ + 1 /* query string */ + 1 /* params length */
- + params /* number of params */)) {
+ if (clientMessage
+ .getNumberOfParts() > (1 /* type */ + 1 /* query string */ + 1 /* params length */
+ + params /* number of params */)) {
int timeout = clientMessage.getPart(3).getInt();
serverConnection.setRequestSpecificTimeout(timeout);
paramStartIndex = 4;
@@ -85,8 +86,8 @@ public class Query651 extends BaseCommandQuery {
}
if (logger.isDebugEnabled()) {
- logger.debug("{}: Received query request from {} queryString: {}{}", serverConnection.getName(),
- serverConnection.getSocketString(), queryString,
+ logger.debug("{}: Received query request from {} queryString: {}{}",
+ serverConnection.getName(), serverConnection.getSocketString(), queryString,
(queryParams != null ? (" with num query parameters :" + queryParams.length) : ""));
}
try {
@@ -128,7 +129,8 @@ public class Query651 extends BaseCommandQuery {
}
}
- processQueryUsingParams(clientMessage, query, queryString, regionNames, start, null, queryContext, serverConnection, true, queryParams);
+ processQueryUsingParams(clientMessage, query, queryString, regionNames, start, null,
+ queryContext, serverConnection, true, queryParams);
} catch (QueryInvalidException e) {
throw new QueryInvalidException(e.getMessage() + queryString);
}
[3/3] geode git commit: Run spotlessApply
Posted by kl...@apache.org.
Run spotlessApply
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/b6527b31
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/b6527b31
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/b6527b31
Branch: refs/heads/feature/GEODE-2632-16
Commit: b6527b31cc78c0c1505a654f3c427ca501462be3
Parents: 060faa5
Author: Kirk Lund <kl...@apache.org>
Authored: Fri May 19 15:23:12 2017 -0700
Committer: Kirk Lund <kl...@apache.org>
Committed: Fri May 19 15:23:12 2017 -0700
----------------------------------------------------------------------
.../java/org/apache/geode/GemFireException.java | 7 +-
.../geode/cache/CacheRuntimeException.java | 4 +-
.../geode/internal/cache/ha/HARegionQueue.java | 18 +--
.../cache/tier/sockets/BaseCommand.java | 152 ++++++++++++-------
.../cache/tier/sockets/CacheClientNotifier.java | 8 +-
.../ServerInterestRegistrationMessage.java | 31 ++--
.../cache/tier/sockets/command/AddPdxEnum.java | 3 +-
.../cache/tier/sockets/command/AddPdxType.java | 3 +-
.../cache/tier/sockets/command/ClearRegion.java | 14 +-
.../cache/tier/sockets/command/ClientReady.java | 12 +-
.../tier/sockets/command/CloseConnection.java | 11 +-
.../tier/sockets/command/CommitCommand.java | 3 +-
.../cache/tier/sockets/command/ContainsKey.java | 9 +-
.../tier/sockets/command/ContainsKey66.java | 9 +-
.../tier/sockets/command/CreateRegion.java | 10 +-
.../cache/tier/sockets/command/Default.java | 10 +-
.../cache/tier/sockets/command/Destroy.java | 15 +-
.../cache/tier/sockets/command/Destroy65.java | 34 +++--
.../tier/sockets/command/DestroyRegion.java | 11 +-
.../tier/sockets/command/ExecuteFunction.java | 3 +-
.../tier/sockets/command/ExecuteFunction65.java | 3 +-
.../tier/sockets/command/ExecuteFunction66.java | 3 +-
.../tier/sockets/command/ExecuteFunction70.java | 3 +-
.../sockets/command/ExecuteRegionFunction.java | 3 +-
.../command/ExecuteRegionFunction61.java | 3 +-
.../command/ExecuteRegionFunction65.java | 3 +-
.../command/ExecuteRegionFunction66.java | 3 +-
.../command/ExecuteRegionFunctionSingleHop.java | 3 +-
.../sockets/command/GatewayReceiverCommand.java | 85 +++++------
.../cache/tier/sockets/command/Get70.java | 14 +-
.../cache/tier/sockets/command/GetAll.java | 8 +-
.../cache/tier/sockets/command/GetAll651.java | 8 +-
.../cache/tier/sockets/command/GetAll70.java | 11 +-
.../sockets/command/GetAllWithCallback.java | 11 +-
.../command/GetClientPRMetadataCommand.java | 6 +-
.../command/GetClientPRMetadataCommand66.java | 6 +-
.../sockets/command/GetFunctionAttribute.java | 3 +-
.../tier/sockets/command/GetPDXEnumById.java | 5 +-
.../tier/sockets/command/GetPDXIdForEnum.java | 3 +-
.../tier/sockets/command/GetPDXIdForType.java | 3 +-
.../tier/sockets/command/GetPDXTypeById.java | 5 +-
.../cache/tier/sockets/command/Invalid.java | 7 +-
.../cache/tier/sockets/command/Invalidate.java | 18 ++-
.../cache/tier/sockets/command/KeySet.java | 12 +-
.../cache/tier/sockets/command/MakePrimary.java | 7 +-
.../cache/tier/sockets/command/PeriodicAck.java | 5 +-
.../cache/tier/sockets/command/Ping.java | 11 +-
.../cache/tier/sockets/command/Put.java | 25 +--
.../cache/tier/sockets/command/Put61.java | 20 ++-
.../cache/tier/sockets/command/Put65.java | 35 +++--
.../cache/tier/sockets/command/PutAll.java | 23 ++-
.../cache/tier/sockets/command/PutAll70.java | 31 ++--
.../cache/tier/sockets/command/PutAll80.java | 35 +++--
.../sockets/command/PutUserCredentials.java | 9 +-
.../cache/tier/sockets/command/Query.java | 3 +-
.../cache/tier/sockets/command/Query651.java | 12 +-
.../command/RegisterDataSerializers.java | 12 +-
.../sockets/command/RegisterInstantiators.java | 14 +-
.../tier/sockets/command/RegisterInterest.java | 21 +--
.../sockets/command/RegisterInterest61.java | 19 +--
.../sockets/command/RegisterInterestList.java | 18 ++-
.../sockets/command/RegisterInterestList61.java | 18 ++-
.../sockets/command/RegisterInterestList66.java | 15 +-
.../cache/tier/sockets/command/RemoveAll.java | 36 +++--
.../tier/sockets/command/RemoveUserAuth.java | 4 +-
.../cache/tier/sockets/command/Request.java | 14 +-
.../tier/sockets/command/RequestEventValue.java | 20 ++-
.../cache/tier/sockets/command/Size.java | 6 +-
.../command/TXSynchronizationCommand.java | 13 +-
.../sockets/command/UnregisterInterest.java | 14 +-
.../sockets/command/UnregisterInterestList.java | 11 +-
.../command/UpdateClientNotification.java | 3 +-
.../cache/tier/sockets/command/CloseCQ.java | 16 +-
.../cache/tier/sockets/command/ExecuteCQ.java | 13 +-
.../cache/tier/sockets/command/ExecuteCQ61.java | 16 +-
.../cache/tier/sockets/command/GetCQStats.java | 12 +-
.../tier/sockets/command/GetDurableCQs.java | 10 +-
.../cache/tier/sockets/command/MonitorCQ.java | 18 ++-
.../cache/tier/sockets/command/StopCQ.java | 16 +-
79 files changed, 677 insertions(+), 474 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/GemFireException.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/GemFireException.java b/geode-core/src/main/java/org/apache/geode/GemFireException.java
index 3a69307..cd80019 100644
--- a/geode-core/src/main/java/org/apache/geode/GemFireException.java
+++ b/geode-core/src/main/java/org/apache/geode/GemFireException.java
@@ -19,8 +19,7 @@ package org.apache.geode;
* GemFire.
* <p>
* Since these exceptions are unchecked, this class really <em>ought</em> to be called
- * {@code GemFireRuntimeException}; however, the current name is retained for compatibility's
- * sake.
+ * {@code GemFireRuntimeException}; however, the current name is retained for compatibility's sake.
* <p>
* This class is abstract to enforce throwing more specific exception types. Please avoid using
* GemFireException to describe an arbitrary error condition
@@ -60,8 +59,8 @@ public abstract class GemFireException extends RuntimeException {
}
/**
- * Returns the root cause of this {@code GemFireException} or {@code null} if the cause
- * is nonexistent or unknown.
+ * Returns the root cause of this {@code GemFireException} or {@code null} if the cause is
+ * nonexistent or unknown.
*/
public Throwable getRootCause() {
if (this.getCause() == null) {
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/cache/CacheRuntimeException.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/CacheRuntimeException.java b/geode-core/src/main/java/org/apache/geode/cache/CacheRuntimeException.java
index 89b596f..7732e96 100644
--- a/geode-core/src/main/java/org/apache/geode/cache/CacheRuntimeException.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/CacheRuntimeException.java
@@ -41,8 +41,8 @@ public abstract class CacheRuntimeException extends GemFireException {
}
/**
- * Constructs an instance of {@code CacheRuntimeException} with the specified detail message
- * and cause.
+ * Constructs an instance of {@code CacheRuntimeException} with the specified detail message and
+ * cause.
*
* @param msg the detail message
* @param cause the causal Throwable
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java
index c0d3342..66e34b9 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java
@@ -2059,7 +2059,7 @@ public class HARegionQueue implements RegionQueue {
private static class BlockingHARegionQueue extends HARegionQueue {
private static final String EVENT_ENQUEUE_WAIT_TIME_NAME =
- DistributionConfig.GEMFIRE_PREFIX + "subscription.EVENT_ENQUEUE_WAIT_TIME";
+ DistributionConfig.GEMFIRE_PREFIX + "subscription.EVENT_ENQUEUE_WAIT_TIME";
private static final int DEFAULT_EVENT_ENQUEUE_WAIT_TIME = 100;
@@ -2068,7 +2068,7 @@ public class HARegionQueue implements RegionQueue {
* logged.
*/
private static final String MAX_QUEUE_LOG_FREQUENCY =
- DistributionConfig.GEMFIRE_PREFIX + "logFrequency.clientQueueReachedMaxLimit";
+ DistributionConfig.GEMFIRE_PREFIX + "logFrequency.clientQueueReachedMaxLimit";
private static final long DEFAULT_LOG_FREQUENCY = 1000;
@@ -2095,8 +2095,7 @@ public class HARegionQueue implements RegionQueue {
private final Object permitMon = new Object();
/**
- * Lock on which the take & remove threads block awaiting data from put
- * operations
+ * Lock on which the take & remove threads block awaiting data from put operations
*/
private final StoppableReentrantLock lock;
@@ -2107,9 +2106,9 @@ public class HARegionQueue implements RegionQueue {
/**
* System property value denoting the time in milliseconds. Any thread putting an event into a
- * subscription queue, which is full, will wait this much time for the queue to make space. It'll
- * then enqueue the event possibly causing the queue to grow beyond its capacity/max-size. See
- * #51400.
+ * subscription queue, which is full, will wait this much time for the queue to make space.
+ * It'll then enqueue the event possibly causing the queue to grow beyond its capacity/max-size.
+ * See #51400.
*/
private final int enqueueEventWaitTime;
@@ -2142,8 +2141,7 @@ public class HARegionQueue implements RegionQueue {
}
private static int calcEnqueueEventWaitTime() {
- int value =
- Integer.getInteger(EVENT_ENQUEUE_WAIT_TIME_NAME, DEFAULT_EVENT_ENQUEUE_WAIT_TIME);
+ int value = Integer.getInteger(EVENT_ENQUEUE_WAIT_TIME_NAME, DEFAULT_EVENT_ENQUEUE_WAIT_TIME);
if (value < 0) {
value = DEFAULT_EVENT_ENQUEUE_WAIT_TIME;
}
@@ -2209,7 +2207,7 @@ public class HARegionQueue implements RegionQueue {
if ((this.maxQueueSizeHitCount % this.logFrequency) == 0) {
logger.warn(LocalizedMessage.create(
LocalizedStrings.HARegionQueue_CLIENT_QUEUE_FOR_0_IS_FULL,
- new Object[] { this.region.getName() }));
+ new Object[] {this.region.getName()}));
this.maxQueueSizeHitCount = 0;
}
++this.maxQueueSizeHitCount;
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/BaseCommand.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/BaseCommand.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/BaseCommand.java
index f09c854..1fb8c8c 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/BaseCommand.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/BaseCommand.java
@@ -87,7 +87,8 @@ public abstract class BaseCommand implements Command {
private static final byte[] OK_BYTES = new byte[] {0};
- public static final int MAXIMUM_CHUNK_SIZE = Integer.getInteger("BridgeServer.MAXIMUM_CHUNK_SIZE", 100);
+ public static final int MAXIMUM_CHUNK_SIZE =
+ Integer.getInteger("BridgeServer.MAXIMUM_CHUNK_SIZE", 100);
/** Whether to suppress logging of IOExceptions */
private static final boolean SUPPRESS_IO_EXCEPTION_LOGGING =
@@ -99,14 +100,16 @@ public abstract class BaseCommand implements Command {
* of them completes or fails. The bytes are computed based in the size sent in the incoming msg
* header.
*/
- private static final int MAX_INCOMING_DATA = Integer.getInteger("BridgeServer.MAX_INCOMING_DATA", -1);
+ private static final int MAX_INCOMING_DATA =
+ Integer.getInteger("BridgeServer.MAX_INCOMING_DATA", -1);
/**
* Maximum number of concurrent incoming client messages that a bridge server will allow. Once a
* server is working on this number additional incoming client messages will wait until one of
* them completes or fails.
*/
- private static final int MAX_INCOMING_MESSAGES = Integer.getInteger("BridgeServer.MAX_INCOMING_MSGS", -1);
+ private static final int MAX_INCOMING_MESSAGES =
+ Integer.getInteger("BridgeServer.MAX_INCOMING_MSGS", -1);
private static final Semaphore INCOMING_DATA_LIMITER;
@@ -192,8 +195,10 @@ public abstract class BaseCommand implements Command {
*
* @return true if thread should masquerade as a transactional thread.
*/
- protected boolean shouldMasqueradeForTx(Message clientMessage, ServerConnection serverConnection) {
- return serverConnection.getClientVersion().compareTo(Version.GFE_66) >= 0 && clientMessage.getTransactionId() > TXManagerImpl.NOTX;
+ protected boolean shouldMasqueradeForTx(Message clientMessage,
+ ServerConnection serverConnection) {
+ return serverConnection.getClientVersion().compareTo(Version.GFE_66) >= 0
+ && clientMessage.getTransactionId() > TXManagerImpl.NOTX;
}
/**
@@ -260,8 +265,8 @@ public abstract class BaseCommand implements Command {
return tag;
}
- public abstract void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
- throws IOException, ClassNotFoundException, InterruptedException;
+ public abstract void cmdExecute(Message clientMessage, ServerConnection serverConnection,
+ long start) throws IOException, ClassNotFoundException, InterruptedException;
protected void writeReply(Message origMsg, ServerConnection serverConnection) throws IOException {
Message replyMsg = serverConnection.getReplyMessage();
@@ -292,7 +297,8 @@ public abstract class BaseCommand implements Command {
}
}
- private static void handleEOFException(Message msg, ServerConnection serverConnection, Exception eof) {
+ private static void handleEOFException(Message msg, ServerConnection serverConnection,
+ Exception eof) {
CachedRegionHelper crHelper = serverConnection.getCachedRegionHelper();
CacheServerStats stats = serverConnection.getCacheServerStats();
boolean potentialModification = serverConnection.getPotentialModification();
@@ -307,7 +313,8 @@ public abstract class BaseCommand implements Command {
int transId = msg != null ? msg.getTransactionId() : Integer.MIN_VALUE;
logger.warn(LocalizedMessage.create(
LocalizedStrings.BaseCommand_0_EOFEXCEPTION_DURING_A_WRITE_OPERATION_ON_REGION__1_KEY_2_MESSAGEID_3,
- new Object[] {serverConnection.getName(), serverConnection.getModRegion(), serverConnection.getModKey(), transId }));
+ new Object[] {serverConnection.getName(), serverConnection.getModRegion(),
+ serverConnection.getModKey(), transId}));
} else {
logger.debug("EOF exception", eof);
logger.info(LocalizedMessage.create(
@@ -332,7 +339,8 @@ public abstract class BaseCommand implements Command {
serverConnection.setClientDisconnectedException(e);
}
- private static void handleIOException(Message msg, ServerConnection serverConnection, Exception e) {
+ private static void handleIOException(Message msg, ServerConnection serverConnection,
+ Exception e) {
CachedRegionHelper crHelper = serverConnection.getCachedRegionHelper();
boolean potentialModification = serverConnection.getPotentialModification();
@@ -342,7 +350,8 @@ public abstract class BaseCommand implements Command {
int transId = msg != null ? msg.getTransactionId() : Integer.MIN_VALUE;
logger.warn(LocalizedMessage.create(
LocalizedStrings.BaseCommand_0_UNEXPECTED_IOEXCEPTION_DURING_OPERATION_FOR_REGION_1_KEY_2_MESSID_3,
- new Object[] {serverConnection.getName(), serverConnection.getModRegion(), serverConnection.getModKey(), transId }),
+ new Object[] {serverConnection.getName(), serverConnection.getModRegion(),
+ serverConnection.getModKey(), transId}),
e);
} else {
logger.warn(LocalizedMessage.create(LocalizedStrings.BaseCommand_0_UNEXPECTED_IOEXCEPTION,
@@ -354,7 +363,8 @@ public abstract class BaseCommand implements Command {
serverConnection.setClientDisconnectedException(e);
}
- private static void handleShutdownException(Message msg, ServerConnection serverConnection, Exception e) {
+ private static void handleShutdownException(Message msg, ServerConnection serverConnection,
+ Exception e) {
CachedRegionHelper crHelper = serverConnection.getCachedRegionHelper();
boolean potentialModification = serverConnection.getPotentialModification();
@@ -363,11 +373,14 @@ public abstract class BaseCommand implements Command {
int transId = msg != null ? msg.getTransactionId() : Integer.MIN_VALUE;
logger.warn(LocalizedMessage.create(
LocalizedStrings.BaseCommand_0_UNEXPECTED_SHUTDOWNEXCEPTION_DURING_OPERATION_ON_REGION_1_KEY_2_MESSAGEID_3,
- new Object[] {serverConnection.getName(), serverConnection.getModRegion(), serverConnection.getModKey(), transId }),
+ new Object[] {serverConnection.getName(), serverConnection.getModRegion(),
+ serverConnection.getModKey(), transId}),
e);
} else {
- logger.warn(LocalizedMessage.create(
- LocalizedStrings.BaseCommand_0_UNEXPECTED_SHUTDOWNEXCEPTION, serverConnection.getName()), e);
+ logger.warn(
+ LocalizedMessage.create(LocalizedStrings.BaseCommand_0_UNEXPECTED_SHUTDOWNEXCEPTION,
+ serverConnection.getName()),
+ e);
}
}
serverConnection.setFlagProcessMessagesAsFalse();
@@ -399,12 +412,14 @@ public abstract class BaseCommand implements Command {
if (!wroteExceptionResponse) {
logger.warn(LocalizedMessage.create(
LocalizedStrings.BaseCommand_0_UNEXPECTED_EXCEPTION_DURING_OPERATION_ON_REGION_1_KEY_2_MESSAGEID_3,
- new Object[] {serverConnection.getName(), serverConnection.getModRegion(), serverConnection.getModKey(), transId }),
+ new Object[] {serverConnection.getName(), serverConnection.getModRegion(),
+ serverConnection.getModKey(), transId}),
e);
} else {
if (logger.isDebugEnabled()) {
logger.debug("{}: Exception during operation on region: {} key: {} messageId: {}",
- serverConnection.getName(), serverConnection.getModRegion(), serverConnection.getModKey(), transId, e);
+ serverConnection.getName(), serverConnection.getModRegion(),
+ serverConnection.getModKey(), transId, e);
}
}
} else {
@@ -426,7 +441,8 @@ public abstract class BaseCommand implements Command {
}
}
- private static void handleThrowable(Message msg, ServerConnection serverConnection, Throwable th) {
+ private static void handleThrowable(Message msg, ServerConnection serverConnection,
+ Throwable th) {
boolean requiresResponse = serverConnection.getTransientFlag(REQUIRES_RESPONSE);
boolean responded = serverConnection.getTransientFlag(RESPONDED);
boolean requiresChunkedResponse = serverConnection.getTransientFlag(REQUIRES_CHUNKED_RESPONSE);
@@ -435,8 +451,10 @@ public abstract class BaseCommand implements Command {
try {
try {
if (th instanceof Error) {
- logger.fatal(LocalizedMessage.create(
- LocalizedStrings.BaseCommand_0_UNEXPECTED_ERROR_ON_SERVER, serverConnection.getName()), th);
+ logger.fatal(
+ LocalizedMessage.create(LocalizedStrings.BaseCommand_0_UNEXPECTED_ERROR_ON_SERVER,
+ serverConnection.getName()),
+ th);
}
if (requiresResponse && !responded) {
if (requiresChunkedResponse) {
@@ -452,7 +470,8 @@ public abstract class BaseCommand implements Command {
int transId = msg != null ? msg.getTransactionId() : Integer.MIN_VALUE;
logger.warn(LocalizedMessage.create(
LocalizedStrings.BaseCommand_0_UNEXPECTED_EXCEPTION_DURING_OPERATION_ON_REGION_1_KEY_2_MESSAGEID_3,
- new Object[] {serverConnection.getName(), serverConnection.getModRegion(), serverConnection.getModKey(), transId }),
+ new Object[] {serverConnection.getName(), serverConnection.getModRegion(),
+ serverConnection.getModKey(), transId}),
th);
} else {
logger.warn(LocalizedMessage.create(LocalizedStrings.BaseCommand_0_UNEXPECTED_EXCEPTION,
@@ -471,15 +490,19 @@ public abstract class BaseCommand implements Command {
}
}
- protected static void writeChunkedException(Message origMsg, Throwable e, ServerConnection serverConnection) throws IOException {
- writeChunkedException(origMsg, e, serverConnection, serverConnection.getChunkedResponseMessage());
+ protected static void writeChunkedException(Message origMsg, Throwable e,
+ ServerConnection serverConnection) throws IOException {
+ writeChunkedException(origMsg, e, serverConnection,
+ serverConnection.getChunkedResponseMessage());
}
- protected static void writeChunkedException(Message origMsg, Throwable e, ServerConnection serverConnection, ChunkedMessage originalResponse) throws IOException {
+ protected static void writeChunkedException(Message origMsg, Throwable e,
+ ServerConnection serverConnection, ChunkedMessage originalResponse) throws IOException {
writeChunkedException(origMsg, e, serverConnection, originalResponse, 2);
}
- private static void writeChunkedException(Message origMsg, Throwable exception, ServerConnection serverConnection, ChunkedMessage originalResponse, int numOfParts)
+ private static void writeChunkedException(Message origMsg, Throwable exception,
+ ServerConnection serverConnection, ChunkedMessage originalResponse, int numOfParts)
throws IOException {
Throwable e = getClientException(serverConnection, exception);
ChunkedMessage chunkedResponseMsg = serverConnection.getChunkedResponseMessage();
@@ -492,8 +515,8 @@ public abstract class BaseCommand implements Command {
chunkedResponseMsg.addStringPart(getExceptionTrace(e));
}
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending exception chunk while reply in progress: {}", serverConnection.getName(),
- e.getMessage(), e);
+ logger.debug("{}: Sending exception chunk while reply in progress: {}",
+ serverConnection.getName(), e.getMessage(), e);
}
} else {
chunkedResponseMsg.setMessageType(MessageType.EXCEPTION);
@@ -506,7 +529,8 @@ public abstract class BaseCommand implements Command {
chunkedResponseMsg.addStringPart(getExceptionTrace(e));
}
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending exception chunk: {}", serverConnection.getName(), e.getMessage(), e);
+ logger.debug("{}: Sending exception chunk: {}", serverConnection.getName(), e.getMessage(),
+ e);
}
}
chunkedResponseMsg.sendChunk(serverConnection);
@@ -673,8 +697,8 @@ public abstract class BaseCommand implements Command {
}
}
- static void writeQueryResponseChunk(Object queryResponseChunk, CollectionType collectionType, boolean lastChunk, ServerConnection serverConnection)
- throws IOException {
+ static void writeQueryResponseChunk(Object queryResponseChunk, CollectionType collectionType,
+ boolean lastChunk, ServerConnection serverConnection) throws IOException {
ChunkedMessage queryResponseMsg = serverConnection.getQueryResponseMessage();
queryResponseMsg.setNumberOfParts(2);
queryResponseMsg.setLastChunk(lastChunk);
@@ -683,7 +707,8 @@ public abstract class BaseCommand implements Command {
queryResponseMsg.sendChunk(serverConnection);
}
- protected static void writeQueryResponseException(Message origMsg, Throwable exception, ServerConnection serverConnection) throws IOException {
+ protected static void writeQueryResponseException(Message origMsg, Throwable exception,
+ ServerConnection serverConnection) throws IOException {
Throwable e = getClientException(serverConnection, exception);
ChunkedMessage queryResponseMsg = serverConnection.getQueryResponseMessage();
ChunkedMessage chunkedResponseMsg = serverConnection.getChunkedResponseMessage();
@@ -696,8 +721,8 @@ public abstract class BaseCommand implements Command {
queryResponseMsg.addObjPart(e);
queryResponseMsg.addStringPart(getExceptionTrace(e));
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending exception chunk while reply in progress: {}", serverConnection.getName(),
- e.getMessage(), e);
+ logger.debug("{}: Sending exception chunk while reply in progress: {}",
+ serverConnection.getName(), e.getMessage(), e);
}
queryResponseMsg.sendChunk(serverConnection);
} else {
@@ -710,7 +735,8 @@ public abstract class BaseCommand implements Command {
chunkedResponseMsg.addObjPart(e);
chunkedResponseMsg.addStringPart(getExceptionTrace(e));
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending exception chunk: {}", serverConnection.getName(), e.getMessage(), e);
+ logger.debug("{}: Sending exception chunk: {}", serverConnection.getName(), e.getMessage(),
+ e);
}
chunkedResponseMsg.sendChunk(serverConnection);
}
@@ -721,7 +747,8 @@ public abstract class BaseCommand implements Command {
// Send chunked response header identifying error message
ChunkedMessage chunkedResponseMsg = serverConnection.getChunkedResponseMessage();
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending error message header type: {} transaction: {}", serverConnection.getName(), messageType, origMsg.getTransactionId());
+ logger.debug("{}: Sending error message header type: {} transaction: {}",
+ serverConnection.getName(), messageType, origMsg.getTransactionId());
}
chunkedResponseMsg.setMessageType(messageType);
chunkedResponseMsg.setTransactionId(origMsg.getTransactionId());
@@ -737,7 +764,8 @@ public abstract class BaseCommand implements Command {
chunkedResponseMsg.sendChunk(serverConnection);
}
- protected static void writeFunctionResponseException(Message origMsg, int messageType, ServerConnection serverConnection, Throwable exception) throws IOException {
+ protected static void writeFunctionResponseException(Message origMsg, int messageType,
+ ServerConnection serverConnection, Throwable exception) throws IOException {
Throwable e = getClientException(serverConnection, exception);
ChunkedMessage functionResponseMsg = serverConnection.getFunctionResponseMessage();
ChunkedMessage chunkedResponseMsg = serverConnection.getChunkedResponseMessage();
@@ -748,8 +776,8 @@ public abstract class BaseCommand implements Command {
functionResponseMsg.addObjPart(e);
functionResponseMsg.addStringPart(getExceptionTrace(e));
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending exception chunk while reply in progress: {}", serverConnection.getName(),
- e.getMessage(), e);
+ logger.debug("{}: Sending exception chunk while reply in progress: {}",
+ serverConnection.getName(), e.getMessage(), e);
}
functionResponseMsg.sendChunk(serverConnection);
} else {
@@ -762,7 +790,8 @@ public abstract class BaseCommand implements Command {
chunkedResponseMsg.addObjPart(e);
chunkedResponseMsg.addStringPart(getExceptionTrace(e));
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending exception chunk: {}", serverConnection.getName(), e.getMessage(), e);
+ logger.debug("{}: Sending exception chunk: {}", serverConnection.getName(), e.getMessage(),
+ e);
}
chunkedResponseMsg.sendChunk(serverConnection);
}
@@ -955,14 +984,17 @@ public abstract class BaseCommand implements Command {
/**
* @param list is a List of entry keys
*/
- private static void sendRegisterInterestResponseChunk(Region region, Object riKey, List list, boolean lastChunk, ServerConnection servConn) throws IOException {
+ private static void sendRegisterInterestResponseChunk(Region region, Object riKey, List list,
+ boolean lastChunk, ServerConnection servConn) throws IOException {
ChunkedMessage chunkedResponseMsg = servConn.getRegisterInterestResponseMessage();
chunkedResponseMsg.setNumberOfParts(1);
chunkedResponseMsg.setLastChunk(lastChunk);
chunkedResponseMsg.addObjPart(list, false);
String regionName = region == null ? " null " : region.getFullPath();
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending{}register interest response chunk for region: {} for keys: {} chunk=<{}>", servConn.getName(), lastChunk ? " last " : " ", regionName, riKey, chunkedResponseMsg);
+ logger.debug(
+ "{}: Sending{}register interest response chunk for region: {} for keys: {} chunk=<{}>",
+ servConn.getName(), lastChunk ? " last " : " ", regionName, riKey, chunkedResponseMsg);
}
chunkedResponseMsg.sendChunk(servConn);
@@ -977,7 +1009,7 @@ public abstract class BaseCommand implements Command {
private static boolean sendTombstonesInRIResults(ServerConnection servConn,
InterestResultPolicy policy) {
return policy == InterestResultPolicy.KEYS_VALUES
- && servConn.getClientVersion().compareTo(Version.GFE_80) >= 0;
+ && servConn.getClientVersion().compareTo(Version.GFE_80) >= 0;
}
/**
@@ -998,7 +1030,8 @@ public abstract class BaseCommand implements Command {
// Handle list of keys
if (region != null) {
for (Object entryKey : keyList) {
- if (region.containsKey(entryKey) || sendTombstonesInRIResults(servConn, policy) && region.containsTombstone(entryKey)) {
+ if (region.containsKey(entryKey)
+ || sendTombstonesInRIResults(servConn, policy) && region.containsTombstone(entryKey)) {
appendInterestResponseKey(region, keyList, entryKey, newKeyList, servConn);
}
@@ -1016,8 +1049,8 @@ public abstract class BaseCommand implements Command {
justification = "Null value handled in sendNewRegisterInterestResponseChunk()")
private static void handleKVSingleton(LocalRegion region, Object entryKey,
boolean serializeValues, ServerConnection servConn) throws IOException {
- VersionedObjectList values = new VersionedObjectList(MAXIMUM_CHUNK_SIZE, true, region == null || region.getAttributes().getConcurrencyChecksEnabled(),
- serializeValues);
+ VersionedObjectList values = new VersionedObjectList(MAXIMUM_CHUNK_SIZE, true,
+ region == null || region.getAttributes().getConcurrencyChecksEnabled(), serializeValues);
if (region != null) {
if (region.containsKey(entryKey) || region.containsTombstone(entryKey)) {
@@ -1083,8 +1116,8 @@ public abstract class BaseCommand implements Command {
return;
}
- VersionedObjectList values = new VersionedObjectList(MAXIMUM_CHUNK_SIZE, true, region == null || region.getAttributes().getConcurrencyChecksEnabled(),
- serializeValues);
+ VersionedObjectList values = new VersionedObjectList(MAXIMUM_CHUNK_SIZE, true,
+ region == null || region.getAttributes().getConcurrencyChecksEnabled(), serializeValues);
if (region != null) {
@@ -1190,7 +1223,7 @@ public abstract class BaseCommand implements Command {
private static boolean isRemovalToken(final Object value) {
return value == Token.REMOVED_PHASE1 || value == Token.REMOVED_PHASE2
- || value == Token.DESTROYED || value == Token.TOMBSTONE;
+ || value == Token.DESTROYED || value == Token.TOMBSTONE;
}
public static void appendNewRegisterInterestResponseChunkFromLocal(LocalRegion region,
@@ -1207,7 +1240,8 @@ public abstract class BaseCommand implements Command {
if (values.size() == MAXIMUM_CHUNK_SIZE) {
// Send the chunk and clear the list
// values.setKeys(null); // Now we need to send keys too.
- sendNewRegisterInterestResponseChunk(region, riKeys != null ? riKeys : "ALL_KEYS", values, false, servConn);
+ sendNewRegisterInterestResponseChunk(region, riKeys != null ? riKeys : "ALL_KEYS", values,
+ false, servConn);
values.clear();
}
} // for
@@ -1245,7 +1279,8 @@ public abstract class BaseCommand implements Command {
}
if (values.size() == MAXIMUM_CHUNK_SIZE) {
// Send the chunk and clear the list
- sendNewRegisterInterestResponseChunk(region, riKeys != null ? riKeys : "ALL_KEYS", values, false, servConn);
+ sendNewRegisterInterestResponseChunk(region, riKeys != null ? riKeys : "ALL_KEYS", values,
+ false, servConn);
values.clear();
}
} // for
@@ -1259,9 +1294,9 @@ public abstract class BaseCommand implements Command {
chunkedResponseMsg.addObjPart(list, false);
String regionName = region == null ? " null " : region.getFullPath();
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sending{}register interest response chunk for region: {} for keys: {} chunk=<{}>",
- servConn.getName(), lastChunk ? " last " : " ", regionName, riKey, chunkedResponseMsg
- );
+ logger.debug(
+ "{}: Sending{}register interest response chunk for region: {} for keys: {} chunk=<{}>",
+ servConn.getName(), lastChunk ? " last " : " ", regionName, riKey, chunkedResponseMsg);
}
chunkedResponseMsg.sendChunk(servConn);
}
@@ -1341,8 +1376,8 @@ public abstract class BaseCommand implements Command {
handleKVKeysPR((PartitionedRegion) region, keyList, serializeValues, servConn);
return;
}
- VersionedObjectList values = new VersionedObjectList(MAXIMUM_CHUNK_SIZE, true, region == null || region.getAttributes().getConcurrencyChecksEnabled(),
- serializeValues);
+ VersionedObjectList values = new VersionedObjectList(MAXIMUM_CHUNK_SIZE, true,
+ region == null || region.getAttributes().getConcurrencyChecksEnabled(), serializeValues);
// Handle list of keys
if (region != null) {
@@ -1384,7 +1419,8 @@ public abstract class BaseCommand implements Command {
* @param entryKey key we're responding to
* @param list list to append to
*/
- private static void appendInterestResponseKey(LocalRegion region, Object riKey, Object entryKey, List list, ServerConnection servConn) throws IOException {
+ private static void appendInterestResponseKey(LocalRegion region, Object riKey, Object entryKey,
+ List list, ServerConnection servConn) throws IOException {
list.add(entryKey);
if (logger.isDebugEnabled()) {
logger.debug("{}: appendInterestResponseKey <{}>; list size was {}; region: {}",
@@ -1397,8 +1433,8 @@ public abstract class BaseCommand implements Command {
}
}
- private static void appendInterestResponseKeys(LocalRegion region, Object riKey, Collection entryKeys, List collector, ServerConnection servConn)
- throws IOException {
+ private static void appendInterestResponseKeys(LocalRegion region, Object riKey,
+ Collection entryKeys, List collector, ServerConnection servConn) throws IOException {
for (final Object entryKey : entryKeys) {
appendInterestResponseKey(region, riKey, entryKey, collector, servConn);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifier.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifier.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifier.java
index 5631184..4c19df2 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifier.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/CacheClientNotifier.java
@@ -125,16 +125,16 @@ public class CacheClientNotifier {
* BridgeServer.SOCKET_BUFFER_SIZE system property.
*/
private static final int socketBufferSize =
- Integer.getInteger("BridgeServer.SOCKET_BUFFER_SIZE", 32768);
+ Integer.getInteger("BridgeServer.SOCKET_BUFFER_SIZE", 32768);
private static final long CLIENT_PING_TASK_PERIOD =
- Long.getLong(DistributionConfig.GEMFIRE_PREFIX + "serverToClientPingPeriod", 60000);
+ Long.getLong(DistributionConfig.GEMFIRE_PREFIX + "serverToClientPingPeriod", 60000);
/**
* package-private to avoid synthetic accessor
*/
static final long CLIENT_PING_TASK_COUNTER =
- Long.getLong(DistributionConfig.GEMFIRE_PREFIX + "serverToClientPingCounter", 3);
+ Long.getLong(DistributionConfig.GEMFIRE_PREFIX + "serverToClientPingCounter", 3);
private static volatile CacheClientNotifier ccnSingleton;
@@ -189,7 +189,7 @@ public class CacheClientNotifier {
* provide a read-only {@code Set} of listeners.
*/
private final Set readableInterestRegistrationListeners =
- Collections.unmodifiableSet(this.writableInterestRegistrationListeners);
+ Collections.unmodifiableSet(this.writableInterestRegistrationListeners);
private final Map<String, DefaultQuery> compiledQueries = new ConcurrentHashMap<>();
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ServerInterestRegistrationMessage.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ServerInterestRegistrationMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ServerInterestRegistrationMessage.java
index 5860982..7118347 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ServerInterestRegistrationMessage.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ServerInterestRegistrationMessage.java
@@ -1,18 +1,16 @@
/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance with the License. You may obtain a
+ * copy of the License at
*
- * http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
*
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
*/
package org.apache.geode.internal.cache.tier.sockets;
@@ -31,7 +29,8 @@ import org.apache.geode.distributed.internal.ReplyProcessor21;
import org.apache.geode.internal.InternalDataSerializer;
/**
- * Send interest registration to another server. Since interest registration performs a state-flush operation this message must not transmitted on an ordered socket.
+ * Send interest registration to another server. Since interest registration performs a state-flush
+ * operation this message must not transmitted on an ordered socket.
* <p>
* Extracted from CacheClientNotifier
*/
@@ -42,7 +41,8 @@ public class ServerInterestRegistrationMessage extends HighPriorityDistributionM
private ClientInterestMessageImpl clientMessage;
private int processorId;
- ServerInterestRegistrationMessage(ClientProxyMembershipID clientId, ClientInterestMessageImpl clientInterestMessage) {
+ ServerInterestRegistrationMessage(ClientProxyMembershipID clientId,
+ ClientInterestMessageImpl clientInterestMessage) {
this.clientId = clientId;
this.clientMessage = clientInterestMessage;
}
@@ -51,7 +51,8 @@ public class ServerInterestRegistrationMessage extends HighPriorityDistributionM
// deserializing in fromData
}
- static void sendInterestChange(DM dm, ClientProxyMembershipID clientId, ClientInterestMessageImpl clientInterestMessage) {
+ static void sendInterestChange(DM dm, ClientProxyMembershipID clientId,
+ ClientInterestMessageImpl clientInterestMessage) {
ServerInterestRegistrationMessage registrationMessage =
new ServerInterestRegistrationMessage(clientId, clientInterestMessage);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/AddPdxEnum.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/AddPdxEnum.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/AddPdxEnum.java
index fb0bd50..2cb36cd 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/AddPdxEnum.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/AddPdxEnum.java
@@ -44,7 +44,8 @@ public class AddPdxEnum extends BaseCommand {
serverConnection.setAsTrue(REQUIRES_RESPONSE);
if (logger.isDebugEnabled()) {
logger.debug("{}: Received get pdx id for enum request ({} parts) from {}",
- serverConnection.getName(), clientMessage.getNumberOfParts(), serverConnection.getSocketString());
+ serverConnection.getName(), clientMessage.getNumberOfParts(),
+ serverConnection.getSocketString());
}
int noOfParts = clientMessage.getNumberOfParts();
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/AddPdxType.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/AddPdxType.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/AddPdxType.java
index 10a065c..3feba0d 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/AddPdxType.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/AddPdxType.java
@@ -44,7 +44,8 @@ public class AddPdxType extends BaseCommand {
serverConnection.setAsTrue(REQUIRES_RESPONSE);
if (logger.isDebugEnabled()) {
logger.debug("{}: Received get pdx id for type request ({} parts) from {}",
- serverConnection.getName(), clientMessage.getNumberOfParts(), serverConnection.getSocketString());
+ serverConnection.getName(), clientMessage.getNumberOfParts(),
+ serverConnection.getSocketString());
}
int noOfParts = clientMessage.getNumberOfParts();
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ClearRegion.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ClearRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ClearRegion.java
index c9c5a9d..ab19954 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ClearRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ClearRegion.java
@@ -78,8 +78,9 @@ public class ClearRegion extends BaseCommand {
}
regionName = regionNamePart.getString();
if (logger.isDebugEnabled()) {
- logger.debug(serverConnection.getName() + ": Received clear region request (" + clientMessage.getPayloadLength()
- + " bytes) from " + serverConnection.getSocketString() + " for region " + regionName);
+ logger.debug(serverConnection.getName() + ": Received clear region request ("
+ + clientMessage.getPayloadLength() + " bytes) from " + serverConnection.getSocketString()
+ + " for region " + regionName);
}
// Process the clear region request
@@ -91,7 +92,8 @@ public class ClearRegion extends BaseCommand {
LocalizedStrings.ClearRegion_THE_INPUT_REGION_NAME_FOR_THE_CLEAR_REGION_REQUEST_IS_NULL
.toLocalizedString();
- writeErrorResponse(clientMessage, MessageType.CLEAR_REGION_DATA_ERROR, errMessage, serverConnection);
+ writeErrorResponse(clientMessage, MessageType.CLEAR_REGION_DATA_ERROR, errMessage,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -108,7 +110,8 @@ public class ClearRegion extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
try {
// Clear the region
@@ -141,7 +144,8 @@ public class ClearRegion extends BaseCommand {
writeReply(clientMessage, serverConnection);
serverConnection.setAsTrue(RESPONDED);
if (logger.isDebugEnabled()) {
- logger.debug(serverConnection.getName() + ": Sent clear region response for region " + regionName);
+ logger.debug(
+ serverConnection.getName() + ": Sent clear region response for region " + regionName);
}
stats.incWriteClearRegionResponseTime(DistributionStats.getStatTime() - start);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ClientReady.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ClientReady.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ClientReady.java
index 053ef8a..cf9c470 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ClientReady.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ClientReady.java
@@ -35,7 +35,8 @@ public class ClientReady extends BaseCommand {
private ClientReady() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
CacheServerStats stats = serverConnection.getCacheServerStats();
{
long oldStart = start;
@@ -47,11 +48,12 @@ public class ClientReady extends BaseCommand {
int clientPort = serverConnection.getSocketPort();
if (logger.isDebugEnabled()) {
logger.debug("{}: Received client ready request ({} bytes) from {} on {}:{}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getProxyID(), clientHost,
- clientPort);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getProxyID(), clientHost, clientPort);
}
- serverConnection.getAcceptor().getCacheClientNotifier().readyForEvents(serverConnection.getProxyID());
+ serverConnection.getAcceptor().getCacheClientNotifier()
+ .readyForEvents(serverConnection.getProxyID());
long oldStart = start;
start = DistributionStats.getStatTime();
@@ -62,7 +64,7 @@ public class ClientReady extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(serverConnection.getName() + ": Processed client ready request from "
- + serverConnection.getProxyID() + " on " + clientHost + ":" + clientPort);
+ + serverConnection.getProxyID() + " on " + clientHost + ":" + clientPort);
}
} finally {
stats.incWriteClientReadyResponseTime(DistributionStats.getStatTime() - start);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CloseConnection.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CloseConnection.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CloseConnection.java
index 378a322..21f0cad 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CloseConnection.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CloseConnection.java
@@ -39,7 +39,8 @@ public class CloseConnection extends BaseCommand {
private CloseConnection() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
CacheServerStats stats = serverConnection.getCacheServerStats();
long oldStart = start;
boolean respondToClient = serverConnection.getClientVersion().compareTo(Version.GFE_90) >= 0;
@@ -64,12 +65,12 @@ public class CloseConnection extends BaseCommand {
byte[] keepaliveByte = keepalivePart.getSerializedForm();
boolean keepalive = (keepaliveByte == null || keepaliveByte[0] == 0) ? false : true;
- serverConnection.getAcceptor().getCacheClientNotifier().setKeepAlive(serverConnection.getProxyID(),
- keepalive);
+ serverConnection.getAcceptor().getCacheClientNotifier()
+ .setKeepAlive(serverConnection.getProxyID(), keepalive);
if (logger.isDebugEnabled()) {
- logger.debug("{}: Processed close request from {}:{}, keepAlive: {}", serverConnection.getName(),
- clientHost, clientPort, keepalive);
+ logger.debug("{}: Processed close request from {}:{}, keepAlive: {}",
+ serverConnection.getName(), clientHost, clientPort, keepalive);
}
} finally {
if (respondToClient) {
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CommitCommand.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CommitCommand.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CommitCommand.java
index b2bba4f..366d77c 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CommitCommand.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CommitCommand.java
@@ -50,7 +50,8 @@ public class CommitCommand extends BaseCommand {
private CommitCommand() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
serverConnection.setAsTrue(REQUIRES_RESPONSE);
TXManagerImpl txMgr = (TXManagerImpl) serverConnection.getCache().getCacheTransactionManager();
InternalDistributedMember client =
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ContainsKey.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ContainsKey.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ContainsKey.java
index 50d1197..9cb2528 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ContainsKey.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ContainsKey.java
@@ -51,7 +51,8 @@ public class ContainsKey extends BaseCommand {
}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
Part regionNamePart = null;
Part keyPart = null;
String regionName = null;
@@ -78,7 +79,8 @@ public class ContainsKey extends BaseCommand {
}
if (logger.isDebugEnabled()) {
logger.debug("{}: Received containsKey request ({} bytes) from {} for region {} key {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName, key);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName, key);
}
// Process the containsKey request
@@ -99,7 +101,8 @@ public class ContainsKey extends BaseCommand {
LocalizedStrings.ContainsKey_THE_INPUT_REGION_NAME_FOR_THE_CONTAINSKEY_REQUEST_IS_NULL
.toLocalizedString();
}
- writeErrorResponse(clientMessage, MessageType.CONTAINS_KEY_DATA_ERROR, errMessage, serverConnection);
+ writeErrorResponse(clientMessage, MessageType.CONTAINS_KEY_DATA_ERROR, errMessage,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ContainsKey66.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ContainsKey66.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ContainsKey66.java
index 53bb414..b2ce055 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ContainsKey66.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ContainsKey66.java
@@ -55,7 +55,8 @@ public class ContainsKey66 extends BaseCommand {
}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
Part regionNamePart = null, keyPart = null;
String regionName = null;
Object key = null;
@@ -82,7 +83,8 @@ public class ContainsKey66 extends BaseCommand {
}
if (logger.isDebugEnabled()) {
logger.debug("{}: Received containsKey request ({} bytes) from {} for region {} key {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName, key);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName, key);
}
// Process the containsKey request
@@ -103,7 +105,8 @@ public class ContainsKey66 extends BaseCommand {
LocalizedStrings.ContainsKey_THE_INPUT_REGION_NAME_FOR_THE_CONTAINSKEY_REQUEST_IS_NULL
.toLocalizedString();
}
- writeErrorResponse(clientMessage, MessageType.CONTAINS_KEY_DATA_ERROR, errMessage, serverConnection);
+ writeErrorResponse(clientMessage, MessageType.CONTAINS_KEY_DATA_ERROR, errMessage,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CreateRegion.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CreateRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CreateRegion.java
index b7ab01b..0dec596 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CreateRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/CreateRegion.java
@@ -41,7 +41,8 @@ public class CreateRegion extends BaseCommand {
}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
Part regionNamePart = null;
String regionName = null;
serverConnection.setAsTrue(REQUIRES_RESPONSE);
@@ -59,8 +60,8 @@ public class CreateRegion extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Received create region request ({} bytes) from {} for parent region {} region {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), parentRegionName,
- regionName);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), parentRegionName, regionName);
}
// Process the create region request
@@ -82,7 +83,8 @@ public class CreateRegion extends BaseCommand {
LocalizedStrings.CreateRegion_THE_INPUT_REGION_NAME_FOR_THE_CREATE_REGION_REQUEST_IS_NULL
.toLocalizedString();
}
- writeErrorResponse(clientMessage, MessageType.CREATE_REGION_DATA_ERROR, errMessage, serverConnection);
+ writeErrorResponse(clientMessage, MessageType.CREATE_REGION_DATA_ERROR, errMessage,
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Default.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Default.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Default.java
index 359e1b4..3daaec5 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Default.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Default.java
@@ -37,14 +37,16 @@ public class Default extends BaseCommand {
private Default() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
// requiresResponse = true; NOT NEEDED... ALWAYS SEND ERROR RESPONSE
logger.fatal(
LocalizedMessage.create(LocalizedStrings.Default_0_UNKNOWN_MESSAGE_TYPE_1_WITH_TX_2_FROM_3,
- new Object[] {
- serverConnection.getName(), MessageType.getString(clientMessage.getMessageType()),
- Integer.valueOf(clientMessage.getTransactionId()), serverConnection.getSocketString()}));
+ new Object[] {serverConnection.getName(),
+ MessageType.getString(clientMessage.getMessageType()),
+ Integer.valueOf(clientMessage.getTransactionId()),
+ serverConnection.getSocketString()}));
writeErrorResponse(clientMessage, MessageType.UNKNOWN_MESSAGE_TYPE_ERROR, serverConnection);
// responded = true; NOT NEEDED... ALWAYS SEND ERROR RESPONSE
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Destroy.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Destroy.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Destroy.java
index 0699c8b..83ab394 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Destroy.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Destroy.java
@@ -90,7 +90,8 @@ public class Destroy extends BaseCommand {
}
if (logger.isDebugEnabled()) {
logger.debug("{}: Received destroy request ({} bytes) from {} for region {} key {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName, key);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName, key);
}
// Process the destroy request
@@ -110,7 +111,8 @@ public class Destroy extends BaseCommand {
.append(LocalizedStrings.Destroy__THE_INPUT_REGION_NAME_FOR_THE_DESTROY_REQUEST_IS_NULL
.toLocalizedString());
}
- writeErrorResponse(clientMessage, MessageType.DESTROY_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.DESTROY_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -128,7 +130,8 @@ public class Destroy extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
try {
// for integrated security
@@ -154,7 +157,7 @@ public class Destroy extends BaseCommand {
// exception happens. Just log it and continue.
logger.info(LocalizedMessage.create(
LocalizedStrings.Destroy_0_DURING_ENTRY_DESTROY_NO_ENTRY_WAS_FOUND_FOR_KEY_1,
- new Object[] { serverConnection.getName(), key}));
+ new Object[] {serverConnection.getName(), key}));
} catch (RegionDestroyedException rde) {
writeException(clientMessage, rde, false, serverConnection);
serverConnection.setAsTrue(RESPONDED);
@@ -198,8 +201,8 @@ public class Destroy extends BaseCommand {
}
serverConnection.setAsTrue(RESPONDED);
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sent destroy response for region {} key {}", serverConnection.getName(), regionName,
- key);
+ logger.debug("{}: Sent destroy response for region {} key {}", serverConnection.getName(),
+ regionName, key);
}
stats.incWriteDestroyResponseTime(DistributionStats.getStatTime() - start);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Destroy65.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Destroy65.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Destroy65.java
index 0ee0fc4..3aebbb5 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Destroy65.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/Destroy65.java
@@ -158,8 +158,9 @@ public class Destroy65 extends BaseCommand {
if (logger.isDebugEnabled()) {
logger.debug(
"{}: Received destroy65 request ({} bytes; op={}) from {} for region {} key {}{} txId {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), operation, serverConnection.getSocketString(),
- regionName, key, (operation == Operation.REMOVE ? " value=" + expectedOldValue : ""),
+ serverConnection.getName(), clientMessage.getPayloadLength(), operation,
+ serverConnection.getSocketString(), regionName, key,
+ (operation == Operation.REMOVE ? " value=" + expectedOldValue : ""),
clientMessage.getTransactionId());
}
boolean entryNotFoundForRemove = false;
@@ -181,7 +182,8 @@ public class Destroy65 extends BaseCommand {
.append(LocalizedStrings.Destroy__THE_INPUT_REGION_NAME_FOR_THE_DESTROY_REQUEST_IS_NULL
.toLocalizedString());
}
- writeErrorResponse(clientMessage, MessageType.DESTROY_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.DESTROY_DATA_ERROR, errMessage.toString(),
+ serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -199,7 +201,8 @@ public class Destroy65 extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
EventIDHolder clientEvent = new EventIDHolder(eventId);
Breadcrumbs.setEventId(eventId);
@@ -236,7 +239,8 @@ public class Destroy65 extends BaseCommand {
}
}
if (operation == null || operation == Operation.DESTROY) {
- region.basicBridgeDestroy(key, callbackArg, serverConnection.getProxyID(), true, clientEvent);
+ region.basicBridgeDestroy(key, callbackArg, serverConnection.getProxyID(), true,
+ clientEvent);
} else {
// this throws exceptions if expectedOldValue checks fail
try {
@@ -254,15 +258,15 @@ public class Destroy65 extends BaseCommand {
}
// try the operation anyway to ensure that it's been distributed to all servers
try {
- region.basicBridgeRemove(key, expectedOldValue, callbackArg, serverConnection.getProxyID(),
- true, clientEvent);
+ region.basicBridgeRemove(key, expectedOldValue, callbackArg,
+ serverConnection.getProxyID(), true, clientEvent);
} catch (EntryNotFoundException e) {
// ignore, and don't set entryNotFoundForRemove because this was a successful
// operation - bug #51664
}
} else {
- region.basicBridgeRemove(key, expectedOldValue, callbackArg, serverConnection.getProxyID(),
- true, clientEvent);
+ region.basicBridgeRemove(key, expectedOldValue, callbackArg,
+ serverConnection.getProxyID(), true, clientEvent);
if (logger.isDebugEnabled()) {
logger.debug("region.remove succeeded");
}
@@ -281,7 +285,7 @@ public class Destroy65 extends BaseCommand {
// exception happens. Just log it and continue.
logger.info(LocalizedMessage.create(
LocalizedStrings.Destroy_0_DURING_ENTRY_DESTROY_NO_ENTRY_WAS_FOUND_FOR_KEY_1,
- new Object[] { serverConnection.getName(), key}));
+ new Object[] {serverConnection.getName(), key}));
entryNotFoundForRemove = true;
} catch (RegionDestroyedException rde) {
writeException(clientMessage, rde, false, serverConnection);
@@ -318,17 +322,19 @@ public class Destroy65 extends BaseCommand {
pr.getNetworkHopType(), clientEvent.getVersionTag());
pr.clearNetworkHopData();
} else {
- writeReply(clientMessage, serverConnection, entryNotFoundForRemove | clientEvent.getIsRedestroyedEntry(),
+ writeReply(clientMessage, serverConnection,
+ entryNotFoundForRemove | clientEvent.getIsRedestroyedEntry(),
clientEvent.getVersionTag());
}
} else {
- writeReply(clientMessage, serverConnection, entryNotFoundForRemove | clientEvent.getIsRedestroyedEntry(),
+ writeReply(clientMessage, serverConnection,
+ entryNotFoundForRemove | clientEvent.getIsRedestroyedEntry(),
clientEvent.getVersionTag());
}
serverConnection.setAsTrue(RESPONDED);
if (logger.isDebugEnabled()) {
- logger.debug("{}: Sent destroy response for region {} key {}", serverConnection.getName(), regionName,
- key);
+ logger.debug("{}: Sent destroy response for region {} key {}", serverConnection.getName(),
+ regionName, key);
}
stats.incWriteDestroyResponseTime(DistributionStats.getStatTime() - start);
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/DestroyRegion.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/DestroyRegion.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/DestroyRegion.java
index de37040..886994e 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/DestroyRegion.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/DestroyRegion.java
@@ -89,7 +89,8 @@ public class DestroyRegion extends BaseCommand {
regionName = regionNamePart.getString();
if (logger.isDebugEnabled()) {
logger.debug("{}: Received destroy region request ({} bytes) from {} for region {}",
- serverConnection.getName(), clientMessage.getPayloadLength(), serverConnection.getSocketString(), regionName);
+ serverConnection.getName(), clientMessage.getPayloadLength(),
+ serverConnection.getSocketString(), regionName);
}
// Process the destroy region request
@@ -101,7 +102,8 @@ public class DestroyRegion extends BaseCommand {
LocalizedStrings.DestroyRegion__THE_INPUT_REGION_NAME_FOR_THE_DESTROY_REGION_REQUEST_IS_NULL
.toLocalizedString());
- writeErrorResponse(clientMessage, MessageType.DESTROY_REGION_DATA_ERROR, errMessage.toString(), serverConnection);
+ writeErrorResponse(clientMessage, MessageType.DESTROY_REGION_DATA_ERROR,
+ errMessage.toString(), serverConnection);
serverConnection.setAsTrue(RESPONDED);
return;
}
@@ -120,7 +122,8 @@ public class DestroyRegion extends BaseCommand {
ByteBuffer eventIdPartsBuffer = ByteBuffer.wrap(eventPart.getSerializedForm());
long threadId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
long sequenceId = EventID.readEventIdPartsFromOptmizedByteArray(eventIdPartsBuffer);
- EventID eventId = new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
+ EventID eventId =
+ new EventID(serverConnection.getEventMemberIDByteArray(), threadId, sequenceId);
try {
// user needs to have data:manage on all regions in order to destory a particular region
@@ -138,7 +141,7 @@ public class DestroyRegion extends BaseCommand {
} catch (DistributedSystemDisconnectedException e) {
// FIXME better exception hierarchy would avoid this check
if (serverConnection.getCachedRegionHelper().getCache().getCancelCriterion()
- .cancelInProgress() != null) {
+ .cancelInProgress() != null) {
if (logger.isDebugEnabled()) {
logger.debug(
"{} ignoring message of type {} from client {} because shutdown occurred during message processing.",
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction.java
index 1d0fc8c..c146d27 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction.java
@@ -64,7 +64,8 @@ public class ExecuteFunction extends BaseCommand {
}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection servConn, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection servConn, long start)
+ throws IOException {
Object function = null;
Object args = null;
MemberMappedArgument memberMappedArg = null;
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction65.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction65.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction65.java
index 4a0a993..23d5b18 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction65.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction65.java
@@ -63,7 +63,8 @@ public class ExecuteFunction65 extends BaseCommand {
ExecuteFunction65() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection servConn, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection servConn, long start)
+ throws IOException {
Object function = null;
Object args = null;
MemberMappedArgument memberMappedArg = null;
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction66.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction66.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction66.java
index f4aac7a..46302bc 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction66.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction66.java
@@ -87,7 +87,8 @@ public class ExecuteFunction66 extends BaseCommand {
ExecuteFunction66() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection servConn, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection servConn, long start)
+ throws IOException {
Object function = null;
Object args = null;
MemberMappedArgument memberMappedArg = null;
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction70.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction70.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction70.java
index bf5f70b..09fe20e 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction70.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction70.java
@@ -51,7 +51,8 @@ public class ExecuteFunction70 extends ExecuteFunction66 {
private ExecuteFunction70() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection serverConnection, long start)
+ throws IOException {
super.cmdExecute(clientMessage, serverConnection, start);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction.java
index 3147fe5..82a378d 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction.java
@@ -63,7 +63,8 @@ public class ExecuteRegionFunction extends BaseCommand {
private ExecuteRegionFunction() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection servConn, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection servConn, long start)
+ throws IOException {
String regionName = null;
Object function = null;
Object args = null;
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction61.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction61.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction61.java
index 73ab621..12919d0 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction61.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction61.java
@@ -63,7 +63,8 @@ public class ExecuteRegionFunction61 extends BaseCommand {
private ExecuteRegionFunction61() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection servConn, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection servConn, long start)
+ throws IOException {
String regionName = null;
Object function = null;
Object args = null;
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction65.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction65.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction65.java
index f1540f9..3be907b 100755
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction65.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction65.java
@@ -60,7 +60,8 @@ public class ExecuteRegionFunction65 extends BaseCommand {
private ExecuteRegionFunction65() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection servConn, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection servConn, long start)
+ throws IOException {
String regionName = null;
Object function = null;
Object args = null;
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java
index 25d69d6..674082c 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java
@@ -64,7 +64,8 @@ public class ExecuteRegionFunction66 extends BaseCommand {
private ExecuteRegionFunction66() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection servConn, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection servConn, long start)
+ throws IOException {
String regionName = null;
Object function = null;
Object args = null;
http://git-wip-us.apache.org/repos/asf/geode/blob/b6527b31/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunctionSingleHop.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunctionSingleHop.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunctionSingleHop.java
index 725f03b..cf96137 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunctionSingleHop.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunctionSingleHop.java
@@ -62,7 +62,8 @@ public class ExecuteRegionFunctionSingleHop extends BaseCommand {
private ExecuteRegionFunctionSingleHop() {}
@Override
- public void cmdExecute(Message clientMessage, ServerConnection servConn, long start) throws IOException {
+ public void cmdExecute(Message clientMessage, ServerConnection servConn, long start)
+ throws IOException {
String regionName = null;
Object function = null;