Function flush_db_sync

monkey/monkey.py:216–221

()

    asyncore.close_all()

def flush_db_sync():
    server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server.connect(('127.0.0.1', 6379))
    server.send(_buildResp("flushdb"))
    resp = server.recv(8192)
    assert(resp[:3] == "+OK".encode('utf-8'))

def init_blocking():
    global clients