From 40cef7d36084fbe86d34cfa497628d8972c4c9e7 Mon Sep 17 00:00:00 2001
From: pgamba <pgamba@localhost>
Date: Thu, 29 Mar 2007 17:53:41 +0000
Subject: [PATCH]
---
opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java | 20 ++++++++++++++++++++
1 files changed, 20 insertions(+), 0 deletions(-)
diff --git a/opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java b/opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java
index 8fb1917..a985e6b 100644
--- a/opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java
+++ b/opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java
@@ -27,6 +27,8 @@
package org.opends.server.synchronization.plugin;
import static org.opends.server.loggers.Error.logError;
+import static org.opends.server.loggers.debug.DebugLogger.debugEnabled;
+import static org.opends.server.loggers.debug.DebugLogger.debugInfo;
import static org.opends.server.messages.MessageHandler.getMessage;
import static org.opends.server.synchronization.common.LogMessages.*;
import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString;
@@ -345,6 +347,10 @@
{
if (session != null)
{
+ logError(ErrorLogCategory.SYNCHRONIZATION,
+ ErrorLogSeverity.NOTICE,
+ "Broker : connect closing session" , 1);
+
session.close();
session = null;
}
@@ -498,6 +504,7 @@
try
{
SynchronizationMessage msg = session.receive();
+
if (msg instanceof WindowMessage)
{
WindowMessage windowMsg = (WindowMessage) msg;
@@ -544,6 +551,11 @@
connected = false;
try
{
+ if (debugEnabled())
+ {
+ debugInfo("ChangelogBroker Stop Closing session");
+ }
+
session.close();
} catch (IOException e)
{}
@@ -682,4 +694,12 @@
{
return numLostConnections;
}
+
+ private void log(String message)
+ {
+ int msgID = MSGID_UNKNOWN_TYPE;
+ logError(ErrorLogCategory.SYNCHRONIZATION,
+ ErrorLogSeverity.SEVERE_ERROR,
+ message, msgID);
+ }
}
--
Gitblit v1.10.0