Commit9994464

authored and

committed

Implement PaxosGet and PaxosSet.

1 parentf78894b commit9994464Copy full SHA for 9994464

File tree

+34

-4

lines changed

+34

-4

lines changed

Lines changed: 32 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -1191,14 +1191,43 @@ void MtmOnNodeConnect(int nodeId)`
`1191`	`1191`	`*/`
`1192`	`1192`	`voidPaxosGet(charconstkey,intsize,PaxosTimestampts,boolnowait)`
`1193`	`1193`	`{`
`1194`		`-if (size!=NULL) {`
	`1194`	`+unsignedenclen,declen,len;`
	`1195`	`+charenc,dec;`
	`1196`	`+Assert(ts==NULL);// not implemented`
	`1197`	`+`
	`1198`	`+enc=raftable_get(key);`
	`1199`	`+if (enc==NULL)`
	`1200`	`+{`
`1195`	`1201`	`*size=0;`
	`1202`	`+returnNULL;`
	`1203`	`+}`
	`1204`	`+`
	`1205`	`+enclen=strlen(enc);`
	`1206`	`+declen=hex_dec_len(enc,enclen);`
	`1207`	`+dec=palloc(declen);`
	`1208`	`+len=hex_decode(enc,enclen,dec);`
	`1209`	`+pfree(enc);`
	`1210`	`+Assert(len==declen);`
	`1211`	`+`
	`1212`	`+if (size!=NULL) {`
	`1213`	`+*size=declen;`
`1196`	`1214`	`}`
`1197`		`-returnNULL;`
	`1215`	`+returndec;`
`1198`	`1216`	`}`
`1199`	`1217`
`1200`	`1218`	`voidPaxosSet(charconstkey,voidconstvalue,intsize,boolnowait)`
`1201`		`-{}`
	`1219`	`+{`
	`1220`	`+unsignedenclen,declen,len;`
	`1221`	`+charenc,dec;`
	`1222`	`+`
	`1223`	`+enclen=hex_enc_len(value,size);`
	`1224`	`+enc=palloc(enclen);`
	`1225`	`+len=hex_encode(value,size,enc);`
	`1226`	`+Assert(len==enclen);`
	`1227`	`+`
	`1228`	`+raftable_set(key,enc,nowait ?1 :INT_MAX);`
	`1229`	`+pfree(enc);`
	`1230`	`+}`
`1202`	`1231`
`1203`	`1232`
`1204`	`1233`	`/*`

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -2,4 +2,5 @@ comment = 'Multimaster'`
`2`	`2`	`default_version = '1.0'`
`3`	`3`	`module_pathname = '$libdir/multimaster'`
`4`	`4`	`schema = mtm`
`5`		`-relocatable = false`
	`5`	`+relocatable = false`
	`6`	`+requires = raftable`

Comments

(0)