torproject/collector
1
0
Fork 0
mirror of https://github.com/torproject/collector.git synced 2025-02-18 16:28:47 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Prepare for the consensus to be unavailable, too.

Browse Source
This commit is contained in:
Karsten Loesing 2010-01-19 20:32:20 +01:00
parent f776d20fd9
commit dde0acb6c7
1 changed files with 18 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/ConsensusDownloader.java
View File

@ -9,18 +9,26 @@ public class ConsensusDownloader {
throws IOException {
System.out.print("Downloading current consensus from " + authority
+ "... ");
BufferedInputStream in = new BufferedInputStream(new URL("http://"
+ authority + "/tor/status-vote/current/consensus").openStream());
StringBuilder sb = new StringBuilder();
int len;
byte[] data = new byte[1024];
while ((len = in.read(data, 0, 1024)) >= 0) {
sb.append(new String(data, 0, len));
URL u = new URL("http://" + authority
+ "/tor/status-vote/current/consensus");
HttpURLConnection huc = (HttpURLConnection) u.openConnection();
huc.setRequestMethod("GET");
huc.connect();
int response = huc.getResponseCode();
if (response == 200) {
BufferedInputStream in = new BufferedInputStream(
huc.getInputStream());
StringBuilder sb = new StringBuilder();
int len;
byte[] data = new byte[1024];
while ((len = in.read(data, 0, 1024)) >= 0) {
sb.append(new String(data, 0, len));
}
in.close();
String consensus = sb.toString();
rdp.parse(new BufferedReader(new StringReader(consensus)));
}
in.close();
String consensus = sb.toString();
System.out.println("done");
rdp.parse(new BufferedReader(new StringReader(consensus)));
}
}