Lines Matching refs:rtspc
138 Curl_dyn_init(&conn->proto.rtspc.buf, MAX_RTP_BUFFERSIZE); in rtsp_setup_connection()
175 data->conn->proto.rtspc.rtp_channel = -1; in rtsp_connect()
185 Curl_dyn_free(&conn->proto.rtspc.buf); in rtsp_disconnect()
213 (data->conn->proto.rtspc.rtp_channel == -1)) { in rtsp_done()
611 struct rtsp_conn *rtspc = &(data->conn->proto.rtspc); in rtp_write_body_junk() local
615 in_body = (data->req.headerline && !rtspc->in_header) && in rtp_write_body_junk()
633 struct rtsp_conn *rtspc = &(data->conn->proto.rtspc); in rtsp_filter_rtp() local
639 bool in_body = (data->req.headerline && !rtspc->in_header) && in rtsp_filter_rtp()
642 switch(rtspc->state) { in rtsp_filter_rtp()
645 DEBUGASSERT(Curl_dyn_len(&rtspc->buf) == 0); in rtsp_filter_rtp()
655 rtspc->state = RTP_PARSE_SKIP; in rtsp_filter_rtp()
656 rtspc->in_header = TRUE; in rtsp_filter_rtp()
676 if(Curl_dyn_addn(&rtspc->buf, buf, 1)) { in rtsp_filter_rtp()
683 rtspc->state = RTP_PARSE_CHANNEL; in rtsp_filter_rtp()
691 DEBUGASSERT(Curl_dyn_len(&rtspc->buf) == 1); in rtsp_filter_rtp()
694 rtspc->state = RTP_PARSE_SKIP; in rtsp_filter_rtp()
702 result = rtp_write_body_junk(data, Curl_dyn_ptr(&rtspc->buf), 1); in rtsp_filter_rtp()
710 Curl_dyn_free(&rtspc->buf); in rtsp_filter_rtp()
714 rtspc->rtp_channel = (unsigned char)buf[0]; in rtsp_filter_rtp()
715 if(Curl_dyn_addn(&rtspc->buf, buf, 1)) { in rtsp_filter_rtp()
722 rtspc->state = RTP_PARSE_LEN; in rtsp_filter_rtp()
727 size_t rtp_len = Curl_dyn_len(&rtspc->buf); in rtsp_filter_rtp()
730 if(Curl_dyn_addn(&rtspc->buf, buf, 1)) { in rtsp_filter_rtp()
739 rtp_buf = Curl_dyn_ptr(&rtspc->buf); in rtsp_filter_rtp()
740 rtspc->rtp_len = RTP_PKT_LENGTH(rtp_buf) + 4; in rtsp_filter_rtp()
741 rtspc->state = RTP_PARSE_DATA; in rtsp_filter_rtp()
746 size_t rtp_len = Curl_dyn_len(&rtspc->buf); in rtsp_filter_rtp()
748 DEBUGASSERT(rtp_len < rtspc->rtp_len); in rtsp_filter_rtp()
749 needed = rtspc->rtp_len - rtp_len; in rtsp_filter_rtp()
751 if(Curl_dyn_addn(&rtspc->buf, buf, needed)) { in rtsp_filter_rtp()
760 rtspc->rtp_channel, rtspc->rtp_len)); in rtsp_filter_rtp()
761 result = rtp_client_write(data, Curl_dyn_ptr(&rtspc->buf), in rtsp_filter_rtp()
762 rtspc->rtp_len); in rtsp_filter_rtp()
763 Curl_dyn_free(&rtspc->buf); in rtsp_filter_rtp()
764 rtspc->state = RTP_PARSE_SKIP; in rtsp_filter_rtp()
769 if(Curl_dyn_addn(&rtspc->buf, buf, blen)) { in rtsp_filter_rtp()
796 struct rtsp_conn *rtspc = &(data->conn->proto.rtspc); in rtsp_rtp_write_resp() local
801 rtspc->in_header = FALSE; in rtsp_rtp_write_resp()
807 blen, rtspc->in_header, is_eos)); in rtsp_rtp_write_resp()
810 if(!rtspc->in_header) { in rtsp_rtp_write_resp()
824 rtspc->in_header = TRUE; in rtsp_rtp_write_resp()
833 rtspc->in_header = FALSE; in rtsp_rtp_write_resp()
835 if(!rtspc->in_header) { in rtsp_rtp_write_resp()
850 if(rtspc->state != RTP_PARSE_SKIP) in rtsp_rtp_write_resp()
857 blen, rtspc->in_header, data->req.done, rtspc->state, in rtsp_rtp_write_resp()
867 (rtspc->state == RTP_PARSE_SKIP)) { in rtsp_rtp_write_resp()
