terminate even if signal is stale; faster termination for shuffle bounder

Author: bknueven

Diff for: mpisppy/cylinders/spoke.py

@@ -27,7 +27,7 @@ def got_kill_signal(self):
         """
         shutdown_buf = self.receive_buffers[self._make_key(Field.SHUTDOWN, 0)]
         self.get_receive_buffer(shutdown_buf, Field.SHUTDOWN, 0)
-        return (shutdown_buf.is_new() and shutdown_buf[0] == 1.0)
+        return shutdown_buf[0] == 1.0
 
     @abc.abstractmethod
     def main(self):

Diff for: mpisppy/cylinders/xhatshufflelooper_bounder.py

@@ -136,6 +136,10 @@ def _vb(msg):
                         _vb(f"   Updating best to {next_scendict}")
                         scenario_cycler.best = next_scendict["ROOT"]
 
+                if self.got_kill_signal():
+                    # time to go; don't solve next
+                    return
+
             next_scendict = scenario_cycler.get_next()
             if next_scendict is not None:
                 _vb(f"   Trying next {next_scendict}")