<entry><structname>pg_stat_activity</><indexterm><primary>pg_stat_activity</primary></indexterm></entry>

<entry>One row per server process, showing database OID, database

name, process <acronym>ID</>, user OID, user name, application name,

client's addressand port number, times at which the server process,

current transaction, and current query began execution, process's waiting

status, and text of the current query.

client's address, hostname (if available),and port number, times at

which the server process,current transaction, and current query began

execution, process's waitingstatus, and text of the current query.

The columns that report data on the current query are available unless

the parameter <varname>track_activities</varname> has been turned off.

Furthermore, these columns are only visible if the user examining

the view is a superuser or the same as the user owning the process

being reported on.

being reported on. The client's hostname will be available only if

<xref linkend="guc-log-hostname"> is set or if the user's hostname

needed to be looked up during <filename>pg_hba.conf</filename>

processing.

</entry>

</row>

<row>

<entry><structname>pg_stat_replication</><indexterm><primary>pg_stat_replication</primary></indexterm></entry>

<entry>One row per WAL sender process, showing process <acronym>ID</>,

user OID, user name, application name, client's address and port number,

time at which the server process began execution, and the current WAL

sender state and transaction log location. In addition, the standby

reports the last transaction log position it received and wrote, the last

position it flushed to disk, and the last position it replayed, and this

information is also displayed here. The columns detailing what exactly

the connection is doing are only visible if the user examining the view

is a superuser.

user OID, user name, application name, client's address, hostname

(if available) and port number, time at which the server process began

execution, and the current WAL sender state and transaction log

location. In addition, the standby reports the last transaction log

position it received and wrote, the last position it flushed to disk,

and the last position it replayed, and this information is also

displayed here. The columns detailing what exactly the connection is

doing are only visible if the user examining the view is a superuser.

The client's hostname will be available only if

<xref linkend="guc-log-hostname"> is set or if the user's hostname

needed to be looked up during <filename>pg_hba.conf</filename>

processing.

</entry>

</row>

U.rolnameAS usename,

S.application_name,

S.client_addr,

S.client_hostname,

S.client_port,

S.backend_start,

S.xact_start,

U.rolnameAS usename,

S.application_name,

S.client_addr,

S.client_hostname,

S.client_port,

S.backend_start,

W.state,

staticPgBackendStatus*BackendStatusArray=NULL;

staticPgBackendStatus*MyBEEntry=NULL;

staticchar*BackendClientHostnameBuffer=NULL;

staticchar*BackendAppnameBuffer=NULL;

staticchar*BackendActivityBuffer=NULL;

mul_size(NAMEDATALEN,MaxBackends));

size=add_size(size,

mul_size(pgstat_track_activity_query_size,MaxBackends));

size=add_size(size,

mul_size(NAMEDATALEN,MaxBackends));

returnsize;

}

}

}

size=mul_size(NAMEDATALEN,MaxBackends);

BackendClientHostnameBuffer= (char*)

ShmemInitStruct("Backend Client Host Name Buffer",size,&found);

if (!found)

{

MemSet(BackendClientHostnameBuffer,0,size);

buffer=BackendClientHostnameBuffer;

for (i=0;i<MaxBackends;i++)

{

BackendStatusArray[i].st_clienthostname=buffer;

buffer+=NAMEDATALEN;

}

}

size=mul_size(pgstat_track_activity_query_size,MaxBackends);

BackendActivityBuffer= (char*)

beentry->st_databaseid=MyDatabaseId;

beentry->st_userid=userid;

beentry->st_clientaddr=clientaddr;

beentry->st_clienthostname[0]='\0';

beentry->st_waiting= false;

beentry->st_appname[0]='\0';

beentry->st_activity[0]='\0';

beentry->st_clienthostname[NAMEDATALEN-1]='\0';

beentry->st_appname[NAMEDATALEN-1]='\0';

beentry->st_activity[pgstat_track_activity_query_size-1]='\0';

beentry->st_changecount++;

Assert((beentry->st_changecount&1)==0);

if (MyProcPort&&MyProcPort->remote_hostname)

strlcpy(beentry->st_clienthostname,MyProcPort->remote_hostname,NAMEDATALEN);

if (application_name)

pgstat_report_appname(application_name);

oldcontext=MemoryContextSwitchTo(funcctx->multi_call_memory_ctx);

tupdesc=CreateTemplateTupleDesc(11, false);

tupdesc=CreateTemplateTupleDesc(12, false);

TupleDescInitEntry(tupdesc, (AttrNumber)1,"datid",OIDOID,-1,0);

TupleDescInitEntry(tupdesc, (AttrNumber)2,"procpid",INT4OID,-1,0);

TupleDescInitEntry(tupdesc, (AttrNumber)3,"usesysid",OIDOID,-1,0);

TupleDescInitEntry(tupdesc, (AttrNumber)8,"query_start",TIMESTAMPTZOID,-1,0);

TupleDescInitEntry(tupdesc, (AttrNumber)9,"backend_start",TIMESTAMPTZOID,-1,0);

TupleDescInitEntry(tupdesc, (AttrNumber)10,"client_addr",INETOID,-1,0);

TupleDescInitEntry(tupdesc, (AttrNumber)11,"client_port",INT4OID,-1,0);

TupleDescInitEntry(tupdesc, (AttrNumber)11,"client_hostname",TEXTOID,-1,0);

TupleDescInitEntry(tupdesc, (AttrNumber)12,"client_port",INT4OID,-1,0);

funcctx->tuple_desc=BlessTupleDesc(tupdesc);

if (funcctx->call_cntr<funcctx->max_calls)

{

Datumvalues[11];

boolnulls[11];

Datumvalues[12];

boolnulls[12];

HeapTupletuple;

PgBackendStatus*beentry;

SockAddrzero_clientaddr;

{

nulls[9]= true;

nulls[10]= true;

nulls[11]= true;

}

{

{

nulls[9]= true;

nulls[10]= true;

nulls[11]= true;

}

{

clean_ipv6_addr(beentry->st_clientaddr.addr.ss_family,remote_host);

values[9]=DirectFunctionCall1(inet_in,

CStringGetDatum(remote_host));

values[10]=Int32GetDatum(atoi(remote_port));

if (beentry->st_clienthostname)

values[10]=CStringGetTextDatum(beentry->st_clienthostname);

nulls[10]= true;

values[11]=Int32GetDatum(atoi(remote_port));

}

}

elseif (beentry->st_clientaddr.addr.ss_family==AF_UNIX)

nulls[9]= true;

values[10]=DatumGetInt32(-1);

nulls[10]= true;

values[11]=DatumGetInt32(-1);

}

{

nulls[9]= true;

nulls[10]= true;

nulls[11]= true;

}

}

}

nulls[8]= true;

nulls[9]= true;

nulls[10]= true;

nulls[11]= true;

}

tuple=heap_form_tuple(funcctx->tuple_desc,values,nulls);

DESCR("statistics: number of auto analyzes for a table");

DATA(insertOID=1936 (pg_stat_get_backend_idsetPGNSPPGUID1211000ffftts0023""_null__null__null__null_pg_stat_get_backend_idset_null__null__null_ ));

DESCR("statistics: currently active backend IDs");

DATA(insertOID=2022 (pg_stat_get_activityPGNSPPGUID1211000ffffts102249"23""{23,26,23,26,25,25,16,1184,1184,1184,869,23}""{i,o,o,o,o,o,o,o,o,o,o,o}""{pid,datid,procpid,usesysid,application_name,current_query,waiting,xact_start,query_start,backend_start,client_addr,client_port}"_null_pg_stat_get_activity_null__null__null_ ));

DATA(insertOID=2022 (pg_stat_get_activityPGNSPPGUID1211000ffffts102249"23""{23,26,23,26,25,25,16,1184,1184,1184,869,25,23}""{i,o,o,o,o,o,o,o,o,o,o,o,o}""{pid,datid,procpid,usesysid,application_name,current_query,waiting,xact_start,query_start,backend_start,client_addr,client_hostname,client_port}"_null_pg_stat_get_activity_null__null__null_ ));

DESCR("statistics: information about currently active backends");

DATA(insertOID=3099 (pg_stat_get_wal_sendersPGNSPPGUID121100ffffts002249"""{23,25,25,25,25,25}""{o,o,o,o,o,o}""{procpid,state,sent_location,write_location,flush_location,apply_location}"_null_pg_stat_get_wal_senders_null__null__null_ ));

DESCR("statistics: information about currently active replication");

Oidst_databaseid;

Oidst_userid;

SockAddrst_clientaddr;

char*st_clienthostname;/* MUST be null-terminated */

boolst_waiting;