Go to the documentation of this file.
22 #include "config_components.h"
24 #if CONFIG_TLS_PROTOCOL && CONFIG_OPENSSL
25 #include <openssl/opensslv.h>
38 #if CONFIG_TLS_PROTOCOL
48 #if CONFIG_TLS_PROTOCOL
60 if (WSAStartup(MAKEWORD(1,1), &wsaData))
68 int ev = write ? POLLOUT : POLLIN;
69 struct pollfd p = { .fd = fd, .events = ev, .revents = 0 };
123 int err = WSAGetLastError();
129 case WSAEPROTONOSUPPORT:
130 return AVERROR(EPROTONOSUPPORT);
133 case WSAECONNREFUSED:
144 if (addr->sa_family == AF_INET) {
145 return IN_MULTICAST(ntohl(((
struct sockaddr_in *)addr)->sin_addr.s_addr));
147 #if HAVE_STRUCT_SOCKADDR_IN6
148 if (addr->sa_family == AF_INET6) {
173 }
while (timeout <= 0 || runs-- > 0);
185 fd = socket(af,
type | SOCK_CLOEXEC, proto);
186 if (fd == -1 && errno == EINVAL)
189 fd = socket(af,
type, proto);
192 if (fcntl(fd, F_SETFD, FD_CLOEXEC) == -1)
199 if (setsockopt(fd, SOL_SOCKET, SO_NOSIGPIPE, &(
int){1},
sizeof(int))) {
208 socklen_t addrlen,
void *logctx)
212 if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &reuse,
sizeof(reuse))) {
215 ret = bind(fd, addr, addrlen);
228 struct pollfd lp = { fd, POLLIN, 0 };
259 struct pollfd p = {fd, POLLOUT, 0};
266 while ((
ret = connect(fd, addr, addrlen))) {
278 optlen =
sizeof(
ret);
279 if (getsockopt (fd, SOL_SOCKET, SO_ERROR, &
ret, &optlen))
285 "Connection to %s failed (%s), trying next address\n",
308 if (cur ==
base->ai_next) {
312 next = &
base->ai_next;
332 char hostbuf[100], portbuf[20];
336 hostbuf,
sizeof(hostbuf), portbuf,
sizeof(portbuf),
352 struct addrinfo **ptr,
int timeout_ms,
354 int (*
customize_fd)(
void *,
int,
int),
void *customize_ctx)
372 closesocket(attempt->
fd);
383 closesocket(attempt->
fd);
392 closesocket(attempt->
fd);
402 #define NEXT_ATTEMPT_DELAY_MS 200
406 int (*
customize_fd)(
void *,
int,
int),
void *customize_ctx)
409 struct pollfd pfd[3];
410 int nb_attempts = 0,
i, j;
414 char hostbuf[100], portbuf[20];
426 while (nb_attempts > 0 || addrs) {
428 if (nb_attempts < parallel && addrs) {
430 hostbuf,
sizeof(hostbuf), portbuf,
sizeof(portbuf),
435 timeout_ms_per_address,
h,
443 for (
i = 0;
i < nb_attempts;
i++)
444 closesocket(attempts[
i].fd);
445 *fd = attempts[nb_attempts].
fd;
448 pfd[nb_attempts].fd = attempts[nb_attempts].
fd;
449 pfd[nb_attempts].events = POLLOUT;
459 if (nb_attempts < parallel && addrs)
460 next_deadline_us =
FFMIN(next_deadline_us, next_attempt_us);
463 &
h->interrupt_callback);
464 if (last_err < 0 && last_err !=
AVERROR(ETIMEDOUT))
468 for (
i = 0;
i < nb_attempts;
i++) {
470 if (pfd[
i].revents) {
473 optlen =
sizeof(last_err);
474 if (getsockopt(attempts[
i].fd, SOL_SOCKET, SO_ERROR, &last_err, &optlen))
476 else if (last_err != 0)
481 for (j = 0; j < nb_attempts; j++)
483 closesocket(attempts[j].fd);
484 *fd = attempts[
i].
fd;
486 hostbuf,
sizeof(hostbuf), portbuf,
sizeof(portbuf),
501 hostbuf,
sizeof(hostbuf), portbuf,
sizeof(portbuf),
504 "failed: %s\n", hostbuf, portbuf,
av_err2str(last_err));
505 closesocket(attempts[
i].fd);
506 memmove(&attempts[
i], &attempts[
i + 1],
507 (nb_attempts -
i - 1) *
sizeof(*attempts));
508 memmove(&pfd[
i], &pfd[
i + 1],
509 (nb_attempts -
i - 1) *
sizeof(*pfd));
514 for (
i = 0;
i < nb_attempts;
i++)
515 closesocket(attempts[
i].fd);
517 last_err =
AVERROR(ECONNREFUSED);
528 if (!strcmp(pattern,
"*"))
531 if (pattern[0] ==
'*')
533 if (pattern[0] ==
'.')
535 len_p = strlen(pattern);
536 len_h = strlen(hostname);
540 if (!strcmp(pattern, &hostname[len_h - len_p])) {
543 if (hostname[len_h - len_p - 1] ==
'.')
562 char *sep, *next =
NULL;
563 start += strspn(start,
" ,");
564 sep = start + strcspn(start,
" ,");
int64_t av_gettime_relative(void)
Get the current time in microseconds since some unspecified starting point.
#define AV_LOG_WARNING
Something somehow does not look correct.
static void interleave_addrinfo(struct addrinfo *base)
Filter the word “frame” indicates either a video frame or a group of audio as stored in an AVFrame structure Format for each input and each output the list of supported formats For video that means pixel format For audio that means channel sample they are references to shared objects When the negotiation mechanism computes the intersection of the formats supported at each end of a all references to both lists are replaced with a reference to the intersection And when a single format is eventually chosen for a link amongst the remaining all references to the list are updated That means that if a filter requires that its input and output have the same format amongst a supported all it has to do is use a reference to the same list of formats query_formats can leave some formats unset and return AVERROR(EAGAIN) to cause the negotiation mechanism toagain later. That can be used by filters with complex requirements to use the format negotiated on one link to set the formats supported on another. Frame references ownership and permissions
static double cb(void *priv, double x, double y)
static int ff_poll_interrupt(struct pollfd *p, nfds_t nfds, int timeout, AVIOInterruptCB *cb)
void ff_gnutls_init(void)
void ff_log_net_error(void *ctx, int level, const char *prefix)
#define AV_LOG_VERBOSE
Detailed information.
static void print_address_list(void *ctx, const struct addrinfo *addr, const char *title)
void ff_network_close(void)
#define IN6_IS_ADDR_MULTICAST(a)
int ff_network_init(void)
Callback for checking whether to abort blocking functions.
void ff_gnutls_deinit(void)
it s the only field you need to keep assuming you have a context There is some magic you don t need to care about around this just let it vf type
int ff_check_interrupt(AVIOInterruptCB *cb)
Check if the user has requested to interrupt a blocking function associated with cb.
int ff_listen_bind(int fd, const struct sockaddr *addr, socklen_t addrlen, int timeout, URLContext *h)
Bind to a file descriptor and poll for a connection.
#define AV_LOG_ERROR
Something went wrong and cannot losslessly be recovered.
#define FF_ARRAY_ELEMS(a)
static int customize_fd(void *ctx, int fd, int family)
#define av_assert0(cond)
assert() equivalent, that is always enabled.
#define AV_LOG_DEBUG
Stuff which is only useful for libav* developers.
int av_usleep(unsigned usec)
Sleep for a period of time.
int ff_http_match_no_proxy(const char *no_proxy, const char *hostname)
int ff_is_multicast_address(struct sockaddr *addr)
int ff_listen_connect(int fd, const struct sockaddr *addr, socklen_t addrlen, int timeout, URLContext *h, int will_try_next)
Connect to a file descriptor and poll for result.
int ff_network_wait_fd_timeout(int fd, int write, int64_t timeout, AVIOInterruptCB *int_cb)
This works similarly to ff_network_wait_fd, but waits up to 'timeout' microseconds Uses ff_network_wa...
struct sockaddr * ai_addr
int ff_accept(int fd, int timeout, URLContext *h)
Poll for a single connection on the passed file descriptor.
#define av_err2str(errnum)
Convenience macro, the return value should be used only directly in function arguments but never stan...
int ff_socket_nonblock(int socket, int enable)
struct addrinfo * ai_next
#define i(width, name, range_min, range_max)
int ff_network_sleep_interruptible(int64_t timeout, AVIOInterruptCB *int_cb)
Waits for up to 'timeout' microseconds.
const AVIOInterruptCB int_cb
int ff_connect_parallel(struct addrinfo *addrs, int timeout_ms_per_address, int parallel, URLContext *h, int *fd, int(*customize_fd)(void *, int, int), void *customize_ctx)
Connect to any of the given addrinfo addresses, with multiple attempts running in parallel.
int ff_listen(int fd, const struct sockaddr *addr, socklen_t addrlen, void *logctx)
Bind to a file descriptor to an address without accepting connections.
char * av_strdup(const char *s)
Duplicate a string.
#define AVERROR_EXIT
Immediate exit was requested; the called function should not be restarted.
int ff_socket(int af, int type, int proto, void *logctx)
#define NEXT_ATTEMPT_DELAY_MS
static int match_host_pattern(const char *pattern, const char *hostname)
static int start_connect_attempt(struct ConnectionAttempt *attempt, struct addrinfo **ptr, int timeout_ms, URLContext *h, int(*customize_fd)(void *, int, int), void *customize_ctx)
int ff_network_wait_fd(int fd, int write)