yetangitu/FBReaderJ
1
0
Fork 0
mirror of https://github.com/geometer/FBReaderJ.git synced 2025-10-04 18:29:23 +02:00
Code Issues Releases Wiki Activity

file system watcher (prototype)

Browse source
This commit is contained in:
Nikolay Pultsin 2013-01-12 18:12:32 +04:00
parent 9a4b6407e1
commit 50e5a7e299
1 changed files with 57 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

59
src/org/geometerplus/android/fbreader/libraryService/LibraryService.java
View file

@ -20,18 +20,58 @@
package org.geometerplus.android.fbreader.libraryService;
import java.util.List;
import java.util.LinkedList;
import android.app.Service;
import android.content.Intent;
import android.os.IBinder;
import android.os.FileObserver;
import org.geometerplus.fbreader.library.*;
import org.geometerplus.android.fbreader.library.SQLiteBooksDatabase;
public class LibraryService extends Service {
private static final class Observer extends FileObserver {
private static final int MASK =
MOVE_SELF | MOVED_TO | MOVED_FROM | DELETE_SELF | DELETE | CLOSE_WRITE | ATTRIB;
public Observer(String path) {
super(path, MASK);
}
@Override
public void onEvent(int event, String path) {
event = event & ALL_EVENTS;
System.err.println("Event " + event + " on " + path);
switch (event) {
case MOVE_SELF:
// TODO: File(path) removed; stop watching (?)
break;
case MOVED_TO:
// TODO: File(path) removed; File(path) added
break;
case MOVED_FROM:
case DELETE:
// TODO: File(path) removed
break;
case DELETE_SELF:
// TODO: File(path) removed; watching is stopped automatically (?)
break;
case CLOSE_WRITE:
case ATTRIB:
// TODO: File(path) changed (added, removed?)
break;
default:
System.err.println("Unexpected event " + event + " on " + path);
break;
}
}
}
public final class LibraryImplementation extends LibraryInterface.Stub {
private final BookCollection myCollection;
private final List<FileObserver> myFileObservers = new LinkedList<FileObserver>();
LibraryImplementation() {
BooksDatabase database = SQLiteBooksDatabase.Instance();
@ -39,6 +79,12 @@ public class LibraryService extends Service {
database = new SQLiteBooksDatabase(LibraryService.this, "LIBRARY SERVICE");
}
myCollection = new BookCollection(database);
for (String path : myCollection.bookDirectories()) {
final Observer observer = new Observer(path);
observer.startWatching();
myFileObservers.add(observer);
}
final long start = System.currentTimeMillis();
myCollection.addListener(new BookCollection.Listener() {
public void onBookEvent(BookEvent event, Book book) {
@ -69,6 +115,12 @@ public class LibraryService extends Service {
myCollection.startBuild();
}
public void deactivate() {
for (FileObserver observer : myFileObservers) {
observer.stopWatching();
}
}
public int size() {
return myCollection.size();
}
@ -96,7 +148,7 @@ public class LibraryService extends Service {
}
}
private LibraryImplementation myLibrary;
private volatile LibraryImplementation myLibrary;
@Override
public void onStart(Intent intent, int startId) {
@ -126,7 +178,10 @@ public class LibraryService extends Service {
@Override
public void onDestroy() {
System.err.println("LibraryService.onDestroy()");
myLibrary = null;
if (myLibrary != null) {
myLibrary.deactivate();
myLibrary = null;
}
super.onDestroy();
}
}