Method run

cSploit/src/org/csploit/android/net/RemoteReader.java:354–435

()

  }

  public void run() {
    URLConnection connection = null;
    Task task = null;
    boolean isError;
    InputStream stream;
    Notifier notifier;
    URL url;

    running = true;

    Thread.currentThread().setName("RemoteReader[" + host + "]");

    Logger.debug("RemoteReader[" + host +"] started");

    while(running) {

      try {
        synchronized (tasks) {
          while(running && (task = tasks.poll()) == null) {
            tasks.wait();
          }
        }
      } catch (InterruptedException e) {
        Logger.warning("RemoteReader[" + host +"] interrupted");
        break;
      }

      if(task == null) break;

      isError = false;
      notifier = null;
      stream = null;

      try {
        url = new URL(task.getUrl());
      } catch (MalformedURLException e) {
        notifiers.execute(new Notifier(task, ("Bad URL: " + task.getUrl()).getBytes(), true));
        continue;
      }

      if(!url.getHost().equals(host)) {
        Logger.error(String.format("RemoteReader[%s]: URL '%s' does not belong to me", host, task.getUrl()));
        notifiers.execute(new Notifier(task, "Host mismatch".getBytes(), true));
        continue;
      }

      Logger.info("fetching '" + url.toString() + "'");

      try {
        connection = url.openConnection();
        stream = connection.getInputStream();
      } catch (IOException e) {
        if (connection != null && connection instanceof HttpURLConnection) {
          stream = ((HttpURLConnection) connection).getErrorStream();
          isError = true;
        } else {
          notifier = new Notifier(task, e.getMessage().getBytes(), true);
        }