Function process_hello_common

net/net.c:4252–4294

Common code for processing hello and hello reply. * * Inputs: look_for_magic==1 if we want to check for the MAGICNODE. * * Returns: * 1 Hello was rejected (contained bad port numbers or error in * read_hostlist). * -1 IO error, reader thread cleans up. * 0 Success. */

 *    0     Success.
 */
static int process_hello_common(netinfo_type *netinfo_ptr,
                                host_node_type *host_node_ptr,
                                int look_for_magic)
{
    char *hosts[REPMAX];
    int ports[REPMAX];
    host_node_type *newhost, *fndhost;
    int rc;
    int numhosts = REPMAX;

    rc = read_hostlist(netinfo_ptr, host_node_ptr->sb, hosts, ports, &numhosts);
    if (rc < 0)
        return -1; /* reader thread cleans up */
    if (rc != 0) {
        logmsg(LOGMSG_ERROR, 
               "process_hello_common:error from read_hostlist, rc=%d\n", rc);
        return 0;
    }

    /* add each host, dont worry, dupes wont be added */
    for (int i = 0; i < numhosts; i++) {
        // only truly new hosts will return non-NULL
        newhost = add_to_netinfo(netinfo_ptr, intern(hosts[i]), ports[i]);

        if (newhost != NULL) {
            /* get readlock to prevent host from disappearing */
            Pthread_rwlock_rdlock(&(netinfo_ptr->lock));

            fndhost = get_host_node_by_name_ll(netinfo_ptr, intern(hosts[i]));
            if (fndhost)
                connect_to_host(netinfo_ptr, fndhost, host_node_ptr);

            Pthread_rwlock_unlock(&(netinfo_ptr->lock));
        }

        host_node_ptr->got_hello = 1;
    }

    for (int i = 0; i < numhosts; i++)
        free(hosts[i]);

    return 0;
}

static void *reader_thread(void *arg)
{