gr: be more generous of unconnected ports

Signed-off-by: Josh Morman <jmorman@gnuradio.org>

Author: mormj

gr/lib/buffer_management.cc

@@ -60,7 +60,8 @@ void buffer_manager::initialize_buffers(flat_graph_sptr fg,
         for (auto p : input_ports) {
             edge_vector_t ed = fg->find_edge(p);
             if (ed.empty()) {
-                throw std::runtime_error("Edge associated with input port not found");
+                ///throw std::runtime_error("Edge associated with input port not found");
+                continue;
             }
 
             // TODO: more robust way of ensuring readers don't get double-added

gr/lib/flowgraph.cc

@@ -39,7 +39,8 @@ void flowgraph::check_connections(const graph_sptr& g)
     // Are all non-optional ports connected to something
     for (auto& node : g->calc_used_nodes()) {
         for (auto& port : node->output_ports()) {
-            if (!port->optional() && port->connected_ports().empty()) {
+            if (!port->optional() && port->connected_ports().empty() &&
+                node->get_message_port("pdus_out")->connected_ports().empty()) {
                 throw std::runtime_error("Nothing connected to " + node->name() + ": " +
                                          port->name());
             }
@@ -49,7 +50,8 @@ void flowgraph::check_connections(const graph_sptr& g)
 
                 if (port->type() == port_type_t::STREAM) {
 
-                    if (port->connected_ports().empty()) {
+                    if (port->connected_ports().empty() &&
+                        node->get_message_port("pdus_in")->connected_ports().empty()) {
                         throw std::runtime_error("Nothing connected to " + node->name() +
                                                  ": " + port->name());
                     }

schedulers/nbt/lib/graph_executor.cc

@@ -19,7 +19,11 @@ graph_executor::run_one_iteration(std::vector<block_sptr> blocks)
         blocks = d_blocks;
     }
 
+    // This is only for streaming blocks
     for (auto const& b : blocks) { // TODO - order the blocks
+        if (b->work_mode() != block_work_mode_t::DEFAULT) {
+            continue;
+        }
 
         std::vector<block_work_input_sptr> work_input;   //(num_input_ports);
         std::vector<block_work_output_sptr> work_output; //(num_output_ports);