def send(self, msg):
        client_coroutine = self.loop.create_unix_connection(_ClientProtocol, path=self.fname)

        try:
            _, client_proto = self.loop.run_until_complete(client_coroutine)
        except __HOLE__:
            raise IPCError("Could not open %s" % self.fname)

        client_proto.send(msg, is_json=self.is_json)

        try:
            self.loop.run_until_complete(asyncio.wait_for(client_proto.reply, timeout=10))
        except asyncio.TimeoutError:
            raise RuntimeError("Server not responding")

        return client_proto.reply.result()
dataset/ETHPy150Open qtile/qtile/libqtile/ipc.py/Client.send