Providing extended RTMP timestamps and fixing an RTSP leak occuring on

abrupt disconnections

Author: wberube

src/rtmp.c

@@ -135,6 +135,15 @@ static int rtmp_send_packet(int message_type, int stream_id, const void *data, i
         if (remaining > 0) {
             uint8_t h = (3 << 6) | (cs_id & 0x3F);
             if (send_data(&h, 1) < 0) return -1;
+
+            if (timestamp >= 0xFFFFFF) {
+                uint8_t ext_ts[4];
+                ext_ts[0] = (timestamp >> 24) & 0xFF;
+                ext_ts[1] = (timestamp >> 16) & 0xFF;
+                ext_ts[2] = (timestamp >> 8) & 0xFF;
+                ext_ts[3] = timestamp & 0xFF;
+                if (send_data(ext_ts, 4) < 0) return -1;
+            }
         }
     }
     return 0;

src/rtsp/rtsp.c

@@ -398,6 +398,7 @@ static int __message_proc_sock(struct list_t *e, void *p)
             ungetc(first_char, con->fp_tcp_read);
         } else {
             con->con_state = __CON_S_DISCONNECTED;
+            ASSERT(bufpool_detach(con->pool, con) == SUCCESS, ERR("connection detach failed\n"));
             return SUCCESS;
         }
 
@@ -489,6 +490,7 @@ static int __message_proc_sock(struct list_t *e, void *p)
                         ERR("unexpected empty request, forcing disconnect\n");
                         con->con_state = __CON_S_DISCONNECTED;
                     }
+                    ASSERT(bufpool_detach(con->pool, con) == SUCCESS, ERR("connection detach failed\n"));
                     break;
                 default: ERR("unexpected method state\n"); return FAILURE;
             }