virtualenv/FFmpeg
1
0
Fork 0
mirror of https://github.com/FFmpeg/FFmpeg.git synced 2024-12-23 12:43:46 +02:00
Code Issues Releases Activity

lavf: remove FF_API_URL_CLASS cruft.

Browse Source
This commit is contained in:
Anton Khirnov 2011-02-03 12:53:28 +01:00
parent 5763e63913
commit 7f804085f1
4 changed files with 26 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
libavformat/avio.c
View File

@ -31,7 +31,6 @@
#endif #endif
#include "url.h" #include "url.h"
#if FF_API_URL_CLASS
/** @name Logging context. */ /** @name Logging context. */
/*@{*/ /*@{*/
static const char *urlcontext_to_name(void *ptr) static const char *urlcontext_to_name(void *ptr)
@ -44,7 +43,6 @@ static const AVOption options[] = {{NULL}};
static const AVClass urlcontext_class = static const AVClass urlcontext_class =
{ "URLContext", urlcontext_to_name, options, LIBAVUTIL_VERSION_INT }; { "URLContext", urlcontext_to_name, options, LIBAVUTIL_VERSION_INT };
/*@}*/ /*@}*/
#endif
static int default_interrupt_cb(void); static int default_interrupt_cb(void);
@ -99,9 +97,7 @@ static int url_alloc_for_protocol (URLContext **puc, struct URLProtocol *up,
err = AVERROR(ENOMEM); err = AVERROR(ENOMEM);
goto fail; goto fail;
} }
#if FF_API_URL_CLASS
uc->av_class = &urlcontext_class; uc->av_class = &urlcontext_class;
#endif
uc->filename = (char *) &uc[1]; uc->filename = (char *) &uc[1];
strcpy(uc->filename, filename); strcpy(uc->filename, filename);
uc->prot = up; uc->prot = up;

2
libavformat/avio.h
View File

@ -101,9 +101,7 @@ typedef struct {
* @deprecated This struct will be made private * @deprecated This struct will be made private
*/ */
typedef struct URLContext { typedef struct URLContext {
#if FF_API_URL_CLASS
const AVClass *av_class; ///< information for av_log(). Set by url_open(). const AVClass *av_class; ///< information for av_log(). Set by url_open().
#endif
struct URLProtocol *prot; struct URLProtocol *prot;
int flags; int flags;
int is_streamed; /**< true if streamed (no seek possible), default = false */ int is_streamed; /**< true if streamed (no seek possible), default = false */

59
libavformat/rtmpproto.c
View File

@ -38,13 +38,6 @@
#include "rtmppkt.h" #include "rtmppkt.h"
#include "url.h" #include "url.h"
/* we can't use av_log() with URLContext yet... */
#if FF_API_URL_CLASS
#define LOG_CONTEXT s
#else
#define LOG_CONTEXT NULL
#endif
//#define DEBUG //#define DEBUG
/** RTMP protocol handler state */ /** RTMP protocol handler state */
@ -166,7 +159,7 @@ static void gen_release_stream(URLContext *s, RTMPContext *rt)
ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE, 0, ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE, 0,
29 + strlen(rt->playpath)); 29 + strlen(rt->playpath));
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "Releasing stream...\n"); av_log(s, AV_LOG_DEBUG, "Releasing stream...\n");
p = pkt.data; p = pkt.data;
ff_amf_write_string(&p, "releaseStream"); ff_amf_write_string(&p, "releaseStream");
ff_amf_write_number(&p, 2.0); ff_amf_write_number(&p, 2.0);
@ -189,7 +182,7 @@ static void gen_fcpublish_stream(URLContext *s, RTMPContext *rt)
ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE, 0, ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE, 0,
25 + strlen(rt->playpath)); 25 + strlen(rt->playpath));
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "FCPublish stream...\n"); av_log(s, AV_LOG_DEBUG, "FCPublish stream...\n");
p = pkt.data; p = pkt.data;
ff_amf_write_string(&p, "FCPublish"); ff_amf_write_string(&p, "FCPublish");
ff_amf_write_number(&p, 3.0); ff_amf_write_number(&p, 3.0);
@ -212,7 +205,7 @@ static void gen_fcunpublish_stream(URLContext *s, RTMPContext *rt)
ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE, 0, ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE, 0,
27 + strlen(rt->playpath)); 27 + strlen(rt->playpath));
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "UnPublishing stream...\n"); av_log(s, AV_LOG_DEBUG, "UnPublishing stream...\n");
p = pkt.data; p = pkt.data;
ff_amf_write_string(&p, "FCUnpublish"); ff_amf_write_string(&p, "FCUnpublish");
ff_amf_write_number(&p, 5.0); ff_amf_write_number(&p, 5.0);
@ -232,7 +225,7 @@ static void gen_create_stream(URLContext *s, RTMPContext *rt)
RTMPPacket pkt; RTMPPacket pkt;
uint8_t *p; uint8_t *p;
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "Creating stream...\n"); av_log(s, AV_LOG_DEBUG, "Creating stream...\n");
ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE, 0, 25); ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE, 0, 25);
p = pkt.data; p = pkt.data;
@ -254,7 +247,7 @@ static void gen_delete_stream(URLContext *s, RTMPContext *rt)
RTMPPacket pkt; RTMPPacket pkt;
uint8_t *p; uint8_t *p;
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "Deleting stream...\n"); av_log(s, AV_LOG_DEBUG, "Deleting stream...\n");
ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE, 0, 34); ff_rtmp_packet_create(&pkt, RTMP_SYSTEM_CHANNEL, RTMP_PT_INVOKE, 0, 34);
p = pkt.data; p = pkt.data;
@ -276,7 +269,7 @@ static void gen_play(URLContext *s, RTMPContext *rt)
RTMPPacket pkt; RTMPPacket pkt;
uint8_t *p; uint8_t *p;
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "Sending play command for '%s'\n", rt->playpath); av_log(s, AV_LOG_DEBUG, "Sending play command for '%s'\n", rt->playpath);
ff_rtmp_packet_create(&pkt, RTMP_VIDEO_CHANNEL, RTMP_PT_INVOKE, 0, ff_rtmp_packet_create(&pkt, RTMP_VIDEO_CHANNEL, RTMP_PT_INVOKE, 0,
20 + strlen(rt->playpath)); 20 + strlen(rt->playpath));
pkt.extra = rt->main_channel_id; pkt.extra = rt->main_channel_id;
@ -310,7 +303,7 @@ static void gen_publish(URLContext *s, RTMPContext *rt)
RTMPPacket pkt; RTMPPacket pkt;
uint8_t *p; uint8_t *p;
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "Sending publish command for '%s'\n", rt->playpath); av_log(s, AV_LOG_DEBUG, "Sending publish command for '%s'\n", rt->playpath);
ff_rtmp_packet_create(&pkt, RTMP_SOURCE_CHANNEL, RTMP_PT_INVOKE, 0, ff_rtmp_packet_create(&pkt, RTMP_SOURCE_CHANNEL, RTMP_PT_INVOKE, 0,
30 + strlen(rt->playpath)); 30 + strlen(rt->playpath));
pkt.extra = rt->main_channel_id; pkt.extra = rt->main_channel_id;
@ -478,7 +471,7 @@ static int rtmp_handshake(URLContext *s, RTMPContext *rt)
int server_pos, client_pos; int server_pos, client_pos;
uint8_t digest[32]; uint8_t digest[32];
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "Handshaking...\n"); av_log(s, AV_LOG_DEBUG, "Handshaking...\n");
av_lfg_init(&rnd, 0xDEADC0DE); av_lfg_init(&rnd, 0xDEADC0DE);
// generate handshake packet - 1536 bytes of pseudorandom data // generate handshake packet - 1536 bytes of pseudorandom data
@ -489,16 +482,16 @@ static int rtmp_handshake(URLContext *s, RTMPContext *rt)
ffurl_write(rt->stream, tosend, RTMP_HANDSHAKE_PACKET_SIZE + 1); ffurl_write(rt->stream, tosend, RTMP_HANDSHAKE_PACKET_SIZE + 1);
i = ffurl_read_complete(rt->stream, serverdata, RTMP_HANDSHAKE_PACKET_SIZE + 1); i = ffurl_read_complete(rt->stream, serverdata, RTMP_HANDSHAKE_PACKET_SIZE + 1);
if (i != RTMP_HANDSHAKE_PACKET_SIZE + 1) { if (i != RTMP_HANDSHAKE_PACKET_SIZE + 1) {
av_log(LOG_CONTEXT, AV_LOG_ERROR, "Cannot read RTMP handshake response\n"); av_log(s, AV_LOG_ERROR, "Cannot read RTMP handshake response\n");
return -1; return -1;
} }
i = ffurl_read_complete(rt->stream, clientdata, RTMP_HANDSHAKE_PACKET_SIZE); i = ffurl_read_complete(rt->stream, clientdata, RTMP_HANDSHAKE_PACKET_SIZE);
if (i != RTMP_HANDSHAKE_PACKET_SIZE) { if (i != RTMP_HANDSHAKE_PACKET_SIZE) {
av_log(LOG_CONTEXT, AV_LOG_ERROR, "Cannot read RTMP handshake response\n"); av_log(s, AV_LOG_ERROR, "Cannot read RTMP handshake response\n");
return -1; return -1;
} }
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "Server version %d.%d.%d.%d\n", av_log(s, AV_LOG_DEBUG, "Server version %d.%d.%d.%d\n",
serverdata[5], serverdata[6], serverdata[7], serverdata[8]); serverdata[5], serverdata[6], serverdata[7], serverdata[8]);
if (rt->is_input && serverdata[5] >= 3) { if (rt->is_input && serverdata[5] >= 3) {
@ -506,7 +499,7 @@ static int rtmp_handshake(URLContext *s, RTMPContext *rt)
if (!server_pos) { if (!server_pos) {
server_pos = rtmp_validate_digest(serverdata + 1, 8); server_pos = rtmp_validate_digest(serverdata + 1, 8);
if (!server_pos) { if (!server_pos) {
av_log(LOG_CONTEXT, AV_LOG_ERROR, "Server response validating failed\n"); av_log(s, AV_LOG_ERROR, "Server response validating failed\n");
return -1; return -1;
} }
} }
@ -518,7 +511,7 @@ static int rtmp_handshake(URLContext *s, RTMPContext *rt)
digest, 32, digest, 32,
digest); digest);
if (memcmp(digest, clientdata + RTMP_HANDSHAKE_PACKET_SIZE - 32, 32)) { if (memcmp(digest, clientdata + RTMP_HANDSHAKE_PACKET_SIZE - 32, 32)) {
av_log(LOG_CONTEXT, AV_LOG_ERROR, "Signature mismatch\n"); av_log(s, AV_LOG_ERROR, "Signature mismatch\n");
return -1; return -1;
} }
@ -552,13 +545,13 @@ static int rtmp_parse_result(URLContext *s, RTMPContext *rt, RTMPPacket *pkt)
const uint8_t *data_end = pkt->data + pkt->data_size; const uint8_t *data_end = pkt->data + pkt->data_size;
#ifdef DEBUG #ifdef DEBUG
ff_rtmp_packet_dump(LOG_CONTEXT, pkt); ff_rtmp_packet_dump(s, pkt);
#endif #endif
switch (pkt->type) { switch (pkt->type) {
case RTMP_PT_CHUNK_SIZE: case RTMP_PT_CHUNK_SIZE:
if (pkt->data_size != 4) { if (pkt->data_size != 4) {
av_log(LOG_CONTEXT, AV_LOG_ERROR, av_log(s, AV_LOG_ERROR,
"Chunk size change packet is not 4 bytes long (%d)\n", pkt->data_size); "Chunk size change packet is not 4 bytes long (%d)\n", pkt->data_size);
return -1; return -1;
} }
@ -566,10 +559,10 @@ static int rtmp_parse_result(URLContext *s, RTMPContext *rt, RTMPPacket *pkt)
ff_rtmp_packet_write(rt->stream, pkt, rt->chunk_size, rt->prev_pkt[1]); ff_rtmp_packet_write(rt->stream, pkt, rt->chunk_size, rt->prev_pkt[1]);
rt->chunk_size = AV_RB32(pkt->data); rt->chunk_size = AV_RB32(pkt->data);
if (rt->chunk_size <= 0) { if (rt->chunk_size <= 0) {
av_log(LOG_CONTEXT, AV_LOG_ERROR, "Incorrect chunk size %d\n", rt->chunk_size); av_log(s, AV_LOG_ERROR, "Incorrect chunk size %d\n", rt->chunk_size);
return -1; return -1;
} }
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "New chunk size = %d\n", rt->chunk_size); av_log(s, AV_LOG_DEBUG, "New chunk size = %d\n", rt->chunk_size);
break; break;
case RTMP_PT_PING: case RTMP_PT_PING:
t = AV_RB16(pkt->data); t = AV_RB16(pkt->data);
@ -578,12 +571,12 @@ static int rtmp_parse_result(URLContext *s, RTMPContext *rt, RTMPPacket *pkt)
break; break;
case RTMP_PT_CLIENT_BW: case RTMP_PT_CLIENT_BW:
if (pkt->data_size < 4) { if (pkt->data_size < 4) {
av_log(LOG_CONTEXT, AV_LOG_ERROR, av_log(s, AV_LOG_ERROR,
"Client bandwidth report packet is less than 4 bytes long (%d)\n", "Client bandwidth report packet is less than 4 bytes long (%d)\n",
pkt->data_size); pkt->data_size);
return -1; return -1;
} }
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "Client bandwidth = %d\n", AV_RB32(pkt->data)); av_log(s, AV_LOG_DEBUG, "Client bandwidth = %d\n", AV_RB32(pkt->data));
rt->client_report_size = AV_RB32(pkt->data) >> 1; rt->client_report_size = AV_RB32(pkt->data) >> 1;
break; break;
case RTMP_PT_INVOKE: case RTMP_PT_INVOKE:
@ -593,7 +586,7 @@ static int rtmp_parse_result(URLContext *s, RTMPContext *rt, RTMPPacket *pkt)
if (!ff_amf_get_field_value(pkt->data + 9, data_end, if (!ff_amf_get_field_value(pkt->data + 9, data_end,
"description", tmpstr, sizeof(tmpstr))) "description", tmpstr, sizeof(tmpstr)))
av_log(LOG_CONTEXT, AV_LOG_ERROR, "Server error: %s\n",tmpstr); av_log(s, AV_LOG_ERROR, "Server error: %s\n",tmpstr);
return -1; return -1;
} else if (!memcmp(pkt->data, "\002\000\007_result", 10)) { } else if (!memcmp(pkt->data, "\002\000\007_result", 10)) {
switch (rt->state) { switch (rt->state) {
@ -624,7 +617,7 @@ static int rtmp_parse_result(URLContext *s, RTMPContext *rt, RTMPPacket *pkt)
case STATE_CONNECTING: case STATE_CONNECTING:
//extract a number from the result //extract a number from the result
if (pkt->data[10] || pkt->data[19] != 5 || pkt->data[20]) { if (pkt->data[10] || pkt->data[19] != 5 || pkt->data[20]) {
av_log(LOG_CONTEXT, AV_LOG_WARNING, "Unexpected reply on connect()\n"); av_log(s, AV_LOG_WARNING, "Unexpected reply on connect()\n");
} else { } else {
rt->main_channel_id = (int) av_int2dbl(AV_RB64(pkt->data + 21)); rt->main_channel_id = (int) av_int2dbl(AV_RB64(pkt->data + 21));
} }
@ -651,7 +644,7 @@ static int rtmp_parse_result(URLContext *s, RTMPContext *rt, RTMPPacket *pkt)
if (!t && !strcmp(tmpstr, "error")) { if (!t && !strcmp(tmpstr, "error")) {
if (!ff_amf_get_field_value(ptr, data_end, if (!ff_amf_get_field_value(ptr, data_end,
"description", tmpstr, sizeof(tmpstr))) "description", tmpstr, sizeof(tmpstr)))
av_log(LOG_CONTEXT, AV_LOG_ERROR, "Server error: %s\n",tmpstr); av_log(s, AV_LOG_ERROR, "Server error: %s\n",tmpstr);
return -1; return -1;
} }
t = ff_amf_get_field_value(ptr, data_end, t = ff_amf_get_field_value(ptr, data_end,
@ -701,7 +694,7 @@ static int get_packet(URLContext *s, int for_header)
} }
rt->bytes_read += ret; rt->bytes_read += ret;
if (rt->bytes_read > rt->last_bytes_read + rt->client_report_size) { if (rt->bytes_read > rt->last_bytes_read + rt->client_report_size) {
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "Sending bytes read report\n"); av_log(s, AV_LOG_DEBUG, "Sending bytes read report\n");
gen_bytes_read(s, rt, rpkt.timestamp + 1); gen_bytes_read(s, rt, rpkt.timestamp + 1);
rt->last_bytes_read = rt->bytes_read; rt->last_bytes_read = rt->bytes_read;
} }
@ -822,7 +815,7 @@ static int rtmp_open(URLContext *s, const char *uri, int flags)
ff_url_join(buf, sizeof(buf), "tcp", NULL, hostname, port, NULL); ff_url_join(buf, sizeof(buf), "tcp", NULL, hostname, port, NULL);
if (ffurl_open(&rt->stream, buf, AVIO_RDWR) < 0) { if (ffurl_open(&rt->stream, buf, AVIO_RDWR) < 0) {
av_log(LOG_CONTEXT, AV_LOG_ERROR, "Cannot open connection %s\n", buf); av_log(s, AV_LOG_ERROR, "Cannot open connection %s\n", buf);
goto fail; goto fail;
} }
@ -866,7 +859,7 @@ static int rtmp_open(URLContext *s, const char *uri, int flags)
rt->bytes_read = 0; rt->bytes_read = 0;
rt->last_bytes_read = 0; rt->last_bytes_read = 0;
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "Proto = %s, path = %s, app = %s, fname = %s\n", av_log(s, AV_LOG_DEBUG, "Proto = %s, path = %s, app = %s, fname = %s\n",
proto, path, rt->app, rt->playpath); proto, path, rt->app, rt->playpath);
gen_connect(s, rt, proto, hostname, port); gen_connect(s, rt, proto, hostname, port);
@ -933,7 +926,7 @@ static int rtmp_write(URLContext *s, const uint8_t *buf, int size)
const uint8_t *buf_temp = buf; const uint8_t *buf_temp = buf;
if (size < 11) { if (size < 11) {
av_log(LOG_CONTEXT, AV_LOG_DEBUG, "FLV packet too small %d\n", size); av_log(s, AV_LOG_DEBUG, "FLV packet too small %d\n", size);
return 0; return 0;
} }

3
libavformat/version.h
View File

@ -44,9 +44,6 @@
#ifndef FF_API_OLD_METADATA2 #ifndef FF_API_OLD_METADATA2
#define FF_API_OLD_METADATA2 (LIBAVFORMAT_VERSION_MAJOR < 54) #define FF_API_OLD_METADATA2 (LIBAVFORMAT_VERSION_MAJOR < 54)
#endif #endif
#ifndef FF_API_URL_CLASS
#define FF_API_URL_CLASS (LIBAVFORMAT_VERSION_MAJOR >= 53)
#endif
#ifndef FF_API_READ_SEEK #ifndef FF_API_READ_SEEK
#define FF_API_READ_SEEK (LIBAVFORMAT_VERSION_MAJOR < 54) #define FF_API_READ_SEEK (LIBAVFORMAT_VERSION_MAJOR < 54)
#endif #endif