Revision 31:7ca80c48a6d7, committed 2018-12-06
- Comitter:
- leomerel
- Date:
- Thu Dec 06 20:28:22 2018 +0000
- Parent:
- 30:f8df12b28719
- Commit message:
- VF; Version finale remise avec le rapport final. Par rapport a la version precedente, on a ajoute la communication avec le rasberryPi.
Changed in this revision
diff -r f8df12b28719 -r 7ca80c48a6d7 main.cpp
--- a/main.cpp Wed Dec 05 16:13:36 2018 +0000
+++ b/main.cpp Thu Dec 06 20:28:22 2018 +0000
@@ -1,3 +1,9 @@
+/*
+* GTA (Gestion du Trafic Adaptatif) Sherbrooke
+* Code à mettre dans le mbed du noeud fixe
+* Par : Léo MEREL, Jean-Philippe BAILLARGEON, Pierre BLOUET, Alex VIGNEAULT, Mikaël LAMONTAGNE
+*/
+
#include "mbed.h"
#include "XBeeLib.h"
#include "rtos.h"
@@ -28,8 +34,9 @@
//Gestion
int temps = 5000; //durée (en ms) pour qu'une voiture traverse le chantier
+int duree_cycle = 10000; // durée (en ms) du cycle d'allumage classique
Timer timer;
-int whosred;
+int isRed;
Thread t_setFeu1Vert;
Thread t_setFeu2Vert;
bool stay1=0; /* stay est une variable qui est à 1 lorsqu'on veut qu'un feu reste à une */
@@ -56,27 +63,36 @@
Mail<int,128> mail_box;
+// Envoyer un message au rasberryPi
void sendMessage() {
EthernetInterface eth;
eth.init(); //Use DHCP
eth.connect();
- printf("\nClient IP Address is %s\n", eth.getIPAddress());
+ printf("\r\nClient IP Address is %s\r\n", eth.getIPAddress());
// Connect to Server
TCPSocketConnection socket;
while (socket.connect(ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT) < 0) {
- printf("Unable to connect to (%s) on port (%d)\n", ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT);
+ printf("Unable to connect to (%s) on port (%d)\r\n", ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT);
wait(1);
}
- printf("Connected to Server at %s\n",ECHO_SERVER_ADDRESS);
+ printf("Connected to Server at %s\r\n",ECHO_SERVER_ADDRESS);
int * i = 0;
- char hello[] = "10";
+ char hello[] = "100";
while(1) {
osEvent evt = mail_box.get();
if (evt.status == osEventMail) {
i = (int*)evt.value.p;
- sprintf(hello, "%d", i);
- printf("Sending message to Server : '%s' \n",hello);
+ if(*i<10){
+ sprintf(hello, "00%d\r\n", *i);
+ }
+ else if(*i<100){
+ sprintf(hello, "0%d\r\n", *i);
+ }
+ else{
+ sprintf(hello, "%d\r\n", *i);
+ }
+ printf("Sending message to Server : '%s' \r\n",hello);
socket.send_all(hello, sizeof(hello) - 1);
mail_box.free(i);
}
@@ -85,6 +101,7 @@
}
+// Envoyer un message à un autre mbed, via un xbee d'adresse connue
static void send_explicit_data_to_remote_node(XBeeZB& xbee, const RemoteXBeeZB& RemoteDevice,const char * data)
{
const uint8_t dstEP = 0xE8;
@@ -112,7 +129,8 @@
log_serial->printf("Nombre de voitures feu 1 : %d\r\n",voituresFeu1);
log_serial->printf("Nombre de voitures feu 2 : %d\r\n",voituresFeu2);
int *a = mail_box.alloc();
- a = voituresFeu1+voituresFeu2;
+ *a = voituresFeu1+voituresFeu2;
+ log_serial->printf("Voiture total : %d\r\n",*a);
mail_box.put(a);
}
else if (data[0]==0x70){
@@ -127,21 +145,22 @@
log_serial->printf("Nombre de voitures feu 1 : %d\r\n",voituresFeu1);
log_serial->printf("Nombre de voitures feu 2 : %d\r\n",voituresFeu2);
int *a = mail_box.alloc();
- a = voituresFeu1+voituresFeu2;
+ *a = voituresFeu1+voituresFeu2;
+ log_serial->printf("Voiture total : %d\r\n",*a);
mail_box.put(a);
}
else if (data[0]==0x72){
// confirmation que r1 est bien rouge, donc peut demander au r2 de passer au vert
if ( UINT64_LO32(remote_addr64) == UINT64_LO32(REMOTE_NODE_ADDR64_LSB1)){
if(vehicule_urgence==0){
- whosred = 1;
+ isRed = 1;
t_setFeu2Vert.signal_set(0x1);
}
}
// confirmation que r2 est bien rouge, donc peut demander au r1 de passer au vert
else if ( UINT64_LO32(remote_addr64) == UINT64_LO32(REMOTE_NODE_ADDR64_LSB2)){
if(vehicule_urgence==0){
- whosred = 2;
+ isRed = 2;
t_setFeu1Vert.signal_set(0x1);
}
}
@@ -155,7 +174,7 @@
Thread::wait(temps);
if(vehicule_urgence==0){
send_explicit_data_to_remote_node(xbee, remoteDevice1,set_vert);
- log_serial->printf("r1 passe au vert");
+ log_serial->printf("r1 passe au vert\r\n");
}
}
}
@@ -167,10 +186,11 @@
if(vehicule_urgence==0){
send_explicit_data_to_remote_node(xbee, remoteDevice2,set_vert);
}
- log_serial->printf("r2 passe au vert");
+ log_serial->printf("r2 passe au vert\r\n");
}
}
+// Connection faite au démarrage du programme lorsqu'on reset le mbed
void connect_Xbee()
{
log_serial = new Serial(DEBUG_TX, DEBUG_RX);
@@ -193,7 +213,7 @@
log_serial->printf(".");
}
log_serial->printf("Connection reussie.\r\n");
- whosred=1;
+ isRed=1;
}
void gestion()
@@ -222,13 +242,13 @@
else{
stay1=0;
stay2=0;
- if(whosred==1){
+ if(isRed==1){
send_explicit_data_to_remote_node(xbee, remoteDevice2,set_rouge);
}
- else if(whosred==2){
+ else if(isRed==2){
send_explicit_data_to_remote_node(xbee, remoteDevice1,set_rouge);
}
- Thread::wait(10000);
+ Thread::wait(duree_cycle);
}
}
}
@@ -237,9 +257,6 @@
led3 = !led3;
t_urgence.signal_set(0x1);
}
-void fall() {
- led2 = !led2;
-}
void blink(){
while(1){
@@ -266,9 +283,7 @@
}
}
-int main()
-{
-
+int main(){
led2=0;
led3=0;
led4=0;
@@ -282,7 +297,6 @@
t_Ethernet.start(sendMessage);
button.rise(&rise); // attach the address of the flip function to the rising edge
- button.fall(&fall);
while (true) {
uint32_t receive_value = xbee.process_rx_frames();//nécessaire pour lire (constamment) la valeur recue
Leo Merel
