async def METHOD_NAME(ep):
    global _connected
    global _disconnected
    _lock.acquire()
    _connected += 1
    _lock.release()
    for i in range(TRANSFER_ITERATIONS):
        print("ITER: ", i)
        # Send meta data
        await send(ep, _frames)
    print("CONFIRM RECEIPT")
    await ep.close()
    _lock.acquire()
    _disconnected += 1
    _lock.release()
    # break