!747

m {

  static long timeout = 5000;

  p {

    final S pivot = randomID(6);

    new L<S> myNames;

    makeAndroid_forcePublic = true;

    makeAndroid_allowVMInspection = false;

    Android android = makeAndroid2("", stringfunc { pivot }, false);

    ServerSocket server = startDialogServer_serverSocket;

    for (S name : litlist("tinybrain.de", "second.tinybrain.de"/*, "google.de"*/)) {

      print("Checking " + name);

      boolean result = isItMe(name, android.port, pivot, timeout);

      print("  => " + result);

      if (result) myNames.add(name);

    }

    print("My names: " + structure(myNames));

    server.close(); // TODO: close the client connections

    //sleepSeconds(2);

    //listUserThreadsWithStackTraces();

    //System.exit(0);

    // SHOULD now exit properly by itself

  }

  !include #1000915 // Flag class

  static boolean isItMe(final String name, final int port, final S pivot, long timeout) {

    final new Flag ok;

    final new Flag done;

    Thread t = new Thread("Talking to " + name + ":" + port) {

      public void run() {

        try {

          DialogIO io = talkTo(name, port);

          print("Connected to " + name + ":" + port + ".");

          if (!io.waitForLine())

            return;

          S line = io.readLineNoBlock();

          io.sendLine("please give pivot");

          if (!io.waitForLine())

            return;

          line = io.readLineNoBlock();

          print("Line read: " + quote(line));

          io.close();

          if (pivot.equals(line))

            ok.raise();

        } catch (RuntimeException e) {

          print("[internal] " + e);

        } finally {

          done.raise();

        }

      }

    };

    t.start();

    done.waitUntilUp(timeout);

    print("Interrupting thread.");

    t.interrupt();

    return ok.isUp();

  }

}