Function deadlockdetect_thread

bdb/threads.c:154–209

}

void *deadlockdetect_thread(void *arg)
{
    bdb_state_type *bdb_state;
    int aborted;

    bdb_state = (bdb_state_type *)arg;

    if (bdb_state->parent)
        bdb_state = bdb_state->parent;

    while (!bdb_state->after_llmeta_init_done)
        sleep(1);

    thread_started("bdb deadlockdetect");

    bdb_thread_event(bdb_state, 1);

    while (1) {
        int rc;
        int policy;

        BDB_READLOCK("deadlockdetect thread");

        policy = DB_LOCK_MINWRITE;

        if (bdb_state->attr->deadlock_most_writes)
            policy = DB_LOCK_MAXWRITE;
        if (bdb_state->attr->deadlock_youngest_ever)
            policy = DB_LOCK_YOUNGEST_EVER;

        if (db_is_exiting()) {
            logmsg(LOGMSG_DEBUG, "deadlockdetect_thread: exiting\n");

            BDB_RELLOCK();
            bdb_thread_event(bdb_state, 0);
            pthread_exit(NULL);
        }

        aborted = 0;

        rc = bdb_state->dbenv->lock_detect(bdb_state->dbenv, 0, policy,
                                           &aborted);

        if (rc != 0) {
            logmsg(LOGMSG_FATAL, "lock_detect rc %d\n", rc);
            exit(1);
        }

        BDB_RELLOCK();

        if (aborted != 0) /* loop hard if aborted */
            poll(0, 0, bdb_state->attr->deadlockdetectms);
        else
            sleep(1);
    }
}

void *master_lease_thread(void *arg)