blob: f0fa1d27cce363108756a7cfdfe024903c520654 (
plain)
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
|
#include <stdio.h>
#include <string.h>
#include <pthread.h>
#include "com.h"
#include "../records.h"
static void *rcvIPFromMasterThread(void *args){
while(1){
rcvIPFromMaster();
puts("Master IP receive !");
//delay(IP_SEND_INTERVAL/2); // Add delay to free cpu resources
}
}
static void *sendIPToSlaveThread(void *args){
while(1){
puts("Send Master IP to slave...");
sendIPToSlave();
delay(IP_SEND_INTERVAL); // Wait five minutes
}
}
static void *rcvDataFromSlaveThread(void *args){
while(1){
GWFrame frame;
frame=rcvDataFromSlave();
puts("Frame receive from a slave !");
saveFrame(frame);
}
}
void startGWCom(){
#if IS_MASTER != 0
pthread_t sendIPThread, rcvDataThread;
pthread_create(&sendIPThread, NULL, sendIPToSlaveThread, NULL);
pthread_create(&rcvDataThread, NULL, rcvDataFromSlaveThread, NULL);
#else
pthread_t rcvIPThread;
pthread_create(&rcvIPThread, NULL, rcvIPFromMasterThread, NULL);
#endif
}
|
