* ptrack_init_lsn() — returns LSN of the last ptrack map initialization.

* ptrack_get_pagemapset(start_lsn pg_lsn) — returns a set of changed data files with bitmaps of changed blocks since specified`start_lsn`.

* ptrack_get_change_stat(start_lsn pg_lsn) — returns statistic of changes (number of files, pages and size in MB) since specified`start_lsn`.

* ptrack_get_change_file_stat(start_lsn pg_lsn) — returns per file statistic of changes (number of pages and size in MB) since specified`start_lsn`.

Usage example:

\echo Use"ALTER EXTENSION ptrack UPDATE;" to load this file.\ quit

DROPFUNCTION ptrack_get_pagemapset(start_lsn pg_lsn);

CREATEFUNCTIONptrack_get_pagemapset(start_lsn pg_lsn)

RETURNS TABLE (pathtext,

pagecountbigint,

pagemapbytea)

LANGUAGE C STRICT VOLATILE;

CREATEFUNCTIONptrack_get_change_stat(start_lsn pg_lsn)

RETURNS TABLE (

filesbigint,

pagesbigint,

pagesnumeric,

)AS

$func$

RETURN QUERY

SELECT changed_files,

changed_pages,

block_size*changed_pages/(1024.0*1024)

block_size*changed_pages/(1024.0*1024)

(SELECTcount(path)AS changed_files,

sum(

length(replace(right((pagemap)::text,-1)::varbit::text,'0',''))

)AS changed_pages

sum(pagecount)AS changed_pages

FROM ptrack_get_pagemapset(start_lsn)) s;

END

$func$ LANGUAGE plpgsql;

CREATEFUNCTIONptrack_get_change_file_stat(start_lsn pg_lsn)

RETURNS TABLE (

file_pathtext,

pagesint,

)AS

$func$

DECLARE

block_sizebigint;

block_size := (SELECT settingFROM pg_settingsWHERE name='block_size');

RETURN QUERY

SELECTs.path,

changed_pages,

block_size*changed_pages/(1024.0*1024)

(SELECTpath,

length(replace(right((pagemap)::text,-1)::varbit::text,'0',''))

AS changed_pages

FROM ptrack_get_pagemapset(start_lsn)) s

ORDER BY (changed_pages,s.path)DESC;

END

$func$ LANGUAGE plpgsql;

FuncCallContext*funcctx;

MemoryContextoldcontext;

datapagemap_tpagemap;

int64pagecount=0;

chargather_path[MAXPGPATH];

#ifPG_VERSION_NUM >=120000

tupdesc=CreateTemplateTupleDesc(2);

tupdesc=CreateTemplateTupleDesc(3);

tupdesc=CreateTemplateTupleDesc(2, false);

tupdesc=CreateTemplateTupleDesc(3, false);

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

TupleDescInitEntry(tupdesc, (AttrNumber)2,"pagemap",BYTEAOID,-1,0);

TupleDescInitEntry(tupdesc, (AttrNumber)2,"pagecount",INT8OID,-1,0);

TupleDescInitEntry(tupdesc, (AttrNumber)3,"pagemap",BYTEAOID,-1,0);

funcctx->tuple_desc=BlessTupleDesc(tupdesc);

funcctx->user_fctx=ctx;

if (pagemap.bitmap!=NULL)

{

Datumvalues[2];

boolnulls[2]= {false};

Datumvalues[3];

boolnulls[3]= {false};

charpathname[MAXPGPATH];

bytea*result=NULL;

Sizeresult_sz=pagemap.bitmapsize+VARHDRSZ;

strcpy(pathname,ctx->relpath);

values[0]=CStringGetTextDatum(pathname);

values[1]=PointerGetDatum(result);

values[1]=Int64GetDatum(pagecount);

values[2]=PointerGetDatum(result);

pfree(pagemap.bitmap);

pagemap.bitmap=NULL;

pagemap.bitmapsize=0;

pagecount=0;

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

if (htup)

if (update_lsn2 >=ctx->lsn)

{

pagecount+=1;

datapagemap_add(&pagemap,ctx->bid.blocknum % ((BlockNumber)RELSEG_SIZE));

}

}

ctx->bid.blocknum+=1;

use TestLib;

use Test::More;

plantests=>25;

plantests=>24;

my$node;

my$res;

$res_stdout =$node->safe_psql("postgres","SELECT pages FROM ptrack_get_change_stat('$flush_lsn')");

is($res_stdout > 0, 1,'should be able to get aggregated stats of changes');

$res_stdout =$node->safe_psql("postgres","SELECT count(*) FROM ptrack_get_change_file_stat('$flush_lsn')");

is($res_stdout > 0, 1,'should be able to get per file stats of changes');

$node->append_conf(

'postgresql.conf',q{