async def METHOD_NAME(ep):
    if not self.args.enable_am:
        if self.args.reuse_alloc:
            recv_msg = Array(xp.zeros(self.args.n_bytes, dtype="u1"))
            assert recv_msg.nbytes == self.args.n_bytes
    for i in range(self.args.n_iter + self.args.n_warmup_iter):
        if self.args.enable_am:
            recv = await ep.am_recv()
            await ep.am_send(recv)
        else:
            if not self.args.reuse_alloc:
                recv_msg = Array(xp.zeros(self.args.n_bytes, dtype="u1"))
            await ep.recv(recv_msg)
            await ep.send(recv_msg)
    await ep.close()
    lf.close()