Lines Matching refs:reply
908 RTSPMessageHeader *reply, const char *p)
917 reply->nb_transports = 0;
924 th = &reply->transports[reply->nb_transports];
1028 reply->nb_transports++;
1029 if (reply->nb_transports >= RTSP_MAX_TRANSPORTS)
1090 RTSPMessageHeader *reply, const char *buf,
1099 get_word_sep(reply->session_id, sizeof(reply->session_id), ";", &p);
1102 reply->timeout = t;
1105 reply->content_length = strtol(p, NULL, 10);
1107 rtsp_parse_transport(s, reply, p);
1109 reply->seq = strtol(p, NULL, 10);
1111 rtsp_parse_range_npt(p, &reply->range_start, &reply->range_end);
1114 av_strlcpy(reply->real_challenge, p, sizeof(reply->real_challenge));
1117 av_strlcpy(reply->server, p, sizeof(reply->server));
1120 reply->notice = strtol(p, NULL, 10);
1123 av_strlcpy(reply->location, p , sizeof(reply->location));
1147 av_strlcpy(reply->content_type, p, sizeof(reply->content_type));
1150 av_strlcpy(reply->stream_id, p, sizeof(reply->stream_id));
1182 int ff_rtsp_read_reply(AVFormatContext *s, RTSPMessageHeader *reply,
1197 memset(reply, 0, sizeof(*reply));
1199 /* parse reply (XXX: use buffers) */
1232 /* get reply code */
1236 reply->status_code = atoi(buf1);
1237 av_strlcpy(reply->reason, p, sizeof(reply->reason));
1239 av_strlcpy(reply->reason, buf1, sizeof(reply->reason)); // method
1244 ff_rtsp_parse_line(s, reply, p, rt, method);
1251 if (rt->session_id[0] == '\0' && reply->session_id[0] != '\0' && !request)
1252 av_strlcpy(rt->session_id, reply->session_id, sizeof(rt->session_id));
1254 content_length = reply->content_length;
1276 if (!strcmp(reply->reason, "OPTIONS") ||
1277 !strcmp(reply->reason, "GET_PARAMETER")) {
1279 if (reply->seq)
1280 av_strlcatf(buf, sizeof(buf), "CSeq: %d\r\n", reply->seq);
1281 if (reply->session_id[0])
1283 reply->session_id);
1298 * if the actual following reply has content data. */
1302 * where a reply to exactly this request is awaited. For
1310 if (rt->seq != reply->seq) {
1312 rt->seq, reply->seq);
1316 if (reply->notice == 2101 /* End-of-Stream Reached */ ||
1317 reply->notice == 2104 /* Start-of-Stream Reached */ ||
1318 reply->notice == 2306 /* Continuous Feed Terminated */) {
1320 } else if (reply->notice >= 4400 && reply->notice < 5500) {
1322 } else if (reply->notice == 2401 /* Ticket Expired */ ||
1323 (reply->notice >= 5500 && reply->notice < 5600) /* end of term */ )
1330 * Send a command to the RTSP server without waiting for the reply.
1406 const char *headers, RTSPMessageHeader *reply,
1409 return ff_rtsp_send_cmd_with_content(s, method, url, headers, reply,
1416 RTSPMessageHeader *reply,
1432 if ((ret = ff_rtsp_read_reply(s, reply, content_ptr, 0, method) ) < 0)
1436 if (reply->status_code == 401 &&
1441 if (reply->status_code > 400){
1444 reply->status_code,
1445 reply->reason);
1458 RTSPMessageHeader reply1, *reply = &reply1;
1513 port = reply->transports[0].client_port_min;
1596 ff_rtsp_send_cmd(s, "SETUP", rtsp_st->control_url, cmd, reply, NULL);
1597 if (reply->status_code == 461 /* Unsupported protocol */ && i == 0) {
1600 } else if (reply->status_code != RTSP_STATUS_OK ||
1601 reply->nb_transports != 1) {
1602 err = ff_rtsp_averror(reply->status_code, AVERROR_INVALIDDATA);
1606 if (rt->server_type == RTSP_SERVER_SATIP && reply->stream_id[0]) {
1612 port, "/stream=%s", reply->stream_id);
1617 if (reply->transports[0].lower_transport != rt->lower_transport ||
1618 reply->transports[0].transport != rt->transport) {
1623 rt->lower_transport = reply->transports[0].lower_transport;
1624 rt->transport = reply->transports[0].transport;
1629 if (reply->transports[0].lower_transport != lower_transport) {
1630 av_log(s, AV_LOG_ERROR, "Nonmatching transport in server reply\n");
1635 switch(reply->transports[0].lower_transport) {
1637 rtsp_st->interleaved_min = reply->transports[0].interleaved_min;
1638 rtsp_st->interleaved_max = reply->transports[0].interleaved_max;
1648 if (reply->transports[0].source[0])
1649 peer = reply->transports[0].source;
1651 reply->transports[0].server_port_min, "%s", options);
1665 if (reply->transports[0].destination.ss_family) {
1666 addr = reply->transports[0].destination;
1667 port = reply->transports[0].port_min;
1668 ttl = reply->transports[0].ttl;
1696 if (rt->nb_rtsp_streams && reply->timeout > 0)
1697 rt->timeout = reply->timeout;
1725 RTSPMessageHeader reply1, *reply = &reply1;
1871 * - sending the whole POST data until getting a 401 reply specifying
1936 ff_rtsp_send_cmd(s, "OPTIONS", rt->control_uri, cmd, reply, NULL);
1937 if (reply->status_code != RTSP_STATUS_OK) {
1938 err = ff_rtsp_averror(reply->status_code, AVERROR_INVALIDDATA);
1943 if (rt->server_type != RTSP_SERVER_REAL && reply->real_challenge[0]) {
1946 } else if (!av_strncasecmp(reply->server, "WMServer/", 9)) {
1949 strcpy(real_challenge, reply->real_challenge);
1958 err = ff_rtsp_setup_input_streams(s, reply);
1996 if (reply->status_code >=300 && reply->status_code < 400 && s->iformat) {
1997 char *new_url = av_strdup(reply->location);
2005 reply->status_code,
2028 RTSPMessageHeader reply;
2029 ret = ff_rtsp_read_reply(s, &reply, NULL, 0, NULL);