Merge commit 'a1a143adb0fd11c474221431417cff25db7d920f'
authorJames Almer <jamrial@gmail.com>
Tue, 26 Sep 2017 21:08:25 +0000 (18:08 -0300)
committerJames Almer <jamrial@gmail.com>
Tue, 26 Sep 2017 21:29:05 +0000 (18:29 -0300)
* commit 'a1a143adb0fd11c474221431417cff25db7d920f':
  rtmp: Rename packet types to closer match the spec

Merged-by: James Almer <jamrial@gmail.com>
1  2 
libavformat/rtmppkt.c
libavformat/rtmppkt.h
libavformat/rtmpproto.c

Simple merge
Simple merge
@@@ -156,8 -156,6 +156,8 @@@ static const uint8_t rtmp_server_key[] 
  };
  
  static int handle_chunk_size(URLContext *s, RTMPPacket *pkt);
- static int handle_server_bw(URLContext *s, RTMPPacket *pkt);
- static int handle_client_bw(URLContext *s, RTMPPacket *pkt);
++static int handle_window_ack_size(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)
  {
@@@ -424,37 -423,6 +424,37 @@@ static int read_connect(URLContext *s, 
          if ((ret = ff_rtmp_packet_read(rt->stream, &pkt, rt->in_chunk_size,
                                         &rt->prev_pkt[0], &rt->nb_prev_pkt[0])) < 0)
              return ret;
-         } else if (pkt.type == RTMP_PT_SERVER_BW) {
-             if ((ret = handle_server_bw(s, &pkt)) < 0) {
 +#ifdef DEBUG
 +        ff_rtmp_packet_dump(s, &pkt);
 +#endif
 +        if (pkt.type == RTMP_PT_CHUNK_SIZE) {
 +            if ((ret = handle_chunk_size(s, &pkt)) < 0) {
 +                ff_rtmp_packet_destroy(&pkt);
 +                return ret;
 +            }
 +        } else if (pkt.type == RTMP_CTRL_ABORT_MESSAGE) {
 +            av_log(s, AV_LOG_ERROR, "received abort message\n");
 +            ff_rtmp_packet_destroy(&pkt);
 +            return AVERROR_UNKNOWN;
 +        } else if (pkt.type == RTMP_PT_BYTES_READ) {
 +            av_log(s, AV_LOG_TRACE, "received acknowledgement\n");
-         } else if (pkt.type == RTMP_PT_CLIENT_BW) {
-             if ((ret = handle_client_bw(s, &pkt)) < 0) {
++        } else if (pkt.type == RTMP_PT_WINDOW_ACK_SIZE) {
++            if ((ret = handle_window_ack_size(s, &pkt)) < 0) {
 +                ff_rtmp_packet_destroy(&pkt);
 +                return ret;
 +            }
++        } else if (pkt.type == RTMP_PT_SET_PEER_BW) {
++            if ((ret = handle_set_peer_bw(s, &pkt)) < 0) {
 +                ff_rtmp_packet_destroy(&pkt);
 +                return ret;
 +            }
 +        } else if (pkt.type == RTMP_PT_INVOKE) {
 +            // received RTMP Command Message
 +            break;
 +        } else {
 +            av_log(s, AV_LOG_ERROR, "Unknown control message type (%d)\n", pkt.type);
 +        }
 +        ff_rtmp_packet_destroy(&pkt);
      }
  
      cp = pkt.data;