|
Lines 664-669
static void _add_registered_cluster(slurmdbd_conn_t *db_conn)
Link Here
|
| 664 |
while ((slurmdbd_conn = list_next(itr))) { |
664 |
while ((slurmdbd_conn = list_next(itr))) { |
| 665 |
if (db_conn == slurmdbd_conn) |
665 |
if (db_conn == slurmdbd_conn) |
| 666 |
break; |
666 |
break; |
|
|
667 |
|
| 668 |
if (!xstrcmp(db_conn->conn->cluster_name, |
| 669 |
slurmdbd_conn->conn->cluster_name) && |
| 670 |
(db_conn->conn->fd != slurmdbd_conn->conn->fd)) { |
| 671 |
error("A new registration for cluster %s CONN:%d just came in, but I am already talking to that cluster (CONN:%u), closing other connection.", |
| 672 |
db_conn->conn->cluster_name, db_conn->conn->fd, |
| 673 |
slurmdbd_conn->conn->cluster_name, |
| 674 |
slurmdbd_conn->conn->fd); |
| 675 |
slurmdbd_conn->conn->rem_port = 0; |
| 676 |
list_delete_item(itr); |
| 677 |
} |
| 667 |
} |
678 |
} |
| 668 |
list_iterator_destroy(itr); |
679 |
list_iterator_destroy(itr); |
| 669 |
if (!slurmdbd_conn) |
680 |
if (!slurmdbd_conn) |
