+ private void send_to_client(Messenger client, Message m) {
+ try {
+ if (D) Log.d(TAG, String.format("Send message to client %s", client.toString()));
+ client.send(m);
+ } catch (RemoteException e) {
+ if (D) Log.e(TAG, String.format("Client %s disappeared", client.toString()));
+ remove_client(client);
+ }
+ }
+
+ private void send_to_clients() {
+ Message m = message();
+ if (D) Log.d(TAG, String.format("Send message to %d clients", clients.size()));
+ for (Messenger client : clients)
+ send_to_client(client, m);
+ }
+
+ private void disconnect(boolean notify) {
+ if (D) Log.d(TAG, "disconnect(): begin");
+
+ telemetry_state.connect = TelemetryState.CONNECT_DISCONNECTED;
+ telemetry_state.address = null;
+
+ if (altos_link != null)
+ altos_link.closing();
+
+ if (telemetry_reader != null) {
+ if (D) Log.d(TAG, "disconnect(): stopping TelemetryReader");
+ telemetry_reader.interrupt();
+ try {
+ telemetry_reader.join();
+ } catch (InterruptedException e) {
+ }
+ telemetry_reader = null;
+ }
+ if (telemetry_logger != null) {
+ if (D) Log.d(TAG, "disconnect(): stopping TelemetryLogger");
+ telemetry_logger.stop();
+ telemetry_logger = null;
+ }
+ if (altos_link != null) {
+ if (D) Log.d(TAG, "disconnect(): stopping AltosDroidLink");
+ altos_link.close();
+ altos_link = null;
+ }
+ telemetry_state.config = null;
+ if (notify) {
+ if (D) Log.d(TAG, "disconnect(): send message to clients");
+ send_to_clients();
+ if (clients.isEmpty()) {
+ if (D) Log.d(TAG, "disconnect(): no clients, terminating");
+ stopSelf();
+ }
+ }
+ }
+
+ private void start_usb(UsbDevice device) {
+ AltosUsb d = new AltosUsb(this, device, handler);
+
+ if (d != null) {
+ disconnect(false);
+ altos_link = d;
+ try {
+ connected();
+ } catch (InterruptedException ie) {
+ }
+ }
+ }
+
+ private void start_altos_bluetooth(DeviceAddress address, boolean pause) {
+ // Get the BLuetoothDevice object
+ BluetoothDevice device = bluetooth_adapter.getRemoteDevice(address.address);
+
+ disconnect(false);
+ if (pause) {
+ try {
+ Thread.sleep(4000);
+ } catch (InterruptedException e) {
+ }
+ }
+ this.address = address;
+ if (D) Log.d(TAG, String.format("start_altos_bluetooth(): Connecting to %s (%s)", device.getName(), device.getAddress()));
+ altos_link = new AltosBluetooth(device, handler);
+ telemetry_state.connect = TelemetryState.CONNECT_CONNECTING;
+ telemetry_state.address = address;
+ send_to_clients();
+ }
+
+ private void connected() throws InterruptedException {
+ if (D) Log.d(TAG, "connected top");
+ try {
+ if (altos_link == null)
+ throw new InterruptedException("no bluetooth");
+ telemetry_state.config = altos_link.config_data();
+ altos_link.set_radio_frequency(telemetry_state.frequency);
+ altos_link.set_telemetry_rate(telemetry_state.telemetry_rate);
+ } catch (TimeoutException e) {
+ // If this timed out, then we really want to retry it, but
+ // probably safer to just retry the connection from scratch.
+ if (D) Log.d(TAG, "connected timeout");
+ if (address != null) {
+ if (D) Log.d(TAG, "connected timeout, retrying");
+ start_altos_bluetooth(address, true);
+ } else {
+ handler.obtainMessage(MSG_CONNECT_FAILED).sendToTarget();
+ disconnect(true);
+ }
+ return;
+ }
+
+ if (D) Log.d(TAG, "connected bluetooth configured");
+ telemetry_state.connect = TelemetryState.CONNECT_CONNECTED;
+ telemetry_state.address = address;
+
+ telemetry_reader = new TelemetryReader(altos_link, handler, telemetry_state.state);
+ telemetry_reader.start();
+
+ if (D) Log.d(TAG, "connected TelemetryReader started");
+
+ telemetry_logger = new TelemetryLogger(this, altos_link);
+
+ if (D) Log.d(TAG, "Notify UI of connection");
+
+ send_to_clients();
+ }
+
+