Skip to content

Commit 54801b7

Browse files
authored
Merge pull request #334 from devreal/ttg-for-mra-print-pending-tasks
Print pending tasks
2 parents c169a85 + 2ec12a5 commit 54801b7

File tree

4 files changed

+14
-4
lines changed

4 files changed

+14
-4
lines changed

ttg/ttg/base/tt.h

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -233,6 +233,10 @@ namespace ttg {
233233
/// @return World in which this lives
234234
virtual ttg::World get_world() const = 0;
235235

236+
virtual void print_incomplete_tasks() const {
237+
throw std::runtime_error("print_incomplete_tasks not implemented!");
238+
}
239+
236240
/// Returns a pointer to the i'th input terminal
237241
ttg::TerminalBase *in(size_t i) {
238242
if (i >= inputs.size()) throw name + ":TTBase: you are requesting an input terminal that does not exist";

ttg/ttg/parsec/ttg.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4159,8 +4159,8 @@ namespace ttg_parsec {
41594159
}
41604160
}
41614161

4162-
void print_incomplete_tasks() {
4163-
parsec_hash_table_for_all(&tasks_table, ht_iter_cb, this);
4162+
virtual void print_incomplete_tasks() const override {
4163+
parsec_hash_table_for_all((parsec_hash_table_t*)&tasks_table, ht_iter_cb, (void*)this);
41644164
}
41654165

41664166
virtual void release() override { do_release(); }

ttg/ttg/tt.h

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,12 @@ namespace ttg {
104104
for (auto &op : tts) op->make_executable();
105105
}
106106

107+
virtual void print_incomplete_tasks() const override {
108+
for (auto& tt : tts) {
109+
tt->print_incomplete_tasks();
110+
}
111+
}
112+
107113
private:
108114
void own_my_tts() const {
109115
for (auto &op : tts) op->owning_ttg = this;

ttg/ttg/util/dot.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ namespace ttg {
7373
if (count != in->get_index()) throw "ttg::Dot: lost count of ins";
7474
if (disable_type) {
7575
ttss << " <in" << count << ">"
76-
<< " " << escape(in->get_key_type_str()) << " " << escape(in->get_name());
76+
<< escape(in->get_name());
7777
} else {
7878
ttss << " <in" << count << ">"
7979
<< " " << escape("<" + in->get_key_type_str() + "," + in->get_value_type_str() + ">") << " "
@@ -98,7 +98,7 @@ namespace ttg {
9898
if (count != out->get_index()) throw "ttg::Dot: lost count of outs";
9999
if (disable_type) {
100100
ttss << " <out" << count << ">"
101-
<< " " << escape(out->get_key_type_str()) << " " << out->get_name();
101+
<< out->get_name();
102102
} else {
103103
ttss << " <out" << count << ">"
104104
<< " " << escape("<" + out->get_key_type_str() + "," + out->get_value_type_str() + ">") << " "

0 commit comments

Comments
 (0)