Lines Matching refs:rt
334 RTSPState *rt = s->priv_data;
403 dynarray_add(&rt->rtsp_streams, &rt->nb_rtsp_streams, rtsp_st);
496 rt->transport = RTSP_TRANSPORT_RDT;
498 if (rt->server_type == RTSP_SERVER_REAL)
717 RTSPState *rt = s->priv_data;
721 ret = url_readbuf(rt->rtsp_hd, buf, 3);
733 ret = url_readbuf(rt->rtsp_hd, buf, len1);
744 RTSPState *rt = s->priv_data;
753 rt->seq++;
755 snprintf(buf1, sizeof(buf1), "CSeq: %d\r\n", rt->seq);
757 if (rt->session_id[0] != '\0' && !strstr(cmd, "\nIf-Match:")) {
758 snprintf(buf1, sizeof(buf1), "Session: %s\r\n", rt->session_id);
765 url_write(rt->rtsp_hd, buf, strlen(buf));
769 rt->last_reply[0] = '\0';
773 if (url_readbuf(rt->rtsp_hd, &ch, 1) != 1)
800 av_strlcat(rt->last_reply, p, sizeof(rt->last_reply));
801 av_strlcat(rt->last_reply, "\n", sizeof(rt->last_reply));
806 if (rt->session_id[0] == '\0' && reply->session_id[0] != '\0')
807 av_strlcpy(rt->session_id, reply->session_id, sizeof(rt->session_id));
813 (void)url_readbuf(rt->rtsp_hd, content, content_length);
824 static void rtsp_close_streams(RTSPState *rt)
829 for(i=0;i<rt->nb_rtsp_streams;i++) {
830 rtsp_st = rt->rtsp_streams[i];
833 if (rt->transport == RTSP_TRANSPORT_RDT)
844 av_free(rt->rtsp_streams);
850 RTSPState *rt = s->priv_data;
859 if (rt->transport == RTSP_TRANSPORT_RDT)
870 } else if (rt->transport != RTSP_TRANSPORT_RDT) {
888 RTSPState *rt = s->priv_data;
895 if (rt->transport == RTSP_TRANSPORT_RDT)
904 for(j = RTSP_RTP_PORT_MIN, i = 0; i < rt->nb_rtsp_streams; ++i) {
907 rtsp_st = rt->rtsp_streams[i];
935 if (rt->server_type != RTSP_SERVER_REAL)
939 if (rt->transport == RTSP_TRANSPORT_RTP)
947 if (rt->server_type == RTSP_SERVER_WMS)
959 if (rt->server_type == RTSP_SERVER_REAL ||
960 rt->server_type == RTSP_SERVER_WMS)
966 if (i == 0 && rt->server_type == RTSP_SERVER_REAL) {
973 rt->session_id, real_res, real_csum);
987 if (reply->transports[0].lower_transport != rt->lower_transport ||
988 reply->transports[0].transport != rt->transport) {
993 rt->lower_transport = reply->transports[0].lower_transport;
994 rt->transport = reply->transports[0].transport;
1045 if (rt->server_type == RTSP_SERVER_REAL)
1046 rt->need_subscription = 1;
1051 for (i=0; i<rt->nb_rtsp_streams; i++) {
1052 if (rt->rtsp_streams[i]->rtp_handle) {
1053 url_close(rt->rtsp_streams[i]->rtp_handle);
1054 rt->rtsp_streams[i]->rtp_handle = NULL;
1063 RTSPState *rt = s->priv_data;
1106 rt->rtsp_hd = rtsp_hd;
1107 rt->seq = 0;
1110 for (rt->server_type = RTSP_SERVER_RTP;;) {
1113 if (rt->server_type == RTSP_SERVER_REAL)
1136 if (rt->server_type != RTSP_SERVER_REAL && reply->real_challenge[0]) {
1137 rt->server_type = RTSP_SERVER_REAL;
1140 rt->server_type = RTSP_SERVER_WMS;
1141 } else if (rt->server_type == RTSP_SERVER_REAL) {
1152 if (rt->server_type == RTSP_SERVER_REAL) {
1183 rt->server_type == RTSP_SERVER_REAL ?
1194 rt->state = RTSP_STATE_IDLE;
1195 rt->seek_timestamp = 0; /* default is to start stream at position
1207 rtsp_close_streams(rt);
1209 url_close(rt->rtsp_hd);
1216 RTSPState *rt = s->priv_data;
1225 ret = url_readbuf(rt->rtsp_hd, buf, 1);
1234 ret = url_readbuf(rt->rtsp_hd, buf, 3);
1245 ret = url_readbuf(rt->rtsp_hd, buf, len);
1248 if (rt->transport == RTSP_TRANSPORT_RDT &&
1253 for(i = 0; i < rt->nb_rtsp_streams; i++) {
1254 rtsp_st = rt->rtsp_streams[i];
1268 RTSPState *rt = s->priv_data;
1279 for(i = 0; i < rt->nb_rtsp_streams; i++) {
1280 rtsp_st = rt->rtsp_streams[i];
1291 for(i = 0; i < rt->nb_rtsp_streams; i++) {
1292 rtsp_st = rt->rtsp_streams[i];
1309 RTSPState *rt = s->priv_data;
1314 if (rt->server_type == RTSP_SERVER_REAL) {
1323 if (!rt->need_subscription) {
1324 if (memcmp (cache, rt->real_setup_cache,
1329 s->filename, rt->last_subscription);
1333 rt->need_subscription = 1;
1337 if (rt->need_subscription) {
1340 memcpy(rt->real_setup_cache, cache,
1342 rt->last_subscription[0] = 0;
1348 for (i = 0; i < rt->nb_rtsp_streams; i++) {
1351 if (s->streams[r]->priv_data == rt->rtsp_streams[i]) {
1354 av_strlcat(rt->last_subscription, ",",
1355 sizeof(rt->last_subscription));
1357 rt->last_subscription,
1358 sizeof(rt->last_subscription), i, rule_nr);
1365 av_strlcatf(cmd, sizeof(cmd), "%s\r\n", rt->last_subscription);
1369 rt->need_subscription = 0;
1371 if (rt->state == RTSP_STATE_PLAYING)
1377 if (rt->cur_transport_priv) {
1378 if (rt->transport == RTSP_TRANSPORT_RDT)
1379 ret = ff_rdt_parse_packet(rt->cur_transport_priv, pkt, NULL, 0);
1381 ret = rtp_parse_packet(rt->cur_transport_priv, pkt, NULL, 0);
1383 rt->cur_transport_priv = NULL;
1388 rt->cur_transport_priv = NULL;
1394 switch(rt->lower_transport) {
1402 if (len >=0 && rtsp_st->transport_priv && rt->transport == RTSP_TRANSPORT_RTP)
1408 if (rt->transport == RTSP_TRANSPORT_RDT)
1416 rt->cur_transport_priv = rtsp_st->transport_priv;
1423 RTSPState *rt = s->priv_data;
1427 av_log(s, AV_LOG_DEBUG, "hello state=%d\n", rt->state);
1429 if (!(rt->server_type == RTSP_SERVER_REAL && rt->need_subscription)) {
1430 if (rt->state == RTSP_STATE_PAUSED) {
1439 (double)rt->seek_timestamp / AV_TIME_BASE);
1446 rt->state = RTSP_STATE_PLAYING;
1453 RTSPState *rt = s->priv_data;
1457 rt = s->priv_data;
1459 if (rt->state != RTSP_STATE_PLAYING)
1461 else if (!(rt->server_type == RTSP_SERVER_REAL && rt->need_subscription)) {
1470 rt->state = RTSP_STATE_PAUSED;
1477 RTSPState *rt = s->priv_data;
1479 rt->seek_timestamp = av_rescale_q(timestamp, s->streams[stream_index]->time_base, AV_TIME_BASE_Q);
1480 switch(rt->state) {
1489 rt->state = RTSP_STATE_IDLE;
1497 RTSPState *rt = s->priv_data;
1503 if (rt->lower_transport == RTSP_LOWER_TRANSPORT_TCP) {
1504 url_fclose(&rt->rtsp_gb);
1512 rtsp_close_streams(rt);
1513 url_close(rt->rtsp_hd);
1556 RTSPState *rt = s->priv_data;
1576 for(i=0;i<rt->nb_rtsp_streams;i++) {
1577 rtsp_st = rt->rtsp_streams[i];
1593 rtsp_close_streams(rt);
1605 RTSPState *rt = s->priv_data;
1606 rtsp_close_streams(rt);