Function hello_msg_common

net/net_evbuffer.c:1260–1329

}

static int hello_msg_common(struct event_info *e)
{
    int rc = -1;
    uint32_t nn;
    uint8_t *buf = e->rd_buf;
    memcpy(&nn, buf, sizeof(nn));
    buf += sizeof(nn);
    const uint32_t n = htonl(nn);
    if (n > REPMAX) {
        hprintf("RECV'd BAD COUNT OF HOSTS:%u (max:%d)\n", n, REPMAX);
        return -1;
    }
    char **hosts = malloc(sizeof(char *) * n);
    for (uint32_t i = 0; i < n; ++i) {
        hosts[i] = malloc(HOSTNAME_LEN + 1);
        memcpy(hosts[i], buf, HOSTNAME_LEN);
        buf += HOSTNAME_LEN;
        hosts[i][HOSTNAME_LEN] = 0;
    }
    uint32_t *ports = malloc(sizeof(uint32_t) * n);
    for (uint32_t i = 0; i < n; ++i) {
        memcpy(&ports[i], buf, sizeof(uint32_t));
        buf += sizeof(ports[i]);
        ports[i] = htonl(ports[i]);
    }
    buf +=  (n * sizeof(uint32_t)); /* We have no use for node numbers */
    for (uint32_t i = 0; i < n; ++i) {
        int need_free = 0;
        char *host = hosts[i];
        if (*host == '.') {
            ++host;
            uint32_t s = atoi(host);
            if (s > HOST_NAME_MAX) {
                hprintf("RECV'd BAD HOSTNAME len:%u (max:%d)\n", s, HOST_NAME_MAX);
                goto out;
            }
            need_free = 1;
            host = malloc(s + 1);
            memcpy(host, buf, s);
            buf += s;
            host[s] = 0;
        }
        if (strcmp(host, gbl_myhostname) == 0) {
            if (need_free) free(host);
            continue;
        }
        struct host_info *hi = host_info_find(host);
        if (hi && event_info_find(e->net_info, hi)) {
            if (need_free) free(host);
            continue;
        }
        char *ihost = intern(host);
        if (need_free) free(host);
        netinfo_type *netinfo_ptr = e->net_info->netinfo_ptr;
        if (netinfo_ptr->allow_rtn && !netinfo_ptr->allow_rtn(netinfo_ptr, ihost)) { /* net_allow_node */
            logmsg(LOGMSG_ERROR, "connection to host:%s not allowed\n", ihost);
            continue;
        }