/**
 * SqlJetFileLockManager.java
 * Copyright (C) 2009-2013 TMate Software Ltd
 * 
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; version 2 of the License.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * For information on how to redistribute this software under
 * the terms of a license other than GNU General Public License
 * contact TMate Software at support@sqljet.com
 */
package org.tmatesoft.sqljet.core.internal.fs;

import org.tmatesoft.sqljet.core.SqlJetLogDefinitions;
import org.tmatesoft.sqljet.core.internal.SqlJetUtility;

import java.io.IOException;
import java.nio.channels.FileChannel;
import java.nio.channels.FileLock;
import java.nio.channels.OverlappingFileLockException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.logging.Logger;

/**
 * @author TMate Software Ltd.
 * @author Sergey Scherbina (sergey.scherbina@gmail.com)
 * 
 */
public class SqlJetFileLockManager {

    private String filePath;
    private FileChannel fileChannel;
    private static Logger filesLogger = Logger.getLogger(SqlJetLogDefinitions.SQLJET_LOG_FILES);

    public SqlJetFileLockManager(String filePath, FileChannel fileChannel) {
        this.filePath = filePath;
        this.fileChannel = fileChannel;
    }

    private static final Map> locks = new ConcurrentHashMap>();

    private interface ILockCreator {
        FileLock createLock(long position, long size, boolean shared) throws IOException;
    }

    private ILockCreator tryLockCreator = new ILockCreator() {
        public FileLock createLock(long position, long size, boolean shared) throws IOException {
            return fileChannel.tryLock(position, size, shared);
        }
    };

    private ILockCreator lockCreator = new ILockCreator() {
        public FileLock createLock(long position, long size, boolean shared) throws IOException {
            return fileChannel.lock(position, size, shared);
        }
    };

    private FileLock createLock(long position, long size, boolean shared, ILockCreator lockCreator)
            throws IOException {
		synchronized (locks) {
			final SqlJetFileLock lock = getLock(position, size);
			if (lock != null) {
				if (shared) {
					lock.addLock();
					return lock;
				} else {
					return null;
				}
			} else {
                final FileLock fileLock;
                try {
                    fileLock = lockCreator.createLock(position, size, shared);
                } catch (OverlappingFileLockException e) {
                    SqlJetUtility.log(filesLogger, "Cannot lock (%d, %d, %s) of %s: the range overlaps with already existing lock;" +
                            "this may be cause by loading %s class from several class loaders",
                            position, size, shared, filePath, getClass().getSimpleName());
                    return null;
                }
                return addLock(fileLock);
			}
		}
    }

    /**
     * @param fileChannel
     * @param position
     * @param size
     * @param shared
     * @return
     * @throws IOException
     */
    public FileLock tryLock(long position, long size, boolean shared) throws IOException {
		return createLock(position, size, shared, tryLockCreator);
    }

    public FileLock lock(long position, long size, boolean shared) throws IOException {
		return createLock(position, size, shared, lockCreator);
    }

    private SqlJetFileLock getLock(long position, long size) {
        if (locks.containsKey(filePath)) {
            for (SqlJetFileLock fl : locks.get(filePath)) {
                if (fl.overlaps(position, size)) {
                    return fl;
                }
            }
        }
        return null;
    }

    /**
     * @param lock
     * @return
     */
    private SqlJetFileLock addLock(FileLock lock) {
        if (lock != null) {
            final SqlJetFileLock l = new SqlJetFileLock(this, lock);
            if (!locks.containsKey(filePath)) {
                locks.put(filePath, new ArrayList());
            }
            locks.get(filePath).add(l);
            return l;
        } else {
            return null;
        }
    }

    public void deleteLock(SqlJetFileLock lock) {
		synchronized (locks) {
			if (locks.containsKey(filePath)) {
				final List list = locks.get(filePath);
				list.remove(lock);
				if (list.size() == 0) {
					locks.remove(filePath);
				}
			}
		}
    }
}