Formatting

src/schedule.cpp

@@ -14,49 +14,33 @@ struct stream_info
 {
     std::unordered_map<instruction_ref, std::size_t> ins2stream;
 
-    void set_stream(instruction_ref ins, std::size_t n)
-    {
-        ins2stream[ins] = n;
-    }
+    void set_stream(instruction_ref ins, std::size_t n) { ins2stream[ins] = n; }
 
-    std::size_t get_stream(instruction_ref ins) const
-    {
-        return ins2stream.at(ins);
-    }
+    std::size_t get_stream(instruction_ref ins) const { return ins2stream.at(ins); }
 
-    bool has_stream(instruction_ref ins) const
-    {
-        return ins2stream.count(ins) > 0;
-    }
+    bool has_stream(instruction_ref ins) const { return ins2stream.count(ins) > 0; }
 
     bool different(const std::vector<instruction_ref>& v) const
     {
-        if (v.size() < 2)
+        if(v.size() < 2)
             return false;
         auto stream = get_stream(v.front());
-        return not std::all_of(v.begin(), v.end(), [&](instruction_ref x) {
-            return get_stream(x) == stream;
-        });
+        return not std::all_of(
+            v.begin(), v.end(), [&](instruction_ref x) { return get_stream(x) == stream; });
     }
 
-    bool is_split_point(instruction_ref ins) const
-    {
-        return different(ins->outputs());
-    }
+    bool is_split_point(instruction_ref ins) const { return different(ins->outputs()); }
 
-    bool is_merge_point(instruction_ref ins) const
-    {
-        return different(ins->inputs());
-    }
+    bool is_merge_point(instruction_ref ins) const { return different(ins->inputs()); }
 
     std::vector<std::size_t> wait_for(instruction_ref ins) const
     {
         std::set<std::size_t> result;
         auto s = get_stream(ins);
-        for(auto i:ins->inputs())
+        for(auto i : ins->inputs())
         {
             auto stream = get_stream(i);
-            if (stream != s)
+            if(stream != s)
                 result.insert(stream);
         }
         return {result.begin(), result.end()};
@@ -85,39 +69,39 @@ void schedule::apply(program& p) const
     // Assign streams
     auto streams = model.concurrency();
     stream_info si;
-    for(std::size_t stream = 0;stream < streams;stream++)
+    for(std::size_t stream = 0; stream < streams; stream++)
     {
         fix([&](auto self, auto ins) {
             // Only assign streams fi not already assigned
-            if (not si.has_stream(ins))
+            if(not si.has_stream(ins))
                 si.set_stream(ins, stream);
             instruction_ref child = p.end();
             std::size_t w         = 0;
-            for(auto i:ins->inputs())
+            for(auto i : ins->inputs())
             {
                 const auto weight = weights[i];
                 // Skip instruction that already have stream assignment or too low of weights
-                if (si.has_stream(i) or weight <= min_partition_threshold) 
+                if(si.has_stream(i) or weight <= min_partition_threshold)
                 {
                     self(i);
                 }
                 // Accumulate the max weight
-                else if (weight > w)
+                else if(weight > w)
                 {
                     child = i;
                     w     = weight;
                 }
             }
-            if (child != p.end())
+            if(child != p.end())
                 self(child);
         })(last);
     }
     // Assign remaining instructions
-    for(auto ins:iterator_for(p))
+    for(auto ins : iterator_for(p))
     {
-        if (si.has_stream(ins))
+        if(si.has_stream(ins))
             continue;
-        si.set_stream(ins, streams-1);
+        si.set_stream(ins, streams - 1);
     }
 
     // Topo sort
@@ -129,16 +113,16 @@ void schedule::apply(program& p) const
     })(last);
 
     // Schedule instructions
-    for(auto ins:iterator_for(p))
+    for(auto ins : iterator_for(p))
     {
-        if (si.is_merge_point(ins)) 
+        if(si.is_merge_point(ins))
         {
             assert(not si.wait_for(ins).empty());
             model.wait(p, ins, si.get_stream(ins), si.wait_for(ins));
             continue;
         }
         // Skip scheduling instructions with no context
-        if (is_context_free(ins->get_operator()) or ins->get_operator().name().front() == '@')
+        if(is_context_free(ins->get_operator()) or ins->get_operator().name().front() == '@')
             continue;
         model.schedule_instruction(p, ins, si.get_stream(ins));
     }

src/targets/gpu/schedule_model.cpp

@@ -100,7 +100,7 @@ std::size_t schedule_model::weight(const operation& op) const
 {
     if(weight_map().count(op.name()) == 0)
     {
-        if (is_context_free(op) or op.name()[0] == '@')
+        if(is_context_free(op) or op.name()[0] == '@')
             return 0;
         return 1;
     }