/*

* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description: 

*

*/

package com.nokia.carbide.remoteconnections.interfaces;

import java.util.Map;

/**

 * Abstract base class providing implementation of in-use semantics of IConnection

 * using a counted map of potential resource strings and implements 

 * {@link IConnection#useConnection(boolean)} allowing external clients to wait

 * for internal clients (service testing) to complete

 */

public abstract class AbstractSynchronizedConnection extends AbstractConnection {

	private Object testingMutex = new Object();

	private boolean testing;

	public AbstractSynchronizedConnection(IConnectionType connectionType, Map<String, String> settings) {

		super(connectionType, settings);

	}

	/**

	 * @return the current resource string value of this connection

	 */

	protected abstract String getCurrentResourceString();

	/**

	 * @return the map of values to counts - should be static to the concrete connection class

	 */

	protected abstract Map<String, Integer> getResourcesMap();

	public boolean isInUse() {

		String resource = getCurrentResourceString();

		synchronized (getResourcesMap()) {

			return getResourcesMap().containsKey(resource);

		}

	}

	public void setInUse(boolean inUse) {

		String resource = getCurrentResourceString();

		synchronized (getResourcesMap()) {

//			System.out.println((inUse?"+":"-")+resource+", thread="+Thread.currentThread().getId());

			if (inUse) {

				Integer count = getResourcesMap().get(resource);

				if (count == null)

					count = 0;

				getResourcesMap().put(resource, ++count);

			}

			else {

				Integer count = getResourcesMap().get(resource);

				if (count != null) {

					count--;

					if (count > 0)

						getResourcesMap().put(resource, count);

					else

						getResourcesMap().remove(resource);

				}

			}

		}

	}

	public void setServiceTestingAndInUse(boolean value) {

		synchronized (testingMutex) {

			testing = value;

			setInUse(value);

		}

	}

	private boolean isTesting() {

		synchronized (testingMutex) {

			return testing;

		}

	}

	public synchronized void useConnection(boolean use) {

		if (use) {

			while (isTesting()) {

				try {

					Thread.sleep(200);

//					System.out.println(getDisplayName() + " was service testing");

				} catch (InterruptedException e) {

				}

			}

		}

		setInUse(use);

	}

	public Object getCurrentResource() {

		return getCurrentResourceString();

	}

}