Commitd070988

committed

Implement PaxosGet and PaxosSet.

1 parent53bb8ae commitd070988Copy full SHA for d070988

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

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)