Implemented begin()

Author: maniacbug

RF24Network.cpp

@@ -18,12 +18,22 @@
 
 RF24Network::RF24Network( RF24& _radio, const RF24NodeLine* _topology ): radio(_radio), topology(_topology)
 {
+  num_nodes = 0;
+  const RF24NodeLine* i = topology;
+  while ( (i++)->parent_node != 0xFFFF )
+    ++num_nodes;
 }
 
 void RF24Network::begin(uint8_t _channel, uint16_t _node_address, rf24_direction_e /*_direction*/ )
 {
-  node_address = _node_address;
+  if ( node_address < num_nodes )
+    node_address = _node_address;
+
   radio.setChannel(_channel);
+  radio.setDataRate(RF24_1MBPS);
+  radio.setCRCLength(RF24_CRC_16);
+  radio.startListening();
+  radio.printDetails();
 }
 
 void RF24Network::update(void)
@@ -45,4 +55,49 @@ bool RF24Network::write(RF24NetworkHeader& /*header*/,const void* /*buf*/, size_
   return false;
 }
 
+void RF24Network::open_pipes(void)
+{
+  // In order to open the right pipes, we need to know whether the node has parents
+  // and/or children
+  bool has_parent = ( topology[node_address].parent_node != 0 );
+  bool has_children = false;
+
+  // If there are any nodes in the topology table which consider this
+  // a parent, then we do have children 
+  int i = num_nodes;
+  while (i-- && !has_children)
+    if ( topology[i].parent_node == node_address )
+      has_children = true; 
+
+  // Open pipes for parent 
+  if ( has_parent )
+  {
+    // Writing pipe to speak to our parent
+    radio.openWritingPipe(topology[node_address].talking_pipe);
+
+    // Listen to our parent.  If we have children, we need to do so
+    // on pipe 0 to make room for more children
+    if ( has_children )
+      radio.openReadingPipe(0,topology[node_address].listening_pipe);
+    else
+      radio.openReadingPipe(1,topology[node_address].listening_pipe);
+  }
+
+  // Listen on children's talking pipes
+  if ( has_children )
+  {
+    // First child listening pipe is #1
+    uint8_t current_pipe = 1;
+  
+    // The topology table tells us who our children are
+    int i = num_nodes;
+    while (i--)
+    {
+      if ( topology[i].parent_node == node_address )
+	radio.openReadingPipe(current_pipe++,topology[i].talking_pipe);
+    }
+  }
+
+}
+
 // vim:ai:cin:sts=2 sw=2 ft=cpp

RF24Network.h

@@ -65,11 +65,6 @@ typedef enum { RF24_NET_UNIDIRECTIONAL = 0, RF24_NET_BIDIRECTIONAL } rf24_direct
 
 class RF24Network
 {
-private:
-  RF24& radio; /**< Underlying radio driver, provides link/physical layers */ 
-  uint16_t node_address; /**< Logical node address of this unit, 1 .. UINT_MAX */
-  const RF24NodeLine* topology; /**< Mapping table of logical node addresses to physical RF pipes */
-
 public:
   RF24Network( RF24& _radio, const RF24NodeLine* _topology);
 
@@ -124,6 +119,16 @@ class RF24Network
    * @return Whether the message was successfully received 
    */
   bool write(RF24NetworkHeader& header,const void* buf, size_t len);
+
+protected:
+  void open_pipes(void);
+
+private:
+  RF24& radio; /**< Underlying radio driver, provides link/physical layers */ 
+  uint16_t node_address; /**< Logical node address of this unit, 1 .. UINT_MAX */
+  const RF24NodeLine* topology; /**< Mapping table of logical node addresses to physical RF pipes */
+  uint16_t num_nodes; /**< Number of nodes in the topology table */
+
 };
 #endif // __RF24_H__
 // vim:ai:cin:sts=2 sw=2 ft=cpp

examples/meshping/meshping.pde

@@ -2,6 +2,7 @@
 #include <RF24Network.h>
 #include <RF24.h>
 #include <SPI.h>
+#include "printf.h"
 
 // Avoid spurious warnings
 #undef PROGMEM 
@@ -17,6 +18,7 @@ RF24NodeLine topology[] =
   { 0x0000000000LL, 0x0000000000LL, 0 }, // Node 0: Invalid
   { 0xE7E7E7E701LL, 0xE7E7E7E701LL, 0 }, // Node 1: Base, has no parent
   { 0xE7E7E7E70ELL, 0xE7E7E7E70ELL, 1 }, // Node 2: Leaf, child of #1
+  { 0xFFFFFFFFFFLL, 0xFFFFFFFFFFLL, -1 }, // End of data marker 
 };
 
 RF24 radio(8,9);
@@ -36,10 +38,18 @@ unsigned long last_time_sent;
 
 void setup(void)
 {
-  SPI.begin();
-  radio.begin();
+  //
+  // Print preamble
+  //
+  
+  Serial.begin(57600);
+  printf_begin();
+  printf("\n\rRF24Network/examples/meshping/\n\r");
+  
+  //
+  // Node configuration 
+  //
 
-  // Figure out which node we are
   pinMode(role_pin,INPUT);
   digitalWrite(role_pin,HIGH);
   if ( digitalRead(role_pin) )
@@ -52,9 +62,14 @@ void setup(void)
     this_node = 2;
     other_node = 1;
   }
+  printf("ADDRESS: %i\n\r",this_node);
 
-
+  //
   // Bring up the RF network
+  //
+
+  SPI.begin();
+  radio.begin();
   network.begin(/*channel*/ 100, /*node address*/ this_node, /*directionality*/ RF24_NET_BIDIRECTIONAL);
 }