{

boolinvisible=ts->status!=TRANSACTION_STATUS_COMMITTED;

if (invisible!=PgXidInMVCCSnapshot(xid,snapshot)) {

fprintf(stderr,"Change visibility for XID %d(csn=%ld, status=%d) in snapshot %ld [%d,%d]\n",xid,ts->csn,ts->status,MtmTx.snapshot,snapshot->xmin,snapshot->xmax);

}

MTM_LOG4("%d: tuple with xid=%d(csn= %ld) is %s in snapshot %ld",

MyProcPid,xid,ts->csn,invisible ?"rollbacked" :"committed",MtmTx.snapshot);

MtmUnlock();

csn_toldestSnapshot=INVALID_CSN;

MtmTransState*prev=NULL;

MtmTransState*ts= (MtmTransState*)hash_search(MtmXid2State,&xid,HASH_FIND,NULL);

MTM_LOG1("%d: MtmAdjustOldestXid(%d): snapshot=%ld, csn=%ld, status=%d",MyProcPid,xid,ts!=NULL ?ts->snapshot :0,ts!=NULL ?ts->csn :0,ts!=NULL ?ts->status :-1);

MTM_LOG2("%d: MtmAdjustOldestXid(%d): snapshot=%ld, csn=%ld, status=%d",MyProcPid,xid,ts!=NULL ?ts->snapshot :0,ts!=NULL ?ts->csn :0,ts!=NULL ?ts->status :-1);

Mtm->gcCount=0;

if (ts!=NULL) {

oldestSnapshot=ts->snapshot;

if (prev!=NULL) {

Mtm->transListHead=prev;

Mtm->oldestXid=xid=prev->xid;

MTM_LOG1("%d: MtmAdjustOldestXid: oldestXid=%d, olderstSnapshot=%ld",MyProcPid,xid,oldestSnapshot);

MTM_LOG2("%d: MtmAdjustOldestXid: oldestXid=%d, olderstSnapshot=%ld",MyProcPid,xid,oldestSnapshot);

}elseif (TransactionIdPrecedes(Mtm->oldestXid,xid)) {

xid=Mtm->oldestXid;

}

---

-hosts:nodes[-1]

gather_facts:no

tasks:

-name:create mm ext

shell:>

-hosts:clients

gather_facts:no

tasks:

-name:generate connstrings

set_fact:

connstr:"-c 'host={{item}} user={{ansible_ssh_user}} port=15432 dbname=postgres'"

with_items:

register:connstrs

-name:make a list

set_fact:

connections:"{{ connstrs.results | map(attribute='ansible_facts.connstr') | join }}"

-hosts:clients[0]

gather_facts:no

tasks:

-name:init database

shell:"~/pg_cluster/install/bin/dtmacid {{connections}} -a 100 -i"

register:init_result

environment:

LD_LIBRARY_PATH:"/home/{{ansible_ssh_user}}/pg_cluster/install/lib"

-debug:var=init_result

-hosts:clients

gather_facts:no

tasks:

-local_action:shell echo "Bench started at `date`" >> perf.results

-name:run transfers

shell:>

register:transfers_result

environment:

LD_LIBRARY_PATH:"/home/{{ansible_ssh_user}}/pg_cluster/install/lib"

-debug:var=transfers_result

-local_action:'shell echo "{{transfers_result.stdout }}" >> perf.results'

-local_action:shell echo "Bench finished at `date`" >> perf.results

copy:src=../{{item}} dest=~/{{item}} mode=0755

with_items:

-"dtmbench.cpp"

-"dtmacid.cpp"

-name:clone pqxx

git:repo=https://github.com/Ambrosys/pqxx.git

-name:install dtmbench

shell:"mv dtmbench ~/pg_cluster/install/bin/dtmbench"

-name:compile dtmacid

shell:"g++ -g -Wall -O2 -o dtmacid dtmacid.cpp -lpqxx -lpq -pthread -L/home/{{ansible_ssh_user}}/pg_cluster/install/lib/ -I/home/{{ansible_ssh_user}}/pg_cluster/install/include/"

-name:install dtmacid

shell:"mv dtmacid ~/pg_cluster/install/bin/dtmacid"

assert((int)r1.size() == cfg.nAccounts && (int)r2.size() == cfg.nAccounts);

for (int i=0; i < cfg.nAccounts; i++) {

int diff = r1[i][0].as(int()) - r2[i][0].as(int());

#if0

fprintf(out, "%d: %d %c %d - [%d,%d]->[%ld,%ld] (snapshot %ld, last CSN %ld) vs. [%d,%d]->[%ld,%ld] (snapshot %ld, last CSN %ld)\n",

i, r1[i][0].as(int()), diff < 0 ? '<' : diff == 0 ? '=' : '>', r2[i][0].as(int()),

r1[i][1].as(int()), r1[i][2].as(int()), r1[i][3].as(int64_t()), r1[i][4].as(int64_t()), r1[i][5].as(int64_t()), r1[i][6].as(int64_t()),

r2[i][1].as(int()), r2[i][2].as(int()), r2[i][3].as(int64_t()), r2[i][4].as(int64_t()), r2[i][5].as(int64_t()), r2[i][6].as(int64_t()));

#endif

if (diff !=0) {

if (delta ==0) {

delta = diff;

if (delta <0) lt++;else gt++;

}elseif (delta!= diff) {

}elseif ((delta^ diff) <0) {

fflush(out);

printf("Inconsistency found for record %d: [%d,%d]->[%ld,%ld] (snapshot %ld, last CSN %ld) vs. [%d,%d]->[%ld,%ld] (snapshot %ld, last CSN %ld)\n", i,

r1[i][1].as(int()), r1[i][2].as(int()), r1[i][3].as(int64_t()), r1[i][4].as(int64_t()), r1[i][5].as(int64_t()), r1[i][6].as(int64_t()),