#include <amqp.h>
#include <amqp_tcp_socket.h>
#include <sys/time.h>
#include "avformat.h"
#include "libavutil/avstring.h"
#include "libavutil/opt.h"
#include "libavutil/time.h"
#include "network.h"
#include "url.h"
#include "urldecode.h"
Go to the source code of this file.
#define DEFAULT_CHANNEL 1 |
static int amqp_proto_write |
( |
URLContext * |
h, |
|
|
const unsigned char * |
buf, |
|
|
int |
size |
|
) |
| |
|
static |
Initial value:= {
{
"pkt_size",
"Maximum send/read packet size",
OFFSET(pkt_size),
AV_OPT_TYPE_INT, { .i64 = 131072 }, 4096, INT_MAX, .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" },
}
static int exchange(MqcState *mqc, uint8_t *cxstate, int lps)
Definition at line 51 of file libamqp.c.
Initial value:= {
.class_name = "amqp",
}
#define LIBAVUTIL_VERSION_INT
const char * av_default_item_name(void *ptr)
Return the context name.
static const AVOption options[]
Definition at line 307 of file libamqp.c.
Initial value:= {
.name = "amqp",
}
static int amqp_proto_write(URLContext *h, const unsigned char *buf, int size)
#define URL_PROTOCOL_FLAG_NETWORK
static int amqp_proto_read(URLContext *h, unsigned char *buf, int size)
static const AVClass amqp_context_class
static int amqp_proto_open(URLContext *h, const char *uri, int flags)
#define flags(name, subs,...)
static int amqp_proto_close(URLContext *h)
Definition at line 314 of file libamqp.c.