DefaultDOManager-old.java

private final Set<String> m_lockedPIDs;

[...]

    /**
     * Creates a new DefaultDOManager.
     */
    public DefaultDOManager(Map<String, String> moduleParameters, Server server, String role)
            throws ModuleInitializationException {
        super(moduleParameters, server, role);
        m_lockedPIDs = new HashSet<String>();
    }

[...]

    private void releaseWriteLock(String pid) {
        synchronized (m_lockedPIDs) {
            m_lockedPIDs.remove(pid);
        }
    }

    private void getWriteLock(String pid) throws ObjectLockedException {
        synchronized (m_lockedPIDs) {
            if (m_lockedPIDs.contains(pid)) {
                throw new ObjectLockedException(pid + " is currently being "
                        + "modified by another thread");
            } else {
                m_lockedPIDs.add(pid);
            }
        }
    }

DefaultDOManager.java

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

[...]
    private final HashMap<String, Lock> m_lockedPIDs;
[...]

    /**
     * Creates a new DefaultDOManager.
     */
    public DefaultDOManager(Map<String, String> moduleParameters, Server server, String role)
            throws ModuleInitializationException {
        super(moduleParameters, server, role);
        m_lockedPIDs = new HashMap<String, Lock>();
    }

[...]

    private void releaseWriteLock(String pid) {
        synchronized (m_lockedPIDs) {
            m_lockedPIDs.remove(pid).unlock();
        }
    }

    private void getWriteLock(String pid) throws ObjectLockedException {
        synchronized (m_lockedPIDs) {
            if ( m_lockedPIDs.containsKey(pid)) {
                 Lock w1 = m_lockedPIDs.get(pid);
                 try {
                 if( !w1.tryLock(5000, TimeUnit.SECONDS)) {
                        throw new ObjectLockedException(pid + " is currently being "
                        + "modified by another thread");
                        }
                 } catch (InterruptedException e) {
                        throw new ObjectLockedException(pid + " is currently being "
                        + "modified by another thread");
                }
            }

            ReentrantReadWriteLock lck = new ReentrantReadWriteLock();
            Lock w = lck.writeLock();
            w.lock();
            m_lockedPIDs.put(pid, w);
        }
    }


[...]