package com.vaguehope.onosendai.storage;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

import android.content.Context;
import android.os.AsyncTask;

import com.vaguehope.onosendai.C;
import com.vaguehope.onosendai.util.LogWrapper;

public abstract class DbBindingAsyncTask<Params, Progress, Result> extends AsyncTask<Params, Progress, Result> {

	private final Context context;
	private final CountDownLatch dbReadyLatch = new CountDownLatch(1);
	private DbClient bndDb;

	public DbBindingAsyncTask (final Context context) {
		super();
		this.context = context;
	}

	private void connectDb () {
		getLog().d("Binding DB service...");
		final CountDownLatch latch = this.dbReadyLatch;
		this.bndDb = new DbClient(this.context, getLog().getPrefix(), new Runnable() {
			@Override
			public void run () {
				latch.countDown();
				getLog().d("DB service bound.");
			}
		});
	}

	private void disposeDb () {
		if (this.bndDb != null) this.bndDb.dispose();
	}

	private boolean waitForDbReady () {
		boolean dbReady = false;
		try {
			dbReady = this.dbReadyLatch.await(C.DB_CONNECT_TIMEOUT_SECONDS, TimeUnit.SECONDS);
		}
		catch (InterruptedException e) {/**/}
		if (!dbReady) getLog().e("Not updateing: Time out waiting for DB service to connect.");
		return dbReady;
	}

	private DbInterface getDb () {
		final DbClient d = this.bndDb;
		if (d == null) return null;
		return d.getDb();
	}

	protected Context getContext () {
		return this.context;
	}

	@Override
	protected final Result doInBackground (final Params... params) {
		connectDb();
		if (!waitForDbReady()) return null;
		try {
			return doInBackgroundWithDb(getDb(), params);
		}
		finally {
			disposeDb();
		}
	}

	protected abstract LogWrapper getLog ();

	protected abstract Result doInBackgroundWithDb (DbInterface db, final Params... params);

}

package com.vaguehope.onosendai.storage;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

import android.content.Context;
import android.os.AsyncTask;

import com.vaguehope.onosendai.C;
import com.vaguehope.onosendai.util.LogWrapper;

public abstract class DbBindingAsyncTask<Params, Progress, Result> extends AsyncTask<Params, Progress, Result> {

	private final Context context;
	private final CountDownLatch dbReadyLatch = new CountDownLatch(1);
	private DbClient bndDb;

	public DbBindingAsyncTask (final Context context) {
		super();
		this.context = context;
	}

	private void connectDb () {
		getLog().d("Binding DB service...");
		final CountDownLatch latch = this.dbReadyLatch;
		this.bndDb = new DbClient(this.context, getLog().getPrefix(), new Runnable() {
			@Override
			public void run () {
				latch.countDown();
				getLog().d("DB service bound.");
			}
		});
	}

	private void disposeDb () {
		if (this.bndDb != null) this.bndDb.dispose();
	}

	private boolean waitForDbReady () {
		boolean dbReady = false;
		try {
			dbReady = this.dbReadyLatch.await(C.DB_CONNECT_TIMEOUT_SECONDS, TimeUnit.SECONDS);
		}
		catch (InterruptedException e) {/**/}
		if (!dbReady) getLog().e("Time out waiting for DB service to connect.");
		return dbReady;
	}

	private DbInterface getDb () {
		final DbClient d = this.bndDb;
		if (d == null) return null;
		return d.getDb();
	}

	protected Context getContext () {
		return this.context;
	}

	@Override
	protected final Result doInBackground (final Params... params) {
		connectDb();
		if (!waitForDbReady()) return null;
		try {
			return doInBackgroundWithDb(getDb(), params);
		}
		finally {
			disposeDb();
		}
	}

	protected abstract LogWrapper getLog ();

	protected abstract Result doInBackgroundWithDb (DbInterface db, final Params... params);

}

Fix copy-paste logging.