/* contrib/pgnodemx/pg_proctab--0.0.10-compat.sql */

-- complain if script is sourced in psql, rather than via CREATE EXTENSION
\echo Use "CREATE EXTENSION pg_proctab VERSION 0.0.10-compat" to load this file. \quit

/*
 * Functions to provide a pg_proctab compatible interface.
 * The hope is that this will allow pgnodemx to work with
 * pg_top as a remote target.
 */

CREATE FUNCTION pg_cputime(
 OUT "user" BIGINT,
 OUT nice BIGINT,
 OUT system BIGINT,
 OUT idle BIGINT,
 OUT iowait BIGINT
)
RETURNS SETOF record
AS $$
 SELECT "user", nice, system, idle, iowait
 FROM proc_cputime()
$$ LANGUAGE sql;

CREATE FUNCTION pg_loadavg(
 OUT load1 FLOAT,
 OUT load5 FLOAT,
 OUT load15 FLOAT,
 OUT last_pid INTEGER
)
RETURNS SETOF record
AS $$
 SELECT load1, load5, load15, last_pid
 FROM proc_loadavg()
$$ LANGUAGE sql;

/*
 * Compatibility note: in the original implementation memshared
 * is always equal to zero. Here we use the value from Shmem instead.
 */
CREATE FUNCTION pg_memusage(
		OUT memused BIGINT,
		OUT memfree BIGINT,
		OUT memshared BIGINT,
		OUT membuffers BIGINT,
		OUT memcached BIGINT,
		OUT swapused BIGINT,
		OUT swapfree BIGINT,
		OUT swapcached BIGINT)
RETURNS SETOF record
AS $$
 WITH m (key,val) AS
 (
   SELECT key, val
   FROM proc_meminfo()
 )
 SELECT
  ((SELECT val FROM m WHERE key = 'MemTotal') - (SELECT val FROM m WHERE key = 'MemFree')) / 1024 as memused,
  (SELECT val FROM m WHERE key = 'MemFree') / 1024 AS memfree,
  (SELECT val FROM m WHERE key = 'Shmem') / 1024 AS memshared,
  (SELECT val FROM m WHERE key = 'Buffers') / 1024 AS membuffers,
  (SELECT val FROM m WHERE key = 'Cached') / 1024 AS memcached,
  ((SELECT val FROM m WHERE key = 'SwapTotal') - (SELECT val FROM m WHERE key = 'SwapFree')) / 1024 AS swapused,
  (SELECT val FROM m WHERE key = 'SwapFree') / 1024 AS swapfree,
  (SELECT val FROM m WHERE key = 'SwapCached') / 1024 as swapcached
$$ LANGUAGE sql;

CREATE FUNCTION pg_proctab(
 OUT pid integer,
 OUT comm character varying,
 OUT fullcomm character varying,
 OUT state character,
 OUT ppid integer,
 OUT pgrp integer,
 OUT session integer,
 OUT tty_nr integer,
 OUT tpgid integer,
 OUT flags integer,
 OUT minflt bigint,
 OUT cminflt bigint,
 OUT majflt bigint,
 OUT cmajflt bigint,
 OUT utime bigint,
 OUT stime bigint,
 OUT cutime bigint,
 OUT cstime bigint,
 OUT priority bigint,
 OUT nice bigint,
 OUT num_threads bigint,
 OUT itrealvalue bigint,
 OUT starttime bigint,
 OUT vsize bigint,
 OUT rss bigint,
 OUT exit_signal integer,
 OUT processor integer,
 OUT rt_priority bigint,
 OUT policy bigint,
 OUT delayacct_blkio_ticks bigint,
 OUT uid integer,
 OUT username character varying,
 OUT rchar bigint,
 OUT wchar bigint,
 OUT syscr bigint,
 OUT syscw bigint,
 OUT reads bigint,
 OUT writes bigint,
 OUT cwrites bigint
)
RETURNS SETOF record
AS $$
 SELECT
  s.pid,
  comm,
  fullcomm,
  state,
  ppid,
  pgrp,
  session,
  tty_nr,
  tpgid,
  flags::integer, /* 10 */
  minflt::bigint,
  cminflt::bigint,
  majflt::bigint,
  cmajflt::bigint,
  utime::bigint,
  stime::bigint,
  cutime::bigint,
  cstime::bigint,
  priority,
  nice, /* 20 */
  num_threads,
  itrealvalue,
  starttime::bigint,
  vsize::bigint,
  (kpages_to_bytes(rss))::bigint / 1024 as rss,
  exit_signal,
  processor,
  rt_priority,
  policy,
  delayacct_blkio_ticks::bigint, /* 30 */
  uid,
  username,
  rchar::bigint,
  wchar::bigint,
  syscr::bigint,
  syscw::bigint,
  reads::bigint,
  writes::bigint,
  cwrites::bigint
 FROM proc_pid_stat() s
 JOIN proc_pid_cmdline() c
 ON s.pid = c.pid
 JOIN proc_pid_io() i
 ON c.pid = i.pid
$$ LANGUAGE sql;

CREATE FUNCTION pg_diskusage (
        OUT major smallint,
        OUT minor smallint,
        OUT devname text,
        OUT reads_completed bigint,
        OUT reads_merged bigint,
        OUT sectors_read bigint,
        OUT readtime bigint,
        OUT writes_completed bigint,
        OUT writes_merged bigint,
        OUT sectors_written bigint,
        OUT writetime bigint,
        OUT current_io bigint,
        OUT iotime bigint,
        OUT totaliotime bigint,
        OUT discards_completed bigint,
        OUT discards_merged bigint,
        OUT sectors_discarded bigint,
        OUT discardtime bigint,
        OUT flushes_completed bigint,
        OUT flushtime bigint
)
RETURNS SETOF record
AS $$
 SELECT
  major_number::smallint AS major,
  minor_number::smallint AS minor,
  device_name AS devname,
  reads_completed_successfully::bigint AS reads_completed,
  reads_merged::bigint AS reads_merged,
  sectors_read::bigint AS sectors_read,
  time_spent_reading_ms AS readtime,
  writes_completed::bigint AS writes_completed,
  writes_merged::bigint AS writes_merged,
  sectors_written::bigint AS sectors_written,
  time_spent_writing_ms AS writetime,
  ios_currently_in_progress AS current_io,
  time_spent_doing_ios_ms AS iotime,
  weighted_time_spent_doing_ios_ms AS totaliotime,
  COALESCE(discards_completed_successfully, 0)::bigint AS discards_completed,
  COALESCE(discards_merged, 0)::bigint AS discards_merged,
  COALESCE(sectors_discarded, 0)::bigint AS sectors_discarded,
  COALESCE(time_spent_discarding, 0) AS discardtime,
  COALESCE(flush_requests_completed_successfully, 0)::bigint AS flushes_completed,
  COALESCE(time_spent_flushing, 0) AS flushtime
 FROM proc_diskstats()
$$ LANGUAGE sql;