Function fstdump_thread

bdb/fstdump.c:231–289

}

static void *fstdump_thread(void *arg)
{
    fstdump_per_thread_t *fstdump = (fstdump_per_thread_t *)arg;
    fstdump_t *common = fstdump->common;
    void *ret = NULL;
    void *sendrec;
    void *databuf;
    size_t buffer_length;
    bdb_state_type *bdb_state = common->bdb_state;

    /*thread_started("bdb fstdump");*/

    /* work out how large a buffer we need.  It must be a multiple of 1KB,
     * larger than the page size and unsigned int aligned
     * (see berkdb docs). */
    buffer_length = bdb_state->attr->fstdump_buffer_length;
    if ((buffer_length & (1024 - 1)) != 0)
        buffer_length &= ~(1024 - 1);
    if (buffer_length < bdb_state->attr->pagesizedta)
        buffer_length = bdb_state->attr->pagesizedta;

    sendrec = mymalloc(common->sendrecsz);
    if (!sendrec)
        logmsg(LOGMSG_ERROR, "fstdump_thread: mymalloc %zu failed (sendrec)\n",
               common->sendrecsz);
    databuf = mymalloc(buffer_length);
    if (!databuf)
        logmsg(LOGMSG_ERROR, "fstdump_thread: mymalloc %u failed (databuf)\n",
                (unsigned)buffer_length);

    if (sendrec && databuf) {
        /* If not threaded then read lock etc already acquired */
        if (fstdump->real_thread) {
            bdb_thread_event(common->bdb_state, BDBTHR_EVENT_START_RDONLY);
            BDB_READLOCK("fstdump_thread");
        }

        ret = fstdump_thread_inner(fstdump, sendrec, databuf, buffer_length);

        if (fstdump->real_thread) {
            BDB_RELLOCK();
            bdb_thread_event(common->bdb_state, BDBTHR_EVENT_DONE_RDONLY);
        }
    } else {
        Pthread_mutex_lock(&common->lock);
        {
            common->bdberr = BDBERR_MALLOC;
            snprintf0(common->errmsg, sizeof(common->errmsg), "out of memory");
        }
        Pthread_mutex_unlock(&common->lock);
    }

    if (sendrec)
        free(sendrec);
    if (databuf)
        free(databuf);

    return ret;