Method onDisconnect

src/dmtcp_coordinator.cpp:786–832

}

void
DmtcpCoordinator::onDisconnect(CoordClient *client)
{
  if (client->isNSWorker()) {
    client->sock().close();
    delete client;
    return;
  }
  for (size_t i = 0; i < clients.size(); i++) {
    if (clients[i] == client) {
      clients.erase(clients.begin() + i);
      break;
    }
  }
  client->sock().close();
  JNOTE("client disconnected") (client->identity()) (client->progname());
  _virtualPidToClientMap.erase(client->virtualPid());

  ComputationStatus s = getStatus();
  if (s.numPeers < 1) {
    if (flags.exitOnLast) {
      JNOTE("last client exited, shutting down..");
      handleUserCommand("q");
    } else {
      removeStaleSharedAreaFile();
    }

    // If a kill in is progress, the coordinator refuses any new connections,
    // thus we need to reset it to false once all the processes in the
    // computations have disconnected.
    killInProgress = false;
  } else {
    // If the coordinator waits at currentBarrier, try to release it.
    if (!currentBarrier.empty()) {
      // If already registered as a worker at current barrier,
      // decrement the worker counter before try to release the barrier.
      if (client->barrier() == currentBarrier) {
        --workersAtCurrentBarrier;
      }
      releaseBarrier(currentBarrier);
    }
  }

  CoordPluginMgr::clientDisconnected(client, s);

  delete client;
}

void
DmtcpCoordinator::initializeComputation()