#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.
◆ STR_LEN
◆ DEFAULT_CHANNEL
#define DEFAULT_CHANNEL 1 |
◆ OFFSET
◆ amqp_proto_open()
◆ amqp_proto_write()
static int amqp_proto_write |
( |
URLContext * |
h, |
|
|
const unsigned char * |
buf, |
|
|
int |
size |
|
) |
| |
|
static |
◆ amqp_proto_read()
◆ amqp_proto_close()
◆ options
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},
}
static int exchange(MqcState *mqc, uint8_t *cxstate, int lps)
Definition at line 50 of file libamqp.c.
◆ amqp_context_class
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 282 of file libamqp.c.
◆ ff_libamqp_protocol
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 289 of file libamqp.c.