Skip to content

Commit

Permalink
finished delete multi, this fix #31
Browse files Browse the repository at this point in the history
  • Loading branch information
jaysonsantos committed Dec 4, 2014
1 parent 1619e22 commit 5add2f3
Showing 1 changed file with 28 additions and 2 deletions.
30 changes: 28 additions & 2 deletions bmemcached/protocol.py
Expand Up @@ -706,9 +706,35 @@ def delete_multi(self, keys):
:rtype: bool
"""
logger.info('Deleting keys %r' % keys)

msg = ''
for key in keys:
pass
msg += struct.pack(
self.HEADER_STRUCT +
self.COMMANDS['delete']['struct'] % len(key),
self.MAGIC['request'],
self.COMMANDS['delete']['command'],
len(key), 0, 0, 0, len(key), 0, 0, key)

msg += struct.pack(
self.HEADER_STRUCT +
self.COMMANDS['noop']['struct'],
self.MAGIC['request'],
self.COMMANDS['noop']['command'],
0, 0, 0, 0, 0, 0, 0)

self._send(msg)

opcode = -1
retval = True
while opcode != self.COMMANDS['noop']['command']:
(magic, opcode, keylen, extlen, datatype, status, bodylen, opaque,
cas, extra_content) = self._get_response()
if status != self.STATUS['success']:
retval = False
if status == self.STATUS['server_disconnected']:
break

return retval

def flush_all(self, time):
"""
Expand Down

0 comments on commit 5add2f3

Please sign in to comment.