Skip to content

Commit d07c8b8

Browse files
committed
Cleanup.
1 parent 1c756d2 commit d07c8b8

1 file changed

Lines changed: 0 additions & 41 deletions

File tree

include/react/propagation/TopoSortEngine.h

Lines changed: 0 additions & 41 deletions
Original file line numberDiff line numberDiff line change
@@ -42,37 +42,6 @@ using std::vector;
4242
using tbb::concurrent_vector;
4343
using tbb::queuing_rw_mutex;
4444
using tbb::task_group;
45-
using tbb::task;
46-
using tbb::task_group_context;
47-
using tbb::empty_task;
48-
49-
using AffinityT = task::affinity_id;
50-
51-
template <typename TNode, typename TTurn>
52-
class UpdateTask : public task
53-
{
54-
public:
55-
UpdateTask(TNode* node, TTurn* turn) :
56-
node_{ node },
57-
turn_{ turn }
58-
{
59-
}
60-
61-
virtual task* execute() override
62-
{
63-
node_->Tick(turn_);
64-
return nullptr;
65-
}
66-
67-
virtual void note_affinity (AffinityT id)
68-
{
69-
node_->Affinity = id;
70-
}
71-
72-
private:
73-
TNode* node_;
74-
TTurn* turn_;
75-
};
7645

7746
///////////////////////////////////////////////////////////////////////////////////////////////////
7847
/// SeqNode
@@ -96,8 +65,6 @@ class ParNode : public IReactiveNode
9665
int Level = 0;
9766
int NewLevel = 0;
9867
atomic<bool> Collected = false;
99-
task* CurrentTask = nullptr;
100-
AffinityT Affinity = 0;
10168

10269
NodeVector<ParNode> Successors;
10370
};
@@ -170,13 +137,6 @@ class ParEngineBase : public EngineBase<ParNode,TTurn>
170137
public:
171138
using DynRequestVectT = concurrent_vector<DynRequestData>;
172139

173-
ParEngineBase() :
174-
context_{task_group_context::bound, task_group_context::default_traits | task_group_context::concurrent_wait}
175-
{
176-
rootTask_ = new( task::allocate_root(context_) ) empty_task;
177-
rootTask_->set_ref_count(1);
178-
}
179-
180140
void OnTurnPropagate(TTurn& turn);
181141

182142
void OnDynamicNodeAttach(ParNode& node, ParNode& parent, TTurn& turn);
@@ -188,7 +148,6 @@ class ParEngineBase : public EngineBase<ParNode,TTurn>
188148

189149
virtual void processChildren(ParNode& node, TTurn& turn) override;
190150

191-
192151
ConcurrentTopoQueue<ParNode> topoQueue_;
193152

194153
DynRequestVectT dynRequests_;

0 commit comments

Comments
 (0)