Lines Matching defs:rtspc

138   Curl_dyn_init(&conn->proto.rtspc.buf, MAX_RTP_BUFFERSIZE);
175 data->conn->proto.rtspc.rtp_channel = -1;
185 Curl_dyn_free(&conn->proto.rtspc.buf);
213 (data->conn->proto.rtspc.rtp_channel == -1)) {
599 struct rtsp_conn *rtspc = &(data->conn->proto.rtspc);
603 in_body = (data->req.headerline && !rtspc->in_header) &&
621 struct rtsp_conn *rtspc = &(data->conn->proto.rtspc);
627 bool in_body = (data->req.headerline && !rtspc->in_header) &&
630 switch(rtspc->state) {
633 DEBUGASSERT(Curl_dyn_len(&rtspc->buf) == 0);
643 rtspc->state = RTP_PARSE_SKIP;
644 rtspc->in_header = TRUE;
664 if(Curl_dyn_addn(&rtspc->buf, buf, 1)) {
671 rtspc->state = RTP_PARSE_CHANNEL;
679 DEBUGASSERT(Curl_dyn_len(&rtspc->buf) == 1);
682 rtspc->state = RTP_PARSE_SKIP;
690 result = rtp_write_body_junk(data, Curl_dyn_ptr(&rtspc->buf), 1);
698 Curl_dyn_free(&rtspc->buf);
702 rtspc->rtp_channel = (unsigned char)buf[0];
703 if(Curl_dyn_addn(&rtspc->buf, buf, 1)) {
710 rtspc->state = RTP_PARSE_LEN;
715 size_t rtp_len = Curl_dyn_len(&rtspc->buf);
718 if(Curl_dyn_addn(&rtspc->buf, buf, 1)) {
727 rtp_buf = Curl_dyn_ptr(&rtspc->buf);
728 rtspc->rtp_len = RTP_PKT_LENGTH(rtp_buf) + 4;
729 rtspc->state = RTP_PARSE_DATA;
734 size_t rtp_len = Curl_dyn_len(&rtspc->buf);
736 DEBUGASSERT(rtp_len < rtspc->rtp_len);
737 needed = rtspc->rtp_len - rtp_len;
739 if(Curl_dyn_addn(&rtspc->buf, buf, needed)) {
748 rtspc->rtp_channel, rtspc->rtp_len));
749 result = rtp_client_write(data, Curl_dyn_ptr(&rtspc->buf),
750 rtspc->rtp_len);
751 Curl_dyn_free(&rtspc->buf);
752 rtspc->state = RTP_PARSE_SKIP;
757 if(Curl_dyn_addn(&rtspc->buf, buf, blen)) {
785 struct rtsp_conn *rtspc = &(data->conn->proto.rtspc);
790 rtspc->in_header = FALSE;
797 blen, rtspc->in_header, is_eos));
800 if(!rtspc->in_header) {
814 rtspc->in_header = TRUE;
823 rtspc->in_header = FALSE;
825 if(!rtspc->in_header) {
840 if(rtspc->state != RTP_PARSE_SKIP)
846 " rtspc->state=%d, req.size=%" CURL_FORMAT_CURL_OFF_T ")",
847 blen, rtspc->in_header, *done, rtspc->state, data->req.size));
856 (rtspc->state == RTP_PARSE_SKIP)) {