Function stat_thread_int

plugins/dbqueuedb/dbqueuedb.c:553–639

static int get_stats(struct dbtable *, int, void *, struct consumer_stat *);

static void stat_thread_int(struct dbtable *db, int fullstat, int walk_queue)
{
    if (db->dbtype != DBTYPE_QUEUE && db->dbtype != DBTYPE_QUEUEDB)
        logmsg(LOGMSG_ERROR, "'%s' is not a queue\n", db->tablename);
    else {
        int ii;
        struct consumer_stat stats[MAXCONSUMERS] = {{0}};
        int flags = 0;
        const struct bdb_queue_stats *bdbstats;

        bdbstats = bdb_queue_get_stats(db->handle);

        logmsg(LOGMSG_USER, "(scanning queue '%s' for stats, please wait...)\n",
               db->tablename);
        if (!walk_queue)
            flags = BDB_QUEUE_WALK_FIRST_ONLY;
        if (fullstat)
            flags |= BDB_QUEUE_WALK_KNOWN_CONSUMERS_ONLY;
        get_stats(db, flags, NULL, stats);

        logmsg(LOGMSG_USER, "queue '%s':-\n", db->tablename);
        logmsg(LOGMSG_USER, "  geese added     %u\n", db->num_goose_adds);
        logmsg(LOGMSG_USER, "  geese consumed  %u\n", db->num_goose_consumes);
        logmsg(LOGMSG_USER, "  bdb get bdbstats   %u log %u phys\n",
               bdbstats->n_logical_gets, bdbstats->n_physical_gets);
        logmsg(LOGMSG_USER, "  bdb deadlocks   add %u get %u con %u\n",
               bdbstats->n_add_deadlocks, bdbstats->n_get_deadlocks,
               bdbstats->n_consume_deadlocks);
        logmsg(LOGMSG_USER, "  bdb get not founds %u\n", bdbstats->n_get_not_founds);
        logmsg(LOGMSG_USER, "  bdb con bdbstats   new [con %u, abt %u, gee %u], old %u\n",
               bdbstats->n_new_way_frags_consumed,
               bdbstats->n_new_way_frags_aborted,
               bdbstats->n_new_way_geese_consumed,
               bdbstats->n_old_way_frags_consumed);

        if (db->dbtype == DBTYPE_QUEUEDB) {
            consumer_lock_read(db);
        }
        for (ii = 0; ii < MAXCONSUMERS; ii++) {
            struct consumer *consumer = db->consumers[ii];

            if (!fullstat && !consumer && !stats[ii].has_stuff)
                continue;

            if (consumer) {
                logmsg(LOGMSG_USER, "  [consumer %02d]: ", ii);
                switch (consumer->base.type) {
                default:
                    logmsg(LOGMSG_USER, "unknown consumer type %d?!\n", consumer->base.type);
                    break;
                }
                logmsg(LOGMSG_USER, "    %u messages consumed\n", consumer->n_consumed);
                if (walk_queue)
                    logmsg(LOGMSG_USER, "    %d items on queue\n", stats[ii].depth);
            } else
                logmsg(LOGMSG_USER, "  [consumer %02d]: none\n", ii);

            if (stats[ii].has_stuff) {