Merge pull request #67 from gandreello/giuseppe/woble-fault-injection

Added a fault injection point in WoBLE

Author: robszewczyk

src/ble/BLEEndPoint.cpp

@@ -38,6 +38,7 @@
 #include <Weave/Support/logging/WeaveLogging.h>
 #include <Weave/Support/CodeUtils.h>
 #include <Weave/Support/FlagUtils.hpp>
+#include <Weave/Support/WeaveFaultInjection.h>
 
 #include <BleLayer/BLEEndPoint.h>
 #include <BleLayer/BleLayer.h>
@@ -764,6 +765,17 @@ BLE_ERROR BLEEndPoint::SendNextMessage()
     data = NULL; // Ownership passed to fragmenter's tx buf on PrepareNextFragment success.
 
     // Send first message fragment over the air.
+    WEAVE_FAULT_INJECT(nl::Weave::FaultInjection::kFault_WOBLESend,
+            {
+                if (mRole == kBleRole_Central)
+                {
+                    err = BLE_ERROR_GATT_WRITE_FAILED;
+                } else {
+                    err = BLE_ERROR_GATT_INDICATE_FAILED;
+                }
+                ExitNow();
+            }
+            );
     err = SendCharacteristic(mWoBle.TxPacket());
     SuccessOrExit(err);
 

src/lib/support/WeaveFaultInjection.cpp

@@ -74,6 +74,9 @@ static const nl::FaultInjection::Name sFaultNames[] = {
     "TunnelQueueFull",
     "TunnelPacketDropByPolicy",
 #endif // WEAVE_CONFIG_ENABLE_TUNNELING
+#if CONFIG_NETWORK_LAYER_BLE
+    "WOBLESend",
+#endif // CONFIG_NETWORK_LAYER_BLE
 };
 
 

src/lib/support/WeaveFaultInjection.h

@@ -92,6 +92,9 @@ typedef enum
     kFault_TunnelQueueFull,                     /**< Trigger a WEAVE_ERROR_TUNNEL_SERVICE_QUEUE_FULL when enqueueing a packet in the Tunnel queue */
     kFault_TunnelPacketDropByPolicy,            /**< Trigger an explicit drop of the packet as if done by an application policy */
 #endif // WEAVE_CONFIG_ENABLE_TUNNELING
+#if CONFIG_NETWORK_LAYER_BLE
+    kFault_WOBLESend,                           /**< Inject a GATT error when sending the first fragment of a Weave message over BLE */
+#endif // CONFIG_NETWORK_LAYER_BLE
     kFault_NumItems,
 } Id;
 

src/test-apps/happy/test-templates/WeaveBle.py

@@ -172,6 +172,7 @@ def __start_server_side(self):
             return
 
         cmd += " --enable-bluez-peripheral --peripheral-name N0001 --peripheral-address " + self.interfaces[0]["bd_address"]
+        cmd += " --print-fault-counters"
         self.start_weave_process(node_id=self.server_node_id, cmd=cmd, tag=self.server_process_tag, rootMode=True)
 
     def resetBluez(self):