Commite2050fa

committed

Imporove sleep statistic reporting

1 parent5c4cded commite2050faCopy full SHA for e2050fa

File tree

+19

-13

lines changed

+19

-13

lines changed

Lines changed: 11 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -438,11 +438,21 @@ TransactionId DtmGetOldestXmin(Relation rel, bool ignoreVacuum)`
`438`	`438`
`439`	`439`	`boolDtmXidInMVCCSnapshot(TransactionIdxid,Snapshotsnapshot)`
`440`	`440`	`{`
	`441`	`+#ifTRACE_SLEEP_TIME`
	`442`	`+statictimestamp_tfirstReportTime;`
	`443`	`+statictimestamp_tprevReportTime;`
	`444`	`+statictimestamp_ttotalSleepTime;`
	`445`	`+#endif`
`441`	`446`	`timestamp_tdelay=MIN_WAIT_TIMEOUT;`
`442`	`447`	`Assert(xid!=InvalidTransactionId);`
`443`	`448`
`444`	`449`	`SpinLockAcquire(&local->lock);`
`445`	`450`
	`451`	`+#ifTRACE_SLEEP_TIME`
	`452`	`+if (firstReportTime==0) {`
	`453`	`+firstReportTime=dtm_get_current_time();`
	`454`	`+ }`
	`455`	`+#endif`
`446`	`456`	`while (true)`
`447`	`457`	`{`
`448`	`458`	`DtmTransStatusts= (DtmTransStatus)hash_search(xid2status,&xid,HASH_FIND,NULL);`
`@@ -461,14 +471,11 @@ bool DtmXidInMVCCSnapshot(TransactionId xid, Snapshot snapshot)`
`461`	`471`	`#ifTRACE_SLEEP_TIME`
`462`	`472`	`{`
`463`	`473`	`timestamp_tnow=dtm_get_current_time();`
`464`		`-statictimestamp_tfirstReportTime;`
`465`		`-statictimestamp_tprevReportTime;`
`466`		`-statictimestamp_ttotalSleepTime;`
`467`	`474`	`#endif`
`468`	`475`	`dtm_sleep(delay);`
`469`	`476`	`#ifTRACE_SLEEP_TIME`
`470`	`477`	`totalSleepTime+=dtm_get_current_time()-now;`
`471`		`-if (now>prevReportTime+USEC*10) {`
	`478`	`+if (now>prevReportTime+USEC*1) {`
`472`	`479`	`prevReportTime=now;`
`473`	`480`	`if (firstReportTime==0) {`
`474`	`481`	`firstReportTime=now;`

Lines changed: 1 addition & 1 deletion

Lines changed: 1 addition & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,4 @@`
`1`	`1`	`./dtmbench \`
`2`	`2`	`-c"dbname=postgres host=localhost user=knizhnik port=5432 sslmode=disable" \`
`3`	`3`	`-c"dbname=postgres host=localhost user=knizhnik port=5433 sslmode=disable" \`
`4`		`--c"dbname=postgres host=localhost user=knizhnik port=5434 sslmode=disable" \`
`5`		`--n 1000 -a 1000 -w 10 -r 1$*`
	`4`	`+-n 10000 -a 1000 -w 10 -r 1$*`

Lines changed: 6 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -18,14 +18,14 @@ const (`
`18`	`18`
`19`	`19`
`20`	`20`	`varcfg1= pgx.ConnConfig{`
`21`		`-Host:"astro9",`
`22`		`-Port:15432,`
	`21`	`+Host:"127.0.0.1",`
	`22`	`+Port:5432,`
`23`	`23`	`Database:"postgres",`
`24`	`24`	`}`
`25`	`25`
`26`	`26`	`varcfg2= pgx.ConnConfig{`
`27`		`-Host:"astro9",`
`28`		`-Port:15433,`
	`27`	`+Host:"127.0.0.1",`
	`28`	`+Port:5433,`
`29`	`29`	`Database:"postgres",`
`30`	`30`	`}`
`31`	`31`
`@@ -109,8 +109,8 @@ func transfer(id int, wg *sync.WaitGroup) {`
`109`	`109`
`110`	`110`	`gtid:=strconv.Itoa(id)+"."+strconv.Itoa(i)`
`111`	`111`	`amount:=2*rand.Intn(2)-1`
`112`		`-account1:=2*id+1`
`113`		`-account2:=2*id+2`
	`112`	`+account1:=rand.Intn(N_ACCOUNTS)`
	`113`	`+account2:=rand.Intn(N_ACCOUNTS)`
`114`	`114`
`115`	`115`	`exec(conn1,"begin transaction")`
`116`	`116`	`exec(conn2,"begin transaction")`

Comments

(0)