fabian/telegram_backup
1
0
Fork 0
mirror of https://github.com/fabianonline/telegram_backup.git synced 2024-11-22 16:56:16 +00:00
Code Issues Releases Wiki Activity

Prepared to catch TimeoutExceptions and restart the download, if necessary.

Browse Source
This commit is contained in:
Fabian Schlenz 2016-07-05 14:09:31 +02:00
parent d2795cc7ab
commit 84984ddc20
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/de/fabianonline/telegram_backup/DownloadManager.java
View File

@ -21,6 +21,7 @@ import java.io.FileOutputStream;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.LinkedList; import java.util.LinkedList;
import java.net.URL; import java.net.URL;
import java.util.concurrent.TimeoutException;
import org.apache.commons.io.FileUtils; import org.apache.commons.io.FileUtils;
@ -60,11 +61,18 @@ class DownloadManager {
} else { } else {
throw e; throw e;
} }
} catch (TimeoutException e) {
completed = false;
System.out.println("");
System.out.println("Telegram took too long to respond to our request.");
System.out.println("I'm going to wait a minute and then try again.");
try { Thread.sleep(60*1000); } catch(InterruptedException e2) {}
System.out.println("");
} }
} while (!completed); } while (!completed);
} }
public void _downloadMessages(Integer limit) throws RpcErrorException, IOException { public void _downloadMessages(Integer limit) throws RpcErrorException, IOException, TimeoutException {
System.out.println("Downloading most recent dialog... "); System.out.println("Downloading most recent dialog... ");
int max_message_id = client.messagesGetDialogs( int max_message_id = client.messagesGetDialogs(
0, 0,
@ -157,14 +165,22 @@ class DownloadManager {
System.out.println("messages and media. But be advised that just restarting me is not going to change"); System.out.println("messages and media. But be advised that just restarting me is not going to change");
System.out.println("the fact that Telegram won't talk to me until then."); System.out.println("the fact that Telegram won't talk to me until then.");
try { Thread.sleep((delay + 60) * 1000); } catch(InterruptedException e2) {} try { Thread.sleep((delay + 60) * 1000); } catch(InterruptedException e2) {}
System.out.println("");
} else { } else {
throw e; throw e;
} }
} catch (TimeoutException e) {
completed = false;
System.out.println("");
System.out.println("Telegram took too long to respond to our request.");
System.out.println("I'm going to wait a minute and then try again.");
try { Thread.sleep(60*1000); } catch(InterruptedException e2) {}
System.out.println("");
} }
} while (!completed); } while (!completed);
} }
private void _downloadMedia() throws RpcErrorException, IOException { private void _downloadMedia() throws RpcErrorException, IOException, TimeoutException {
LinkedList<TLMessage> messages = this.db.getMessagesWithMedia(); LinkedList<TLMessage> messages = this.db.getMessagesWithMedia();
prog.onMediaDownloadStart(messages.size()); prog.onMediaDownloadStart(messages.size());
for (TLMessage msg : messages) { for (TLMessage msg : messages) {