greg/stasis-aries-wal
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

ignore size field of hashHeader argument

Browse source
This commit is contained in:
Sears Russell 2008-10-23 20:27:55 +00:00
parent c76f22fd4f
commit fa18df2424
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/stasis/operations/linearHashNTA.c
View file

@ -167,6 +167,7 @@ Operation getLinearHashRemove() {
} }
compensated_function int ThashInsert(int xid, recordid hashHeader, const byte* key, int keySize, const byte* value, int valueSize) { compensated_function int ThashInsert(int xid, recordid hashHeader, const byte* key, int keySize, const byte* value, int valueSize) {
hashHeader.size = sizeof(lladd_hash_header);
pthread_mutex_lock(&linear_hash_mutex); pthread_mutex_lock(&linear_hash_mutex);
int argSize = sizeof(linearHash_insert_arg)+keySize; int argSize = sizeof(linearHash_insert_arg)+keySize;
linearHash_insert_arg * arg = calloc(1,argSize); linearHash_insert_arg * arg = calloc(1,argSize);
@ -243,7 +244,7 @@ compensated_function static int __ThashInsert(int xid, recordid hashHeader, cons
return ret; return ret;
} }
compensated_function int ThashRemove(int xid, recordid hashHeader, const byte * key, int keySize) { compensated_function int ThashRemove(int xid, recordid hashHeader, const byte * key, int keySize) {
hashHeader.size = sizeof(lladd_hash_header);
byte * value; byte * value;
int valueSize; int valueSize;
int ret; int ret;
@ -308,6 +309,7 @@ compensated_function static int __ThashRemove(int xid, recordid hashHeader, cons
compensated_function int ThashLookup(int xid, recordid hashHeader, const byte * key, int keySize, byte ** value) { compensated_function int ThashLookup(int xid, recordid hashHeader, const byte * key, int keySize, byte ** value) {
lladd_hash_header lhh; lladd_hash_header lhh;
hashHeader.size = sizeof(lladd_hash_header);
int ret; int ret;
// This whole thing is safe since the callee's do not modify global state... // This whole thing is safe since the callee's do not modify global state...
@ -398,6 +400,7 @@ compensated_function static void ThashSplitBucket(int xid, recordid hashHeader,
return; return;
} }
lladd_hash_iterator * ThashIterator(int xid, recordid hashHeader, int keySize, int valueSize) { lladd_hash_iterator * ThashIterator(int xid, recordid hashHeader, int keySize, int valueSize) {
hashHeader.size = sizeof(lladd_hash_header);
lladd_hash_iterator * it = calloc(1,sizeof(lladd_hash_iterator)); lladd_hash_iterator * it = calloc(1,sizeof(lladd_hash_iterator));
begin_action_ret(free, it, NULL) { begin_action_ret(free, it, NULL) {
it->hashHeader = hashHeader; it->hashHeader = hashHeader;