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

sync statistics

Browse source
This commit is contained in:
Nikolay Pultsin 2014-07-23 07:16:37 +01:00
parent 45ca655288
commit f0e58a87af
1 changed files with 33 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

51
src/org/geometerplus/android/fbreader/synchroniser/SynchroniserService.java
View file

@ -36,6 +36,14 @@ import org.geometerplus.android.fbreader.libraryService.BookCollectionShadow;
import org.geometerplus.android.fbreader.network.auth.ServiceNetworkContext; import org.geometerplus.android.fbreader.network.auth.ServiceNetworkContext;
public class SynchroniserService extends Service implements IBookCollection.Listener, Runnable { public class SynchroniserService extends Service implements IBookCollection.Listener, Runnable {
enum SyncStatus {
AlreadyUploaded,
Uploaded,
ToBeDeleted,
Failure,
HashNotComputed
}
private final ZLNetworkContext myNetworkContext = new ServiceNetworkContext(this); private final ZLNetworkContext myNetworkContext = new ServiceNetworkContext(this);
private final BookCollectionShadow myCollection = new BookCollectionShadow(); private final BookCollectionShadow myCollection = new BookCollectionShadow();
private static volatile Thread ourSynchronizationThread; private static volatile Thread ourSynchronizationThread;
@ -60,13 +68,14 @@ public class SynchroniserService extends Service implements IBookCollection.List
@Override @Override
public synchronized void run() { public synchronized void run() {
System.err.println("SYNCHRONIZER BINDED TO LIBRARY");
myCollection.addListener(this); myCollection.addListener(this);
if (ourSynchronizationThread == null) { if (ourSynchronizationThread == null) {
ourSynchronizationThread = new Thread() { ourSynchronizationThread = new Thread() {
public void run() { public void run() {
final long start = System.currentTimeMillis();
int count = 0;
final Map<SyncStatus,Integer> statusCounts = new HashMap<SyncStatus,Integer>();
try { try {
System.err.println("HELLO THREAD");
myActualHashesFromServer.clear(); myActualHashesFromServer.clear();
myDeletedHashesFromServer.clear(); myDeletedHashesFromServer.clear();
try { try {
@ -84,7 +93,6 @@ public class SynchroniserService extends Service implements IBookCollection.List
System.err.println("DO NOT SYNCHRONIZE: ALL HASHES REQUEST FAILED"); System.err.println("DO NOT SYNCHRONIZE: ALL HASHES REQUEST FAILED");
return; return;
} }
System.err.println("START SYNCRONIZATION " + new Date());
for (BookQuery q = new BookQuery(new Filter.Empty(), 20);; q = q.next()) { for (BookQuery q = new BookQuery(new Filter.Empty(), 20);; q = q.next()) {
final List<Book> books = myCollection.books(q); final List<Book> books = myCollection.books(q);
if (books.isEmpty()) { if (books.isEmpty()) {
@ -100,11 +108,17 @@ public class SynchroniserService extends Service implements IBookCollection.List
continue; continue;
} }
myProcessed.add(book); myProcessed.add(book);
System.err.println("Processing " + book.getTitle() + " [" + book.File.getPath() + "]"); ++count;
uploadBookToServer(book); final SyncStatus status = uploadBookToServer(book);
final Integer sc = statusCounts.get(status);
statusCounts.put(status, sc != null ? sc + 1 : 1);
} }
} finally { } finally {
System.err.println("BYE-BYE THREAD " + new Date()); System.err.println("SYNCHRONIZATION FINISHED IN " + (System.currentTimeMillis() - start) + "msecs");
System.err.println("TOTAL BOOKS PROCESSED: " + count);
for (SyncStatus value : SyncStatus.values()) {
System.err.println("STATUS " + value + ": " + statusCounts.get(value));
}
ourSynchronizationThread = null; ourSynchronizationThread = null;
} }
} }
@ -136,6 +150,8 @@ public class SynchroniserService extends Service implements IBookCollection.List
} }
private final class UploadRequest extends ZLNetworkRequest.FileUpload { private final class UploadRequest extends ZLNetworkRequest.FileUpload {
boolean Success = false;
UploadRequest(File file) { UploadRequest(File file) {
super(BASE_URL + "book.upload", file, false); super(BASE_URL + "book.upload", file, false);
} }
@ -162,29 +178,24 @@ public class SynchroniserService extends Service implements IBookCollection.List
} else if (id != null && hashes != null) { } else if (id != null && hashes != null) {
System.err.println("UPLOADED SUCCESSFULLY: " + id); System.err.println("UPLOADED SUCCESSFULLY: " + id);
myActualHashesFromServer.addAll(hashes); myActualHashesFromServer.addAll(hashes);
Success = true;
} else { } else {
System.err.println("UNEXPECED RESPONSE: " + response); System.err.println("UNEXPECED RESPONSE: " + response);
} }
} }
} }
private void uploadBookToServer(Book book) { private SyncStatus uploadBookToServer(Book book) {
final ZLPhysicalFile file = book.File.getPhysicalFile(); final ZLPhysicalFile file = book.File.getPhysicalFile();
if (file == null) {
return;
}
final String hash = myCollection.getHash(book); final String hash = myCollection.getHash(book);
if (hash == null) { if (hash == null) {
System.err.println("Failed: checksum not computed"); return SyncStatus.HashNotComputed;
return;
} }
if (myActualHashesFromServer.contains(hash)) { if (myActualHashesFromServer.contains(hash)) {
System.err.println("BOOK ALREADY UPLOADED"); return SyncStatus.AlreadyUploaded;
return;
} }
if (myDeletedHashesFromServer.contains(hash)) { if (myDeletedHashesFromServer.contains(hash)) {
System.err.println("BOOK ALREADY UPLOADED AND DELETED"); return SyncStatus.ToBeDeleted;
return;
} }
final Map<String,Object> result = new HashMap<String,Object>(); final Map<String,Object> result = new HashMap<String,Object>();
final PostRequest verificationRequest = final PostRequest verificationRequest =
@ -198,6 +209,7 @@ public class SynchroniserService extends Service implements IBookCollection.List
myNetworkContext.perform(verificationRequest); myNetworkContext.perform(verificationRequest);
} catch (ZLNetworkException e) { } catch (ZLNetworkException e) {
e.printStackTrace(); e.printStackTrace();
return SyncStatus.Failure;
} }
final String csrfToken = myNetworkContext.getCookieValue(DOMAIN, "csrftoken"); final String csrfToken = myNetworkContext.getCookieValue(DOMAIN, "csrftoken");
try { try {
@ -208,21 +220,24 @@ public class SynchroniserService extends Service implements IBookCollection.List
uploadRequest.addHeader("Referer", verificationRequest.getURL()); uploadRequest.addHeader("Referer", verificationRequest.getURL());
uploadRequest.addHeader("X-CSRFToken", csrfToken); uploadRequest.addHeader("X-CSRFToken", csrfToken);
myNetworkContext.perform(uploadRequest); myNetworkContext.perform(uploadRequest);
return uploadRequest.Success ? SyncStatus.Uploaded : SyncStatus.Failure;
} catch (ZLNetworkException e) { } catch (ZLNetworkException e) {
e.printStackTrace(); e.printStackTrace();
return SyncStatus.Failure;
} }
} else { } else {
final List<String> hashes = (List<String>)result.get("hashes"); final List<String> hashes = (List<String>)result.get("hashes");
if ("found".equals(status)) { if ("found".equals(status)) {
System.err.println("BOOK ALREADY UPLOADED");
myActualHashesFromServer.addAll(hashes); myActualHashesFromServer.addAll(hashes);
return SyncStatus.AlreadyUploaded;
} else /* if ("deleted".equals(status)) */ { } else /* if ("deleted".equals(status)) */ {
System.err.println("BOOK ALREADY UPLOADED AND DELETED");
myDeletedHashesFromServer.addAll(hashes); myDeletedHashesFromServer.addAll(hashes);
return SyncStatus.ToBeDeleted;
} }
} }
} catch (Exception e) { } catch (Exception e) {
System.err.println("UNEXPECTED RESPONSE: " + result); System.err.println("UNEXPECTED RESPONSE: " + result);
return SyncStatus.Failure;
} }
} }