summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSean Reifschneider <sean@realgo.com>2023-04-16 10:27:24 -0600
committerSean Reifschneider <sean@realgo.com>2023-04-16 10:27:24 -0600
commit12f9bf1fb70082e4dc704cfb037e96335bddaa5f (patch)
tree3f4e539edc68d6431268345af85b9a5f15323c4a
parent6948c119219733e6cd1ba20e9c6d0909fc177435 (diff)
downloadpython-memcached-12f9bf1fb70082e4dc704cfb037e96335bddaa5f.tar.gz
Adding test for quit_all
-rw-r--r--memcache.py5
-rw-r--r--tests/test_memcache.py3
2 files changed, 5 insertions, 3 deletions
diff --git a/memcache.py b/memcache.py
index 1eefcf7..bbc2149 100644
--- a/memcache.py
+++ b/memcache.py
@@ -364,7 +364,7 @@ class Client(threading.local):
serverData[slab[0]][slab[1]] = item[2]
return data
- def quit_all(self):
+ def quit_all(self) -> None:
'''Send a "quit" command to all servers and wait for the connection to close.'''
for s in self.servers:
s.quit()
@@ -1480,10 +1480,9 @@ class _Host(object):
self.buffer = buf[rlen:]
return buf[:rlen]
- def quit(self):
+ def quit(self) -> None:
'''Send a "quit" command to remote server and wait for connection to close.'''
if self.socket:
- # Using self.send_cmd, so no need for '\r\n'.
self.send_cmd('quit')
# We can't close the local socket until the remote end processes the quit
diff --git a/tests/test_memcache.py b/tests/test_memcache.py
index e87dd09..3593e03 100644
--- a/tests/test_memcache.py
+++ b/tests/test_memcache.py
@@ -48,6 +48,9 @@ class TestMemcache(unittest.TestCase):
self.check_setget("an_integer", 42)
self.check_setget("an_integer_2", 42, noreply=True)
+ def test_quit_all(self):
+ self.mc.quit_all()
+
def test_delete(self):
self.check_setget("long", int(1 << 30))
result = self.mc.delete("long")