From fbda6e0892dcfcc8dd43d21f6fb134aabb8d0cac Mon Sep 17 00:00:00 2001
From: jarnou <jarnou@localhost>
Date: Tue, 03 Jul 2007 09:29:17 +0000
Subject: [PATCH] Commits the refactoring of the core server to provide support for proxy/distribution/virtual functionnalities. This includes the new set of local operations, as well as the workflow and networkgroup support.
---
opends/src/server/org/opends/server/api/ClientConnection.java | 35 +++++++++++++++++++++++++++++++++--
1 files changed, 33 insertions(+), 2 deletions(-)
diff --git a/opends/src/server/org/opends/server/api/ClientConnection.java b/opends/src/server/org/opends/server/api/ClientConnection.java
index 46475d5..cacc625 100644
--- a/opends/src/server/org/opends/server/api/ClientConnection.java
+++ b/opends/src/server/org/opends/server/api/ClientConnection.java
@@ -41,6 +41,8 @@
import org.opends.server.core.PersistentSearch;
import org.opends.server.core.PluginConfigManager;
import org.opends.server.core.SearchOperation;
+import org.opends.server.core.NetworkGroup;
+import org.opends.server.types.AbstractOperation;
import org.opends.server.types.Attribute;
import org.opends.server.types.AttributeType;
import org.opends.server.types.AttributeValue;
@@ -117,6 +119,9 @@
// A set of persistent searches registered for this client.
private CopyOnWriteArrayList<PersistentSearch> persistentSearches;
+ // The network group to which the connection belongs to.
+ private NetworkGroup networkGroup;
+
/**
@@ -136,6 +141,7 @@
lookthroughLimit = DirectoryServer.getLookthroughLimit();
finalized = false;
privileges = new HashSet<Privilege>();
+ networkGroup = NetworkGroup.getDefaultNetworkGroup();
}
@@ -653,7 +659,8 @@
* @return The set of operations in progress for this client
* connection.
*/
- public abstract Collection<Operation> getOperationsInProgress();
+ public abstract Collection<AbstractOperation>
+ getOperationsInProgress();
@@ -667,7 +674,8 @@
* or <CODE>null</CODE> if no such operation could be
* found.
*/
- public abstract Operation getOperationInProgress(int messageID);
+ public abstract AbstractOperation
+ getOperationInProgress(int messageID);
@@ -1542,5 +1550,28 @@
{
finalizeConnectionInternal();
}
+
+
+ /**
+ * Returns the network group to which the connection belongs.
+ *
+ * @return the network group attached to the connection
+ */
+ public NetworkGroup getNetworkGroup()
+ {
+ return networkGroup;
+ }
+
+ /**
+ * Sets the network group to which the connection belongs.
+ *
+ * @param networkGroup the network group to which the
+ * connections belongs to
+ */
+ public void setNetworkGroup (NetworkGroup networkGroup)
+ {
+ this.networkGroup = networkGroup;
+ }
+
}
--
Gitblit v1.10.0