Skip to content

F
ffmpeg.wasm-core
Commit f858a6e2 authored by James Almer's avatar James Almer
Browse files
Options

Merge commit 'a1a143ad' 

* commit 'a1a143ad':
  rtmp: Rename packet types to closer match the spec
Merged-by: 's avatarJames Almer <jamrial@gmail.com>
parents c83c164f a1a143ad
Hide whitespace changes
Inline Side-by-side
Showing with 49 additions and 49 deletions
libavformat/rtmppkt.c
View file @ f858a6e2
...@@ -574,9 +574,9 @@ static const char* rtmp_packet_type(int type) ...@@ -574,9 +574,9 @@ static const char* rtmp_packet_type(int type)
switch (type) { switch (type) {
case RTMP_PT_CHUNK_SIZE: return "chunk size"; case RTMP_PT_CHUNK_SIZE: return "chunk size";
case RTMP_PT_BYTES_READ: return "bytes read"; case RTMP_PT_BYTES_READ: return "bytes read";
case RTMP_PT_PING: return "ping"; case RTMP_PT_USER_CONTROL: return "user control";
case RTMP_PT_SERVER_BW: return "server bandwidth"; case RTMP_PT_WINDOW_ACK_SIZE: return "window acknowledgement size";
case RTMP_PT_CLIENT_BW: return "client bandwidth"; case RTMP_PT_SET_PEER_BW: return "set peer bandwidth";
case RTMP_PT_AUDIO: return "audio packet"; case RTMP_PT_AUDIO: return "audio packet";
case RTMP_PT_VIDEO: return "video packet"; case RTMP_PT_VIDEO: return "video packet";
case RTMP_PT_FLEX_STREAM: return "Flex shared stream"; case RTMP_PT_FLEX_STREAM: return "Flex shared stream";
...@@ -674,10 +674,10 @@ void ff_rtmp_packet_dump(void *ctx, RTMPPacket *p) ...@@ -674,10 +674,10 @@ void ff_rtmp_packet_dump(void *ctx, RTMPPacket *p)
break; break;
src += sz; src += sz;
} }
} else if (p->type == RTMP_PT_SERVER_BW){ } else if (p->type == RTMP_PT_WINDOW_ACK_SIZE) {
av_log(ctx, AV_LOG_DEBUG, "Server BW = %d\n", AV_RB32(p->data)); av_log(ctx, AV_LOG_DEBUG, "Window acknowledgement size = %d\n", AV_RB32(p->data));
} else if (p->type == RTMP_PT_CLIENT_BW){ } else if (p->type == RTMP_PT_SET_PEER_BW) {
av_log(ctx, AV_LOG_DEBUG, "Client BW = %d\n", AV_RB32(p->data)); av_log(ctx, AV_LOG_DEBUG, "Set Peer BW = %d\n", AV_RB32(p->data));
} else if (p->type != RTMP_PT_AUDIO && p->type != RTMP_PT_VIDEO && p->type != RTMP_PT_METADATA) { } else if (p->type != RTMP_PT_AUDIO && p->type != RTMP_PT_VIDEO && p->type != RTMP_PT_METADATA) {
int i; int i;
for (i = 0; i < p->size; i++) for (i = 0; i < p->size; i++)
......
libavformat/rtmppkt.h
View file @ f858a6e2
...@@ -47,9 +47,9 @@ enum RTMPChannel { ...@@ -47,9 +47,9 @@ enum RTMPChannel {
typedef enum RTMPPacketType { typedef enum RTMPPacketType {
RTMP_PT_CHUNK_SIZE = 1, ///< chunk size change RTMP_PT_CHUNK_SIZE = 1, ///< chunk size change
RTMP_PT_BYTES_READ = 3, ///< number of bytes read RTMP_PT_BYTES_READ = 3, ///< number of bytes read
RTMP_PT_PING, ///< ping RTMP_PT_USER_CONTROL, ///< user control
RTMP_PT_SERVER_BW, ///< server bandwidth RTMP_PT_WINDOW_ACK_SIZE, ///< window acknowledgement size
RTMP_PT_CLIENT_BW, ///< client bandwidth RTMP_PT_SET_PEER_BW, ///< peer bandwidth
RTMP_PT_AUDIO = 8, ///< audio packet RTMP_PT_AUDIO = 8, ///< audio packet
RTMP_PT_VIDEO, ///< video packet RTMP_PT_VIDEO, ///< video packet
RTMP_PT_FLEX_STREAM = 15, ///< Flex shared stream RTMP_PT_FLEX_STREAM = 15, ///< Flex shared stream
......
libavformat/rtmpproto.c
View file @ f858a6e2
...@@ -156,8 +156,8 @@ static const uint8_t rtmp_server_key[] = { ...@@ -156,8 +156,8 @@ static const uint8_t rtmp_server_key[] = {
}; };
static int handle_chunk_size(URLContext *s, RTMPPacket *pkt); static int handle_chunk_size(URLContext *s, RTMPPacket *pkt);
static int handle_server_bw(URLContext *s, RTMPPacket *pkt); static int handle_window_ack_size(URLContext *s, RTMPPacket *pkt);
static int handle_client_bw(URLContext *s, RTMPPacket *pkt); static int handle_set_peer_bw(URLContext *s, RTMPPacket *pkt);
static int add_tracked_method(RTMPContext *rt, const char *name, int id) static int add_tracked_method(RTMPContext *rt, const char *name, int id)
{ {
...@@ -438,13 +438,13 @@ static int read_connect(URLContext *s, RTMPContext *rt) ...@@ -438,13 +438,13 @@ static int read_connect(URLContext *s, RTMPContext *rt)
return AVERROR_UNKNOWN; return AVERROR_UNKNOWN;
} else if (pkt.type == RTMP_PT_BYTES_READ) { } else if (pkt.type == RTMP_PT_BYTES_READ) {
av_log(s, AV_LOG_TRACE, "received acknowledgement\n"); av_log(s, AV_LOG_TRACE, "received acknowledgement\n");
} else if (pkt.type == RTMP_PT_SERVER_BW) { } else if (pkt.type == RTMP_PT_WINDOW_ACK_SIZE) {
if ((ret = handle_server_bw(s, &pkt)) < 0) { if ((ret = handle_window_ack_size(s, &pkt)) < 0) {
ff_rtmp_packet_destroy(&pkt); ff_rtmp_packet_destroy(&pkt);
return ret; return ret;
} }
} else if (pkt.type == RTMP_PT_CLIENT_BW) { } else if (pkt.type == RTMP_PT_SET_PEER_BW) {
if ((ret = handle_client_bw(s, &pkt)) < 0) { if ((ret = handle_set_peer_bw(s, &pkt)) < 0) {
ff_rtmp_packet_destroy(&pkt); ff_rtmp_packet_destroy(&pkt);
return ret; return ret;
} }
...@@ -485,7 +485,7 @@ static int read_connect(URLContext *s, RTMPContext *rt) ...@@ -485,7 +485,7 @@ static int read_connect(URLContext *s, RTMPContext *rt)
// Send Window Acknowledgement Size (as defined in specification) // Send Window Acknowledgement Size (as defined in specification)
if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL,
RTMP_PT_SERVER_BW, 0, 4)) < 0) RTMP_PT_WINDOW_ACK_SIZE, 0, 4)) < 0)
return ret; return ret;
p = pkt.data; p = pkt.data;
bytestream_put_be32(&p, rt->server_bw); bytestream_put_be32(&p, rt->server_bw);
...@@ -495,9 +495,9 @@ static int read_connect(URLContext *s, RTMPContext *rt) ...@@ -495,9 +495,9 @@ static int read_connect(URLContext *s, RTMPContext *rt)
ff_rtmp_packet_destroy(&pkt); ff_rtmp_packet_destroy(&pkt);
if (ret < 0) if (ret < 0)
return ret; return ret;
// Send Peer Bandwidth // Set Peer Bandwidth
if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL,
RTMP_PT_CLIENT_BW, 0, 5)) < 0) RTMP_PT_SET_PEER_BW, 0, 5)) < 0)
return ret; return ret;
p = pkt.data; p = pkt.data;
bytestream_put_be32(&p, rt->server_bw); bytestream_put_be32(&p, rt->server_bw);
...@@ -509,14 +509,14 @@ static int read_connect(URLContext *s, RTMPContext *rt) ...@@ -509,14 +509,14 @@ static int read_connect(URLContext *s, RTMPContext *rt)
if (ret < 0) if (ret < 0)
return ret; return ret;
// Ping request // User control
if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL,
RTMP_PT_PING, 0, 6)) < 0) RTMP_PT_USER_CONTROL, 0, 6)) < 0)
return ret; return ret;
p = pkt.data; p = pkt.data;
bytestream_put_be16(&p, 0); // 0 -> Stream Begin bytestream_put_be16(&p, 0); // 0 -> Stream Begin
bytestream_put_be32(&p, 0); bytestream_put_be32(&p, 0); // Stream 0
ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size, ret = ff_rtmp_packet_write(rt->stream, &pkt, rt->out_chunk_size,
&rt->prev_pkt[1], &rt->nb_prev_pkt[1]); &rt->prev_pkt[1], &rt->nb_prev_pkt[1]);
ff_rtmp_packet_destroy(&pkt); ff_rtmp_packet_destroy(&pkt);
...@@ -742,12 +742,12 @@ static int gen_buffer_time(URLContext *s, RTMPContext *rt) ...@@ -742,12 +742,12 @@ static int gen_buffer_time(URLContext *s, RTMPContext *rt)
uint8_t *p; uint8_t *p;
int ret; int ret;
if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_PING, if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_USER_CONTROL,
1, 10)) < 0) 1, 10)) < 0)
return ret; return ret;
p = pkt.data; p = pkt.data;
bytestream_put_be16(&p, 3); bytestream_put_be16(&p, 3); // SetBuffer Length
bytestream_put_be32(&p, rt->stream_id); bytestream_put_be32(&p, rt->stream_id);
bytestream_put_be32(&p, rt->client_buffer_time); bytestream_put_be32(&p, rt->client_buffer_time);
...@@ -874,12 +874,12 @@ static int gen_pong(URLContext *s, RTMPContext *rt, RTMPPacket *ppkt) ...@@ -874,12 +874,12 @@ static int gen_pong(URLContext *s, RTMPContext *rt, RTMPPacket *ppkt)
return AVERROR_INVALIDDATA; return AVERROR_INVALIDDATA;
} }
if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_PING, if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL,RTMP_PT_USER_CONTROL,
ppkt->timestamp + 1, 6)) < 0) ppkt->timestamp + 1, 6)) < 0)
return ret; return ret;
p = pkt.data; p = pkt.data;
bytestream_put_be16(&p, 7); bytestream_put_be16(&p, 7); // PingResponse
bytestream_put_be32(&p, AV_RB32(ppkt->data+2)); bytestream_put_be32(&p, AV_RB32(ppkt->data+2));
return rtmp_send_packet(rt, &pkt, 0); return rtmp_send_packet(rt, &pkt, 0);
...@@ -895,7 +895,7 @@ static int gen_swf_verification(URLContext *s, RTMPContext *rt) ...@@ -895,7 +895,7 @@ static int gen_swf_verification(URLContext *s, RTMPContext *rt)
int ret; int ret;
av_log(s, AV_LOG_DEBUG, "Sending SWF verification...\n"); av_log(s, AV_LOG_DEBUG, "Sending SWF verification...\n");
if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_PING, if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_USER_CONTROL,
0, 44)) < 0) 0, 44)) < 0)
return ret; return ret;
...@@ -907,15 +907,15 @@ static int gen_swf_verification(URLContext *s, RTMPContext *rt) ...@@ -907,15 +907,15 @@ static int gen_swf_verification(URLContext *s, RTMPContext *rt)
} }
/** /**
* Generate server bandwidth message and send it to the server. * Generate window acknowledgement size message and send it to the server.
*/ */
static int gen_server_bw(URLContext *s, RTMPContext *rt) static int gen_window_ack_size(URLContext *s, RTMPContext *rt)
{ {
RTMPPacket pkt; RTMPPacket pkt;
uint8_t *p; uint8_t *p;
int ret; int ret;
if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_SERVER_BW, if ((ret = ff_rtmp_packet_create(&pkt, RTMP_NETWORK_CHANNEL, RTMP_PT_WINDOW_ACK_SIZE,
0, 4)) < 0) 0, 4)) < 0)
return ret; return ret;
...@@ -1553,19 +1553,19 @@ static int handle_chunk_size(URLContext *s, RTMPPacket *pkt) ...@@ -1553,19 +1553,19 @@ static int handle_chunk_size(URLContext *s, RTMPPacket *pkt)
return 0; return 0;
} }
static int handle_ping(URLContext *s, RTMPPacket *pkt) static int handle_user_control(URLContext *s, RTMPPacket *pkt)
{ {
RTMPContext *rt = s->priv_data; RTMPContext *rt = s->priv_data;
int t, ret; int t, ret;
if (pkt->size < 2) { if (pkt->size < 2) {
av_log(s, AV_LOG_ERROR, "Too short ping packet (%d)\n", av_log(s, AV_LOG_ERROR, "Too short user control packet (%d)\n",
pkt->size); pkt->size);
return AVERROR_INVALIDDATA; return AVERROR_INVALIDDATA;
} }
t = AV_RB16(pkt->data); t = AV_RB16(pkt->data);
if (t == 6) { if (t == 6) { // PingRequest
if ((ret = gen_pong(s, rt, pkt)) < 0) if ((ret = gen_pong(s, rt, pkt)) < 0)
return ret; return ret;
} else if (t == 26) { } else if (t == 26) {
...@@ -1580,48 +1580,48 @@ static int handle_ping(URLContext *s, RTMPPacket *pkt) ...@@ -1580,48 +1580,48 @@ static int handle_ping(URLContext *s, RTMPPacket *pkt)
return 0; return 0;
} }
static int handle_client_bw(URLContext *s, RTMPPacket *pkt) static int handle_set_peer_bw(URLContext *s, RTMPPacket *pkt)
{ {
RTMPContext *rt = s->priv_data; RTMPContext *rt = s->priv_data;
if (pkt->size < 4) { if (pkt->size < 4) {
av_log(s, AV_LOG_ERROR, av_log(s, AV_LOG_ERROR,
"Client bandwidth report packet is less than 4 bytes long (%d)\n", "Peer bandwidth packet is less than 4 bytes long (%d)\n",
pkt->size); pkt->size);
return AVERROR_INVALIDDATA; return AVERROR_INVALIDDATA;
} }
rt->client_report_size = AV_RB32(pkt->data); rt->client_report_size = AV_RB32(pkt->data);
if (rt->client_report_size <= 0) { if (rt->client_report_size <= 0) {
av_log(s, AV_LOG_ERROR, "Incorrect client bandwidth %d\n", av_log(s, AV_LOG_ERROR, "Incorrect peer bandwidth %d\n",
rt->client_report_size); rt->client_report_size);
return AVERROR_INVALIDDATA; return AVERROR_INVALIDDATA;
} }
av_log(s, AV_LOG_DEBUG, "Client bandwidth = %d\n", rt->client_report_size); av_log(s, AV_LOG_DEBUG, "Peer bandwidth = %d\n", rt->client_report_size);
rt->client_report_size >>= 1; rt->client_report_size >>= 1;
return 0; return 0;
} }
static int handle_server_bw(URLContext *s, RTMPPacket *pkt) static int handle_window_ack_size(URLContext *s, RTMPPacket *pkt)
{ {
RTMPContext *rt = s->priv_data; RTMPContext *rt = s->priv_data;
if (pkt->size < 4) { if (pkt->size < 4) {
av_log(s, AV_LOG_ERROR, av_log(s, AV_LOG_ERROR,
"Too short server bandwidth report packet (%d)\n", "Too short window acknowledgement size packet (%d)\n",
pkt->size); pkt->size);
return AVERROR_INVALIDDATA; return AVERROR_INVALIDDATA;
} }
rt->server_bw = AV_RB32(pkt->data); rt->server_bw = AV_RB32(pkt->data);
if (rt->server_bw <= 0) { if (rt->server_bw <= 0) {
av_log(s, AV_LOG_ERROR, "Incorrect server bandwidth %d\n", av_log(s, AV_LOG_ERROR, "Incorrect window acknowledgement size %d\n",
rt->server_bw); rt->server_bw);
return AVERROR_INVALIDDATA; return AVERROR_INVALIDDATA;
} }
av_log(s, AV_LOG_DEBUG, "Server bandwidth = %d\n", rt->server_bw); av_log(s, AV_LOG_DEBUG, "Window acknowledgement size = %d\n", rt->server_bw);
return 0; return 0;
} }
...@@ -1863,7 +1863,7 @@ static int write_begin(URLContext *s) ...@@ -1863,7 +1863,7 @@ static int write_begin(URLContext *s)
// Send Stream Begin 1 // Send Stream Begin 1
if ((ret = ff_rtmp_packet_create(&spkt, RTMP_NETWORK_CHANNEL, if ((ret = ff_rtmp_packet_create(&spkt, RTMP_NETWORK_CHANNEL,
RTMP_PT_PING, 0, 6)) < 0) { RTMP_PT_USER_CONTROL, 0, 6)) < 0) {
av_log(s, AV_LOG_ERROR, "Unable to create response packet\n"); av_log(s, AV_LOG_ERROR, "Unable to create response packet\n");
return ret; return ret;
} }
...@@ -2091,7 +2091,7 @@ static int handle_invoke_result(URLContext *s, RTMPPacket *pkt) ...@@ -2091,7 +2091,7 @@ static int handle_invoke_result(URLContext *s, RTMPPacket *pkt)
if ((ret = gen_fcpublish_stream(s, rt)) < 0) if ((ret = gen_fcpublish_stream(s, rt)) < 0)
goto fail; goto fail;
} else { } else {
if ((ret = gen_server_bw(s, rt)) < 0) if ((ret = gen_window_ack_size(s, rt)) < 0)
goto fail; goto fail;
} }
...@@ -2340,16 +2340,16 @@ static int rtmp_parse_result(URLContext *s, RTMPContext *rt, RTMPPacket *pkt) ...@@ -2340,16 +2340,16 @@ static int rtmp_parse_result(URLContext *s, RTMPContext *rt, RTMPPacket *pkt)
if ((ret = handle_chunk_size(s, pkt)) < 0) if ((ret = handle_chunk_size(s, pkt)) < 0)
return ret; return ret;
break; break;
case RTMP_PT_PING: case RTMP_PT_USER_CONTROL:
if ((ret = handle_ping(s, pkt)) < 0) if ((ret = handle_user_control(s, pkt)) < 0)
return ret; return ret;
break; break;
case RTMP_PT_CLIENT_BW: case RTMP_PT_SET_PEER_BW:
if ((ret = handle_client_bw(s, pkt)) < 0) if ((ret = handle_set_peer_bw(s, pkt)) < 0)
return ret; return ret;
break; break;
case RTMP_PT_SERVER_BW: case RTMP_PT_WINDOW_ACK_SIZE:
if ((ret = handle_server_bw(s, pkt)) < 0) if ((ret = handle_window_ack_size(s, pkt)) < 0)
return ret; return ret;
break; break;
case RTMP_PT_INVOKE: case RTMP_PT_INVOKE:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment