1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171 | /** RF24Mesh_Example_Node2Node.ino by TMRh20
*
* This example sketch shows how to communicate between two (non-master) nodes using
* RF24Mesh & RF24Network
**/
#include "RF24.h"
#include "RF24Network.h"
#include "RF24Mesh.h"
#include <SPI.h>
//#include <printf.h>
//########### USER CONFIG ###########
/**** Configure the nrf24l01 CE and CS pins ****/
RF24 radio(7, 8);
RF24Network network(radio);
RF24Mesh mesh(radio, network);
/**
* User Configuration:
* nodeID - A unique identifier for each radio. Allows addressing to change dynamically
* with physical changes to the mesh. (numbers 1-255 allowed)
*
* otherNodeID - A unique identifier for the 'other' radio
*
**/
#define nodeID 3
#define otherNodeID 2
//#################################
uint32_t millisTimer = 0;
uint32_t stringTimer = 0;
char dataStr[] = { "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890" };
char tmpStr[sizeof(dataStr) + 1];
uint8_t strCtr = 1;
uint32_t delayTime = 120;
void setup() {
Serial.begin(115200);
while (!Serial) {
// some boards need this because of native USB capability
}
// Set the nodeID manually
mesh.setNodeID(nodeID);
// Connect to the mesh
Serial.println(F("Connecting to the mesh..."));
if (!mesh.begin()) {
if (radio.isChipConnected()) {
while (mesh.renewAddress() == MESH_DEFAULT_ADDRESS) {
// mesh.renewAddress() will return MESH_DEFAULT_ADDRESS on failure to connect
Serial.println(F("Connecting to the mesh..."));
}
} else {
Serial.println(F("Radio hardware not responding."));
while (1) {
// hold in an infinite loop
}
}
}
}
unsigned int sizeCtr = 2;
uint32_t errorCount = 0;
uint32_t duplicates = 0;
uint32_t totalData = 0;
void loop() {
mesh.update();
while (network.available()) {
RF24NetworkHeader hdr;
size_t dataSize = network.peek(hdr);
totalData += dataSize;
if (hdr.type == 'S') {
if (dataSize != sizeCtr) {
if (dataSize == sizeCtr + 1) {
duplicates++;
}
sizeCtr = dataSize + 1;
errorCount++;
} else {
sizeCtr++;
if (sizeCtr > sizeof(dataStr)) {
sizeCtr = 2;
}
//if(sizeCtr > 12){ sizeCtr = 2; }
}
network.read(hdr, &tmpStr, dataSize);
//Serial.println(tmpStr);
} else if (hdr.type == 'M') {
uint32_t mills;
network.read(hdr, &mills, sizeof(mills));
Serial.print(F("Received "));
Serial.print(mills);
int _ID = 0;
_ID = mesh.getNodeID(hdr.from_node);
if (_ID > 0) {
if (_ID == nodeID) {
Serial.println(F(" from master."));
} else {
Serial.print(F(" from node(ID) "));
Serial.print(_ID);
Serial.println('.');
}
} else {
Serial.println(F("Mesh ID Lookup Failed"));
}
Serial.print(F("Total Data Received: "));
Serial.print(totalData);
Serial.println(" bytes");
Serial.print(F("Detected Errors in data received (Including Duplicates): "));
Serial.println(errorCount);
Serial.print(F("Duplicates: "));
Serial.println(duplicates);
Serial.println(F("-------------------------------------"));
}
}
// Send to the master node every second
if (millis() - millisTimer >= 1000) {
millisTimer = millis();
// Send an 'M' type to other Node containing the current millis()
if (!mesh.write(&millisTimer, 'M', sizeof(millisTimer), otherNodeID)) {
Serial.println(F("Send fail"));
if (!mesh.checkConnection()) {
do {
Serial.println(F("Reconnecting to mesh network..."));
} while (mesh.renewAddress() == MESH_DEFAULT_ADDRESS);
} else {
Serial.println(F("Send fail, Test OK"));
}
} else {
Serial.print(F("Send OK: "));
Serial.println(millisTimer);
}
}
if (millis() - stringTimer >= delayTime) {
stringTimer = millis();
//Copy the current number of characters to the temporary array
memcpy(tmpStr, dataStr, strCtr);
//Set the last character to NULL
tmpStr[strCtr] = '\0';
// Send the temp string as an 'S' type message
// Send it to otherNodeID (An RF24Mesh address lookup will be performed)
//bool ok = mesh.write(tmpStr,'S',strCtr+1,otherNodeID);
if (mesh.write(tmpStr, 'S', strCtr + 1, otherNodeID)) {
strCtr++;
delayTime = 333;
//Set the sending length back to 1 once max size is reached
if (strCtr == sizeof(dataStr)) {
strCtr = 1;
}
//if(strCtr == 12){ strCtr=1; }
}
}
}
|