Commit 01b4689d authored by Michael Niedermayer's avatar Michael Niedermayer

Merge remote-tracking branch 'qatar/master'

* qatar/master:
  rtmp: rename main_channel_id to stream_id.
Merged-by: 's avatarMichael Niedermayer <michaelni@gmx.at>
parents 208f9dd2 f8d1bb67
...@@ -85,7 +85,7 @@ typedef struct RTMPContext { ...@@ -85,7 +85,7 @@ typedef struct RTMPContext {
char *app; ///< name of application char *app; ///< name of application
char *conn; ///< append arbitrary AMF data to the Connect message char *conn; ///< append arbitrary AMF data to the Connect message
ClientState state; ///< current state ClientState state; ///< current state
int main_channel_id; ///< an additional channel ID which is used for some invocations int stream_id; ///< ID assigned by the server for the stream
uint8_t* flv_data; ///< buffer with data for demuxer uint8_t* flv_data; ///< buffer with data for demuxer
int flv_size; ///< current buffer size int flv_size; ///< current buffer size
int flv_off; ///< number of bytes read from current buffer int flv_off; ///< number of bytes read from current buffer
...@@ -652,7 +652,7 @@ static int gen_delete_stream(URLContext *s, RTMPContext *rt) ...@@ -652,7 +652,7 @@ static int gen_delete_stream(URLContext *s, RTMPContext *rt)
ff_amf_write_string(&p, "deleteStream"); ff_amf_write_string(&p, "deleteStream");
ff_amf_write_number(&p, ++rt->nb_invokes); ff_amf_write_number(&p, ++rt->nb_invokes);
ff_amf_write_null(&p); ff_amf_write_null(&p);
ff_amf_write_number(&p, rt->main_channel_id); ff_amf_write_number(&p, rt->stream_id);
return rtmp_send_packet(rt, &pkt, 0); return rtmp_send_packet(rt, &pkt, 0);
} }
...@@ -672,7 +672,7 @@ static int gen_buffer_time(URLContext *s, RTMPContext *rt) ...@@ -672,7 +672,7 @@ static int gen_buffer_time(URLContext *s, RTMPContext *rt)
p = pkt.data; p = pkt.data;
bytestream_put_be16(&p, 3); bytestream_put_be16(&p, 3);
bytestream_put_be32(&p, rt->main_channel_id); bytestream_put_be32(&p, rt->stream_id);
bytestream_put_be32(&p, rt->client_buffer_time); bytestream_put_be32(&p, rt->client_buffer_time);
return rtmp_send_packet(rt, &pkt, 0); return rtmp_send_packet(rt, &pkt, 0);
...@@ -694,7 +694,7 @@ static int gen_play(URLContext *s, RTMPContext *rt) ...@@ -694,7 +694,7 @@ static int gen_play(URLContext *s, RTMPContext *rt)
0, 29 + strlen(rt->playpath))) < 0) 0, 29 + strlen(rt->playpath))) < 0)
return ret; return ret;
pkt.extra = rt->main_channel_id; pkt.extra = rt->stream_id;
p = pkt.data; p = pkt.data;
ff_amf_write_string(&p, "play"); ff_amf_write_string(&p, "play");
...@@ -718,7 +718,7 @@ static int gen_seek(URLContext *s, RTMPContext *rt, int64_t timestamp) ...@@ -718,7 +718,7 @@ static int gen_seek(URLContext *s, RTMPContext *rt, int64_t timestamp)
if ((ret = ff_rtmp_packet_create(&pkt, 3, RTMP_PT_INVOKE, 0, 26)) < 0) if ((ret = ff_rtmp_packet_create(&pkt, 3, RTMP_PT_INVOKE, 0, 26)) < 0)
return ret; return ret;
pkt.extra = rt->main_channel_id; pkt.extra = rt->stream_id;
p = pkt.data; p = pkt.data;
ff_amf_write_string(&p, "seek"); ff_amf_write_string(&p, "seek");
...@@ -744,7 +744,7 @@ static int gen_publish(URLContext *s, RTMPContext *rt) ...@@ -744,7 +744,7 @@ static int gen_publish(URLContext *s, RTMPContext *rt)
0, 30 + strlen(rt->playpath))) < 0) 0, 30 + strlen(rt->playpath))) < 0)
return ret; return ret;
pkt.extra = rt->main_channel_id; pkt.extra = rt->stream_id;
p = pkt.data; p = pkt.data;
ff_amf_write_string(&p, "publish"); ff_amf_write_string(&p, "publish");
...@@ -1977,7 +1977,7 @@ static int handle_invoke_result(URLContext *s, RTMPPacket *pkt) ...@@ -1977,7 +1977,7 @@ static int handle_invoke_result(URLContext *s, RTMPPacket *pkt)
if (pkt->data[10] || pkt->data[19] != 5 || pkt->data[20]) { if (pkt->data[10] || pkt->data[19] != 5 || pkt->data[20]) {
av_log(s, 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 = av_int2double(AV_RB64(pkt->data + 21)); rt->stream_id = av_int2double(AV_RB64(pkt->data + 21));
} }
if (!rt->is_input) { if (!rt->is_input) {
...@@ -2668,7 +2668,7 @@ static int rtmp_write(URLContext *s, const uint8_t *buf, int size) ...@@ -2668,7 +2668,7 @@ static int rtmp_write(URLContext *s, const uint8_t *buf, int size)
pkttype, ts, pktsize)) < 0) pkttype, ts, pktsize)) < 0)
return ret; return ret;
rt->out_pkt.extra = rt->main_channel_id; rt->out_pkt.extra = rt->stream_id;
rt->flv_data = rt->out_pkt.data; rt->flv_data = rt->out_pkt.data;
if (pkttype == RTMP_PT_NOTIFY) if (pkttype == RTMP_PT_NOTIFY)
......
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