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

fix minor memory leak

Browse source 
git-svn-id: svn+ssh://svn.corp.yahoo.com/yahoo/yrl/labs/pnuts/code/logstore@1089 8dad8b1f-cf64-0410-95b6-bcf113ffbcfe
This commit is contained in:
sears 2010-09-01 17:40:52 +00:00
parent 29d482cffe
commit b1e5e3ad78
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
requestDispatch.cpp
View file

@ -23,17 +23,18 @@ inline int requestDispatch<HANDLE>::op_bulk_insert(logtable<datatuple> *ltable,
while((tups[cur_tup_count] = readtuplefromsocket(fd, &err))) { while((tups[cur_tup_count] = readtuplefromsocket(fd, &err))) {
cur_tup_count++; cur_tup_count++;
if(cur_tup_count == tups_size) { if(cur_tup_count == tups_size) {
ltable->insertManyTuples(tups, cur_tup_count); // ltable->insertManyTuples(tups, cur_tup_count);
for(int i = 0; i < cur_tup_count; i++) { for(int i = 0; i < cur_tup_count; i++) {
datatuple::freetuple(tups[i]); datatuple::freetuple(tups[i]);
} }
cur_tup_count = 0; cur_tup_count = 0;
} }
} }
ltable->insertManyTuples(tups, cur_tup_count); // ltable->insertManyTuples(tups, cur_tup_count);
for(int i = 0; i < cur_tup_count; i++) { for(int i = 0; i < cur_tup_count; i++) {
datatuple::freetuple(tups[i]); datatuple::freetuple(tups[i]);
} }
free(tups);
if(!err) err = writeoptosocket(fd, LOGSTORE_RESPONSE_SUCCESS); if(!err) err = writeoptosocket(fd, LOGSTORE_RESPONSE_SUCCESS);
return err; return err;
} }