author | Maja Grubišić <maja.grubisic@live.com> |
Sat, 10 Nov 2012 19:16:38 +0100 | |
changeset 9134 | 7a750f032acd |
parent 6821 | 203367ae7433 |
child 11356 | 8589e611d657 |
permissions | -rw-r--r-- |
150
663120712cd9
fix coding style
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
131
diff
changeset
|
1 |
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */ |
9
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
2 |
/* |
4054
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
3 |
* Copyright (c) 2009 INRIA |
9
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
4 |
* |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
5 |
* This program is free software; you can redistribute it and/or modify |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
6 |
* it under the terms of the GNU General Public License version 2 as |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
7 |
* published by the Free Software Foundation; |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
8 |
* |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
9 |
* This program is distributed in the hope that it will be useful, |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
10 |
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
11 |
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
12 |
* GNU General Public License for more details. |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
13 |
* |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
14 |
* You should have received a copy of the GNU General Public License |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
15 |
* along with this program; if not, write to the Free Software |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
16 |
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
17 |
* |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
18 |
* Author: Mathieu Lacage <mathieu.lacage@sophia.inria.fr> |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
19 |
*/ |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
20 |
|
4047
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
21 |
#ifndef CALENDAR_SCHEDULER_H |
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
22 |
#define CALENDAR_SCHEDULER_H |
9
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
23 |
|
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
24 |
#include "scheduler.h" |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
25 |
#include <stdint.h> |
4052
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
26 |
#include <list> |
9
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
27 |
|
16
99e833adbb46
change yans namespace to ns3
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
9
diff
changeset
|
28 |
namespace ns3 { |
9
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
29 |
|
25
9b3bb088c560
first cut at george's ideas on api
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
16
diff
changeset
|
30 |
class EventImpl; |
9
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
31 |
|
3182 | 32 |
/** |
33 |
* \ingroup scheduler |
|
4054
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
34 |
* \brief a calendar queue event scheduler |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
35 |
* |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
36 |
* This event scheduler is a direct implementation of the algorithm known as a calendar queue. |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
37 |
* first published in 1988 in "Calendar Queues: A Fast O(1) Priority Queue Implementation for |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
38 |
* the Simulation Event Set Problem" by Randy Brown. There are many refinements published |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
39 |
* later but this class implements the original algorithm (to the best of my knowledge). |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
40 |
* |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
41 |
* Note: This queue is much slower than I expected (much slower than the std::map queue) |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
42 |
* and this seems to be because the original resizing policy is horribly bad. This is |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
43 |
* most likely the reason why there have been so many variations published which all |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
44 |
* slightly tweak the resizing heuristics to obtain a better distribution of events |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
45 |
* across buckets. |
3182 | 46 |
*/ |
6180
cd0d8ba00e6c
coding style
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4054
diff
changeset
|
47 |
class CalendarScheduler : public Scheduler |
3806
d0381b7f3030
define Scheduler::Event and use it in Scheduler::Insert
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3805
diff
changeset
|
48 |
{ |
4047
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
49 |
public: |
4054
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
50 |
static TypeId GetTypeId (void); |
d1df606b20f8
add SchedulerType global variable
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4052
diff
changeset
|
51 |
|
4047
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
52 |
CalendarScheduler (); |
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
53 |
virtual ~CalendarScheduler (); |
9
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
54 |
|
3806
d0381b7f3030
define Scheduler::Event and use it in Scheduler::Insert
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3805
diff
changeset
|
55 |
virtual void Insert (const Event &ev); |
1009
adc3ac9baea8
optimize EventImpl refcounting
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
963
diff
changeset
|
56 |
virtual bool IsEmpty (void) const; |
3807
268b86ce5435
don't use EventId in Schedulers: use Scheduler::Event instead.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3806
diff
changeset
|
57 |
virtual Event PeekNext (void) const; |
268b86ce5435
don't use EventId in Schedulers: use Scheduler::Event instead.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3806
diff
changeset
|
58 |
virtual Event RemoveNext (void); |
268b86ce5435
don't use EventId in Schedulers: use Scheduler::Event instead.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3806
diff
changeset
|
59 |
virtual void Remove (const Event &ev); |
1009
adc3ac9baea8
optimize EventImpl refcounting
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
963
diff
changeset
|
60 |
|
4047
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
61 |
private: |
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
62 |
void ResizeUp (void); |
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
63 |
void ResizeDown (void); |
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
64 |
void Resize (uint32_t newSize); |
4051
3df44c5a1ec1
introduce lastPrio to handle resizing correctly
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4048
diff
changeset
|
65 |
uint32_t CalculateNewWidth (void); |
6180
cd0d8ba00e6c
coding style
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4054
diff
changeset
|
66 |
void Init (uint32_t nBuckets, |
4052
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
67 |
uint64_t width, |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
68 |
uint64_t startPrio); |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
69 |
inline uint32_t Hash (uint64_t key) const; |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
70 |
void PrintInfo (void); |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
71 |
void DoResize (uint32_t newSize, uint32_t newWidth); |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
72 |
Scheduler::Event DoRemoveNext (void); |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
73 |
void DoInsert (const Event &ev); |
194
882aa1fc50fd
optimize other all comparison operators
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
182
diff
changeset
|
74 |
|
4052
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
75 |
typedef std::list<Scheduler::Event> Bucket; |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
76 |
Bucket *m_buckets; |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
77 |
// number of buckets in array |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
78 |
uint32_t m_nBuckets; |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
79 |
// duration of a bucket |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
80 |
uint64_t m_width; |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
81 |
// bucket index from which the last event was dequeued |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
82 |
uint32_t m_lastBucket; |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
83 |
// priority at the top of the bucket from which last event was dequeued |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
84 |
uint64_t m_bucketTop; |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
85 |
// the priority of the last event removed |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
86 |
uint64_t m_lastPrio; |
62bed1686d48
simplify the implementation
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
4051
diff
changeset
|
87 |
// number of events in queue |
4047
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
88 |
uint32_t m_qSize; |
9
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
89 |
}; |
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
90 |
|
3805
902c5237743a
reuse operator < (EventKey)
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3187
diff
changeset
|
91 |
} // namespace ns3 |
9
2c31ae7c94db
import from yans
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
diff
changeset
|
92 |
|
4047
83d920cdfd3f
a Calendar queue without resizing.
Mathieu Lacage <mathieu.lacage@sophia.inria.fr>
parents:
3807
diff
changeset
|
93 |
#endif /* CALENDAR_SCHEDULER_H */ |