Commite9335ab

committed

Dynamically calculate number of participants

1 parent3796257 commite9335abCopy full SHA for e9335ab

File tree

+11

-2

lines changed

+11

-2

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,8 @@`
`14`	`14`	`typedefstructTransaction {`
`15`	`15`	`xid_txid;`
`16`	`16`
`17`		`-intsize;`
	`17`	`+intsize;// number of paritcipants`
	`18`	`+intmax_size;// maximal number of participants`
`18`	`19`
`19`	`20`	`// for + against ≤ size`
`20`	`21`	`intvotes_for;`

Lines changed: 8 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -280,7 +280,8 @@ static char onbegin(void stream, void clientdata, cmd_t cmd) {`
`280`	`280`
`281`	`281`	`prev_gxid=t->xid=next_gxid++;`
`282`	`282`	`t->snapshots_count=0;`
`283`		`-t->size=size;`
	`283`	`+t->max_size=size;`
	`284`	`+t->size=1;`
`284`	`285`
`285`	`286`	`CLIENT_SNAPSENT(clientdata)=0;`
`286`	`287`	`CLIENT_XID(clientdata)=t->xid;`
`@@ -436,6 +437,12 @@ static char onsnapshot(void stream, void clientdata, cmd_t cmd) {`
`436`	`437`	`if (CLIENT_XID(clientdata)==INVALID_XID) {`
`437`	`438`	`CLIENT_SNAPSENT(clientdata)=0;`
`438`	`439`	`CLIENT_XID(clientdata)=t->xid;`
	`440`	`+t->size+=1;`
	`441`	`+CHECK(`
	`442`	`+t->size <=t->max_size,`
	`443`	`+clientdata,`
	`444`	`+"SNAPSHOT: too many participants"`
	`445`	`+ );`
`439`	`446`	`}`
`440`	`447`
`441`	`448`	`CHECK(`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -28,6 +28,7 @@ void transaction_clear(Transaction *t) {`
`28`	`28`
`29`	`29`	`t->xid=INVALID_XID;`
`30`	`30`	`t->size=0;`
	`31`	`+t->max_size=0;`
`31`	`32`	`t->votes_for=0;`
`32`	`33`	`t->votes_against=0;`
`33`	`34`	`t->snapshots_count=0;`

Comments

(0)