You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by el...@apache.org on 2010/07/20 10:21:33 UTC
svn commit: r965751 -
/directory/apacheds/trunk/core/src/main/java/org/apache/directory/server/core/subtree/SubentryCache.java
Author: elecharny
Date: Tue Jul 20 08:21:33 2010
New Revision: 965751
URL: http://svn.apache.org/viewvc?rev=965751&view=rev
Log:
Made the subentry cache thread safe
Modified:
directory/apacheds/trunk/core/src/main/java/org/apache/directory/server/core/subtree/SubentryCache.java
Modified: directory/apacheds/trunk/core/src/main/java/org/apache/directory/server/core/subtree/SubentryCache.java
URL: http://svn.apache.org/viewvc/directory/apacheds/trunk/core/src/main/java/org/apache/directory/server/core/subtree/SubentryCache.java?rev=965751&r1=965750&r2=965751&view=diff
==============================================================================
--- directory/apacheds/trunk/core/src/main/java/org/apache/directory/server/core/subtree/SubentryCache.java (original)
+++ directory/apacheds/trunk/core/src/main/java/org/apache/directory/server/core/subtree/SubentryCache.java Tue Jul 20 08:21:33 2010
@@ -20,9 +20,9 @@
package org.apache.directory.server.core.subtree;
-import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.directory.shared.ldap.name.DN;
@@ -55,7 +55,7 @@ public class SubentryCache implements It
*/
public SubentryCache()
{
- cache = new HashMap<DN, Subentry>();
+ cache = new ConcurrentHashMap<DN, Subentry>();
cacheSize = new AtomicInteger( 0 );
}
@@ -65,7 +65,7 @@ public class SubentryCache implements It
*/
public SubentryCache( int maxSize )
{
- cache = new HashMap<DN, Subentry>();
+ cache = new ConcurrentHashMap<DN, Subentry>();
cacheSize = new AtomicInteger( 0 );
cacheMaxSize = maxSize;
}
@@ -92,7 +92,6 @@ public class SubentryCache implements It
*/
final Subentry removeSubentry( DN dn )
{
- int k = dn.hashCode();
Subentry oldSubentry = cache.remove( dn );
if ( oldSubentry != null )
@@ -114,7 +113,6 @@ public class SubentryCache implements It
*/
/* No qualifier */ Subentry addSubentry( DN dn, Subentry subentry )
{
- int k = dn.hashCode();
if ( cacheSize.get() > cacheMaxSize )
{
// TODO : Throw an exception here