}
}
+static int url_readbuf(URLContext *h, unsigned char *buf, int size)
+{
+ int ret, len;
+
+ len = 0;
+ while (len < size) {
+ ret = url_read(h, buf+len, size-len);
+ if (ret < 1)
+ return ret;
+ len += ret;
+ }
+ return len;
+}
+
/* skip a RTP/TCP interleaved packet */
static void rtsp_skip_packet(AVFormatContext *s)
{
int ret, len, len1;
uint8_t buf[1024];
- ret = url_read(rt->rtsp_hd, buf, 3);
+ ret = url_readbuf(rt->rtsp_hd, buf, 3);
if (ret != 3)
return;
len = (buf[1] << 8) | buf[2];
len1 = len;
if (len1 > sizeof(buf))
len1 = sizeof(buf);
- ret = url_read(rt->rtsp_hd, buf, len1);
+ ret = url_readbuf(rt->rtsp_hd, buf, len1);
if (ret != len1)
return;
len -= len1;
for(;;) {
q = buf;
for(;;) {
- if (url_read(rt->rtsp_hd, &ch, 1) != 1)
+ if (url_readbuf(rt->rtsp_hd, &ch, 1) != 1)
break;
if (ch == '\n')
break;
if (content_length > 0) {
/* leave some room for a trailing '\0' (useful for simple parsing) */
content = av_malloc(content_length + 1);
- url_read(rt->rtsp_hd, content, content_length);
+ (void)url_readbuf(rt->rtsp_hd, content, content_length);
content[content_length] = '\0';
}
if (content_ptr)
#endif
redo:
for(;;) {
- ret = url_read(rt->rtsp_hd, buf, 1);
+ ret = url_readbuf(rt->rtsp_hd, buf, 1);
#ifdef DEBUG_RTP_TCP
printf("ret=%d c=%02x [%c]\n", ret, buf[0], buf[0]);
#endif
if (buf[0] == '$')
break;
}
- ret = url_read(rt->rtsp_hd, buf, 3);
+ ret = url_readbuf(rt->rtsp_hd, buf, 3);
if (ret != 3)
return -1;
id = buf[0];
if (len > buf_size || len < 12)
goto redo;
/* get the data */
- ret = url_read(rt->rtsp_hd, buf, len);
+ ret = url_readbuf(rt->rtsp_hd, buf, len);
if (ret != len)
return -1;
RTSPHeader reply1, *reply = &reply1;
char cmd[1024];
- printf("hello state=%d\n", rt->state);
+ av_log(s, AV_LOG_DEBUG, "hello state=%d\n", rt->state);
if (rt->state == RTSP_STATE_PAUSED) {
snprintf(cmd, sizeof(cmd),