2
* Copyright (c) 2007 The Libav Project
4
* This file is part of Libav.
6
* Libav is free software; you can redistribute it and/or
7
* modify it under the terms of the GNU Lesser General Public
8
* License as published by the Free Software Foundation; either
9
* version 2.1 of the License, or (at your option) any later version.
11
* Libav is distributed in the hope that it will be useful,
12
* but WITHOUT ANY WARRANTY; without even the implied warranty of
13
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14
* Lesser General Public License for more details.
16
* You should have received a copy of the GNU Lesser General Public
17
* License along with Libav; if not, write to the Free Software
18
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
22
#include "libavcodec/internal.h"
24
#define THREADS (HAVE_PTHREADS || (defined(WIN32) && !defined(__MINGW32CE__)))
30
#include "libavcodec/w32pthreads.h"
35
#include <openssl/ssl.h>
36
static int openssl_init;
38
#include <openssl/crypto.h>
39
#include "libavutil/avutil.h"
40
pthread_mutex_t *openssl_mutexes;
41
static void openssl_lock(int mode, int type, const char *file, int line)
43
if (mode & CRYPTO_LOCK)
44
pthread_mutex_lock(&openssl_mutexes[type]);
46
pthread_mutex_unlock(&openssl_mutexes[type]);
48
#if !defined(WIN32) && OPENSSL_VERSION_NUMBER < 0x10000000
49
static unsigned long openssl_thread_id(void)
51
return (intptr_t) pthread_self();
57
#include <gnutls/gnutls.h>
58
#if THREADS && GNUTLS_VERSION_NUMBER <= 0x020b00
63
GCRY_THREAD_OPTION_PTHREAD_IMPL;
67
void ff_tls_init(void)
69
avpriv_lock_avformat();
73
SSL_load_error_strings();
75
if (!CRYPTO_get_locking_callback()) {
77
openssl_mutexes = av_malloc(sizeof(pthread_mutex_t) * CRYPTO_num_locks());
78
for (i = 0; i < CRYPTO_num_locks(); i++)
79
pthread_mutex_init(&openssl_mutexes[i], NULL);
80
CRYPTO_set_locking_callback(openssl_lock);
81
#if !defined(WIN32) && OPENSSL_VERSION_NUMBER < 0x10000000
82
CRYPTO_set_id_callback(openssl_thread_id);
90
#if THREADS && GNUTLS_VERSION_NUMBER < 0x020b00
91
if (gcry_control(GCRYCTL_ANY_INITIALIZATION_P) == 0)
92
gcry_control(GCRYCTL_SET_THREAD_CBS, &gcry_threads_pthread);
96
avpriv_unlock_avformat();
99
void ff_tls_deinit(void)
101
avpriv_lock_avformat();
106
if (CRYPTO_get_locking_callback() == openssl_lock) {
108
CRYPTO_set_locking_callback(NULL);
109
for (i = 0; i < CRYPTO_num_locks(); i++)
110
pthread_mutex_destroy(&openssl_mutexes[i]);
111
av_free(openssl_mutexes);
117
gnutls_global_deinit();
119
avpriv_unlock_avformat();
122
int ff_network_inited_globally;
124
int ff_network_init(void)
130
if (!ff_network_inited_globally)
131
av_log(NULL, AV_LOG_WARNING, "Using network protocols without global "
132
"network initialization. Please use "
133
"avformat_network_init(), this will "
134
"become mandatory later.\n");
136
if (WSAStartup(MAKEWORD(1,1), &wsaData))
142
int ff_network_wait_fd(int fd, int write)
144
int ev = write ? POLLOUT : POLLIN;
145
struct pollfd p = { .fd = fd, .events = ev, .revents = 0 };
147
ret = poll(&p, 1, 100);
148
return ret < 0 ? ff_neterrno() : p.revents & (ev | POLLERR | POLLHUP) ? 0 : AVERROR(EAGAIN);
151
void ff_network_close(void)
159
int ff_neterrno(void)
161
int err = WSAGetLastError();
164
return AVERROR(EAGAIN);
166
return AVERROR(EINTR);
172
int ff_is_multicast_address(struct sockaddr *addr)
174
if (addr->sa_family == AF_INET) {
175
return IN_MULTICAST(ntohl(((struct sockaddr_in *)addr)->sin_addr.s_addr));
177
#if HAVE_STRUCT_SOCKADDR_IN6
178
if (addr->sa_family == AF_INET6) {
179
return IN6_IS_ADDR_MULTICAST(&((struct sockaddr_in6 *)addr)->sin6_addr);