Function process_ack_with_payload

net/net_evbuffer.c:1403–1433

}

static int process_ack_with_payload(struct event_info *e)
{
    host_node_type *host_node_ptr = e->host_node_ptr;
    net_ack_message_payload_type *ack = &e->ack;
    if (e->state == 0) {
        ++e->state;
        net_ack_message_payload_type_get(ack, e->rd_buf, e->rd_buf + sizeof(*ack));
        e->need = ack->paylen;
        return 0;
    }
    void *p = malloc(ack->paylen);
    memcpy(p, e->rd_buf, ack->paylen);
    Pthread_mutex_lock(&host_node_ptr->wait_mutex);
    seq_data *ptr = host_node_ptr->wait_list;
    while (ptr != NULL && (ptr->seqnum != ack->seqnum)) {
        ptr = ptr->next;
    }
    if (ptr) {
        ptr->ack = 1;
        ptr->outrc = ack->outrc;
        ptr->payload = p;
        ptr->payloadlen = ack->paylen;
        Pthread_cond_signal(&host_node_ptr->ack_wakeup);
    }
    Pthread_mutex_unlock(&host_node_ptr->wait_mutex);
    if (!ptr) {
        free(p);
    }
    message_done(e);
    return 0;
}

static int process_decom_nodenum(struct event_info *e)
{