Function watcher_thread

bdb/rep.c:5315–5800

}

void *watcher_thread(void *arg)
{
    bdb_state_type *bdb_state;
    extern int gbl_rep_lock_time_ms;
    extern int gbl_truncating_log;
    char *master_host = db_eid_invalid;
    int stopped_count = 0;
    int i;
    int j;
    int time_now, time_then;
    int rc;
    int master_is_bad = 0;
    int done = 0;
    char *rep_master = 0;
    int list_start;

    gbl_watcher_thread_ran = comdb2_time_epoch();

    thrman_register(THRTYPE_WATCHDOG);
    thread_started("bdb watcher");

    /* hold off on "watching" for a little bit during startup */
    sleep(5);

    bdb_state = (bdb_state_type *)arg;
    bdb_thread_event(bdb_state, BDBTHR_EVENT_START_RDONLY);

    /* if we were passed a child, find his parent */
    if (bdb_state->parent)
        bdb_state = bdb_state->parent;

    print(bdb_state, "watcher_thread started as 0x%"PRIxPTR"\n",
          (intptr_t)pthread_self());

    poll(NULL, 0, (rand() % 100) + 1000);

    i = 0;
    j = 0;

    bdb_state->repinfo->disable_watcher = 0;

    while (!db_is_stopped()) {
        time_now = comdb2_time_epoch();
        time_then = bdb_state->repinfo->disable_watcher;

        if (time_now < time_then) {
            int diff;
            diff = time_then - time_now;

            /* safeguard - no way are we gonna pause more than a minute here */
            if (diff > 60)
                diff = 60;
            logmsg(LOGMSG_WARN, "watcher thread pausing for %d second\n", diff);
            sleep(diff);
        }

        if (gbl_truncating_log) {
            stopped_count++;