+++ /dev/null
-/*
- * Copyright © 2011 Keith Packard <keithp@keithp.com>
- * Copyright © 2012 Mike Beattie <mike@ethernal.org>
- *
- * This program is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful, but
- * WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License along
- * with this program; if not, write to the Free Software Foundation, Inc.,
- * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
- */
-
-package org.altusmetrum.AltosDroid;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.util.UUID;
-
-import android.bluetooth.BluetoothAdapter;
-import android.bluetooth.BluetoothDevice;
-import android.bluetooth.BluetoothSocket;
-//import android.os.Bundle;
-import android.os.Handler;
-//import android.os.Message;
-
-import org.altusmetrum.altoslib_13.*;
-
-public class AltosBluetooth extends AltosDroidLink {
-
- private ConnectThread connect_thread = null;
-
- private BluetoothDevice device;
- private BluetoothSocket socket;
- private InputStream input;
- private OutputStream output;
- private boolean pause;
-
- // Constructor
- public AltosBluetooth(BluetoothDevice device, Handler handler, boolean pause) {
- super(handler);
- this.device = device;
- this.handler = handler;
- this.pause = pause;
-
- connect_thread = new ConnectThread();
- connect_thread.start();
- }
-
- void connected() {
- if (closed()) {
- AltosDebug.debug("connected after closed");
- return;
- }
-
- AltosDebug.check_ui("connected\n");
- try {
- synchronized(this) {
- if (socket != null) {
- input = socket.getInputStream();
- output = socket.getOutputStream();
- super.connected();
- }
- }
- } catch (InterruptedException ie) {
- connect_failed();
- } catch (IOException io) {
- connect_failed();
- }
- }
-
- private void connect_failed() {
- if (closed()) {
- AltosDebug.debug("connect_failed after closed");
- return;
- }
-
- close_device();
- input = null;
- output = null;
- handler.obtainMessage(TelemetryService.MSG_CONNECT_FAILED, this).sendToTarget();
- AltosDebug.error("ConnectThread: Failed to establish connection");
- }
-
- void close_device() {
- BluetoothSocket tmp_socket;
-
- synchronized(this) {
- tmp_socket = socket;
- socket = null;
- }
-
- if (tmp_socket != null) {
- try {
- tmp_socket.close();
- } catch (IOException e) {
- AltosDebug.error("close_socket failed");
- }
- }
- }
-
- public void close() {
- super.close();
- input = null;
- output = null;
- }
-
- private final UUID SPP_UUID = UUID.fromString("00001101-0000-1000-8000-00805F9B34FB");
-
- private void create_socket(BluetoothDevice device) {
-
- BluetoothSocket tmp_socket = null;
-
- AltosDebug.check_ui("create_socket\n");
- try {
- tmp_socket = device.createInsecureRfcommSocketToServiceRecord(SPP_UUID);
- } catch (IOException e) {
- e.printStackTrace();
- }
- if (socket != null) {
- AltosDebug.debug("Socket already allocated %s", socket.toString());
- close_device();
- }
- synchronized (this) {
- socket = tmp_socket;
- }
- }
-
- private class ConnectThread extends Thread {
-
- public void run() {
- AltosDebug.debug("ConnectThread: BEGIN (pause %b)", pause);
- setName("ConnectThread");
-
- if (pause) {
- try {
- Thread.sleep(4000);
- } catch (InterruptedException e) {
- }
- }
-
- create_socket(device);
- // Always cancel discovery because it will slow down a connection
- try {
- BluetoothAdapter.getDefaultAdapter().cancelDiscovery();
- } catch (Exception e) {
- AltosDebug.debug("cancelDiscovery exception %s", e.toString());
- }
-
- BluetoothSocket local_socket = null;
-
- synchronized (AltosBluetooth.this) {
- if (!closed())
- local_socket = socket;
- }
-
- if (local_socket != null) {
- try {
- // Make a connection to the BluetoothSocket
- // This is a blocking call and will only return on a
- // successful connection or an exception
- local_socket.connect();
- } catch (Exception e) {
- AltosDebug.debug("Connect exception %s", e.toString());
- try {
- local_socket.close();
- } catch (Exception ce) {
- AltosDebug.debug("Close exception %s", ce.toString());
- }
- local_socket = null;
- }
- }
-
- if (local_socket != null) {
- connected();
- } else {
- connect_failed();
- }
-
- AltosDebug.debug("ConnectThread: completed");
- }
- }
-
- private synchronized void wait_connected() throws InterruptedException, IOException {
- AltosDebug.check_ui("wait_connected\n");
- if (input == null && socket != null) {
- AltosDebug.debug("wait_connected...");
- wait();
- AltosDebug.debug("wait_connected done");
- }
- if (socket == null)
- throw new IOException();
- }
-
- int write(byte[] buffer, int len) {
- if (output == null)
- return -1;
- try {
- output.write(buffer, 0, len);
- } catch (IOException ie) {
- return -1;
- }
- return len;
- }
-
- int read(byte[] buffer, int len) {
- if (input == null)
- return -1;
- try {
- return input.read(buffer, 0, len);
- } catch (IOException ie) {
- return -1;
- }
- }
-
- // Stubs of required methods when extending AltosLink
- public boolean can_cancel_reply() { return false; }
- public boolean show_reply_timeout() { return true; }
- public void hide_reply_timeout() { }
-
-}
projects / fw / altos / blobdiff