Skip to content

Commit 99283b6

Browse files
davidrohrcuveland
authored andcommitted
Throw in case an FLP cannot connect, Now we have nmin, and in any case, a dead FLP should break the run
1 parent a5fb13c commit 99283b6

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/common/rpc/StfSenderRpcClient.h

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -274,15 +274,14 @@ class StfSenderRpcClientCollection {
274274
}
275275

276276
// test if actual connections are performing on StfSender
277-
// NOTE: we cannot fail TfBuilder because the whole run will fail until nmin ODC/DDS is implemented
278-
// TfBuilder must be transition to Ready, but the input will be disabled
279277
bool lConnWorking = checkStfSenderRpcConn();
280278

281279
auto lMsg = "StfSender gRPC connection finished. success={} failed={}";
282280
if (lConnWorking) {
283281
IDDLOG(lMsg, lConnWorking, getNumConnectedClients() - getNumWorkingClients());
284282
} else {
285283
EDDLOG(lMsg, lConnWorking, getNumConnectedClients() - getNumWorkingClients());
284+
throw std::runtime_error("TfBuilder could not connect to all FLPs, terminating");
286285
}
287286

288287
// only continue when all connections are established

0 commit comments

Comments
 (0)