rays/pylibmc
Archived
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Always quit and free memcached result in gets

Browse Source
This commit is contained in:
lericson 2010-10-09 00:53:37 +02:00
parent 9d4b01ff4d
commit 8186f9f009
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
_pylibmcmodule.c
View File

@ -448,22 +448,22 @@ static PyObject *PylibMC_Client_gets(PylibMC_Client *self, PyObject *arg) {
ret = _PylibMC_parse_memcached_value((char *)mc_val, val_size, flags); ret = _PylibMC_parse_memcached_value((char *)mc_val, val_size, flags);
ret = Py_BuildValue("(NL)", ret, cas); ret = Py_BuildValue("(NL)", ret, cas);
/* reset cursor if mget for some reason returned more than one result.
this should be a no-op otherwise. */
memcached_quit(self->mc);
/* deallocate any indirect buffers, even though the struct itself
is on our stack */
memcached_result_free(&results_obj);
return ret;
} else if (rc == MEMCACHED_END) { } else if (rc == MEMCACHED_END) {
/* Key not found => (None, None) */ /* Key not found => (None, None) */
return Py_BuildValue("(OO)", Py_None, Py_None); return Py_BuildValue("(OO)", Py_None, Py_None);
} else { } else {
return PylibMC_ErrFromMemcached(self, "memcached_gets", rc); return PylibMC_ErrFromMemcached(self, "memcached_gets", rc);
} }
/* reset cursor if mget for some reason returned more than one result.
this should be a no-op otherwise. */
memcached_quit(self->mc);
/* deallocate any indirect buffers, even though the struct itself
is on our stack */
memcached_result_free(&results_obj);
return ret;
} }
/* {{{ Set commands (set, replace, add, prepend, append) */ /* {{{ Set commands (set, replace, add, prepend, append) */