Boss/Mod/ChannelFinderBy*: Only re-trigger if not already running.

Boss/Mod/ChannelFinderByDistance.cpp

@@ -384,8 +384,15 @@ void ChannelFinderByDistance::start() {
 		     >([this](Msg::SolicitChannelCandidates const& _) {
 		if (!rpc)
 			return Ev::lift();
+		if (running)
+			return Ev::lift();
+
+		running = true;
 		auto run = Run::create(bus, *rpc, waiter, self_id);
-		return Boss::concurrent(run->run());
+		return Boss::concurrent(run->run().then([this]() {
+			running = false;
+			return Ev::lift();
+		}));
 	});
 }
 

Boss/Mod/ChannelFinderByDistance.hpp

@@ -21,6 +21,7 @@ class ChannelFinderByDistance {
 	Boss::Mod::Rpc* rpc;
 	Boss::Mod::Waiter& waiter;
 	Ln::NodeId self_id;
+	bool running;
 
 	class Run;
 
@@ -37,6 +38,7 @@ class ChannelFinderByDistance {
 			       ) : bus(bus_)
 				 , rpc(nullptr)
 				 , waiter(waiter_)
+				 , running(false)
 				 { start(); }
 };
 

Boss/Mod/ChannelFinderByListpays.cpp

@@ -48,7 +48,10 @@ void ChannelFinderByListpays::start() {
 		     >([this](Msg::SolicitChannelCandidates const& m) {
 		if (!rpc)
 			return Ev::lift();
+		if (running)
+			return Ev::lift();
 
+		running = true;
 		auto act = rpc->command( "listpays", Json::Out::empty_object()
 				       ).then([this](Jsmn::Object res) {
 			auto payees = std::map<Ln::NodeId, std::size_t>();
@@ -124,6 +127,9 @@ void ChannelFinderByListpays::start() {
 			act += Ev::foreach(std::move(f), std::move(proposals));
 
 			return act;
+		}).then([this]() {
+			running = false;
+			return Ev::lift();
 		});
 		return Boss::concurrent(act);
 	});

Boss/Mod/ChannelFinderByListpays.hpp

@@ -22,6 +22,8 @@ class ChannelFinderByListpays {
 	/* Peers we already have channels with.  */
 	std::set<Ln::NodeId> channels;
 
+	bool running;
+
 	void start();
 
 public:
@@ -33,6 +35,7 @@ class ChannelFinderByListpays {
 	ChannelFinderByListpays( S::Bus& bus_
 			       ) : bus(bus_)
 				 , rpc(nullptr)
+				 , running(false)
 				 { start(); }
 };