Method run

android/src/BluetoothServerPort.java:78–108

()

  }

  @Override public void run() {
    while (true) {
      try {
        /* copy serverSocket to a local variable, so we can compare it
           with null without risking a race condition with the thread
           calling close() */
        BluetoothServerSocket ss = serverSocket;
        if (ss == null)
          /* close() is being called by another thread, which now
             waits for this thread to quit */
          break;

        BluetoothSocket socket = ss.accept();
        Log.i(TAG, "Accepted Bluetooth connection from " +
              BluetoothHelper.getDisplayString(socket));
        BluetoothPort port = new BluetoothPort(socket);

        /* make writes non-blocking and potentially lossy, to avoid
           blocking when one of the peers doesn't receive quickly
           enough */
        port.setWriteTimeout(0);

        add(port);
      } catch (IOException e) {
        Log.e(TAG, "Bluetooth server socket has failed", e);
        closeServerSocket();
        error(e.getMessage());
        break;
      }
    }
  }

  @Override public void close() {
    closeServerSocket();