OSDN Git Service

Expose connection update callback (3/4)
authorJakub Pawlowski <jpawlowski@google.com>
Fri, 24 Mar 2017 01:13:33 +0000 (18:13 -0700)
committerJakub Pawlowski <jpawlowski@google.com>
Fri, 24 Mar 2017 16:57:53 +0000 (09:57 -0700)
Test: manual
Bug: 30622771
Change-Id: Ie731cf45bbb0ef01c5c6c13d149d75fea82e38d8

jni/com_android_bluetooth_gatt.cpp
src/com/android/bluetooth/gatt/GattService.java

index 90c3835..30cf32e 100644 (file)
@@ -163,6 +163,7 @@ static jmethodID method_getSampleGattDbElement;
 static jmethodID method_onGetGattDb;
 static jmethodID method_onClientPhyUpdate;
 static jmethodID method_onClientPhyRead;
+static jmethodID method_onClientConnUpdate;
 
 /**
  * Server callback methods
@@ -183,6 +184,7 @@ static jmethodID method_onServerCongestion;
 static jmethodID method_onServerMtuChanged;
 static jmethodID method_onServerPhyUpdate;
 static jmethodID method_onServerPhyRead;
+static jmethodID method_onServerConnUpdate;
 
 /**
  * Advertiser callback methods
@@ -523,11 +525,19 @@ void btgattc_phy_updated_cb(int conn_id, uint8_t tx_phy, uint8_t rx_phy,
   CallbackEnv sCallbackEnv(__func__);
   if (!sCallbackEnv.valid()) return;
 
-  info("ASDFASDFADSFDSAFDS");
   sCallbackEnv->CallVoidMethod(mCallbacksObj, method_onClientPhyUpdate, conn_id,
                                tx_phy, rx_phy, status);
 }
 
+void btgattc_conn_updated_cb(int conn_id, uint16_t interval, uint16_t latency,
+                             uint16_t timeout, uint8_t status) {
+  CallbackEnv sCallbackEnv(__func__);
+  if (!sCallbackEnv.valid()) return;
+
+  sCallbackEnv->CallVoidMethod(mCallbacksObj, method_onClientConnUpdate,
+                               conn_id, interval, latency, timeout, status);
+}
+
 static const btgatt_scanner_callbacks_t sGattScannerCallbacks = {
     btgattc_scan_result_cb,
     btgattc_batchscan_reports_cb,
@@ -553,7 +563,8 @@ static const btgatt_client_callbacks_t sGattClientCallbacks = {
     btgattc_get_gatt_db_cb,
     NULL, /* services_removed_cb */
     NULL, /* services_added_cb */
-    btgattc_phy_updated_cb};
+    btgattc_phy_updated_cb,
+    btgattc_conn_updated_cb};
 
 /**
  * BTA server callbacks
@@ -726,6 +737,15 @@ void btgatts_phy_updated_cb(int conn_id, uint8_t tx_phy, uint8_t rx_phy,
                                tx_phy, rx_phy, status);
 }
 
+void btgatts_conn_updated_cb(int conn_id, uint16_t interval, uint16_t latency,
+                             uint16_t timeout, uint8_t status) {
+  CallbackEnv sCallbackEnv(__func__);
+  if (!sCallbackEnv.valid()) return;
+
+  sCallbackEnv->CallVoidMethod(mCallbacksObj, method_onServerConnUpdate,
+                               conn_id, interval, latency, timeout, status);
+}
+
 static const btgatt_server_callbacks_t sGattServerCallbacks = {
     btgatts_register_app_cb,
     btgatts_connection_cb,
@@ -741,7 +761,8 @@ static const btgatt_server_callbacks_t sGattServerCallbacks = {
     btgatts_indication_sent_cb,
     btgatts_congestion_cb,
     btgatts_mtu_changed_cb,
-    btgatts_phy_updated_cb};
+    btgatts_phy_updated_cb,
+    btgatts_conn_updated_cb};
 
 /**
  * GATT callbacks
@@ -821,6 +842,8 @@ static void classInitNative(JNIEnv* env, jclass clazz) {
       env->GetMethodID(clazz, "onClientPhyRead", "(IIII)V");
   method_onClientPhyUpdate =
       env->GetMethodID(clazz, "onClientPhyUpdate", "(IIII)V");
+  method_onClientConnUpdate =
+      env->GetMethodID(clazz, "onClientConnUpdate", "(IIIII)V");
 
   // Server callbacks
 
@@ -855,6 +878,8 @@ static void classInitNative(JNIEnv* env, jclass clazz) {
       env->GetMethodID(clazz, "onServerPhyRead", "(IIII)V");
   method_onServerPhyUpdate =
       env->GetMethodID(clazz, "onServerPhyUpdate", "(IIII)V");
+  method_onServerConnUpdate =
+      env->GetMethodID(clazz, "onServerConnUpdate", "(IIIII)V");
 
   info("classInitNative: Success!");
 }
index 701d9d4..b1b4f77 100644 (file)
@@ -833,6 +833,19 @@ public class GattService extends ProfileService {
         app.callback.onPhyRead(address, txPhy, rxPhy, status);
     }
 
+    void onClientConnUpdate(int connId, int interval, int latency, int timeout, int status)
+            throws RemoteException {
+        if (DBG) Log.d(TAG, "onClientConnUpdate() - connId=" + connId + ", status=" + status);
+
+        String address = mClientMap.addressByConnId(connId);
+        if (address == null) return;
+
+        ClientMap.App app = mClientMap.getByConnId(connId);
+        if (app == null) return;
+
+        app.callback.onConnectionUpdated(address, interval, latency, timeout, status);
+    }
+
     void onServerPhyUpdate(int connId, int txPhy, int rxPhy, int status) throws RemoteException {
         if (DBG) Log.d(TAG, "onServerPhyUpdate() - connId=" + connId + ", status=" + status);
 
@@ -857,6 +870,19 @@ public class GattService extends ProfileService {
         app.callback.onPhyRead(address, txPhy, rxPhy, status);
     }
 
+    void onServerConnUpdate(int connId, int interval, int latency, int timeout, int status)
+            throws RemoteException {
+        if (DBG) Log.d(TAG, "onServerConnUpdate() - connId=" + connId + ", status=" + status);
+
+        String address = mServerMap.addressByConnId(connId);
+        if (address == null) return;
+
+        ServerMap.App app = mServerMap.getByConnId(connId);
+        if (app == null) return;
+
+        app.callback.onConnectionUpdated(address, interval, latency, timeout, status);
+    }
+
     void onSearchCompleted(int connId, int status) throws RemoteException {
         if (DBG) Log.d(TAG, "onSearchCompleted() - connId=" + connId+ ", status=" + status);
         // Gatt DB is ready!