check_and_subscribe_port
err = check_and_subscribe_port(src_client, src_port, subs, true,
err = check_and_subscribe_port(dest_client, dest_port, subs, false,