summaryrefslogtreecommitdiffstats
path: root/machine/m_common.c
diff options
context:
space:
mode:
Diffstat (limited to 'machine/m_common.c')
-rw-r--r--machine/m_common.c79
1 files changed, 0 insertions, 79 deletions
diff --git a/machine/m_common.c b/machine/m_common.c
index 70a1258..cc4e94a 100644
--- a/machine/m_common.c
+++ b/machine/m_common.c
@@ -31,85 +31,6 @@ char *procstatenames[] =
" disabled, ", NULL
};
-/*
- * Get database info via the above QUERY_STAT_DB info.
- * Returns rate info on the various statistics by comparing current
- * values with previous values.
- */
-void
-get_database_info(struct db_info *db_info, struct pg_conninfo_ctx *conninfo)
-{
- struct timeval thistime;
- double timediff;
- int i;
- int rows;
- PGresult *pgresult = NULL;
- struct db_info cur_info;
- static struct timeval lasttime;
- static struct db_info last_db_info;
-
- /* calculate the time difference since our last check */
- gettimeofday(&thistime, 0);
- if (lasttime.tv_sec)
- timediff = ((thistime.tv_sec - lasttime.tv_sec) +
- (thistime.tv_usec - lasttime.tv_usec) * 1e-6);
- else
- timediff = 0;
-
- lasttime = thistime;
-
- rows = 0;
- connect_to_db(conninfo);
- if (conninfo->connection != NULL)
- {
- pgresult = PQexec(conninfo->connection, QUERY_STAT_DB);
- if (PQresultStatus(pgresult) == PGRES_TUPLES_OK)
- rows = PQntuples(pgresult);
-
- }
- if (rows == 0)
- {
- /* Database probably stopped, clear current and last */
- memset(&last_db_info, 0, sizeof(last_db_info));
- }
- memset(&cur_info, 0, sizeof(cur_info));
- for (i = 0; i < rows; i++)
- {
- PQgetvalue(pgresult, i, 2);
- /* Count all databases, even with no active backends */
- cur_info.numDb++;
- cur_info.numXact += atoi(PQgetvalue(pgresult, i, 3));
- cur_info.numRollback += atoi(PQgetvalue(pgresult, i, 4));
- cur_info.numBlockRead += atoi(PQgetvalue(pgresult, i, 5));
- cur_info.numBlockHit += atoi(PQgetvalue(pgresult, i, 6));
- cur_info.numTupleFetched += atoi(PQgetvalue(pgresult, i, 8));
- cur_info.numTupleAltered += atoi(PQgetvalue(pgresult, i, 9)) +
- atoi(PQgetvalue(pgresult, i, 10)) +
- atoi(PQgetvalue(pgresult, i, 11));
- cur_info.numConflict += atoi(PQgetvalue(pgresult, i, 12));
- }
- if (pgresult != NULL)
- PQclear(pgresult);
- disconnect_from_db(conninfo);
- if (timediff <= 0)
- {
- last_db_info = cur_info;
- memset(db_info, 0, sizeof(*db_info));
- return;
- }
-
- /* Compute the rate information */
- db_info->numDb = cur_info.numDb;
- db_info->numXact = (double)(cur_info.numXact - last_db_info.numXact) / timediff;
- db_info->numRollback = (double)(cur_info.numRollback - last_db_info.numRollback) / timediff;
- db_info->numBlockRead = (double)(cur_info.numBlockRead - last_db_info.numBlockRead) / timediff;
- db_info->numBlockHit = (double)(cur_info.numBlockHit - last_db_info.numBlockHit) / timediff;
- db_info->numTupleFetched = (double)(cur_info.numTupleFetched - last_db_info.numTupleFetched) / timediff;
- db_info->numTupleAltered = (double)(cur_info.numTupleAltered - last_db_info.numTupleAltered) / timediff;
- db_info->numConflict = (double)(cur_info.numConflict - last_db_info.numConflict) / timediff;
- last_db_info = cur_info;
-}
-
void
update_state(int *pgstate, char *state)
{