moparisthebest/k-9
1
0
Fork 0
mirror of https://github.com/moparisthebest/k-9 synced 2025-02-17 07:30:16 -05:00
Code Issues Releases Wiki Activity

astyle

Browse Source
This commit is contained in:
Jesse Vincent 2010-10-08 05:34:46 +00:00
parent 945bccd633
commit 7881039cbf
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/com/fsck/k9/provider/MessageProvider.java
View File

@ -52,7 +52,7 @@ public class MessageProvider extends ContentProvider
{ {
/** /**
* The number of milliseconds since Jan. 1, 1970, midnight GMT. * The number of milliseconds since Jan. 1, 1970, midnight GMT.
* *
* <P>Type: INTEGER (long)</P> * <P>Type: INTEGER (long)</P>
*/ */
String SEND_DATE = "date"; String SEND_DATE = "date";
@ -545,7 +545,7 @@ public class MessageProvider extends ContentProvider
@Override @Override
public Cursor query(Uri uri, String[] projection, String selection, String[] selectionArgs, public Cursor query(Uri uri, String[] projection, String selection, String[] selectionArgs,
String sortOrder) throws Exception String sortOrder) throws Exception
{ {
mSemaphore.acquire(); mSemaphore.acquire();
@ -564,7 +564,8 @@ public class MessageProvider extends ContentProvider
final WeakReference<MonitoredCursor> weakReference = new WeakReference<MonitoredCursor>(wrapped); final WeakReference<MonitoredCursor> weakReference = new WeakReference<MonitoredCursor>(wrapped);
/* make sure the cursor is closed after 30 seconds */ /* make sure the cursor is closed after 30 seconds */
mScheduledPool.schedule(new Runnable() { mScheduledPool.schedule(new Runnable()
{
@Override @Override
public void run() public void run()
@ -582,11 +583,12 @@ public class MessageProvider extends ContentProvider
Log.w(K9.LOG_TAG, "Exception while forcibly closing cursor", e); Log.w(K9.LOG_TAG, "Exception while forcibly closing cursor", e);
} }
} }
}}, 30, TimeUnit.SECONDS); }
}, 30, TimeUnit.SECONDS);
return wrapped; return wrapped;
} }
} }
/** /**
@ -676,9 +678,11 @@ public class MessageProvider extends ContentProvider
private MessageHelper mMessageHelper; private MessageHelper mMessageHelper;
/* package */ Semaphore mSemaphore = new Semaphore(1); /* package */
Semaphore mSemaphore = new Semaphore(1);
/* package */ ScheduledExecutorService mScheduledPool = Executors.newScheduledThreadPool(1); /* package */
ScheduledExecutorService mScheduledPool = Executors.newScheduledThreadPool(1);
@Override @Override
public boolean onCreate() public boolean onCreate()
@ -696,7 +700,8 @@ public class MessageProvider extends ContentProvider
{ {
Log.v(K9.LOG_TAG, "Registering content resolver notifier"); Log.v(K9.LOG_TAG, "Registering content resolver notifier");
MessagingController.getInstance(application).addListener(new MessagingListener() { MessagingController.getInstance(application).addListener(new MessagingListener()
{
@Override @Override
public void searchStats(final AccountStats stats) public void searchStats(final AccountStats stats)
{ {