This is an automated email from the ASF dual-hosted git repository.
markt pushed a commit to branch 7.0.x
in repository https://gitbox.apache.org/repos/asf/tomcat.git
commit 6421a8c0f5beb06683c7a0535560a51fb8c52c62
Author: Mark Thomas <ma...@apache.org>
AuthorDate: Wed May 22 12:07:35 2019 +0100
Refactor #requestCompleted to re-use DeltaSession#getDiff()
---
.../org/apache/catalina/ha/session/DeltaManager.java | 20 ++------------------
1 file changed, 2 insertions(+), 18 deletions(-)
diff --git a/java/org/apache/catalina/ha/session/DeltaManager.java
b/java/org/apache/catalina/ha/session/DeltaManager.java
index 25b3f96..0ee5251 100644
--- a/java/org/apache/catalina/ha/session/DeltaManager.java
+++ b/java/org/apache/catalina/ha/session/DeltaManager.java
@@ -38,7 +38,6 @@ import org.apache.catalina.session.ManagerBase;
import org.apache.catalina.tribes.Member;
import org.apache.catalina.tribes.io.ReplicationStream;
import org.apache.tomcat.util.ExceptionUtils;
-import org.apache.tomcat.util.collections.SynchronizedStack;
import org.apache.tomcat.util.res.StringManager;
/**
@@ -971,8 +970,6 @@ public class DeltaManager extends ClusterManagerBase{
public ClusterMessage requestCompleted(String sessionId, boolean expires) {
DeltaSession session = null;
SessionMessage msg = null;
- SynchronizedStack<DeltaRequest> deltaRequestPool =
getDeltaRequestPool();
- DeltaRequest deltaRequest = null;
try {
session = (DeltaSession) findSession(sessionId);
if (session == null) {
@@ -980,30 +977,17 @@ public class DeltaManager extends ClusterManagerBase{
// removed the session from the Manager.
return null;
}
- DeltaRequest newDeltaRequest = deltaRequestPool.pop();
- if (newDeltaRequest == null) {
- // Will be configured in replaceDeltaRequest()
- newDeltaRequest = new DeltaRequest(null, isRecordAllActions());
- }
- deltaRequest = session.replaceDeltaRequest(newDeltaRequest);
- if (deltaRequest.getSize() > 0) {
+ if (session.isDirty()) {
counterSend_EVT_SESSION_DELTA++;
- byte[] data = deltaRequest.serialize();
msg = new SessionMessageImpl(getName(),
SessionMessage.EVT_SESSION_DELTA,
- data,
+ session.getDiff(),
sessionId,
sessionId + "-" +
System.currentTimeMillis());
}
} catch (IOException x) {
log.error(sm.getString("deltaManager.createMessage.unableCreateDeltaRequest",sessionId),
x);
return null;
- } finally {
- if (deltaRequest != null) {
- // Reset the instance before it is returned to the pool
- deltaRequest.reset();
- deltaRequestPool.push(deltaRequest);
- }
}
if(msg == null) {
if(!expires && !session.isPrimarySession()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org
