Method fetch

cSploit/src/org/csploit/android/net/RemoteReader.java:266–324

(final String url)

  }

  public static byte[] fetch(final String url) throws IOException {
    class BlockingReceiver implements Receiver {

      private boolean done = false;
      private byte[] content = null;
      private String errorMessage = null;

      @Override
      public void onContentFetched(byte[] content) {
        this.content = content;
        this.done = true;
        synchronized (this) {
          this.notify();
        }
      }

      @Override
      public void onError(byte[] description) {
        this.errorMessage = new String(description);
        this.done = true;
        synchronized (this) {
          this.notify();
        }
      }

      public byte[] getContent() {
        return content;
      }

      public boolean isDone() {
        return done;
      }

      public String getErrorMessage() {
        return errorMessage;
      }
    }

    RemoteReader reader = fromUrl(url);
    BlockingReceiver r = new BlockingReceiver();
    Task t = new Task(url, r);
    reader.addFirst(t);

    try {
      synchronized (r) {
        while(!r.isDone())
          r.wait();
      }
    } catch (InterruptedException e) {
      throw new IOException("Interrupted while fetching content");
    }

    byte[] res = r.getContent();

    if(res == null)
      throw new IOException(r.getErrorMessage());

    return res;