You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jackrabbit.apache.org by al...@apache.org on 2011/07/12 11:51:13 UTC
svn commit: r1145513 -
/jackrabbit/trunk/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/RepositoryImpl.java
Author: alexparvulescu
Date: Tue Jul 12 09:51:12 2011
New Revision: 1145513
URL: http://svn.apache.org/viewvc?rev=1145513&view=rev
Log:
JCR-3019 RepositoryImpl.activeSessions should use Session instead of SessionImpl
Modified:
jackrabbit/trunk/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/RepositoryImpl.java
Modified: jackrabbit/trunk/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/RepositoryImpl.java
URL: http://svn.apache.org/viewvc/jackrabbit/trunk/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/RepositoryImpl.java?rev=1145513&r1=1145512&r2=1145513&view=diff
==============================================================================
--- jackrabbit/trunk/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/RepositoryImpl.java (original)
+++ jackrabbit/trunk/jackrabbit-core/src/main/java/org/apache/jackrabbit/core/RepositoryImpl.java Tue Jul 12 09:51:12 2011
@@ -206,7 +206,7 @@ public class RepositoryImpl extends Abst
/**
* active sessions (weak references)
*/
- private final Map<SessionImpl, SessionImpl> activeSessions =
+ private final Map<Session, Session> activeSessions =
new ReferenceMap(ReferenceMap.WEAK, ReferenceMap.WEAK);
// flag indicating if repository has been shut down
@@ -1113,14 +1113,14 @@ public class RepositoryImpl extends Abst
// (copy sessions to array to avoid ConcurrentModificationException;
// manually copy entries rather than calling ReferenceMap#toArray() in
// order to work around http://issues.apache.org/bugzilla/show_bug.cgi?id=25551)
- List<SessionImpl> sa;
+ List<Session> sa;
synchronized (activeSessions) {
- sa = new ArrayList<SessionImpl>(activeSessions.size());
- for (SessionImpl session : activeSessions.values()) {
+ sa = new ArrayList<Session>(activeSessions.size());
+ for (Session session : activeSessions.values()) {
sa.add(session);
}
}
- for (SessionImpl session : sa) {
+ for (Session session : sa) {
if (session != null) {
session.logout();
}
@@ -2398,7 +2398,7 @@ public class RepositoryImpl extends Abst
synchronized (activeSessions) {
// remove workspaces with active sessions
- for (SessionImpl ses : activeSessions.values()) {
+ for (Session ses : activeSessions.values()) {
wspNames.remove(ses.getWorkspace().getName());
}
}