-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathPWDriver.h
110 lines (81 loc) · 3.02 KB
/
PWDriver.h
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
/*
* Copyright (C) 2015 Miguel Rodríguez Pérez <miguel@det.uvigo.es>
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#ifndef PWDRIVER_H
#define PWDRIVER_H
#include "DutyDriver.h"
#include "Event.h"
#include "Node.h"
#include <map>
#include <tuple>
/* Based on PW-MAC:
* Nodes wait for listening until predicted wake-up time of the receiver, if known
* Receivers enter a fixed sleep cycle of length L after each reception (random between ½ and 1½L)
* Each receiver uses a different rng
* We ignore the idle time after beacon transmission
*
*/
class PWNode;
class PWDriver : public DutyDriver {
private:
std::map<Node::nodeid_t, std::tuple<Event::evtime_t, unsigned int>> predictions;
Event::evtime_t scheduleTxSlowPath(Event::evtime_t now, int backoff) const;
void scheduleListen(Node::nodeid_t dst, Event::evtime_t now);
protected:
class PseudoRNG {
const unsigned int a_, c_, m_;
unsigned int x_;
public:
PseudoRNG(unsigned int seed) : a_(1103515245), c_(12345), m_(1 << 31), x_(seed) {
}
auto getCurrentValue() const {
return x_;
}
auto operator()() {
x_ = (a_ * x_ + c_) % m_;
return x_;
}
auto randMax() const {
return m_;
}
} rng_;
virtual Event::evtime_t getExpectedExactBeaconTime(Node::nodeid_t dst, Event::evtime_t now);
Event::evtime_t getTimeUntilListen();
Event::evtime_t getExpectedBeaconTime(Node::nodeid_t dst, Event::evtime_t now) {
auto beacon_time = getExpectedExactBeaconTime(dst, now);
return std::max(now, beacon_time - 10e-3); // 10ms error máx
}
Event::evtime_t getPrevBeaconTime(Node::nodeid_t dst, Event::evtime_t next_beacon);
public:
PWDriver(const Node& node, Event::evtime_t bitlen);
virtual void newData(unsigned int next_hop, Event::evtime_t now) {
DutyDriver::newData(next_hop, now);
scheduleListen(next_hop, now);
}
virtual Event::evtime_t scheduleTx(Event::evtime_t now, int backoff) const {
if (backoff == 0)
return now;
return scheduleTxSlowPath(now, backoff);
}
virtual Event::evtime_t scheduleRx(Event::evtime_t now) {
return now + getTimeUntilListen();
}
virtual void setIdlestMode(Event::evtime_t now) {
// We wake-up ourselves when appropriate
setStatus(status_t::SLEEPING, now);
}
};
#endif /* PWDRIVER_H */