From patchwork Mon Jun 15 09:16:55 2020 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Florian Levis X-Patchwork-Id: 20414 Return-Path: X-Original-To: patchwork@ffaux-bg.ffmpeg.org Delivered-To: patchwork@ffaux-bg.ffmpeg.org Received: from ffbox0-bg.mplayerhq.hu (ffbox0-bg.ffmpeg.org [79.124.17.100]) by ffaux.localdomain (Postfix) with ESMTP id 34CF544B5F9 for ; Mon, 15 Jun 2020 12:17:25 +0300 (EEST) Received: from [127.0.1.1] (localhost [127.0.0.1]) by ffbox0-bg.mplayerhq.hu (Postfix) with ESMTP id 0F31068B5C5; Mon, 15 Jun 2020 12:17:25 +0300 (EEST) X-Original-To: ffmpeg-devel@ffmpeg.org Delivered-To: ffmpeg-devel@ffmpeg.org Received: from mail-wr1-f68.google.com (mail-wr1-f68.google.com [209.85.221.68]) by ffbox0-bg.mplayerhq.hu (Postfix) with ESMTPS id 749DA68B361 for ; Mon, 15 Jun 2020 12:17:18 +0300 (EEST) Received: by mail-wr1-f68.google.com with SMTP id r7so16311196wro.1 for ; Mon, 15 Jun 2020 02:17:18 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:to:cc:subject:date:message-id:in-reply-to:references :mime-version:content-transfer-encoding; bh=2znEI7WyRlJfhp69q2gFUXIWeAk0vrxgfqplWmk1F6A=; b=jMXu9W3QhlYgICuOSnJz2B5I96klNDR5YMx+Xdro+zMK35Z+i5ISw7404PeuXksGl8 9F0AyZ3ZI3rvkdCtpKKS9WtfPdGTk8Es03Gb6PxWEBiRGyl5FIL/9/1pN8JsXlE1G1n2 tuF95eLPhx94K2Fe2YZPqBkulTFSL5at0pJXQdNSgseGZrAsC//tsUL78bFOO3NYsrrT VwIj89M96OFiZgKBsf2wu1YJBiozJSkpO/wn3Hzoi3Aff0NEkILC7tW8F3rkjcS3BUPv RhFYn4nmjZOVtAwjL/dq3hL1MmWzgji26XwBiri0OGhOB7SwFmiV7l5mR6hsZkupbDMe 9w0g== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:to:cc:subject:date:message-id:in-reply-to :references:mime-version:content-transfer-encoding; bh=2znEI7WyRlJfhp69q2gFUXIWeAk0vrxgfqplWmk1F6A=; b=QmuhYxx8hHgk3MKpchqe7JsSBQkOxfKvYPmHCWiXxxT2J8sILMCYucEIUSAr0jzVgs uEB03MQUUcyiuuGvpdQ/a3f2PLzy93bgoVgsPIpgCK2oDGWNUSH7H2j3HZNovqyGhddg Fm6TxZDv9C0QwtXfZxIS0+KzUt5QFAprzaC1Ls0kWJsKwrvp/hvBQYc92CInYKtvi0It EVwIQSJSx/KDTyXLx+bjc+gfp6kPVwoyE4y9Z61tAD2h+fuXR/3uhZZ3bf1DjY6JPlWD Z/3SdQREKqNXxouTXDfu30YszRMyVXH89ybbmOpui8imwrdseaafpAYq5YgcGITuDR9H 2Agw== X-Gm-Message-State: AOAM5301m33FCLjh3Mk3nc+wibnngI/LtZhl9S2RhftnM5vUZjHa4+iC KEE17lGCf6sIJW4eiBNxAiKof6th/78= X-Google-Smtp-Source: ABdhPJx6GcmAvAQfZFTR3BMlR/eSoCGiX078d3zHVqZrbKO+OVhy5uCnRFqgQCy1L6WSIWr2K4wCCQ== X-Received: by 2002:adf:a449:: with SMTP id e9mr27674568wra.294.1592212637506; Mon, 15 Jun 2020 02:17:17 -0700 (PDT) Received: from localhost.localdomain (82-64-71-170.subs.proxad.net. [82.64.71.170]) by smtp.gmail.com with ESMTPSA id z25sm21149419wmf.10.2020.06.15.02.17.16 (version=TLS1_2 cipher=ECDHE-ECDSA-AES128-GCM-SHA256 bits=128/128); Mon, 15 Jun 2020 02:17:16 -0700 (PDT) From: Levis Florian To: ffmpeg-devel@ffmpeg.org Date: Mon, 15 Jun 2020 11:16:55 +0200 Message-Id: <20200615091655.76925-1-levis.florian@gmail.com> X-Mailer: git-send-email 2.27.0 In-Reply-To: <20200614165606.36659-1-levis.florian@gmail.com> References: <20200614165606.36659-1-levis.florian@gmail.com> MIME-Version: 1.0 Subject: [FFmpeg-devel] [PATCH] avformat: AMQP: add option delivery_mode X-BeenThere: ffmpeg-devel@ffmpeg.org X-Mailman-Version: 2.1.20 Precedence: list List-Id: FFmpeg development discussions and patches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Reply-To: FFmpeg development discussions and patches Cc: Levis Florian Errors-To: ffmpeg-devel-bounces@ffmpeg.org Sender: "ffmpeg-devel" Signed-off-by: Levis Florian --- doc/protocols.texi | 13 +++++++++++++ libavformat/libamqp.c | 6 +++++- 2 files changed, 18 insertions(+), 1 deletion(-) diff --git a/doc/protocols.texi b/doc/protocols.texi index 7aa758541c..336246e67a 100644 --- a/doc/protocols.texi +++ b/doc/protocols.texi @@ -109,6 +109,19 @@ the received message may be truncated causing decoding errors. The timeout in seconds during the initial connection to the broker. The default value is rw_timeout, or 5 seconds if rw_timeout is not set. +@item delivery_mode @var{mode} +Sets the delivery mode. + +The following values are recognized: +@table @samp +@item persistent +Delivery mode set to "persistent" (2). This is the default value. + +@item non-persistent +Delivery mode set to "non-persistent" (1) + +@end table + @end table @section async diff --git a/libavformat/libamqp.c b/libavformat/libamqp.c index aaf0e51152..83de2229fb 100644 --- a/libavformat/libamqp.c +++ b/libavformat/libamqp.c @@ -39,6 +39,7 @@ typedef struct AMQPContext { int pkt_size; int64_t connection_timeout; int pkt_size_overflow; + int delivery_mode; } AMQPContext; #define STR_LEN 1024 @@ -52,6 +53,9 @@ static const AVOption options[] = { { "exchange", "Exchange to send/read packets", OFFSET(exchange), AV_OPT_TYPE_STRING, { .str = "amq.direct" }, 0, 0, .flags = D | E }, { "routing_key", "Key to filter streams", OFFSET(routing_key), AV_OPT_TYPE_STRING, { .str = "amqp" }, 0, 0, .flags = D | E }, { "connection_timeout", "Initial connection timeout", OFFSET(connection_timeout), AV_OPT_TYPE_DURATION, { .i64 = -1 }, -1, INT64_MAX, .flags = D | E}, + { "delivery_mode", "Delivery mode", OFFSET(delivery_mode), AV_OPT_TYPE_INT, { .i64 = AMQP_DELIVERY_PERSISTENT }, 1, 2, .flags = E, "delivery_mode"}, + { "persistent", "persistent delivery mode", 0, AV_OPT_TYPE_CONST, {.i64=AMQP_DELIVERY_PERSISTENT }, 0, 0, E, "delivery_mode" }, + { "non-persistent", "non-persistent delivery mode", 0, AV_OPT_TYPE_CONST, {.i64=AMQP_DELIVERY_NONPERSISTENT }, 0, 0, E, "delivery_mode" }, { NULL } }; @@ -222,7 +226,7 @@ static int amqp_proto_write(URLContext *h, const unsigned char *buf, int size) props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG | AMQP_BASIC_DELIVERY_MODE_FLAG; props.content_type = amqp_cstring_bytes("octet/stream"); - props.delivery_mode = 2; /* persistent delivery mode */ + props.delivery_mode = s->delivery_mode; ret = amqp_basic_publish(s->conn, DEFAULT_CHANNEL, amqp_cstring_bytes(s->exchange), amqp_cstring_bytes(s->routing_key), 0, 0,